如何用redis作为消息队列,最好附上java代码,感谢各位了

Question

各位大佬好,是这样子的,我一直是用ActiveMQ作为消息中间件使用,但是人家说可以用redis的list实现消息队列,但是我有一个疑问,就是有两个系统,一个向redis发送消息,可是他怎么通知
另外一个系统去消费消息呢...

Answer 1

比如两个系统，系统A和系统B，当系统A有新消息时，加入redis的list列表里：
RedisUtil.lpush(key, value);
系统B前端进行轮询，定时访问接口去获取list列表里面的消息，接口里面循环获取Redis中的消息：
while (true) {
String attr = RedisUtil.lpop(key);
if (attr == null) {
// 没有需要处理的数据了
break;
}
//处理当前attr消息并返回给前端
}