Spring Boot与ActiveMQ整合

 spring boot与activemq整合

1使用内嵌服务

（1）在pom.xml中引入activemq起步依赖

<dependency>

    <groupid>org.springframework.boot</groupid>

    <artifactid>spring-boot-starter-activemq</artifactid>

</dependency>

（2）创建消息生产者

/**

 * 消息生产者

 * @author administrator

 */

@restcontroller

public class queuecontroller {

@autowired

private jmsmessagingtemplate jmsmessagingtemplate;

 

@requestmapping("/send")

public void send(string text){

jmsmessagingtemplate.convertandsend("itcast", text);

}

}

（3）创建消息消费者

@component

public class consumer {

@jmslistener(destination="itcast")

public void readmessage(string text){

system.out.println("接收到消息："+text);

}

}

测试：启动服务后，在浏览器执行 

.do?text=aaaaa

即可看到控制台输出消息提示。spring boot内置了activemq的服务，所以我们不用单独启动也可以执行应用程序。

2使用外部服务

在src/main/resources下的application.properties增加配置, 指定activemq的地址

spring.activemq.broker-url=tcp://192.168.25.135:61616

运行后，会在activemq中看到发送的queue，如下图：

 

3发送map信息

（1）修改queuecontroller.java

@requestmapping("/sendmap")

public void sendmap(){

map map=new hashmap<>();

map.put("mobile", "13900001111");

map.put("content", "恭喜获得10元代金券");

jmsmessagingtemplate.convertandsend("itcast_map",map);

}

（2）修改consumer.java

@jmslistener(destination="itcast_map")

public void readmap(map map){

system.out.println(map);

}