ActiveMQ 在 SpringBoot 中的应用

【生产者的spring-boot框架配置文件】:

 

【生产者】:

【生产者main方法】：

 

【消费者spring-boot框架配置文件】：

【消费者【同步接收】消息】：

【消费者主方法】

Spring-boot框架整合ActiveMQ重中之重：

******【消费者】采用【异步接收】：

【方式一】：

使用@JmsListener注解的方式创建 【消息监听器】。

【方式二】

@Configuration注解 和 @Bean注解 配合使用。

1）、@Configuration注解 相当于是 xml配置文件。

2）、@Bean相当于是 <bean>标签。

【Spring-boot配置文件】：

【@Configuration ,  @Bean , @Autowired 等注解 配置创建一个 listener监听器】

【回调的自定义监听器中的onMessage方法】

不管是 集成到 spring 还是spring-boot中，只要是通过监听器listener来进行监听ActiveMQ，从而获取 目标消息的 【异步接收】方式，都是创建一个 listener的Bean对象，然后 spring容器就会拿着这个bean对象启动Listener监听器进行监听服务，也就是说 我们想要 启动listener监听器 ，直接就读取配置文件创建spring容器就可以了，创建容器的同时为我们创建bean对象，从而开启了监听服务。