spring-data-redis 怎么监听消息队列有消息来了呢

先有A、B两个系统,B系统往redis消息队列里面lpush一个消息, A系统怎么知道消息来了呢? 如果采用发布/订阅模式是可以知道的,但是现在想知道消息队列 A系统怎么监听这个消息队列呢? 用的是spring-data-redis

阅读 12.5k
2 个回答

有个messageListener.A系统继承他实现一个handler的方法,JAVA代码里启动的时候注册监听器就好了

如果使用的是lpush让队列中存入消息,那么消费者直接blpop从队列取消息即可,因为blpop是阻塞式的,你设置一个超时时间,超时时间内如果有消息进来会自动获取到,如果没有则结束等待,外面使用一个循环即可。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题