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

Spring Boot与ActiveMQ整合的步骤

程序员文章站 2024-02-23 21:40:10
1.1使用内嵌服务 (1)在pom.xml中引入activemq起步依赖 org.sp...

1.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);
 } 
}

测试:启动服务后,在浏览器执行即可看到控制台输出消息提示。spring boot内置了activemq的服务,所以我们不用单独启动也可以执行应用程序。

1.2使用外部服务

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

Spring Boot与ActiveMQ整合的步骤

1.3.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); 
 }

总结

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