关键词:
activeMq简单实例:
package com.gordon; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; /** * 生产者 * Created by gordon on 2018/9/8. */ public class Sender public static final String userName = "admin"; public static final String password = "admin"; public static final String connect_url = "tcp://192.168.157.4:61616"; public static final String QUEUE = "queue"; public static final String TOPIC = "topic"; public static void main(String[] args) throws JMSException // testSender(QUEUE); testSender(TOPIC);// 测试广播模式先启动客户端 private static void testSender(String mode) throws JMSException ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName,password,connect_url); Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); TextMessage massage = session.createTextMessage(); // Queue queue = session.createQueue(QUEUE); // Topic topic = session.createTopic(TOPIC); Destination destination = null; if(mode.equals(QUEUE)) destination = session.createQueue(mode); massage.setText("测试queue队列模式"); else if (mode.equals(TOPIC)) destination = session.createTopic(mode); massage.setText("测试topic广播模式"); MessageProducer producer = session.createProducer(destination); // 使用MessageProducer的serDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode) // producer.setDeliveryMode(DeliveryMode.PERSISTENT);将消息传递特性置为持久化 producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 非持久化 producer.send(massage); System.out.println("====生产者发送消息====="); if(connection != null) connection.close(); System.out.println("====生产者发送消息===结束==");
package com.gordon; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; import javax.jms.Destination; import javax.jms.Queue; /** * 消费者 * Created by gordon on 2018/9/6. */ public class Receiver public static void main(String[] args) throws JMSException // testReceiver(Sender.QUEUE); testReceiver(Sender.TOPIC); public static void testReceiver(String mode) throws JMSException /* 1、建立ConnectionFactory工厂对象,需要填入用户名、密码、以及要连接的地址, 注意不要包的路径,不要倒成spring里面的*/ ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(Sender.userName,Sender.password,Sender.connect_url); /* 2、通过ConnectionFactory工厂对象创建一个Connection连接, 并且调用Connection.start()方法开启连接,默认是关闭的*/ Connection connection = connectionFactory.createConnection(); connection.start(); /* 3、通过Connection对象创建Session会话(上下文环境对象),用于接收消息。Connection可以创建一个或多个Session 注意:会话是单线程的,所以消息是连续的,就是说消息是按照发送的顺序一个一个接收的 参数1:是否启用事务(表示不开启事务) 参数2:接收模式(一般设置为自动接收)*/ Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); /* 4、通过Session创建Destination对象,即一个客户端用来指定生产者目标 和 消费者来源 的对象 Destination destination = session.createQueue("queue"); PTP模式中:Destination被称为Queue,队列 Pub/Sub模式中:Destination被称为Topic,主题 在程序中可以使用多个Queue 和 Topic */ //Queue queue1 = session.createQueue(mode);// 注意要和消息生产者的队列名一致 Destination destination = null; if(mode.equals(Sender.QUEUE)) destination = session.createQueue(mode); else if (mode.equals(Sender.TOPIC)) destination = session.createTopic(mode); /* 5、通过Session对象创建消息的发送对接收对象(生产者或消费者,MessageProducer/MessageConsumer)*/ MessageConsumer messageConsumer = session.createConsumer(destination); // 多次运行main方法,测试创建多个消费者接收topic消息 System.out.println("messageConsumer : " + messageConsumer.hashCode()); /* 6、使用JMS规范消息类型创建消息数据 1. StreamMessage : Java原始值的数据流 2. MapMessage : 一套名称-值对 3.TextMessage : 一个字符串对象 4.ObjectMessage : 一个序列化的Java对象 5.BytesMessage : 一个未解释字节的数据流 发送端使用MessageProducer.send()方法发送数据 接收端使用MessageConsumer.receive()接收数据 */ //System.out.println("AAAAAAAAAA"); //TextMessage msg = (TextMessage) messageConsumer.receive(); // receiver()同步方式,执行后当前一直挂起,等待接收消息,后面那句打印B的语句没有输出, // 知道发送者发送消息,这里接收到消息才会继续往后执行 //System.out.println("BBBBBBBBBB"); //System.out.println("===消费者接收===" + msg.getText()); /* 7、最后一定要关闭connection连接,否则ActiveMQ不能释放资源, 关闭一个Connection同样也关闭了Session、MessageProducer、MessageConsumer。 但是,客户端一般不要关闭连接,除非特殊情况,这也是手动关闭(在页面搞个按钮点击关闭)。 为什么??很简单,如果客户端关闭,那如何接收消息?难道每次都要手动开启连接??这也太麻烦了点。 当然也有这种操作,毕竟少。我们都希望它是自动接收,所以客户端一般都一直保持连接 */ // if(connection != null) // connection.close(); // System.out.println("===消费者接收===结束==="); // // 生成环境一般是用监听器方式,此方式是异步执行,同时生产者开启事务或者使用持久化(持久化可以设置文件大小) messageConsumer.setMessageListener(new CustomMessageListener());
package com.gordon; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; /** * 消息监听器,它会另起一个线程监听消息服务器 * Created by gordon on 2018/9/8. */ public class CustomMessageListener implements MessageListener @Override public void onMessage(Message message) TextMessage textMessage = (TextMessage) message; try String text = textMessage.getText(); System.out.println(" ===== 消费者 接收消息 === " + text); catch (JMSException e) e.printStackTrace();
启动关闭:activeMq start / activeMq stop
activeMq端口:8161(web管理页面端口)、61616(activemq服务监控端口)
进入web控制台:http://192.168.157.4:8161
activeMq默认登录账号密码:admin admin
消息发布的两种方式:
topic:广播形式
(1)每个消息可以有多个消费者
(2)生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它
订阅之后发布的消息。JMS 规范允许客户创建持久订阅,这在一定程度上放松了时间
上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发送的消息。
ptp:点对点形式
(1)每个消息只能有一个消费者
(2)消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消
息的时候是否处于运行状态,它都可以提取消息。
在点对点消息传递域中,目的地被称为队列(queue);在发布/订阅消息传递域中,目的地被称为主题(topic)
activeMq web Queues控制台:
Number of Pending Message:等待消费的队列
Number of Consumers :该队列被多少个消费者消费
Message Enqueued :进入队列的消息总数量(只增不减)
Message Dequeued :出了队列的消息总数量(即被消费了的消息数量)
参考:
[activeMq基础系列文章]("https://www.cnblogs.com/HigginCui/category/955998.html")
[activeMq消费者是如何接收消息的]("http://manzhizhen.iteye.com/category/318342")
[activeMq性能优化系列文章]("https://blog.csdn.net/yinwenjie/article/details/50916518")
[activeMq消息机制以及ACK机制详解]("http://shift-alt-ctrl.iteye.com/blog/2020182")
[activeMq 常见问题解决]("https://blog.csdn.net/niwei3527/article/details/80607550")
[activeMq面试题]("https://blog.csdn.net/belvine/article/details/79399798")
activemq-初识mq--主题topic(代码片段)
1.导入依赖<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency>2.编写生产者代码编写生产者步骤获取连接工 查看详情
activemq-初识mq--队列queue(代码片段)
1.导入依赖<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency>2.编写生产者代码编写生产者步骤获取连接工 查看详情
activemq-初识mq--队列queue(代码片段)
1.导入依赖<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency>2.编写生产者代码编写生产者步骤获取连接工 查看详情
activemq-初识mq--主题topic(代码片段)
1.导入依赖<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency>2.编写生产者代码编写生产者步骤获取连接工厂获取连接connection获取session创建目的地q... 查看详情
activemq-初识mq--队列queue(代码片段)
1.导入依赖<dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency>2.编写生产者代码编写生产者步骤获取连接工厂获取连接connection获取session创建目的地q... 查看详情
activemq(代码片段)
activemq前言使用步骤1.安装2.java操作activemq2.1队列模式2.1主题模式2.3topic和queue的对比总结3.jms4.发布订阅5.事务6.签收7.broker8.springboot整合activemq8.1activemq-produce(生产者)8.2activemq-consumer(消费者)8.3topic模式9.传输协议9.1nio协议(重点)9.2auto 查看详情
activemq使用(代码片段)
一、Windows安装ActiveMQ1.下载解压2.启动服务二、Linux安装ActiveMQ1.下载解压2.启动访问三、队列模式1.创建maven项目2.生产者3.消费者四、主题模式1.修改队列名字2.修改主题五、Spring集成ActiveMQ1.pom.xml2.消息接口3.... 查看详情
linuxwindows安装activemq(代码片段)
Linux、Windows安装ActiveMQ一、下载二、Linux安装2.1、下载方式2.2、测试2.3、配置三、Windows安装四、ActiveMQ集群4.1、为什么使用集群4.2、BrokerClusters部署4.3、MasterSlave部署(主从)4.3.1、Sharestoragemasterslave(共享存储)4.3.2、Replicated... 查看详情
activemq构建应用-5(代码片段)
Broker:相当于一个ActiveMQ服务器实例命令行启动参数示例如下: 1:activemqstart:使用默认的activemq.xml来启动 2:activemqstartxbean:file:../conf/activemq-2.xml:使用指定的配置文件来启动 3:如果不指定file,也就是xbean:activemq-2.xm... 查看详情
activemq(代码片段)
ActiveMq文章目录ActiveMq一、MQ简介二、参考文档三、软件安装路径和端口规划四、安装步骤1下载安装包2解压3启动activemq4验证运行情况(1打开管理网站(2查看日志文件或控制台输出(3查看端口(4./activemqstatus5关闭a... 查看详情
activemq初识activemq
了解JMSJMS即Java消息服务(JavaMessageService)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。Java消息服务是一个与具体平台无关的API规范,绝大... 查看详情
初识-spring(代码片段)
1.Spring是什么?1.1什么是容器?1.2什么是IoC?1.2.1传统程序开发1.2.2解决办法1.2.3对比总结1.3什么是DI?2.总结2.1Spring是什么?如何理解Spring?2.2IoC和DI是啥?有什么区别?2.3Spring最核心的功能是啥?1.Spring是什么?我们通常所说的Spring指的是SpringF... 查看详情
numpy初识(代码片段)
文章目录numpy初识一、numpy是什么?二、numpy数组2.1数组使用2.2创建数组1.使用empty创建空数组2.使用arange函数创建3.使用zeros函数生成数组4.ones函数生成数组5.diag函数生成对角矩阵6.N维数组2.3访问数组元素三、了解矩阵3.1广播惊... 查看详情
activemq入门实例(代码片段)
ActiveMq入门实例:1.下载ActiveMQ去官方网站下载:http://activemq.apache.org/2.运行ActiveMQ解压缩apache-activemq-5.5.1-bin.zip,然后双击apache-activemq-5.5.1inactivemq.bat运行ActiveMQ程序。启动ActiveMQ以后,登陆:http://localhost:8161/ad 查看详情
springjms与activemq初识
SpringJMS与ActiveMQ初识1.1Springjms与ActiveMQ简介 jms的全称是JavaMessageService,其主要作用是在生产者与消费者之间进行消息的传递;实际业务场景下,当A系统完成某项业务操作后,需要通知B系统或者其他任意系统A系统操作完... 查看详情
初识多线程(代码片段)
初识多线程前言一、操作系统1.冯诺依曼体系结构2.操作系统二、进程2.1操作系统管理进程2.2进程的组成2.3时间片2.4并行和并发2.5内核态和用户态2.6进程状态三、多线程3.1线程是什么?3.2进程和线程的区别3.3Java实现多线程3.4... 查看详情
初识函数(代码片段)
1.什么是函数 函数就是具备某一功能的工具2.为什么要用函数 1增加程序的可读性,让程序变得清晰 2减少代码冗余 3增加可扩展性3如何用函数 函数的使用必须遵循的原则:先定义,后调用 语法: d... 查看详情
动态代理初识(代码片段)
代理模式 *概念: 1.真实对象:被代理的对象 2.代理对象: 3.代理模式:代理对象代理真实对象,达到增强真实对象功能的目的 *实现方式: 1.静态代理:有一个类文件描述代理模式 2.动... 查看详情