捕获与Apache Load Balancer和node/io.socket后端的断开连接

Question

注意:我已经解决了大部分问题,但仍然遇到了捕获断开连接的问题,如更新部分中此帖子的底部所述.

注2:根据要求,我发布了更完整的设置视图.请参阅本文底部的标题.

我试图在Apache中设置负载均衡器,但它不适用于socket.io.我的Apache代码如下所示:

<VirtualHost *:80>
        ServerAdmin webmaster@example.com
        ServerName jpl.example.com

        ProxyRequests off

        Header add Set-Cookie "ROUTEID=.%{BALANCER_WORKER_ROUTE}e; path=/" env=BALANCER_ROUTE_CHANGED
        <Proxy "balancer://mycluster">
                BalancerMember "http://203.0.113.22:3000" route=1
                BalancerMember "http://203.0.113.23:3000" route=2
        </Proxy>

        ProxyPass "/test/" "balancer://mycluster/"
        ProxyPassReverse "/test/" "balancer://mycluster/"    

</VirtualHost>

socket.io的问题

我面临的问题是,在后端我有一个node.js服务器,它使用socket.io连接在subdir1/index.html和subdir2.index.html中进行长轮询.不幸的是,socket.io喜欢只从根目录运行:

http://203.0.113.22:3000/socket.io/

如果我尝试运行它,它无法找到它:

http://jpl.example.com/test/socket.io

我在服务器上的index.js文件的开头如下所示:

// Setup basic express server
var express = require('express');
var app = express();
var server = require('http').createServer(app);
var io = require('socket.io')(server);

我的/subdir1/index.html(也是从服务器加载)的一部分最初看起来像这样:

