原文地址:http://blog.csdn.net/kimmking/article/details/17449019
实现点对点消息通知的关键问题
ActiveMQ使用MQTT协议,加上android上的paho包,即可简单实现消息通知功能,但是mqtt协议只支持topic,而且不能用selector,使得点对点的消息投递变成问题。
有两个解决思路:
1、每个clientId,建一个topic...这个办法对解决消息点对点投递非常有效,但是有两个大问题:
- 随着用户数增多,topic数量增多,对管理性要求增大,对内存的管理也有问题。
- 消息广播操作也变得非常麻烦,只能一个个的发送了。
2、另一个思路,就是在消息广播的基础上,进行点对点控制,实现某些特征的消息投递到指定的订阅者。
这个的实现比较简单,而且没有上面方案的大问题。代码稍微改下即可:https://github.com/apache/activemq/pull/5/files
其实就只添加了一个新的类: ClientIdFilterDispatchPolicy
可以git clone所在版本源码,然后加上这个类,mvn package以后使用。
也可以用我打包好的jar:http://pan.baidu.com/s/1gjaf
使用说明
本修改实现mqtt协议使用单个topic,来做消息广播和点对点的投递。
1、将本文件夹下的activemq-broker-5.9.0.jar、activemq-spring-5.9.0.jar换掉apache-activemq-5.9.0\lib下的jar。
2、参考本文件夹下activemq.xml,在topic上配置
<dispatchPolicy>
<clientIdFilterDispatchPolicy />
</dispatchPolicy>
3、对于此配置下的所有名称以.PTP结尾的队列,
如果要投递消息的properties里包含PTP_CLIENTID,则系统只会将此消息发给clientId为此值的订阅者;如果当前没有此clientId的订阅者,消息不会被任何人接收到。
如果投递消息的properties里不包含PTP_CLIENTID,则消息广播给所有的订阅者。 跟正常消息投递一致。
其中后缀.PTP和键值PTP_CLIENTID,是可以配置的:
<dispatchPolicy>
<clientIdFilterDispatchPolicy ptpSuffix="" ptpClientId="clientId"/>
</dispatchPolicy>
如上配置,使得此policy下的所有topic都起作用,且消息的properties里获取clientId的key变成clientId。
消息发布者,如果要对所有人广播消息,直接发送消息即可。
如果要对指定的消息订阅者发消息,请在消息里设置接收者的clientId:
message.setStringProperty(PTP_CLIENTID, clientId);则此消息只有指定的订阅者可以拿到。
简单测试
两台android设备使用MQTT协议订阅到ActiveMQ的同一个topic,clientId分别为mqtt-1001和mqtt1002;
写代码发两条消息,设置消息属性中PTP_CLIENTID分别为mqtt-1001和mqtt1002;
两个设备分别接收到自己的消息通知,相互之间没有影响。还可以测试下如果消息没有PTP_CLIENTID,两个都能收到。
相关推荐
SpringBoot+ActiveMq+MQTT实现消息的发送和接收 后台消费者、生产者、消息发送接口、发送消息业务类等相关配置
activemq+mqtt+android通信,手机与电脑连接同一个局域网,IP地址为局域网的IP
java中使用消息中间件ActiveMQ的MQTT协议发布消息使用fusesource,fusesource提供三种方式实现发布消息的方式,分别是阻塞式(BlockingConnection)、回调式(CallbackConnection)和Future样式(FutureConnection)
使用SpringMVC、Spring、ActiveMQ发送和接受Mqtt消息。
ActiveMQ MQTT Android客户端Demo
Activemq-MQTT-Websocket库Js文件mqttws31.js 前端使用Websocket连接Activemq中间件的Js库文件
activeMq 实现mqtt 协议的 client ,mqtt-spy. 用于测试
ActiveMQ+zookeeper实现高可用和负载均衡(代码和测试)
官方版本,亲测可用
9、用POI实现对数据的导入导出功能,及POI对excel的操作。 10、后台权限采用流行的shiro权限管理框架,通过本项目可以深入了解shiro权限框架的应用及原理。 11、项目部署采用tomcat+Nginx的集群部署方式,在...
基于Spring+JMS+ActiveMQ+Tomcat,我使用的版本情况如下所示:Spring 3.2.0,ActiveMQ 5.4.3,Tomcat 6.0.43。本例通过详细的说明和注释,实现消息服务的基本功能:发送与接收。Spring对JMS提供了很好的支持,可以...
ActiveMQ+Core+API ActiveMQ+Core+API ActiveMQ+Core+API ActiveMQ+Core+API
基于Spring+JMS+ActiveMQ+Tomcat,我使用的版本情况如下所示: •Spring 2.5 •ActiveMQ 5.4.0 •Tomcat 6.0.30 下面通过学习与配置,实现消息服务的基本功能:发送与接收。Spring对JMS提供了很好的支持,可以...
ActiveMQ MQTT Android 客户端Demo
Android基于MQTT协议利用ActiveMQ发送消息给Android端接收,属于长连接那种,类似Socket通信
activemq+swing 实现的聊天工具(可执行文件和完整工程源码, activemq+swing 实现的聊天工具(可执行文件和完整工程源码) 可执行文件右键运行即可 执行Start.java可启动程序
activeMQ+spring+springmvc整合示例
SpringBoot整合ActiveMQ+websocket.docx ,该文档包含于activemq整合的各个情况,springboot,js,websocket与mq整合,该资源是上传代码的word文档部分
ActiveMQ+In+Action翻译笔记-+更新版2011.pdf
ActiveMq整合SpringMVC实现批量邮件进行异步发送,下载后可在Eclipse中直接使用(含有ActiveMq安装文件已配置好解压即可用)希望对大家有所帮助