Яростный Мечserperпропущено...
Да. Единственное, что необходимо для запроса к БД это request.headers['host'].тогда примерно такой набросок:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
var http = require('http');
var sys = require('util');
var buffer = ...; // некий буфер для данных, детали придумай сам
http.createServer(function(request, response) {
var proxy_request = null,
reqEnd = false;
getProxyDataFromDB(request.headers, function(data) {
var proxy = http.createClient(data.port, data.host);
proxy_request = proxy.request(request.method, request.url, request.headers);
proxy_request.addListener('response', function (proxy_response) {
proxy_response.addListener('data', function(chunk) {
response.write(chunk, 'binary');
});
proxy_response.addListener('end', function() {
response.end();
});
response.writeHead(proxy_response.statusCode, proxy_response.headers);
});
proxy_request.write(buffer.getAllData(), 'binary');
if (reqEnd) { proxy_request.end(); }
});
request.addListener('data', function(chunk) {
if (proxy_request) {
proxy_request.write(chunk, 'binary');
} else {
buffer.add(chunk);
}
});
request.addListener('end', function() {
if (proxy_request) {
proxy_request.end();
} else {
reqEnd = true;
}
});
}).listen(8080);
сначала отправляешь запрос в БД (getProxyDataFromDB), по факту выполнения он создает proxy_request.
параллельно берутся данные из request. пока нет proxy_request, они накапливаются в буфере (buffer.add), иначе идут прямо в proxy_request, то же самое с end() - либо вызывается proxy_request.end();, либо ставится флаг, что входные данные получены.
proxy_request при своем создании пишет в себя данные, которые успели накопиться (возможно, пустые), и если есть флаг об окончании приема входных данных, вызывает proxy_request.end();
вроде должно работать :)
Спасибо, буду пробовать. О таком подходе и думал как-раз, только реализацию работы через объект-оббертку сделать, что-бы работа выглядела примерно так-же как с http.Client.
