0

我试图建立一个 node.js 服务器来向客户端发送消息，然后它将使用 jquery 通知库显示消息，如果有人感兴趣，我正在使用这个通知库：http: //needim.github.com/通知/

此刻，我有一个 postgres 数据库，该数据库设置了一个表，该表上有一个触发器以写入侦听器。

触发器如下：

CREATE OR REPLACE FUNCTION new_noti() RETURNS trigger AS $$
DECLARE
BEGIN
    PERFORM pg_notify('watchers', TG_TABLE_NAME || ',msg,' || NEW.msg );
    RETURN new;
END; 
$$ LANGUAGE plpgsql;

然后我有一个 node.js 服务器，如下所示：

var pg = require ('pg');

var pgConString = "pg://aydin:password@localhost/test"

var app = require('http').createServer(handler)
    , io = require('socket.io').listen(app)
    , url = require('url')

app.listen(8080);

function handler (request, respsonse) {
    var client = new pg.Client(pgConString);
    client.connect();
    client.query('LISTEN "watchers"');
    client.on('notification', function(msg) {
        console.log(msg.payload);
        sendMessage(msg.payload);
    });
}

function sendMessage(message) {
    io.sockets.emit('notification', {'message': message});
}

然后我有一些客户端代码如下：

<script type="text/javascript">
    var socket = io.connect('http://localhost:8080');
    socket.on('notification', function (data) {
        console.log(data.message);
        newNoty(data);
    });

    function newNoty(data) {
        noty({
            "text":data.message,
            buttons: [{
                type: 'button green',
                text: 'Go to' 
            }],
            "theme":"noty_theme_twitter",
            "layout":"bottomRight",
            "type":"information",
            "animateOpen":{
                "height":"toggle"
            },
            "animateClose":{
                "height":"toggle"
            },
            "speed":500,
            "timeout":7500,
            "closeButton":true,
            "closeOnSelfClick":true,
            "closeOnSelfOver":false,
            "modal":false,
        });
    }
</script>

这不起作用，似乎 node.js 从未收到 postgres 通知，我认为这是因为我正在使用函数处理程序，而我实际上并没有从客户端代码向它发出任何请求。我不确定如何做到这一点以及它是否是正确的方法？是否有可以在连接而不是请求时触发的功能？

我什至以正确的方式做事吗？node.js 向其发送消息的客户端是否应该有服务器？它如何知道客户何时可用？任何帮助或指导教程将不胜感激。谢谢你。

4

1 回答 1

0

在客户端发送 HTTP 请求之前，您实际上并没有设置数据库连接。由于同源问题（您的客户端代码似乎来自您显示的服务器以外的其他地方），这看起来可能永远不会发生。

在任何情况下，您可能希望建立连接以响应"connection"来自的事件io.sockets（即，将当前位于 HTTP 请求处理程序中的内容移动到那里）。这就是它“知道客户何时可用”的方式。或者，也许您应该将其作为初始化的一部分。您的客户端代码看起来不错，但它与上下文无关，因此很难判断它是否真的符合您的需求。

于 2012-07-12T20:58:40.343 回答