0

我在我的 Express.js Web 应用程序中使用 socket.io 为正在侦听调用 SQL 查询的事件的客户端打开套接字。服务器套接字如下所示：

socket.on('updates', function(PEMSID){
        setInterval(function(){
            gps_helper.get_gps(PEMSID, function(data){      //query GPS table for marker coordinates
                socket.emit('message', {message: data});
            });
        }, 10000);

因此，每隔 10 秒get_gps()就会调用一次函数进行长轮询，以检查是否有任何新记录已添加到表中。该get_gps()函数如下所示：

exports.get_gps = function(PEMSID, callback) {
    var sql = require('msnodesql');
    var connStr = "Driver={SQL Server Native Client 11.0};Server=myHost,1433;Database=myDB;UID=Username;PWD=Password;";
    var mQuery = "EXEC Z_CoordsByPEMS '" + PEMSID + "'";
    sql.open(connStr, function(err,conn){
        if(err)
            return console.error("Could not connect to sql: ", err);
        conn.query(mQuery,function(err,results){
            if (err)
                return console.error("Error running query: ", err);
            callback(results);  //return query results
        });
    });
}

我遇到的问题是get_gps()每次轮询任何更新时都会打开与 SQL 数据库的新连接。这显然会在托管数据库的服务器上造成疯狂的开销并且需要更改，因为服务器的 CPU 最终会达到最大容量并且所有未来的查询都会超时。我正在使用该模块msnodesql来执行 SQL db 任务，但似乎close()API 中没有关闭现有连接的函数。我想我需要创建一个全局连接，然后让所有新的套接字引用它，以便进行长轮询。但是，鉴于 Express.js/node.js 的异步特性，我不确定如何设置全局连接，如果可能的话。

4

1 回答 1

3

目前，您正在为您发送的每个查询创建一个新的 SQL 连接。相反，您说过您希望每个 socket.io 连接有一个 SQL 连接。每当收到updates请求时创建 SQL 连接（假设每个 socket.io 连接只收到一次此消息）：

socket.on('updates', function(PEMSID){
    var sql = require('msnodesql');

    // open a new socket for each `updates` message
    sql.open(connStr, function(err,conn){
        if(err) { return console.error("Could not connect to sql: ", err); }

        // when the connection is made, start the interval
        setInterval(function(){

            // each interval, get_gps, and pass `conn` as an argument
            gps_helper.get_gps(conn, PEMSID, function(data){      //query GPS table for marker coordinates
                socket.emit('message', {message: data});
            });
        }, 10000);
    });
});

然后你的get_gps函数将接受一个conn参数：

exports.get_gps = function(conn, PEMSID, callback) {
    var connStr = "Driver={SQL Server Native Client 11.0};Server=myHost,1433;Database=myDB;UID=Username;PWD=Password;";
    var mQuery = "EXEC Z_CoordsByPEMS '" + PEMSID + "'";

    // no need to open `conn`; it's already made
    conn.query(mQuery,function(err,results){
        if (err)
            return console.error("Error running query: ", err);
        callback(results);  //return query results
    });
}

如果您想要一个全局 SQL 连接，只需将sql.open调用移到更高的位置：

// create conn outside of the socket.io message callback
sql.open(connStr, function(err,conn){
    if(err) { return console.error("Could not connect to sql: ", err); }

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

        socket.on('updates', function(PEMSID){
            setInterval(function(){
                gps_helper.get_gps(conn, PEMSID, function(data){      //query GPS table for marker coordinates
                    socket.emit('message', {message: data});
                });
            }, 10000);
        });

    });
});
于 2013-11-05T14:03:57.613 回答