<script src="/socket.io/socket.io.js"></script>
<script>
    var socket = io.connect();
    socket.on('notification', function (data) {

但是当我通过代理访问它时,我现在收到错误.错误是:

http://jpl.example.com/socket.io/socket.io.js 404 (Not Found)

我试过把它改成这个:

<script src="/test/socket.io/socket.io.js"></script>
<script src="http://code.jquery.com/jquery-latest.min.js"></script>
<script>
    var refresh_value = 0;
    var refresh_time = 0;
    //var socket = io.connect();
    var socket = io.connect('http://example.com/', {path: "/test/"});
    socket.on('notification', function (data) {

它不再给我一个错误,但没有迹象表明它正在与套接字通信.

我在这里做错了什么,我怎么能让它发挥作用？

更新

我现在主要解决了使用问题:

var socket = io.connect('http://example.com/', {path: "/test/socket.io"});

代替:

var socket = io.connect('http://example.com/', {path: "/test/"});

最后的问题:

事情现在正在发挥作用,但我仍然遇到以下问题:

检测到客户端实际关闭了页面大约需要一分钟.没有Proxy和Apache负载均衡器,我没有这个问题.我尝试了各种各样的事情,例如将KeepAlive设置为"no",并使用以下内容修改此页面顶部的VirtualHost:

        <Proxy "balancer://mycluster">
                BalancerMember "http://203.0.113.22:3000" route=1 max=128 ttl=300 retry=60 connectiontimeout=5 timeout=300 ping=2
                BalancerMember "http://203.0.113.23:3000" route=2 max=128 ttl=300 retry=60 connectiontimeout=5 timeout=300 ping=2
        </Proxy>

但它仍然需要大约一分钟才能识别出客户端已离开页面.我该怎么做才能解决这个问题？

更完整的设置视图

根据要求,为了帮助诊断问题,我发布了一个更完整的设置视图.我尽可能多地消除了尽可能多的细节:

我目前的Apache文件:

<VirtualHost *:80>
    # Admin email, Server Name (domain name), and any aliases
    ServerAdmin webmaster@example.com
    ServerName jpl.example.com

    ProxyRequests off

    Header add Set-Cookie "ROUTEID=.%{BALANCER_WORKER_ROUTE}e; path=/" env=BALANCER_ROUTE_CHANGED
    <Proxy "balancer://mycluster">
        BalancerMember "http://203.0.113.22:3000" route=1 keepalive=On smax=1 connectiontimeout=10 retry=600 timeout=900 ttl=900
        BalancerMember "http://203.0.113.23:3000" route=2 keepalive=On smax=1 connectiontimeout=10 retry=600 timeout=900 ttl=900
        ProxySet stickysession=ROUTEID
    </Proxy>

    <Proxy "balancer://myws">
        BalancerMember "ws://203.0.113.22:3000" route=1 keepalive=On smax=1 connectiontimeout=10 retry=600 timeout=900 ttl=900
        BalancerMember "ws://203.0.113.23:3000" route=2 keepalive=On smax=1 connectiontimeout=10 retry=600 timeout=900 ttl=900
        ProxySet stickysession=ROUTEID
    </Proxy>

    RewriteEngine On
    RewriteCond %{REQUEST_URI}  ^/test/socket.io                [NC]
    RewriteCond %{QUERY_STRING} transport=websocket        [NC]
    RewriteRule /(.*)           balancer://myws/$1 [P,L]

    ProxyPass "/test/" "balancer://mycluster/"
    ProxyPassReverse "/test/" "balancer://mycluster/"

</VirtualHost>

在每个服务器上,我都有一个节点安装.主index.js看起来像这样:

/************ Set Variables ******************/

// Setup basic express server
var express = require('express');
var app = express();
var server = require('http').createServer(app);
var io = require('socket.io')(server);
var port = process.env.PORT || 3000;
var fs                  = require('fs'),
    mysql               = require('mysql'),
    connectionsArray    = [],
    connection          = mysql.createConnection({
        host        : 'localhost',
        user        : 'myusername',
        password    : 'mypassword',
        database    : 'mydatabase',
        port        : 3306
    }),
    POLLING_INTERVAL = 5000;


server.listen(port, function () {
        console.log("-----------------------------------");
        console.log('Server listening at port %d', port);
});

// Routing
app.use(express.static(__dirname + "/public"));


/*********  Connect to DB ******************/
connection.connect(function(err) {
        if (err == null){
                console.log("Connected to Database!");
        }
        else {
                console.log( err );
                process.exit();
        }
});



/***********************  Looping *********************/

var pollingLoop = function () {

        var query = connection.query('SELECT * FROM spec_table'),
        specs = [];

        query
        .on('error', function(err) {
                console.log( err );
                updateSockets( err );
        })

        .on('result', function( spec ) {
                specs.push( spec );
        })

        .on('end',function(){
                pollingLoop2(specs);
        });

};

var pollingLoop2 = function (specs) {

        // Make the database query
        var query = connection.query('SELECT * FROM info_table'),
        infos = [];

        // set up the query listeners
        query
        .on('error', function(err) {
                console.log( err );
                updateSockets( err );
        })

        .on('result', function( info ) {
                infos.push( info );
        })

        .on('end',function(){
                if(connectionsArray.length) {
                        setTimeout( pollingLoop, POLLING_INTERVAL );
                        updateSockets({specs:specs, infos:infos});
                }
        });

};

/***************  Create new websocket ****************/
//This is where I can tell who connected and who disconnected.

io.sockets.on('connection', function ( socket ) {

        var socketId = socket.id;

        var clientIp = socket.request.connection.remoteAddress;

        var time = new Date();
        console.log(time);
        console.log("\033[32mJOINED\033[0m: "+ clientIp + " (Socket ID: " + socketId + ")");

        // start the polling loop only if at least there is one user connected
        if (!connectionsArray.length) {
                pollingLoop();
        }

        socket.on('disconnect', function () {
                var socketIndex = connectionsArray.indexOf( socket );

                var time = new Date();
                console.log(time);
                console.log("\033[31mLEFT\033[0m: "+ clientIp + " (Socket ID: " + socketId + ")");

                if (socketIndex >= 0) {
                        connectionsArray.splice( socketIndex, 1 );
                }
                console.log('    Number of connections: ' + connectionsArray.length);
        });

        connectionsArray.push( socket );
        console.log('    Number of connections: ' + connectionsArray.length);

});


/********* Function updateSockets ************/

var updateSockets = function ( data ) {

        connectionsArray.forEach(function( tmpSocket ){
                tmpSocket.volatile.emit( 'notification' , data );
        });

};

最后,在我的public/dir1/index.html文件中,我有一些看起来像这样的东西:

//HTML code here
<script src="/test/socket.io/socket.io.js"></script>
<script>
    var socket = io.connect('', {path: "/test/socket.io"});
    socket.on('notification', function (data) {
            $.each(data.specs,function(index,spec){
                    //Other js code here
            })
    })
</script>
//More HTML code here

通过此特定设置,连接可以正常工作,但在我检测到页面关闭之前需要一分多钟.此外,通过此设置,还会在控制台中记录错误:

WebSocket connection to 'ws://jpl.example.com/test/socket.io/?EIO=3&transport=websocket&sid=QE5aCExz3nAGBYcZAAAA' failed: Connection closed before receiving a handshake response
ws @ socket.io.js:5325

我做错了什么以及如何修复我的代码以便我可以在它们发生的那一刻检测到断开连接？

注意:如果我不使用子目录/ test /,它可以正常工作.

另请注意:这只是URL中出现的子目录.它在任何地方都不存在于文件系统中.

此外,如果您注意到我的代码中我可以写得更好的区域,我愿意接受提示和建议.

Answer 1

我对 Apache mod_proxy 不太熟悉，但我认为您的问题与您的路径有关。

我设置了一个小测试，看看我是否可以提供帮助（并玩一下），在我的测试中，我将把 HTTP 和 ws 流量代理到单个后端。这就是你所做的加上 websocket 的事情。

服务器（LXD 容器）：

• 10.158.250.99 是代理。
• 10.158.250.137 是节点。

首先，在代理上启用 apache mods：

sudo a2enmod proxy
sudo a2enmod proxy_http
sudo a2enmod proxy_wstunnel
sudo a2enmod proxy_balancer
sudo a2enmod lbmethod_byrequests

然后改变000-default.conf：

sudo nano /etc/apache2/sites-available/000-default.conf

这是我清除注释后使用的：

<VirtualHost *:80>
    ServerAdmin webmaster@localhost
    DocumentRoot /var/www/html

    ErrorLog ${APACHE_LOG_DIR}/error.log
    CustomLog ${APACHE_LOG_DIR}/access.log combined

    <Proxy balancer://mycluster>
        BalancerMember http://10.158.250.137:7779
    </Proxy> 

    ProxyPreserveHost On

    # web proxy - forwards to mycluser nodes
    ProxyPass /test/ balancer://mycluster/
    ProxyPassReverse /test/ balancer://mycluster/

    # ws proxy - forwards to web socket server
    ProxyPass /ws/  "ws://10.158.250.137:7778"

</VirtualHost>

上面的配置在做什么：

• 访问代理http://10.158.250.99它将显示默认的 Apache 页面。
• 访问代理，http://10.158.250.99/test/它将把 HTTP 请求转发到http://10.158.250.137:7779。
• 访问代理http://10.158.250.99/ws，它将建立一个 WebSocket 连接ws://10.158.250.137:7778并通过隧道进行连接。

因此，对于我的应用程序，我使用phptty，因为它使用 HTTP 和 WS，它使用 xterm.js 前端，该前端连接到 websockethttp://10.158.250.99/ws以在浏览器中提供 tty。

这是所有工作的屏幕，使用我的LXDui电子应用程序来控制这一切。

因此，请根据我尝试过的设置检查您的设置，看看是否有所不同，在尝试将其应用到您的想法之前，先进行一些尝试，看看事情是如何工作的，这总是好的。

希望能帮助到你。