Spring集成ActiveMQ实现

参考资料

Spring Framework 5.1.8.RELEASE API

导入依赖

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.9.0</version>
</dependency>

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jms</artifactId>
    <version>4.3.18.RELEASE</version>
</dependency>

配置application.xml中的JMS模板

<!--JMS配置-->
<!--Activemq的链接工厂-->
<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    <property name="brokerURL" value="tcp://127.0.0.1:61616" />
</bean>

<!--spring-jms对Activemq的链接工厂进行封装-->
<bean id="JMSconnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
    <property name="targetConnectionFactory" ref="targetConnectionFactory" />
</bean>

<!--消息目的地(队列模式)-->
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
    <constructor-arg value="SpringActiveMQMsg"/>
</bean>

<!--消息目的地(主题模式)-->
<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">      
    <constructor-arg value="SpringActiveMQMsgTopic"/>
</bean>

<!--jms模板，用于进行消息发送-->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="JMSconnectionFactory"/>
</bean>

<!--配置消息监听器-->
<bean id="consumerMessageListener" class="com.scheduleserver.Listener.MyMessageListener"/>

<!--配置消息容器-->
<bean id ="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <!--配置链接工厂-->
    <property name="connectionFactory" ref="JMSconnectionFactory"/>
    <!--配置监听的目的地-->
    <property name="destination" ref="queueDestination"/>
    <!--配置消息监听器-->
    <property name="messageListener" ref="consumerMessageListener"/>
</bean>

生产者发送信息

@Autowired
    private JmsTemplate jmsTemplate;
    // 可能存在多个目的地，因此用按名称注入
    @Resource(name = "queueDestination")
    private Destination destination;

    @PostMapping("/test")
    public ResponseObject test(@RequestParam String msg) {
        jmsTemplate.send(destination , new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage textMessage = session.createTextMessage(msg);
                return textMessage;
            }
        });
        System.out.println("费哥爱你哦： " + msg);
        return ResponseObject.generateSuccessResponse();
    }

消费者接收信息

package com.scheduleserver.Listener;

import javax.jms.JMSException;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class MyMessageListener implements MessageListener {

    @Override
    public void onMessage(javax.jms.Message message) {
        TextMessage tmes = (TextMessage) message;
        try {
            System.out.println(tmes.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

控制台输出：
费哥爱你哦： 自律使我自由！
自律使我自由！

总结

若想按主题发送消息，生产者和消费者的目标地址换成主题目标地址就好了。