ActiveMQ系列教程(五)--实现点对点(P2P)通信模式
2019-12-14 本文已影响0人
sd_1962
这节开始动手写程序,首先写一个简单的P2P通信模式(点对点)的消息队列。分为以下几步
1. 引入pom依赖
作为一个简单实例,先引入一个activemq-core
<dependencies>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-core</artifactId>
<version>5.7.0</version>
</dependency>
</dependencies>
2. 编写消息生产者端(Producer)生产消息
对应例子工程:activemqprovider1
类似于JDBC那几步:
1)创建连接工厂(ConnectionFactory)
2)通过连接工厂创建(到消息队列服务器的)连接(Connection)
3)启动连接(start connection)
4)通过连接创建一个会话(Session)
5)通过会话创建一个目的地(消息队列)
6)通过会话创建一个消息生产者(MessageProducer)
7) 通过会话创建一到多条消息(Message),通过消息生产者发送出去
8)关闭会话和连接(close session,close connection),同JDBC类似,用完释放资源
通过管理控制台来观察
消息生产端未启动前,一个queue(队列)都没有
生产端启动后,创建了一个消息队列,并存在一个待消费消息(入队数量为1,出队为0)
3. 编写消息消费者端(Consumer)消费消息
有生产就得有消费,消息才有意义,下面我们编写消息消费者端
对应例子工程:activemqconsumer1
大部分过程同生产者端一样
1)创建连接工厂
2)通过连接工厂创建(到消息队列服务器的)连接
3)启动连接
4)通过连接创建一个会话(Session)
5)通过会话创建一个目的地(消息队列)
6)通过会话创建一个消息消费者(MessageConsumer)
7) 通过会话创建一到多条消息,通过消息生产者发送出去
8)关闭会话和连接
再次观察控制台
启动消费者端消费消息后,待消费消息数量变为0,出队消息增加为1(表示已消费)
再次启动消费者端,发现进程一直阻塞,因为没有新消息可以消费
在消息中传递额外属性
生产消息时除了包装消息内容外,也可以设置一些其他属性表示对消息的额外说明。
生产方通过消息对象的setXXXProperty方法设置属性,XXX表示不同的数据类型
消费方通过消息对象的getXXXProperty方法获取属性
请大家自行实验并观察控制台