Redis 订阅与发布

Love The Way You Lie 2022-08-05 13:23 198阅读 0赞

Redis是一个key-value的存储系统,提供的key-value类似与Memcached而数据结构又多于memcached,而且性能优异.广泛用于缓存,临时存储等，不仅如此redis pubsub还可以实现发布–订阅功能，实时推送给订阅端。

**1.实现发布功能**

package cn.slimsmart.redis.spring.data.redis.pubsub;
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    
    public class JedisPubSubTest {
    	static JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
    	static {
    		jedisPoolConfig.setMaxTotal(10);
    		jedisPoolConfig.setMaxIdle(2);
    	}
    	static JedisPool pool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379, 5000);
    
    	public static void main(String[] args) {
    		Jedis jedis = pool.getResource();
    		try {
    			jedis.publish("test_channel", "hello word!");
    		} finally {
    			pool.returnResource(jedis);
    		}
    		pool.destroy();
    	}
    }

**2.实现发布订阅功能**  
继续JedisPubSub类实现对订阅到消息后的处理。

package cn.slimsmart.redis.spring.data.redis.pubsub;
    
    import redis.clients.jedis.JedisPubSub;
    
    public class JedisPubSubListener extends JedisPubSub {
    	@Override
    	public void onMessage(String channel, String message) {
    		// 取得订阅的消息后的处理
    		System.out.println(channel + "    " + message);
    	}
    
    	@Override
    	public void onPMessage(String pattern, String channel, String message) {
    		// 取得按表达式的方式订阅的消息后的处理
    	}
    
    	@Override
    	public void onPSubscribe(String pattern, int subscribedChannels) {
    		// 初始化按表达式的方式订阅时候的处理
    	}
    
    	@Override
    	public void onPUnsubscribe(String pattern, int subscribedChannels) {
    		// 取消按表达式的方式订阅时候的处理
    	}
    
    	@Override
    	public void onSubscribe(String channel, int subscribedChannels) {
    		// 初始化订阅时候的处理
    	}
    
    	@Override
    	public void onUnsubscribe(String channel, int subscribedChannels) {
    		// 取消订阅时候的处理
    	}
    }

**3.测试订阅功能**

package cn.slimsmart.redis.spring.data.redis.pubsub;
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    
    public class JedisTest {
    	static JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
    	static {
    		jedisPoolConfig.setMaxTotal(10);
    		jedisPoolConfig.setMaxIdle(2);
    	}
    	static JedisPool pool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379, 5000);
    	public static void main(String[] args) {
    		Jedis jedis = pool.getResource();
    		try {
    			JedisPubSubListener pubsub = new JedisPubSubListener();
    			//订阅
    			jedis.subscribe(pubsub, "hq_xq_pubsub");
    		} finally {
    			pool.returnResource(jedis);
    		}
    		pool.destroy();
    	}
    }

测试的时候先启动JedisTest 类，然后再启动JedisPubSubTest类。主要运行原理就是socket。

关于spring-data-redis实现发布订阅，请参考文章：

[Spring Data Redis实现一个订阅/发布系统][Spring Data Redis]

[Spring Data Redis]: http://blog.csdn.net/zhu_tianwei/article/details/17752553