目录

一、Pom.xml

二、Spring配置文件

三、队列

四、主题

一、Pom.xml

org.apache.activemqactivemq-all5.10.0com.fasterxml.jackson.corejackson-databind2.10.1org.apache.activemqactivemq-pool5.15.10org.springframeworkspring-jms5.2.1.RELEASEorg.apache.xbeanxbean-spring4.15org.springframeworkspring-aop5.2.1.RELEASEorg.springframeworkspring-core4.3.23.RELEASEorg.springframeworkspring-context4.3.23.RELEASEorg.springframeworkspring-aop4.3.23.RELEASEorg.springframeworkspring-orm4.3.23.RELEASE

二、Spring配置文件

三、队列

（一）生产者

@Service
public class SpringMQ_Produce {@Autowiredprivate JmsTemplate jmsTemplate;public static void main(String[] args) {ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");SpringMQ_Produce produce = (SpringMQ_Produce) applicationContext.getBean("springMQ_Produce");
//        produce.jmsTemplate.send(new MessageCreator() {
//            @Override
//            public Message createMessage(Session session) throws JMSException {
//                TextMessage textMessage = session.createTextMessage("spring整合MQ");
//                return textMessage;
//            }
//        });produce.jmsTemplate.send((Session session) -> {TextMessage textMessage = session.createTextMessage("spring整合MQ");return textMessage;});System.out.println("send task over");}
}

（二）消费者

@Service
public class SpringMQ_Consumer {@Autowiredprivate JmsTemplate jmsTemplate;public static void main(String[] args) {ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");SpringMQ_Consumer consumer = (SpringMQ_Consumer) applicationContext.getBean("springMQ_Consumer");String revalue = (String)consumer.jmsTemplate.receiveAndConvert();System.out.println("消费者收到消息："+revalue);}
}

四、主题

（一）spring配置文件修改（橙色为修改或者添加）

（二）生产者和消费者

可以看到前面的生产者和消费者的代码中我们并没有指定使用队列还是主题，所以代码无需改动，但是要注意主题需要先启动消费者。

（三）在spring中实现消费者不启动，直接通过配置监听完成

 上面的主题相当于我们之前的同步阻塞方式，接下来我们实现异步阻塞方式

（1）spring配置文件添加

（2）编写监听类

@Component
public class myMessageListener implements MessageListener {@Overridepublic void onMessage(Message message) {if(null != message && message instanceof TextMessage) {TextMessage textMessage = (TextMessage)message;System.out.println("监听到消息："+textMessage.getText());}}
}

（3）只启动生产者,不启动消费者，自动会监听记录