1.1使用内嵌服务

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

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId></dependency>

（2）创建消息生产者

/** * 消息生产者 * @author Administrator **/@RestControllerpublic class QueueController { @Autowired private JmsMessagingTemplate jmsMessagingTemplate; @RequestMapping("/send") public void send(String text){ jmsMessagingTemplate.convertAndSend("itcast", text); }}

（3）创建消息消费者

@Componentpublic 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

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

总结

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