欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Spring Boot与ActiveMQ整合

程序员文章站 2022-04-10 15:49:39
Spring Boot与ActiveMQ整合 1使用内嵌服务 (1)在pom.xml中引入ActiveMQ起步依赖 org.springframework.boot spring-boot-starter-act ......

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

}

}

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

.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,如下图:

 Spring Boot与ActiveMQ整合

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

}