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
推荐选择ActiveMQ 5

image.png

Window系统下选择zip

image.png

下载完后解压，进入bin目录

在bin目录下32和64分别对应32位和64位操作系统

image.png

可以直接使用activemq.bat启动服务,但是关闭该窗口，服务停止。所以最好把Activemq注册为Windows服务

image.png

以管理员身份运行 InstallService.bat注册服务

image.png

Windows中删除服务需要管理员使用sc delete ActiveMQ

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