java jedis_Redis java jedis PUB/SUB 实例（原创）

左手的ㄟ右手 2022-11-03 11:14 13阅读 0赞

package

com.redis.test;

import

redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

public class JedisPubSubTest \{

public static JedisPool pool;

static \{

JedisPoolConfig

jedispool\_config = new JedisPoolConfig();

jedispool\_config.maxActive =

20;

jedispool\_config.maxIdle =

jedispool\_config.maxWait =

1000;

jedispool\_config.testOnBorrow =

true;

pool = new

JedisPool(jedispool\_config, "127.0.0.1", 6379);

public static

void main(String\[\] args) throws InterruptedException \{

Jedis redisClient1 =

pool.getResource();

Jedis redisClient2 =

pool.getResource();

MyListener listener = new

MyListener();

Publisher pub = new Publisher();

pub.publish(redisClient2);

//发布一个频道

Subscriber sub = new Subscriber();

sub.psub(redisClient1,

listener); // 订阅一个频道

class Subscriber \{

public void psub(final Jedis redisClient, final

MyListener listener) \{

new Thread(new

Runnable() \{

@Override

public void

run() \{

System.out.println("订阅：news.share");

订阅得到信息在lister的onMessage(...)方法中进行处理

订阅多个频道

redisClient.subscribe(listener, "news.share",

"news.log");

//redisClient.subscribe(listener, new

String\[\]\{"news.share","news.log"\});redisClient.psubscribe(listener,

new String\[\] \{ "news.share" \});// 使用模式匹配的方式设置频道

\}).start();

class Publisher \{

public void publish(final Jedis redisClient)

new Thread(new Runnable()

@Override

public void

run() \{

try

Thread.currentThread().sleep(2000);

catch (InterruptedException e) \{

e.printStackTrace();

System.out.println("发布：news.share");

redisClient.publish("news.share",

"ok");

redisClient.publish("news.share",

"hello word");

\}).start();

消息监听：

package

com.redis.test;

import

redis.clients.jedis.JedisPubSub;

public class MyListener extends

JedisPubSub \{

// 取得订阅的消息后的处理

public void onMessage(String channel, String

message) \{

System.out.println(channel +

"=" + message);

初始化订阅时候的处理 public void

onSubscribe(String channel, int subscribedChannels) \{

System.out.println(channel +

"=" +

subscribedChannels+"&&&&&&&");

// 取消订阅时候的处理

public void onUnsubscribe(String channel, int

subscribedChannels) \{

System.out.println(channel +

"=" + subscribedChannels+"\#\#\#\#\#\#\#\#\#");

初始化按表达式的方式订阅时候的处理 public void

onPSubscribe(String pattern, int subscribedChannels) \{

System.out.println(pattern +

"=" + subscribedChannels+"!!!!!!!");

// 取消按表达式的方式订阅时候的处理

public void onPUnsubscribe(String pattern, int

subscribedChannels) \{

System.out.println(pattern +

"=" + subscribedChannels+"@@@@@@@@@");

// 取得按表达式的方式订阅的消息后的处理

public void onPMessage(String pattern, String

channel, String message) \{

System.out.println(pattern +

"=" + channel + "=" + message);

结论: 经测试 sub 必须发pub 之前，否则收不到 message, 不要

pool.returnResource操作，会报异常。

java jedis_Redis java jedis PUB/SUB 实例（原创）

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关猿创征文｜Jedis

相关 Java实现的日历（原创）

相关 Java实现简单的计算器（原创）

相关健康（原创）

相关 java jedis_Redis java jedis PUB/SUB 实例（原创）

相关 jedis调用redis之pubsub

相关 Java原创学习软件

相关【原创】Java byte 位移操作注意事项

相关原创 | jvm02、java虚拟机栈

相关原创 | 深入理解Java内存模型（上）！