Node.js中RSMQ新消息需重启应用才可见的问题求助

我看了你的代码，问题出在消息接收的时机上，咱们一步步捋清楚：

问题根源 #

你在test.js里，把rsmq.receiveMessage()直接写在了文件顶层，这意味着这段代码只会在Node.js应用启动的时候执行一次：

• 应用刚启动时，队列myqueue里还没有消息，所以这次receiveMessage调用不会返回任何内容，自然没输出。
• 当你访问/pubsubTest发送消息后，这次启动时的receiveMessage早就执行完了，不会自动再去查询队列，所以你看不到即时输出。
• 而重启应用时，启动阶段的receiveMessage会去读取队列里已经存在的那条消息，这时候就会打印出你预期的结果。

解决方案 #

根据你的需求场景，有两种常见的处理方式：

1. 测试场景：发送消息后立即接收

如果你只是想在发送消息后马上验证是否能收到，可以把receiveMessage放到sendMessage的回调函数里，或者在路由的异步流程中后续执行：

router.get('/pubsubTest', function (req, res, next) {
 async1.waterfall([
 function (callback) {
 rsmq.sendMessage({qname: "myqueue", message: "Hello World 1"}, function (err, resp) {
 if (resp) {
 console.log("Message sent. ID:", resp);
 // 发送成功后立即尝试接收消息
 rsmq.receiveMessage({qname: "myqueue"}, function (err, receiveResp) {
 if (receiveResp) {
 console.log("Received message:", receiveResp);
 }
 });
 }
 callback(null, 'done!');
 });
 }
 ], function (err, result) {
 res.sendStatus(200);
 });
});

2. 生产场景：持续监听队列

如果是要长期监听队列处理消息，你需要设置一个轮询机制（因为RSMQ基于Redis，本身没有推送通知，需要主动查询）：

// 定义一个轮询函数
function pollQueueForMessages() {
 rsmq.receiveMessage({qname: "myqueue"}, function (err, resp) {
 if (resp) {
 console.log("Received message:", resp);
 // 处理完消息后记得删除，避免重复消费
 rsmq.deleteMessage({qname: "myqueue", id: resp.id}, function(err, deleteResp) {
 if (deleteResp === 1) {
 console.log("Message deleted successfully");
 }
 });
 }
 // 间隔1秒再次查询队列，可以根据需求调整间隔
 setTimeout(pollQueueForMessages, 1000);
 });
}

// 应用启动后开始轮询
pollQueueForMessages();

额外注意点 #

• RSMQ的receiveMessage会把读取到的消息标记为"in flight"（rc字段为1），默认30秒后如果没有删除，消息会重新回到队列，所以处理完消息一定要调用deleteMessage。
• 如果你的队列消息量很大，可以调整轮询间隔，或者使用批量读取的方式（rsmq.receiveMessage支持count参数）。

内容的提问来源于stack exchange，提问作者salep