其中在 Publicher/Subscriber 模式下又有 Nondurable subscription（非持久订阅）
和 durable subscription (持久化订阅)2 种消息处理方式。
五、Point-to-Point (点对点)消息模式开发流程
1、生产者（producer）开发流程（ProducerTool.java）：
1.1 创建 Connection：
根据 url，user 和 password 创建一个 jms Connection。
1.2 创建 Session：
在 connection 的基础上创建一个 session，同时设置是否支持事务和
ACKNOWLEDGE 标识。
1.3 创建 Destination 对象：
需指定其对应的主题（subject）名称，producer 和 consumer 将根据 subject
来发送/接收对应的消息。
1.4 创建 MessageProducer：
根据 Destination 创建 MessageProducer 对象，同时设置其持久模式。
1.5 发送消息到队列（Queue）：
封装 TextMessage 消息，使用 MessageProducer 的 send 方法将消息发送出去。
2、消费者（consumer）开发流程（ConsumerTool.java）：
2.1 实现 MessageListener 接口：
消费者类必须实现 MessageListener 接口，然后在 onMessage()方法中监听消息的
到达并处理。
2.2 创建 Connection：
根据 url，user 和 password 创建一个 jms Connection，如果是 durable 模式，
还需要给 connection 设置一个 clientId。
2.3 创建 Session 和 Destination：
与 ProducerTool.java 中的流程类似，不再赘述。
2.4 创建 replyProducer【可选】：
可以用来将消息处理结果发送给 producer。
2.5 创建 MessageConsumer：
根据 Destination 创建 MessageConsumer 对象。
剩余10页未读，继续阅读
iq105
- 粉丝: 2
- 资源: 20
我的内容管理
展开
最新资源
- 李兴华Java基础教程：从入门到精通
- U盘与硬盘启动安装教程：从菜鸟到专家
- C++面试宝典：动态内存管理与继承解析
- C++ STL源码深度解析：专家级剖析与关键技术
- C/C++调用DOS命令实战指南
- 神经网络补偿的多传感器航迹融合技术
- GIS中的大地坐标系与椭球体解析
- 海思Hi3515 H.264编解码处理器用户手册
- Oracle基础练习题与解答
- 谷歌地球3D建筑筛选新流程详解
- CFO与CIO携手：数据管理与企业增值的战略
- Eclipse IDE基础教程：从入门到精通
- Shell脚本专家宝典：全面学习与资源指南
- Tomcat安装指南：附带JDK配置步骤
- NA3003A电子水准仪数据格式解析与转换研究
- 自动化专业英语词汇精华：必备术语集锦
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
