软件设计：Java实现Redis的消息订阅和发布
作者:AI_爱码小士更新于： 2020-04-15 15:08:43
Redis是一个开源的使用ANSIC语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。从2010年3月15日起，Redis的开发工作由Vmware主持。
java实现Redis的消息订阅和发布
1.首先需要一个消息监听器类
packagecom.sogou.baike.testimport.testSubscribe;
importredis.clients.jedis.JedisPubSub;
/**
*Createdbydenglinjieon2016/6/29.
*/
publicclassRedisMsgPubSubListenerextendsJedisPubSub{
@Override
publicvoidunsubscribe(){
super.unsubscribe();
}
@Override
publicvoidunsubscribe(String...channels){
super.unsubscribe(channels);
}
@Override
publicvoidsubscribe(String...channels){
super.subscribe(channels);
}
@Override
publicvoidpsubscribe(String...patterns){
super.psubscribe(patterns);
}
@Override
publicvoidpunsubscribe(){
super.punsubscribe();
}
@Override
publicvoidpunsubscribe(String...patterns){
super.punsubscribe(patterns);
}
@Override
publicvoidonMessage(Stringchannel,Stringmessage){
System.out.println("channel:"+channel+"receivesmessage:"+message);
this.unsubscribe();
}
@Override
publicvoidonPMessage(Stringpattern,Stringchannel,Stringmessage){
}
@Override
publicvoidonSubscribe(Stringchannel,intsubscribedChannels){
System.out.println("channel:"+channel+"isbeensubscribed:"+subscribedChannels);
}
@Override
publicvoidonPUnsubscribe(Stringpattern,intsubscribedChannels){
}
@Override
publicvoidonPSubscribe(Stringpattern,intsubscribedChannels){
}
@Override
publicvoidonUnsubscribe(Stringchannel,intsubscribedChannels){
System.out.println("channel:"+channel+"isbeenunsubscribed:"+subscribedChannels);
}
}
该类需要继承JedisPubSub，并实现其抽象方法，通过方法的名称很清楚的看出来，这个监听器是用来订阅一个频道，在订阅该频道，取消订阅，收到消息等状态会对应调用相关的方法
2.订阅测试类
publicclassTestSubscribe{
@Test
publicvoidtestSubscribe()throwsException{
Jedisjedis=newJedis("localhost");
RedisMsgPubSubListenerlistener=newRedisMsgPubSubListener();
jedis.subscribe(listener,"redisChatTest");
//othercode
}
}
该类实现对频道redisChatTest的订阅监听，频道的订阅，取消订阅，收到消息都会调用listener对象的对应方法
如果对spring，MyBatis，Netty源码分析，高并发、高性能、分布式、微服务架构的原理，JVM性能优化、分布式架构。感兴趣可以747981058，群内会有不定期的发放免费的资料链接，这些资料都是从各个技术网站搜集、整理出来的，如果你有好的学习资料可以私聊发我，我会注明出处之后分享给大家。
注意：subscribe是一个阻塞的方法，在取消订阅该频道前，会一直阻塞在这，只有当取消了订阅才会执行下面的othercode，参考上面代码，我在onMessage里面收到消息后，调用了this.unsubscribe();来取消订阅，这样才会执行后面的othercode
3.发布消息测试类
PublicclassTestPublish{
@Test
publicvoidtestPublish()throwsException{
Jedisjedis=newJedis("localhost");
jedis.publish("redisChatTest","Java架构技术交流");
Thread.sleep(5000);
jedis.publish("redisChatTest","加入");
Thread.sleep(5000);
jedis.publish("redisChatTest","747981058");
}
}
这个类向频道redisChatTest发布消息，第二步因为订阅了该频道，所以会收到该消息。
redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)和zset(有序集合)。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。
