xinglun 2020-03-01
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
spring.activemq.broker-url=tcp://127.0.0.1:61616 spring.activemq.user=admin spring.activemq.password=admin server.port=8080
package com.wn.p2p; import org.apache.activemq.command.ActiveMQQueue; import org.springframework.jms.core.JmsTemplate; import org.springframework.stereotype.Component; import javax.annotation.Resource; @Component public class P2Pprovider { //注入JMSTemplate @Resource private JmsTemplate jmsTemplate; public void setMessage(){ //点对点创建队列 ActiveMQQueue queue=new ActiveMQQueue("boot_queue"); jmsTemplate.convertAndSend(queue,"消息123"); } }
package com.wn.p2p; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; @RestController public class P2PController { @Resource private P2Pprovider p2Pprovider; @RequestMapping("/setMessage") public String setMessage(){ p2Pprovider.setMessage(); return "success"; } }
spring.activemq.broker-url=tcp://127.0.0.1:61616 spring.activemq.user=admin spring.activemq.password=admin server.port=8081
package com.wn; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.jms.annotation.JmsListener; import javax.jms.JMSException; import javax.jms.TextMessage; @SpringBootApplication public class P2pConsumerApplication { public static void main(String[] args) { SpringApplication.run(P2pConsumerApplication.class, args); } @JmsListener(destination = "boot_queue") public void getMessage(TextMessage message) throws JMSException { System.out.println("接收到的信息:"+message.getText()); } }
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
spring.activemq.broker-url=tcp://127.0.0.1:61616 spring.activemq.user=admin spring.activemq.password=admin server.port=8082 #topic配置 spring.jms.pub-sub-domain=true
package com.wn; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.config.DefaultJmsListenerContainerFactory; import org.springframework.jms.config.JmsListenerContainerFactory; import javax.jms.ConnectionFactory; import javax.jms.JMSException; import javax.jms.TextMessage; @SpringBootApplication public class PubSubConsumerApplication { public static void main(String[] args) { SpringApplication.run(PubSubConsumerApplication.class, args); } //springboot默认只配置queue类型消息,如果要使用topic类型的消息,则需要配置该bean /* @Bean public JmsListenerContainerFactory jmsTopicListenerContainerFactory(ConnectionFactory connectionFactory){ DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); //这里必须设置为true,false则表示是queue类型 factory.setPubSubDomain(true); return factory; }*/ //消费者消费消息 @JmsListener(destination = "boot_topic") public void getMessage(TextMessage message) throws JMSException { System.out.println("接收到消息:"+message.getText()); } }
spring.activemq.broker-url=tcp://127.0.0.1:61616 spring.activemq.user=admin spring.activemq.password=admin server.port=8083
package com.wn.pub_sub; import org.apache.activemq.command.ActiveMQTopic; import org.springframework.jms.core.JmsTemplate; import org.springframework.stereotype.Component; import javax.annotation.Resource; @Component public class Pub_Sub_Provider { @Resource private JmsTemplate jmsTemplate; public void setMessage(){ //创建主题 ActiveMQTopic topic=new ActiveMQTopic("boot_topic"); //springboot默认是队列,如果需要如下设置 jmsTemplate.setPubSubDomain(true); //发送消息 jmsTemplate.convertAndSend(topic,"消息456"); } }
package com.wn.pub_sub; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; @RestController public class Pub_Sub_Controller { @Resource private Pub_Sub_Provider provider; @RequestMapping("/setMessage") public String setMessage(){ provider.setMessage(); return "success"; } }
此时可以查看消费者是否成功接收到消息