redis发布订阅什么用

Redis 发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。

Redis 客户端可以订阅任意数量的频道。（推荐学习：Redis视频教程）

Redis提供了发布订阅功能，可以用于消息的传输，Redis的发布订阅机制包括三个部分，发布者，订阅者和Channel。

发布者和订阅者都是Redis客户端，Channel则为Redis服务器端，发布者将消息发送到某个的频道，订阅了这个频道的订阅者就能接收到这条消息。Redis的这种发布订阅机制与基于主题的发布订阅类似，Channel相当于主题。

1，引入Jedis<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version></dependency>2，具体实现代码package com.hcmony.sword.redis; import org.apache.commons.lang3.StringUtils;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPubSub; /** * <h3>Shenjue.java基本描述</h3> * <p></p> * * @author hcmony * @since V1.0.0, 2019/05/06 20:07 */public class RedisMQ { private static final String TOPIC="TOPIC"; private final JedisPool jedisPool; public RedisMQ(JedisPool jedisPool) {this.jedisPool = jedisPool;} /** * 发布消息 * @param topic * @param messge */public void publish(String topic ,String messge){ Jedis jedis = null;if (StringUtils.isBlank(topic)){topic=TOPIC;}try {jedis = jedisPool.getResource();jedis.publish(topic,messge);}finally {if (null != jedis) {jedis.close();}}} /** * 订阅消息 * @param topic * @param jedisPubSub */public void subscribe(String topic,JedisPubSub jedisPubSub){ Jedis jedis = null;if (StringUtils.isBlank(topic)){topic=TOPIC;}try {jedis = jedisPool.getResource();jedis.subscribe(jedisPubSub,topic);}finally {if (null != jedis) {jedis.close();}}}public static void main(String[] args) {//默认连接本地redis,// loclhost:6379JedisPool jedisPool = new JedisPool();RedisMQ publish = new RedisMQ(jedisPool);new Thread(new Runnable() {@Overridepublic void run() {publish.subscribe("PID",new MyjedisPubSub());}}).start();for (int i=0;i<100;i++){publish.publish("PID","messge"+i);} } public static class MyjedisPubSub extends JedisPubSub {@Overridepublic void onMessage(String channel, String message) {System.out.println("-------channel is "+channel+" message is "+message);}} }更多Redis相关技术文章，请访问Redis数据库使用入门教程栏目进行学习！以上就是redis发布订阅什么用的详细内容，更多请关注小潘博客其它相关文章！