ActiveMQ
Apache ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线。速度快，支持许多跨语言客户端和协议，具有易于使用的企业集成模式和许多高级功能，同时完全支持JMS 1.1和J2EE 1.4
Github地址：https://github.com/apache/activemq
官方网站：http://activemq.apache.org/
API文档：http://activemq.apache.org/maven/apidocs/index.html
特点：
1.支持Java，C，C ++，C＃，Ruby，Perl，Python，PHP等
2.完全支持JMS客户端和Message Broker中的企业集成模式
3.Spring支持以便ActiveMQ可以轻松嵌入到Spring应用程序中，并使用Spring的XML配置机制进行配置
4.支持多种传送协议:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA
5.支持通过JDBC和journal提供高速的消息持久化
6.从设计上保证了高性能的集群,客户端-服务器,点对点
7.支持Ajax
8.支持与Axis的整合
JMS简介：
JMS即Java消息服务Java Message Service应用程序接口是一个Java平台中关于面向消息中间件MOM的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。
JMS和MQ的关系：
JMS是一个用于提供消息服务的技术规范，它制定了在整个消息服务提供过程中的所有数据结构和交互流程。而MQ则是消息队列服务，是面向消息中间件（MOM）的最终实现，是真正的服务提供者；MQ的实现可以基于JMS，也可以基于其他规范或标准。
支持JMS的开源MQ：目前选择的最多的是ActiveMQ
ActiveMQ下载
下载地址：http://activemq.apache.org/download.html
推荐选择最新稳定版
image.png
Window系统下选择zip
image.png
下载完后解压，进入bin目录
在bin目录下32和64分别对应32位和64位操作系统
image.png
可以直接使用activemq.bat启动服务,但是关闭该窗口，服务停止。所以最好把Activemq注册为Windows服务
image.png
以管理员身份运行 InstallService.bat注册服务
image.png
WIN+X进入计算机管理→服务和应用程序→服务
没启动就启动下
image.png
测试ActiveMQ是否安装成功
访问http://localhost:8161/
ActiveMQ管理控制台默认端口是8161，默认对外服务端口为61616
image.png
管理控制台端口可以在conf/jetty.xml中修改
image.png
对外服务端口可以在conf/activemq.xml中修改
image.png
登录管理ActiveMQ
image.png
ActiveMQ默认admin的用户名密码都是admin,可以在conf/jetty-realm.properties中找到
修改的话也可以对应修改
image.png
成功登录的界面如下
image.png
进行ActiveMQ与SpringBoot的集成
引入activemq依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
消息生产者
@RestController
public class Producer {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@RequestMapping("/sendMsg")
public void sendMsg(String msg) {
msg="你好，我是发送msg的";
jmsMessagingTemplate.convertAndSend("my_msg", msg);
System.out.println("msg发送成功");
}
}
注：
从 Spring Framework 4.1开始，JmsMessagingTemplate构建在JmsTemplate之上，
并提供与消息抽象层org.springframework.messaging.Message的集成。 允许以通用的方式来创建要发送的消息。
convertAndSend()是其中一种发送消息的方法，对象实体自动转换为Message对象
具体使用参考：https://docs.spring.io/spring/docs/5.1.3.RELEASE/javadoc-api/
public class JmsMessagingTemplate extends AbstractMessagingTemplate<Destination>
implements JmsMessageOperations, InitializingBean {
@Nullable
private JmsTemplate jmsTemplate;
public void convertAndSend(String destinationName, Object payload) throws MessagingException {
this.convertAndSend(destinationName, payload, (Map)null);
}
......
}
消息消费者
@Component
public class Consumer {
@JmsListener(destination = "my_msg")
public void readMsg(String text) {
System.out.println("接收到消息：" + text);
}
}
采用的是监听者的方式来监听指定地点的消息，采用注解@JmsListener来设置监听方法。
@JmsListene源码
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Repeatable(JmsListeners.class)
@MessageMapping
public @interface JmsListener {
String id() default "";
String containerFactory() default "";
String destination();
String subscription() default "";
String selector() default "";
String concurrency() default "";
}
subscription： 持久化订阅者名称， 设置这个属性，服务器每次重启后，都不会生成新的，一直只有这一个
destination: 监听的 topic 的值或者队列名
yml配置文件
spring:
activemq:
broker-url: tcp://localhost:61616
配置ActiveMQ对外服务端口
启动测试，访问http://localhost:8080/sendMsg
image.png
消息发送接收都成功了
在可视化控制台上面也看到
image.png
网友评论