Node.js redis pub/sub丢失消息

我想从两天开始调试这段代码，我无法弄清楚所以我问你。
代码非常简单：两个端点几乎完成相同的事情。
第一个's'，收听频道'idS'上的任何消息。如果10秒后它不会收到任何东西，它会结束。如果req.body不为空，请将其发送到'c'。
在第二个'c'中，总是向'idS'发送消息并等待通道'idC'上的消息。
在's'变量'id'被设置为1，因此'c'可以理解's'在线。
我有两个不同的测试程序（每个端点一个）。
在testS中，我没有req.body调用端点，当我收到答案时，我再次调用端点，这次是req.body。
在testC中，我只需调用端点并等待答案。当我收到它时，我会在一秒钟后再次呼叫端点。

试验应在这样的工作：
Node.js redis pub/sub丢失消息

■连接，它没有任何发送，但监听通道“标识”。
c连接，在频道'idC'上侦听并在'idS'上发送“测试”。
s在通道'idS'上接收消息“test”并退出。
一个新的连接，在频道'idS'上收听并在'idC'上发送一条消息给c。
c在通道'idC'上接收并退出。
出c在一秒之后再次连接，并重复从2

var express = require('express'), 
    redis = require('redis'), 
    util = require('util'), 
    client = redis.createClient(6379, 'localhost'); 
var router = express.Router(); 

router.post('/s', function(req, res){ 
    var id = req.query.code; 
    var cId = "c_" + id; 
    var sId= "s_" + id; 

    //BUILD RESPONS 
    var respons = {....}; 

    var clientSub = redis.createClient(6379, "localhost"); 
    clientSub.on("message", function(channel, msg){ 
     if(timeoutId) 
      clearTimeout(timeoutId); 
     client.del(id); 
     respons.val = idS; 
     clientSub.unsubscribe(idS); 
     clientSub.quit(); 
     res.send(respons).end(); 
    }); 
    clientSub.subscribe(idS); 
    client.set(id, 1); 

    if(req.body){ 
     client.publish(idC, JSON.stringify(req.body)); 
    } 

    var timeoutId = setTimeout(function(){ 
     if(!res.headersSent){ 
      clientSub.unsubscribe(idS); 
      clientSub.quit(); 
      client.del(id); 
      console.log(" HUB TIMEOUTED " + id); 

      res.json(respons).end(); 
     } 
    },1000*10); 
}); 

router.post('/c', function(req, res){  
    var id = //code to get id 
    var idC = "c_" + id; 
    var idS= "s_" + id; 


    var clientSub = redis.createClient(6379, "localhost"); 
    clientSub.once("message", function(channel, msg){ 
     var respons = {}; 
     respons.data = msg; 
     clientSub.unsubscribe(idC); 
     clientSub.quit(); 
     res.json(respons).end(); 
    }); 
    //subscribe to a channel 
    clientSub.subscribe(idC); 


    //try to send message 
    client.get(id, function(err, reply){ 
     if(err) 
      console.log(err); 
     else if(reply == 1){ 
      client.publish(idS, "test"); 
     } else{ 
      console.log("ERROR!!!"); 
     } 

    }); 
});

问题，appartently，是 'c' 的，有时，不接收对“消息idC'（或s不发送？）。
该错误不在测试程序中。

感谢您的帮助！

来源

2016-01-13 Lorenzo Tassone

用then-redis解决。问题是同步的。

来源

2016-01-15 10:24:31

Node.js redis pub/sub丢失消息

回答

相关问题