初学者在使用ActiveMQ等消息中间件时,可参考此经验深入理解队列模式中生产者的工作原理与实现方式。
1、 本案例采用Maven工程,不熟悉创建方法者可参考相关链接进行学习与操作。
2、 在pom.xml中添加相应坐标信息
3、 创建一个名为QueueProducer的类
4、 创建连接工厂,替换地址为你的实际地址。
5、 获取连接对象,通过连接工厂创建新的连接实例。随后启动该连接,使其进入活动状态,为后续的消息收发操作做好准备,确保连接正常开启并可投入使用。
6、 获取会话,指定是否开启事务及消息确认方式。
7、 首参:是否启用事务处理
8、 第二个参数为消息确认方式
9、 自动确认模式的值为1,表示消息接收后自动确认。
10、 客户端需手动确认,对应值为2。
11、 DUPS_OK_ACKNOWLEDGE值为3,表示自动批量确认消息。
12、 事务已提交并确认,SESSION_TRANSACTED值为0。
13、 创建一个名为test-queue的队列对象,作为消息传递的目标地址。随后,基于当前会话创建一个消息生产者,该生产者负责将消息发送到指定的队列中。接下来,构造一条文本消息,内容为欢迎来到神奇的世界,用于传输具体的信息数据。通过消息生产者将这条文本消息发送至队列,完成消息的投递过程。整个流程实现了从创建队列、生成生产者、封装消息到最终发送的完整操作,确保消息能够顺利进入中间件系统,等待消费者接收与处理,是消息通信中的基础实现步骤。
14、 释放资源
15、 查看管理端操作情况,不熟悉者可参考使用链接。
16、 运行程序后,查看管理端的队列界面。
17、 生产者一生产消息立马就出来了,成功了!
