一、redis做消息队列
1. redis存储的list数据是双向链表实现的，可以作为队列
2. 使用lpush和rpop实现入队和出队
3. 每次使用lpush和rpop都要发起一次连接，性能不好
4. 这是一次生产，一次消费的队列
二、发布/订阅模式(publish/subscribe)，也是作为消息队列
1. 可以一次生产，多次消费
2. 发布：PUBLISH channel message
jedis.publish(CHANNEL_KEY, message);
3. 消费：SUBSCRIBE channel
//消息处理,接收到消息时如何处理
JedisPubSub jps = new JedisPubSub() {
/**
* JedisPubSub类是一个没有抽象方法的抽象类,里面方法都是一些空实现
* 所以可以选择需要的方法覆盖,这儿使用的是SUBSCRIBE指令，所以覆盖了onMessage
* 如果使用PSUBSCRIBE指令，则覆盖onPMessage方法
* 当然也可以选择BinaryJedisPubSub,同样是抽象类，但方法参数为byte[]
*/
@Override
public void onMessage(String channel, String message) {
if(Publisher.CHANNEL_KEY.equals(channel)) {
System.out.println("接收到消息: channel : " + message);
//接收到exit消息后退出
if(EXIT_COMMAND.equals(message)) {
System.exit(0);
}
}
}
/**
* 订阅时
*/
@Override
public void onSubscribe(String channel, int subscribedChannels) {
if(Publisher.CHANNEL_KEY.equals(channel)) {
System.out.println("订阅了频道:" + channel);
}
}
};
//可以订阅多个频道 当前线程会阻塞在这儿
jedis.subscribe(jps, channel);
二、特点
1. 客户端在订阅了消息之后，可以继续订阅，取消订阅，PING，QUIT结束连接
2. 发布的消息在Redis上不存储，因此必须先订阅，再发布
3. 订阅的通道名称支持glob模式匹配
三、API
1. SUBSCRIBE执行订阅
2. PSUBSCRIBE执行glob模式订阅
3. UNSUBSCRIBE取消订阅
4. PUNSUBSCRIBE取消glob模式订阅
5. PUBLISH发布消息
6. PUBSUB执行状态查询
参考：
https://blog.csdn.net/azurelaker/article/details/85045183
https://blog.csdn.net/u011489043/article/details/78780255
