一、创建一个简单的Hello World案例
首先需要导入activemq-all-5.14.5.jar包,写生产端:
package com.ietree.mq.helloworld;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.DeliveryMode;import javax.jms.Destination;import javax.jms.MessageProducer;import javax.jms.Session;import javax.jms.TextMessage;import org.apache.activemq.ActiveMQConnectionFactory;public class Sender { public static void main(String[] args) throws Exception { // 第一步:建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址,均使用默认即可,默认端口为:tcp://localhost:61616 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://localhost:61616"); // 第二步:通过ConnectionFactory工厂对象我们创建一个Connection链接,并且调用ConnectionFactory的start方法开启链接,Connection默认是关闭的 Connection connection = connectionFactory.createConnection(); connection.start(); // 第三步:通过Connection对象创建Session会话(上下文环境对象),用于接收消息,参数配置1为是否启用事务,参数配置2为签收模式,一般我们设置为自动签收 Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); // 第四步:通过Session创建Destination对象,指的是一个客户端用来指定生产消息目标和消费信息来源的对象,在PTP模式中,Destination被称作Queue即队列;在Pub/Sub模式,Destination被称作Topic即主题。在程序中可以使用多个Queue和Topic。 Destination destination = session.createQueue("queue1"); // 第五步:我们需要通过Session对象创建消息的发送和接收对象(生产者和消费者)MessageProducer/MessageConsumer。 MessageProducer messageProducer = session.createProducer(destination); // 第六步:我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode) messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); // 第七步:最后我们使用JMS规范的TextMessage形式创建数据(通过Session对象),并用MessageProducer的send方法发送数据。同理,客户端使用receive方法进行接收数据,最后需要关闭Connection连接。 for (int i = 0; i < 5; i++) { TextMessage textMessage = session.createTextMessage(); textMessage.setText("我是消息内容......" + i); messageProducer.send(textMessage); System.out.println("生产者:" + textMessage.getText()); } if (connection != null) { connection.close(); } }}
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
软考中级精品资料免费领
- 历年真题答案解析
- 备考技巧名师总结
- 高频考点精准押题
- 资料下载
- 历年真题
193.9 KB下载数265
191.63 KB下载数245
143.91 KB下载数1148
183.71 KB下载数642
644.84 KB下载数2756
相关文章
发现更多好内容- 手把手教你装系统:不同方法优缺点分析
- Java中 thread.sleep 的优缺点分别是什么?(Java中thread.sleep的优缺点是什么)
- 如何使用 Javascript 的 escape()函数和 unescape()函数?(Javascript escape()函数和unescape()函数怎么用)
- 【JavaScript】ES6 中class定义类
- 我逛了一下JDK一条街,发现了不少好东西!
- 大数据计算框架Spark之任务调度
- 数据科学岗位将在未来5年内重新洗牌,你准备好转型了吗?
- WiMAX的坑爹史
- 如何理解 apisix Java 的错误处理机制?(apisix Java的错误处理机制)
- 勒索软件如何工作?
猜你喜欢
AI推送时光机ActiveMQ简单入门(新手必看篇)
后端开发2023-05-31
JUnit单元测试入门必看篇
后端开发2023-05-30
Kaggle 新手入门必看,手把手教学
后端开发2023-09-16
新手必看Android Studio入门详解
后端开发2024-04-02
新入门node.js必须要知道的概念(必看篇)
后端开发2022-06-04
FFmpeg视频处理入门教程(新手必看)
后端开发2024-04-02
java数据库连接池新手入门一篇就够了,太简单了!
后端开发2024-04-02
web前端:JavaScript基础教程新手入门必看
后端开发2024-04-23
ASP Web.config转换入门:新手必看的详细解析
后端开发2024-02-12
VUE Nuxt.js中间件使用指南:新手入门必看
后端开发2024-02-04
阿里云ECS服务器入门使用流程(新手必看教程)
后端开发2022-06-04
Django新手必看:从入门到精通Web应用开发①【文末送书三本】
后端开发2023-10-03
Java编程新手必看:如何快速入门算法和自然语言处理
后端开发2023-10-06
咦!没有更多了?去看看其它编程学习网 内容吧