0

Express 3x、node.js、redis を使用しています。私がメッセージを公開しているとき、1人はこのメッセージをサブスクライブで2〜3回受信しました。(たとえば、ブラウザを更新すると、メッセージの受信が毎回 1 ずつ増えます)。以下は私のコードです。

サーバー側: ~~~~~~~~~~

var express = require('express'),
    http = require('http')

var redis = require('redis');
var redisCli = redis.createClient();
var redisPub = redis.createClient();
var redisSub = redis.createClient();

redisCli.on("error", function (err) {
    console.error("\r\n Error generated from redis client ", err);
});
redisPub.on("error", function (err) {
    console.error("\r\n Error generated from redisPub ", err);
});
redisSub.on("error", function (err) {
    console.error("\r\n Error generated from redisSub ", err);
});

var server = http.createServer(app)
  , io = require('socket.io').listen(server);

server.listen(process.env.PORT);

app.configure(function () {
    app.set('views', __dirname + '/views');
    app.set('view engine', 'jade');
    app.set('view options', { layout: false });

    app.use(express.favicon(__dirname + '/favicon.ico', { maxAge: 2592000000 }));
    app.use(express.bodyParser());
    app.use(express.cookieParser());
    app.use(express.session({ secret: "myKey", store: new RedisStore({ maxAge: 86400000, client: redisCli }), cookie: { maxAge: 86400000} }));
    app.use(express.methodOverride());
    app.use(app.router);
    app.use(express.static(__dirname + '/static'));
});

io.configure(function () {
    io.enable('browser client minification');  // send minified client
    io.enable('browser client etag');          // apply etag caching logic based on version number
    io.enable('browser client gzip');          // gzip the file

    io.set('log level', 1);
    io.set("flash policy server", false);
    io.set("transports", ["jsonp-polling", "xhr-polling"]);
});

io.sockets.on('connection', function (client) {
    console.log("server - redisSub.subscribe from io.on.connection");
    redisSub.unsubscribe();
    redisSub.subscribe("announcement");

    redisSub.on("message", function (channel, message) {
        io.sockets.emit('announcement', message);
    });

    client.on('disconnect', function () {
        redisSub.unsubscribe("announcement");
        redisSub.quit();
    });

});

app.post('/PublishMessage', function (req, res) {
    redisPub.publish("announcement", req.body.users);

    res.setHeader('Cache-Control', 'max-age=0, must-revalidate, no-cache, no-store');
    res.setHeader('Connection', 'keep-alive');
    res.contentType('application/json');
    res.setHeader('Expires', new Date().addYears(-10));
    res.json({ result: 'ok' });
});

クライアント側 ~~~~~~~~~

    this.socket = io.connect('http://XXX.XXX.X.XXX/', { transports: ['jsonp-polling', 'xhr-polling'] });
    this.socket.on('connect', function () {
        alert("client - Socket client connect");
    });
    this.socket.on('announcement', function (msg) {
        alert("clientside - announcement ");
        var nUsers = parseInt($('#Summary>article>p:last').text(), 10) + parseInt(msg, 10);
        $('#Summary>article>p:last').text(nUsers);
    });

================================================== ===============だから、誰でも同じことを教えてくれる!!! どうもありがとうございます。

4

1 に答える 1

6

私は socket.io を使用したことがありませんが、接続ハンドラーで物事を複雑にしすぎているように見えます。

ハンドラー内では、接続に反応しているようには見えません (「ユーザー接続」イベントを発行するなど)、または個々のソケット接続の動作を何らかの方法で変更しているようには見えません。

あなたがredisSubしていることは、1 つのクライアントを繰り返しサブスクライブしてサブスクライブ解除することです。私はここで間違っているかもしれませんが、あなたがそうする必要はないと思いますし、そうすべきでもありません。

接続ごとにこのグローバル クライアントのサブ/サブ解除を行う必要がないため、接続ハンドラーの外部で「アナウンスメント」を 1 回サブサブする必要があります。お気に入り：

// Move this subscription outside of the connection handler, and you shouldn't
// have to continue to sub/unsub or otherwise manage it.
redisSub.on("message", function (channel, message) {
    io.sockets.emit('announcement', message);
});

// Since you're not reacting to connections or doing anything with individual
// connection sockets, you don't really have anything to do in this handler.
io.sockets.on('connection', function (socket) {
  // if you ONLY wanted to emit to this socket, you'd do it here
  //socket.emit("announcement", "just for this connection")
});
于 2012-11-24T16:06:44.003 に答える