这是一个好的服务器负载平衡系统吗?
Is this a good server's load balancing system?
我是这个概念的新手,我正在考虑如何横向扩展我的 Xepler Node.js 框架。
因此,主服务器上的主应用程序会将请求代理到队列中的第一个集群(可能使用带有 Redis 的共享内存检索)。每X个请求(取决于服务器的能力,X由我决定,可能使用一个映射),集群将被移动到这个队列的最后一个地方。这样,所有的集群将只收到减少数量的请求。
另一个应用程序,在另一台服务器上,每X秒向所有集群发出请求,以检查是否有人失败,将其从队列中删除(这个队列将在redis上?)
所有集群通常都会 运行 我的网络框架的一个实例。
这对你来说是一个很好的负载平衡系统,还是我完全误解了它的工作原理?谢谢大家
编辑:这就是我的意思(只是一个例子):
var http = require('http'),
https = require('https'),
httpProxy = require('http-proxy'),
proxy = httpProxy.createProxyServer({}),
clusters = [
{
id: 1,
host: "localhost",
port: 8080,
dead : false,
deadTime : undefined
},
{
id: 2,
host: "localhost",
port: 8081,
dead : false,
deadTime : undefined
}
];
http.createServer(function(req, res) {
var target = getAvailableCluster();
if (target != -1) {
proxy.web(req, res, { target: 'http://' + target.host + ':' + target.port });
res.setTimeout(1e3 * 20, function() {
target.dead = true;
target.deadTime = new Date().getTime();
console.log("Cluster " + target.id + " is dead");
});
}
}).listen(80, function() {
console.log('Proxy listening on port 80..');
});
proxy.on('error', function (error, req, res) {
var json;
console.log('proxy error', error);
if (!res.headersSent)
res.writeHead(500, { 'content-type': 'application/json' });
json = { error: 'proxy_error', reason: error.message };
res.end(JSON.stringify(json));
});
setInterval(function() {
var cluster,
currentTime = new Date().getTime();
for (var i=0; i<clusters.length; i++) {
cluster = clusters[i];
if (cluster.dead && (currentTime - cluster.deadTime) > 1000) {
cluster.dead = false;
console.log("Cluster " + cluster.id + " is now alive");
}
}
}, 5000);
function getAvailableCluster() {
var cluster;
for (var i=0; i<clusters.length; i++) {
cluster = clusters.shift();
clusters.push(cluster);
if (!cluster.dead)
return cluster;
}
return -1;
}
你为什么要重新发明轮子?有 hipache 一个反向代理/负载平衡器,据我所知,它具有您需要的所有功能。
我是这个概念的新手,我正在考虑如何横向扩展我的 Xepler Node.js 框架。
因此,主服务器上的主应用程序会将请求代理到队列中的第一个集群(可能使用带有 Redis 的共享内存检索)。每X个请求(取决于服务器的能力,X由我决定,可能使用一个映射),集群将被移动到这个队列的最后一个地方。这样,所有的集群将只收到减少数量的请求。
另一个应用程序,在另一台服务器上,每X秒向所有集群发出请求,以检查是否有人失败,将其从队列中删除(这个队列将在redis上?)
所有集群通常都会 运行 我的网络框架的一个实例。
这对你来说是一个很好的负载平衡系统,还是我完全误解了它的工作原理?谢谢大家
编辑:这就是我的意思(只是一个例子):
var http = require('http'),
https = require('https'),
httpProxy = require('http-proxy'),
proxy = httpProxy.createProxyServer({}),
clusters = [
{
id: 1,
host: "localhost",
port: 8080,
dead : false,
deadTime : undefined
},
{
id: 2,
host: "localhost",
port: 8081,
dead : false,
deadTime : undefined
}
];
http.createServer(function(req, res) {
var target = getAvailableCluster();
if (target != -1) {
proxy.web(req, res, { target: 'http://' + target.host + ':' + target.port });
res.setTimeout(1e3 * 20, function() {
target.dead = true;
target.deadTime = new Date().getTime();
console.log("Cluster " + target.id + " is dead");
});
}
}).listen(80, function() {
console.log('Proxy listening on port 80..');
});
proxy.on('error', function (error, req, res) {
var json;
console.log('proxy error', error);
if (!res.headersSent)
res.writeHead(500, { 'content-type': 'application/json' });
json = { error: 'proxy_error', reason: error.message };
res.end(JSON.stringify(json));
});
setInterval(function() {
var cluster,
currentTime = new Date().getTime();
for (var i=0; i<clusters.length; i++) {
cluster = clusters[i];
if (cluster.dead && (currentTime - cluster.deadTime) > 1000) {
cluster.dead = false;
console.log("Cluster " + cluster.id + " is now alive");
}
}
}, 5000);
function getAvailableCluster() {
var cluster;
for (var i=0; i<clusters.length; i++) {
cluster = clusters.shift();
clusters.push(cluster);
if (!cluster.dead)
return cluster;
}
return -1;
}
你为什么要重新发明轮子?有 hipache 一个反向代理/负载平衡器,据我所知,它具有您需要的所有功能。