redis 发布和订阅

gaojinguan

　　发布：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");
}
}