您的位置:首页 > 数据库 > Redis

Java——Redis的发布订阅基本实现

2016-09-08 14:32 721 查看
参考文档:http://www.runoob.com/redis/redis-pub-sub.html

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

Redis 客户端可以订阅任意数量的频道。

(一)开启2个 redis 客户端,然后在同一个频道JRedisChat发布两次消息,订阅者就能接收到消息

(1)开启订阅客户端1

package com.ict.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisClient1 {
public static void main(String[] args){
Jedis jRedis = new Jedis("localhost");
JedisPubSub jedisPubSub=new JedisPubSub() {
@Override
public void onMessage(String channel, String message) {
super.onMessage(channel, message);
System.out.println(message);

}
};
jRedis.subscribe(jedisPubSub,"JRedisChat");
}
}


(2)开启订阅客户端2

package com.ict.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisClient2 {
public static void main(String[] args){
Jedis jRedis = new Jedis("localhost");
JedisPubSub jedisPubSub=new JedisPubSub() {
@Override
public void onMessage(String channel, String message) {
super.onMessage(channel, message);
System.out.println(message);
}
};
jRedis.subscribe(jedisPubSub,"JRedisChat");
}
}


(3)开启发布客户端

package com.ict.redis;

import redis.clients.jedis.Jedis;

public class RedisPublish {
public static void main(String[] args){
Jedis jRedis = new Jedis("localhost");
jRedis.publish("JRedisChat","my name is chenLong");
jRedis.publish("JRedisChat","Hello chenLong!");
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  java redis 发布订阅