您的位置 首页 技术

redis发布订阅什么用

  Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息。 Redis 客户端可以订阅任意数量的频道。 (推荐学习…

 

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

Redis 客户端可以订阅任意数量的频道。 (推荐学习:Redis视频教程)

Redis提供了发布订阅功能,可以用于消息的传输,Redis的发布订阅机制包括三个部分,发布者,订阅者和Channel。

 

发布者和订阅者都是Redis客户端,Channel则为Redis服务器端,发布者将消息发送到某个的频道,订阅了这个频道的订阅者就能接收到这条消息。Redis的这种发布订阅机制与基于主题的发布订阅类似,Channel相当于主题。

1,引入Jedis

        <dependency>            <groupId>redis.clients</groupId>            <artifactId>jedis</artifactId>            <version>2.9.0</version>        </dependency>

2,具体实现代码

package com.hcmony.sword.redis; import org.apache.commons.lang3.StringUtils;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPubSub; /** * <h3>Shenjue.java基本描述</h3> * <p></p> * * @author hcmony * @since V1.0.0, 2019/05/06 20:07 */public class RedisMQ { private static final String TOPIC="TOPIC"; private final JedisPool jedisPool; public RedisMQ(JedisPool jedisPool) {this.jedisPool = jedisPool;} /** * 发布消息 * @param topic * @param messge */public void publish(String topic ,String messge){ Jedis jedis = null;if (StringUtils.isBlank(topic)){topic=TOPIC;}try {jedis = jedisPool.getResource();jedis.publish(topic,messge);}finally {if (null != jedis) {jedis.close();}}} /** * 订阅消息 * @param topic * @param jedisPubSub */public void subscribe(String topic,JedisPubSub jedisPubSub){ Jedis jedis = null;if (StringUtils.isBlank(topic)){topic=TOPIC;}try {jedis = jedisPool.getResource();jedis.subscribe(jedisPubSub,topic);}finally {if (null != jedis) {jedis.close();}}}  public static void main(String[] args) {//默认连接本地redis,// loclhost:6379JedisPool jedisPool = new JedisPool();RedisMQ publish = new RedisMQ(jedisPool);new Thread(new Runnable() {@Overridepublic void run() {publish.subscribe("PID",new MyjedisPubSub());}}).start();for (int i=0;i<100;i++){publish.publish("PID","messge"+i);} } public static class MyjedisPubSub extends JedisPubSub {@Overridepublic void onMessage(String channel, String message) {System.out.println("-------channel is "+channel+" message is "+message);}} }

更多Redis相关技术文章,请访问Redis数据库使用入门教程栏目进行学习!

以上就是redis发布订阅什么用的详细内容,更多请关注24课堂在线网其它相关文章!

本文来自网络,不代表24小时课堂在线立场,转载请注明出处:https://www.24ketang.cn/14395.html

为您推荐

返回顶部