Node+Docker环境下Redis RSMQ Worker无法自动拉取队列消息求助

DevOps 小满

2026-5-26

排查RSMQ Worker消费者无法自动拉取消息的步骤

既然容器网络已经互通，那咱们从RSMQ Worker的核心配置和运行逻辑入手，一步步排查：

1. 确认队列配置的一致性

先检查生产者和消费者使用的队列名称完全匹配（Redis是大小写敏感的）。你可以进入Redis容器执行redis-cli，用rsmq listQueues命令查看已创建的队列，确保消费者监听的队列确实存在；也可以在两边代码里打印队列名称，确认没有拼写错误。
验证生产者发送消息时的qname参数，和消费者初始化Worker时的qname参数完全一致，比如生产者用sendMessage({ qname: 'taskQueue', message: 'test' })，消费者必须对应new RSMQWorker('taskQueue', ...)。

确认是否正确设置了interval轮询间隔：如果设置为0或者过大的值，会导致Worker不会主动拉取消息。默认轮询间隔是1000ms，你可以明确配置：

const worker = new RSMQWorker('taskQueue', {
  interval: 1000, // 每秒轮询一次队列
  host: 'redis', // 这里必须用Redis容器的服务名，不能写localhost
  port: 6379
});

确认Worker已经启动：如果初始化时设置了autostart: false，或者没有调用worker.start()，Worker是不会开始监听队列的。一定要确保代码里有worker.start()这一行，且没有被条件逻辑拦截。

进入Redis容器，用rsmq getQueueAttributes qname=taskQueue查看队列的msgs（总消息数）和hiddenmsgs（隐藏消息数）。如果hiddenmsgs不为0，说明之前的消息被消费者获取后未确认，导致后续消息被暂时隐藏。可以用rsmq clearQueue qname=taskQueue清空队列后重新测试。
检查消费者的消息处理函数是否正确调用了确认方法：如果处理逻辑里没有调用next()或done()，RSMQ会将消息标记为隐藏，一段时间后才会重新可见，进而阻塞后续消息的拉取。示例代码要确保：
```
worker.on('message', (msg, next, id) => {
  console.log('收到消息:', msg);
  // 你的业务处理逻辑...
  next(); // 确认消息处理完成，从队列删除
});
```

执行docker logs consumer查看消费者容器的Node.js日志，排查是否有Redis连接失败、Worker初始化异常等错误（比如Error: connect ECONNREFUSED，虽然网络能ping通，但也要确认端口是否正确）。
确认消费者容器内的依赖版本和生产者一致：不同版本的rsmq或rsmq-worker可能存在API差异，比如某些版本的Worker初始化参数格式不同，导致无法正常运行。

确保消费者使用的Redis地址是容器服务名（比如redis），而不是localhost——容器内的localhost指向自身，不是宿主机，这是容器网络里常见的坑。既然生产者能成功连接，直接复用生产者的Redis连接配置即可。
如果Redis设置了密码，消费者的RSMQ配置里必须加上password参数，和生产者保持一致。

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