如何深入理解activeMQ的源码实现?
- 内容介绍
- 文章标签
- 相关推荐
本文共计1699个文字,预计阅读时间需要7分钟。
一、hello word,public class Pro_demo_1 { /* 第一步:建立ConnectionFactory工厂对象,需要填写用户名、密码以及要连接的地址,常用默认即可,端口为61616。 第二步:通过ConnectionFactory创建Connection连接对象。 */
一、hello wordpublic class Pro_demo_1 {
/**
* 第一步:建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可,默认端口为"tcp://localhost:61616"。
* 第二步:通过ConnectionFactory工厂对象我们创建一个Connection连接,并且调用Connection的start方法开启连接,Connection默认是关闭的。
* 第三步:通过Connection对象创建Session会话(上下文环境对象),用于接受消息,参数配置1为是否开启是事务,参数配置2位签收模式,一般我们设置自动签收。
* 第四部:通过Session创建Destination对象,指的是一个客户端用来指定生产消费者目标和消费消息来源的对象。在PTP模式中,Destination被称作Queue即队列;
* 在Pub/Sub模式,Destination被称作主题。在程序中可以使用多个Queue和Topic。
* 第五步:我们需要通过Session对象创建消息的发送和接受对象(生产者和消费者)MessageProducer/MessageConsumer。
* 第六步:我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode)。
本文共计1699个文字,预计阅读时间需要7分钟。
一、hello word,public class Pro_demo_1 { /* 第一步:建立ConnectionFactory工厂对象,需要填写用户名、密码以及要连接的地址,常用默认即可,端口为61616。 第二步:通过ConnectionFactory创建Connection连接对象。 */
一、hello wordpublic class Pro_demo_1 {
/**
* 第一步:建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可,默认端口为"tcp://localhost:61616"。
* 第二步:通过ConnectionFactory工厂对象我们创建一个Connection连接,并且调用Connection的start方法开启连接,Connection默认是关闭的。
* 第三步:通过Connection对象创建Session会话(上下文环境对象),用于接受消息,参数配置1为是否开启是事务,参数配置2位签收模式,一般我们设置自动签收。
* 第四部:通过Session创建Destination对象,指的是一个客户端用来指定生产消费者目标和消费消息来源的对象。在PTP模式中,Destination被称作Queue即队列;
* 在Pub/Sub模式,Destination被称作主题。在程序中可以使用多个Queue和Topic。
* 第五步:我们需要通过Session对象创建消息的发送和接受对象(生产者和消费者)MessageProducer/MessageConsumer。
* 第六步:我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode)。

