今天开始写Spring Boot 整合JMS ActiveMQ，用Spring Boot 来整合也是相当的简单。ActiveMQ是一种开源的，实现了JMS1.1规范的面向消息(MOM)的中间件，为应用程序提供高效的、可扩展的、稳定的和安全的企业级消息通信。
下载ActiveMQ，官网地址：
http://activemq.apache.org/本地启动ActiveMQ解压后根据自身的环境启动，如下：
ActiveMQ bat
ActiveMQ Server
3.打开浏览器登录http://localhost:8161
ActiveMQ
输入帐号密码，默认密码可以通过查看conf文件下面的users.properties文件查看，如下：
users.properties
在application.properties中加入配置
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin
通过Maven构建Spring Boot 工程并命名spirng-boot-jms，POM引入依赖：
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.2.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
编写消息生产者：
import com.spring.boot.jms.producter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import javax.jms.Destination;
/**
* Description: 消息生产者
* author: 慢慢来了
* date: 2017/3/23 14:07
*/
@Component
public class Producter{
@Autowired
private JmsMessagingTemplate jmsTemplate;
public void sendMessage(Destination destination, final String message) {
jmsTemplate.convertAndSend(destination, message);
}
}
Destination为接收者队列也就是消息的目的地（消息发送给谁）；message消息内容；JmsMessagingTemplate 也可以用JmsTemplate替换，但必须自已在其构造方法中自动配置如：
@Component
public class MyBean {
private final JmsTemplate jmsTemplate;
@Autowired
public MyBean(JmsTemplate jmsTemplate) {
this.jmsTemplate = jmsTemplate;
}
// ...
}
编写消息消费者：
package com.spring.boot.jms.consumer;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
/**
* Description: 消息消费者
* author: 慢慢来了
* date: 2017/3/23 14:07
*/
@Component
public class Consumer {
@JmsListener(destination = "msg.p2p.queue")
public void processMessage(String content) {
System.out.println("Receiving a message :" + content);
}
}
编写单元测试：
package com.spring.boot.jms;
import com.spring.boot.jms.producter.Producter;
import org.apache.activemq.command.ActiveMQQueue;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import javax.jms.Destination;
@RunWith(SpringRunner.class)
@SpringBootTest
public class SpirngBootJmsApplicationTests {
@Autowired
private Producter producter;
@Test
public void contextLoads() {
Destination p2pMsg = new ActiveMQQueue("msg.p2p.queue");
producter.sendMessage(p2pMsg , "hello , this is jms msg");
}
}
运行结果,消费者输出"Receiving a message :hello , this is jms msg"：
Java Test
ActiveMQ:
ActiveMQ Queue
- 本篇只是演示了单点消息的发送也接收，下篇就会演示消费者收到消息后，处理把结果通知消息生产者;如果文章对你有所帮助请点赞吧~~~~~
参考资料：
http://docs.spring.io/spring-boot/docs/1.5.2.RELEASE/reference/htmlsingle/
