redis的发布订阅和利用Jedis简单演示

逃离我推掉我的手 2023-06-20 06:04 22阅读 0赞

#### redis发布和订阅 ####

语法：

> 订阅给定的一个或多个频道  
> subscribe channel \[channel…\]

客户端1，先订阅。 （和微信公众号一样，订阅了以后，才能收到消息）

redis 127.0.0.1:6379> subscribe my7003
    Reading messages... (press Ctrl-C to quit)

客户端2，发布消息

> 发布消息  
> publish channel 消息内容

redis 127.0.0.1:6379> publish my7003 "大家好"
    (integer) 1
    redis 127.0.0.1:6379> publish my7003 hello
    (integer) 1

这边发完消息，订阅方(客户端1)就收到消息了

redis 127.0.0.1:6379> subscribe my7003
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "my7003"
    3) (integer) 1
    1) "message"
    2) "my7003"
    3) "\xe5\xa4\xa7\xe5\xae\xb6\xe5\xa5\xbd"
    1) "message"
    2) "my7003"
    3) "hello"

同一网段下，登陆别的发布消息的服务器的时候，客户端需要登陆的时候，需要指定ip，不要登陆到自己本机的服务器了。  
`./redis-cli -h ip地址 -p 端口号默认6379`

#### Java利用jedis操作redis ####

> 目前大多使用Spring Data Redis操作redis，spring家族啥都有，整合方便。Jedis算是过时了。

导入依赖

<dependencies>
        
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.0.1</version>
        </dependency>
    </dependencies>

订阅消息

import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPubSub;
    
    public class Demosub extends JedisPubSub { 
    
    
        @Override
        public void onMessage(String channel, String message) { 
            System.out.println("频道是："+channel+",消息是："+message);
        }
    
        public static void main(String[] args) { 
            System.out.println("开始启动订阅者");
            Jedis jedis = new Jedis("192.168.111.140", 6379);
            //订阅消息,new自己,Demosub
            jedis.subscribe(new Demosub(),"cctv5");
        }
    
    
    }

发布消息：

import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPubSub;
    
    public class Demopub{ 
    
        public static void main(String[] args) { 
    
            Jedis jedis = new Jedis("192.168.111.140", 6379);
            jedis.publish("cctv5","hello,篮球比赛开始了");
            System.out.println("消息fas完成！");
        }
    
    }

--------------------

只要订阅了cctv5的，都可以收到（hello,篮球比赛开始了）消息了。