Spring Boot与ActiveMQ整合的步骤

Spring Boot与ActiveMQ整合的步骤

1.1使用内嵌服务

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

org.springframework.boot

spring-boot-starter-activemq

（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("接收到消息：DtaTh"+text);

}

}

测试：启动服务后，在浏览器执行http://localhost:8088/send.do?text=aaaaa即可看到控制台输出消息提示。Spring Boot内置了ActiveMQ的服务，所以我们不用单独启动也可以执行应用程序。

1.2使用外部服务

在src/main/resources下的application.properties增加配置, 指定ActiveMQ的地址spring.activemq.broker-url=tcp://192.168.25.135:61616运行后，会在activeMQ中看到发送的queue

1.3.3发送Map信息

（1）修改QueueController.java

@RequestMapping("/sendmap")

public void sehttp://ndMap(){

Map map=new HashMap<>();

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

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

jmsMessagingTemplate.convertAndSend("itcast_map",map);

}

（2）修改Consumer.java

@JmsListener(destination="itcast_map")

public void readMap(Map map){

System.out.println(map);

}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对我们的支持。如果你想了解更多相关内容请查看下面相关链接

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。