我们在平时的开发中,经常需要使用发布订阅(Pub/Sub)模式来进行消息处理。Java提供了很多中间件来供开发者来根据自己的需求来使用。常见的有基于jms的消息中间件:kafka,rocketmq,rabbitmq.但是很多开发的同学可能不知道,Redis也提供了Pub/Sub模式,Guava中的 EventBus也可以认为是Pub/Sub模式,还有Hazelcast也提供了Pub/Sub功能.
消息中间件kafka,rocketmq,rabbitmq,ons都是实现了jms协议的,他们一般都是有一个中间件服务器,就相当于一个代理,来隔离Pub端和Sub端。Pub端和Sub端都是通过中间服务器来进行交互。消息中间件可以支持消息的发布订阅,消息甚至可以是有序的,或者广播模式。
Redis也提供了Pub/Sub功能,java客户端封装了其内部的pub/sub命令,使用起来也很简单,本人做过测试,如果对消息可靠性要求不是很高,可以使用redis提供对pub/sub功能
Hazelcast提供对pub/sub主要是集群内有效的。Hazelcast是个很神奇的框架,它提供了分布式的Map,Queue,Set,List,Job,CountdownLatch等功能,topic发布订阅只是其功能之一。接入也很简单。
Guava的EventBus也可以当作一个Pub/Sub模式,用户只需要使用@Subscriber注册的方法进行消息处理即可。
@程序员