在前面一篇文章里讨论过几种应用系统集成的方式,发现实际上面向消息队列的集成方案算是一个总体比较合理的选择。这里,我们先针对具体的一个消息队列Activemq的基本通信方式进行探讨。activemq是JMS消息通信规范的一个实现。总的来说,消息规范里面定义最常见的几种消息通信模式主要有发布-订阅、点对点这两种。另外,通过结合这些模式的具体应用,我们在处理某些应用场景的时候也衍生出来了一种请求应答的模式。下面,我们针对这几种方式一一讨论一下。
基础流程
在讨论具体方式的时候,我们先看看使用activemq需要启动服务的主要过程。
按照JMS的规范,我们首先需要获得一个JMS connection factory,通过这个connection factory来创建connection在这个基础之上我们再创建session, destination, producer和consumer。因此主要的几个步骤如下:
1 获得JMS connection factory 通过我们提供特定环境的连接信息来构造factory。
2 利用factory构造JMS connection
3 启动connection
4 通过connection创建JMS session
5 指定JMS destination
6 创建JMS producer或者创建JMS message并提供destination
7 创建JMS consumer或注册JMS message listener
8 发送和接收JMS message
9 关闭所有JMS资源,包括connection, session, producer, consumer等。
publish-subscribe
发布订阅模式有点类似于我们日常生活中订阅报纸。每年到年尾的时候,邮局就会发一本报纸集合让我们来选择订阅哪一个。在这个表里头列了所有出版发行的报纸,那么对于我们每一个订阅者来说,我们可以选择一份或者多份报纸。比如北京日报、潇湘晨报等。那么这些个我们订阅的报纸,就相当于发布订阅模式里的topic。有很多个人订阅报纸,也有人可能和我订阅了相同的报纸。那么,在这里,相当于我们在同一个topic里注册了。对于一份报纸发行方来说,它和所有的订阅者就构成了一个1对多的关系。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)