先有A、B两个系统,B系统往redis消息队列里面lpush一个消息, A系统怎么知道消息来了呢? 如果采用发布/订阅模式是可以知道的,但是现在想知道消息队列 A系统怎么监听这个消息队列呢? 用的是spring-data-redis
先有A、B两个系统,B系统往redis消息队列里面lpush一个消息, A系统怎么知道消息来了呢? 如果采用发布/订阅模式是可以知道的,但是现在想知道消息队列 A系统怎么监听这个消息队列呢? 用的是spring-data-redis
如果使用的是lpush让队列中存入消息,那么消费者直接blpop从队列取消息即可,因为blpop是阻塞式的,你设置一个超时时间,超时时间内如果有消息进来会自动获取到,如果没有则结束等待,外面使用一个循环即可。
8 回答6.5k 阅读
4 回答686 阅读✓ 已解决
2 回答3.4k 阅读
3 回答1.9k 阅读✓ 已解决
1 回答2.1k 阅读✓ 已解决
1 回答2.1k 阅读✓ 已解决
1 回答961 阅读✓ 已解决
有个messageListener.A系统继承他实现一个handler的方法,JAVA代码里启动的时候注册监听器就好了