Redis订阅发布(Java端实现)

今天药忘吃喽~ 2022-07-14 13:54 172阅读 0赞

*   *  一.准备
     *  二.代码
     *  三.成果
     *  四.声明

## 一.准备 ##

1.1 - 自行下载jedis jar包.  
用maven的话

<dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>2.9.0</version>
        <type>jar</type>
        <scope>compile</scope>
    </dependency>

1.2 - 打开 redis 服务器待命.

## 二.代码 ##

1/3.  
先打开  
SUB端:

package example.me.PubSub;
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPubSub;
    
    public class MySub { 
    
        public static void main(String[] args) {
    
            final String host = "127.0.0.1";// Redis服务所在地址
    
            final int port = 6379;          // 主机端口
    
            @SuppressWarnings("resource")
            Jedis subJedis = new Jedis(host, port);
    
            JedisPubSub jedissubSub = new JedisPubSub() {
    
                public void onUnsubscribe(String channel, int num) {
                }
    
                public void onSubscribe(String channel, int num) {
                }
    
                public void onMessage(String channel, String msg) {
                    System.out.println(channel + " : " + msg);
                }
    
                public void onPUnsubscribe(String channel, int num) {
                }
    
                /* * num 订阅数量 */
                public void onPSubscribe(String channel, int num) {
                }
    
                /* * channel0订阅的channel正则表达式 * channel 匹配上该正则channel值 * msg 收到的消息 */
                public void onPMessage(String channel0, String channel, String msg) {
                }
    
            };
    
            /* * 启动订阅，当该方法启动时，将阻塞等待消息 * 说明： * 1.subscribe(JedisPubSub jedisPubSub, String... channels) * 是常规订阅方法，channel值基于完全匹配,方法中channels是多个要订阅的channel值 * 2.psubscribe(JedisPubSub jedisPubSub, String... patterns) * 是正则订阅方法，channel值基于正则匹配,方法中的patterns是多个订阅到正则表达式 * 不同的订阅将会触发JedisPubSub中不同的方法 */
            subJedis.subscribe(jedissubSub, "news", "tvshow");//完全匹配
        }
    
    }

2/3.  
PUB端:

package example.me.PubSub;
    
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    
    public class MyPub { 
    
        public static void main(String[] args) {
    
    
            JedisPoolConfig poolConfig = new JedisPoolConfig();
            poolConfig.setMaxIdle(5);
            poolConfig.setMinIdle(1);
            poolConfig.setMaxWaitMillis(30000);
    
            JedisPool jedisPool = new JedisPool(poolConfig,"localhost", 6379, 100);
    
            Jedis pubJedis = jedisPool.getResource();
    
            try{
            pubJedis.publish("news", "Hello,MySubs~ ");//发送广播
    
            }catch(Exception e){
                e.printStackTrace();
            }finally{
                jedisPool.returnResource(pubJedis);
                jedisPool.close();
            }
    
    
        }
    
    }

3/3.  
同时我们在 redis-cli 端也订阅相同channel:  
![这里写图片描述][SouthEast]

## 三.成果 ##

jedis-SUB端:  
![这里写图片描述][SouthEast 1]

redis-cli端:  
![这里写图片描述][SouthEast 2]

## 四.声明 ##

4.1 - 本篇仅作为基础，还有很多功能未展现.  
4.2 - [Redis-Clients-Officialsite][]已有很多十分优秀的开源项目供参考.

参考资料:[https://redis.io/clients][https_redis.io_clients]  
本文原文地址:[http://blog.csdn.net/timo1160139211][http_blog.csdn.net_timo1160139211]  
小可不才,恭听指正.

[SouthEast]: /images/20220714/91641e14864a49fab688090796a5d401.png
[SouthEast 1]: /images/20220714/5ab28e17d22e48a29a1857ca0d2fb963.png
[SouthEast 2]: /images/20220714/0c0eac93f9924a5ba04519eb1fbf5149.png
[Redis-Clients-Officialsite]: https://redis.io/clients#java
[https_redis.io_clients]: https://redis.io/clients
[http_blog.csdn.net_timo1160139211]: http://blog.csdn.net/timo1160139211