redis 发布和订阅

 

 

 

发布：publish
例：publish mychannel hello2015
返回值是0表示没有订阅者
返回值是1表示已经有了订阅者

订阅：subscribe
例：subscribe mychannel [.....]
返回值是三个：
1) "message"  固定写法
2) "channel"  固定写法
3) "发布者发布的信息"

取消订阅：unsubscribe
例：unsubscribe [channel]

按照规则订阅：psubscribe
例：psubscribe channel?    能匹配channel1 等的的发布者

按照规则取消订阅：punsubscribe
注意：使用punsubscribe命令只能退订通过psubscribe 订阅的规则，不能退订直接通过subscribe 订阅的规则。

 

可以使用这个 发布 订阅功能，实现网站信息推送给订阅者功能，大概代码如下：

package bj.zm.redis;

import org.junit.Test;

import redis.clients.jedis.Jedis;
/**
 * 发布功能
 * @author Administrator
 *
 */
public class TestPub {
	/**
	 * 发布消息
	 */
	@Test
	public void test(){
		Jedis jedis = new Jedis("192.168.1.110", 6379);
		jedis.publish("zmchannel", "hello 2015");
		
	}

}





订阅功能:


package cn.crxy.redis.test;

import java.util.Set;

import org.junit.Test;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;
/**
 * 订阅功能
 * @author Administrator
 *
 */
public class TestSub {
	@Test
	public void test(){
		Jedis jedis = new Jedis("192.168.1.170", 6379);
		final Jedis jedis2 = new Jedis("192.168.1.170", 6379);
		JedisPubSub jedisPubSub = new JedisPubSub() {
			
			@Override
			public void onUnsubscribe(String channel, int subscribedChannels) {
				System.out.println("取消订阅");
			}
			
			@Override
			public void onSubscribe(String channel, int subscribedChannels) {
				System.out.println("订阅成功");
			}
			
			@Override
			public void onPUnsubscribe(String pattern, int subscribedChannels) {
				
			}
			
			@Override
			public void onPSubscribe(String pattern, int subscribedChannels) {
				
			}
			
			@Override
			public void onPMessage(String pattern, String channel, String message) {
				
			}
			
			@Override
			public void onMessage(String channel, String message) {
				/*if(message.equals("quit")){
					this.unsubscribe();
				}*/
				Set<String> set = jedis2.smembers("set");
				/**
				 * Email.sendil(set,message);
				 */
				System.out.println(message);
			}
		};
		jedis.subscribe(jedisPubSub , "crxy");
		
	}

}