Spring Boot与ActiveMQ整合

2019-08-31 07:16:44来源:博客园 阅读 ()

新老客户大回馈,云服务器低至5折

Spring Boot与ActiveMQ整合

 Spring BootActiveMQ整合

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);

}

}

测试:启动服务后,在浏览器执行 

http://localhost:8088/send.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);

}

 


原文链接:https://www.cnblogs.com/hxun/p/11433469.html
如有疑问请与原作者联系

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Java面向对象总结

下一篇:Java描述设计模式(09):装饰模式