1.1使用内嵌服务
（1）在pom.xml中引入activemq起步依赖
|
1
2
3
4
|
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-activemq</artifactid>
</dependency>
|
（2）创建消息生产者
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
/**
* 消息生产者
* @author administrator
**/
@restcontroller
public class queuecontroller {
@autowired
private jmsmessagingtemplate jmsmessagingtemplate;
@requestmapping("/send")
public void send(string text){
jmsmessagingtemplate.convertandsend("itcast", text);
}
}
|
（3）创建消息消费者
|
1
2
3
4
5
6
7
|
@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的服务，所以我们不用单独启动也可以执行应用程序。
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
|
1
2
3
4
5
6
7
|
@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
|
1
2
3
4
|
@jmslistener(destination="itcast_map")
public void readmap(map map){
system.out.println(map);
}
|
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对服务器之家的支持。如果你想了解更多相关内容请查看下面相关链接
原文链接：https://blog.csdn.net/qq_43193797/article/details/83585907