1. 首页 > 重庆网络营销 > 小潘杂谈 >

redis发布订阅什么用

redis发布订阅什么用

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

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

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

redis发布订阅什么用

发布者和订阅者都是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发布订阅什么用的详细内容,更多请关注小潘博客其它相关文章!

本文由重庆小潘seo博客网发布,不代表重庆小潘seo博客网立场,转载联系作者并注明出处:http://www.hkxiaopan.com/column/xiaopan/57910.html

联系我们

在线咨询:点击这里给我发消息

微信号:86345

工作日:9:30-18:30,节假日休息