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

Question

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

Answer 1

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

Answer 2

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