欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java实现Redis的消息订阅和发布

程序员文章站 2022-03-22 12:44:04
1. 首先需要一个消息监听器类 该类需要继承JedisPubSub ,并实现其抽象方法,通过方法的名称很清楚的看出来,这个监听器是用来订阅一个频道,在订阅该频道,取消订阅,收到消息等状态会对应调用相关的方法 2. 订阅测试类 该类实现对频道redisChatTest的订阅监听,频道的订阅,取消订阅, ......

1.  首先需要一个消息监听器类

package com.sogou.baike.testimport.testsubscribe;
 
import redis.clients.jedis.jedispubsub;
 
/**
 * created by denglinjie on 2016/6/29.
 */
public class redismsgpubsublistener extends jedispubsub {
    @override
    public void unsubscribe() {
        super.unsubscribe();
    }
 
    @override
    public void unsubscribe(string... channels) {
        super.unsubscribe(channels);
    }
 
    @override
    public void subscribe(string... channels) {
        super.subscribe(channels);
    }
 
    @override
    public void psubscribe(string... patterns) {
        super.psubscribe(patterns);
    }
 
    @override
    public void punsubscribe() {
        super.punsubscribe();
    }
 
    @override
    public void punsubscribe(string... patterns) {
        super.punsubscribe(patterns);
    }
 
    @override
    public void onmessage(string channel, string message) {
        system.out.println("channel:" + channel + "receives message :" + message);
        this.unsubscribe();
    }
 
    @override
    public void onpmessage(string pattern, string channel, string message) {
 
    }
 
    @override
    public void onsubscribe(string channel, int subscribedchannels) {
        system.out.println("channel:" + channel + "is been subscribed:" + subscribedchannels);
    }
 
    @override
    public void onpunsubscribe(string pattern, int subscribedchannels) {
 
    }
 
    @override
    public void onpsubscribe(string pattern, int subscribedchannels) {
 
    }
 
    @override
    public void onunsubscribe(string channel, int subscribedchannels) {
        system.out.println("channel:" + channel + "is been unsubscribed:" + subscribedchannels);
    }
}

该类需要继承jedispubsub ,并实现其抽象方法,通过方法的名称很清楚的看出来,这个监听器是用来订阅一个频道,在订阅该频道,取消订阅,收到消息等状态会对应调用相关的方法

2.  订阅测试类

public class testsubscribe {
    @test
    public void testsubscribe() throws exception{
        jedis jedis = new jedis("localhost");
        redismsgpubsublistener listener = new redismsgpubsublistener();
        jedis.subscribe(listener, "redischattest");
        //other code
    }
}

该类实现对频道redischattest的订阅监听,频道的订阅,取消订阅,收到消息都会调用listener对象的对应方法

如果对spring,mybatis,netty源码分析,高并发、高性能、分布式、微服务架构的原理,jvm性能优化、分布式架构。感兴趣可以747981058,群内会有不定期的发放免费的资料链接,这些资料都是从各个技术网站搜集、整理出来的,如果你有好的学习资料可以私聊发我,我会注明出处之后分享给大家。

注意:subscribe是一个阻塞的方法,在取消订阅该频道前,会一直阻塞在这,只有当取消了订阅才会执行下面的other code,参考上面代码,我在onmessage里面收到消息后,调用了this.unsubscribe(); 来取消订阅,这样才会执行后面的other code

3.  发布消息测试类

public class testpublish {
    @test
    public void testpublish() throws exception{
        jedis jedis = new jedis("localhost");
        jedis.publish("redischattest", "java架构技术交流");
        thread.sleep(5000);
        jedis.publish("redischattest", "加入");
        thread.sleep(5000);
        jedis.publish("redischattest", "747981058");
    }
}

这个类向频道redischattest发布消息,第二步因为订阅了该频道,所以会收到该消息。