Spring Boot的JMS发送和接收队列消息，基于ActiveMQ

刺骨的言语ヽ痛彻心扉 2023-10-01 12:41 5阅读 0赞

消息队列ActiveMQ是JMS的一种实现，ActiveMQ可以单独作为一个消息队列组件即插即拔，即插即用，参考下面两篇文章：

[分布式MQTT消息订阅-发布框架：高可用性ActiveMQ\_Zhang Phil-CSDN博客\_mqtt分布式架构分布式MQTT消息订阅-发布框架：高可用性ActiveMQActiveMQ是MQTT的一种实现。ActiveMQ基于JMS。ActiveMQ开发包下载地址：http://activemq.apache.org/download.htmlActiveMQ最适合做消息推送。国内很多厂商基于ActiveMQ改造出多种消息推送平台。下载完成ActiveMQ压缩包后解压，解压后直接在Java环境中运...![favicon32.ico][]https://zhangphil.blog.csdn.net/article/details/94759508][MQTT_-_ActiveMQ_Zhang Phil-CSDN_mqtt_MQTT_-_ActiveMQActiveMQ_MQTT_ActiveMQ_JMS_ActiveMQ_http_activemq.apache.org_download.htmlActiveMQ_ActiveMQ_ActiveMQ_Java_..._favicon32.ico_https_zhangphil.blog.csdn.net_article_details_94759508]

[ActiveMQ安装配置和使用简例\_Zhang Phil-CSDN博客本文作者：Zhang Phil原文链接：ActiveMQ安装配置和使用简例ActiveMQ是一套JMS（Java Message Service）开源消息服务实现的组件。以Windows操作系统为例，本文简述了ActiveMQ的安装配置和使用简例。消息服务是互联网应用的最基本功能，只要是互联网应用，就少不了消息通信。而ActiveMQ是一个相对比较成熟稳定的JMS消息服务组件，![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/48173665][ActiveMQ_Zhang Phil-CSDN_Zhang Phil_ActiveMQ_ActiveMQ_JMS_Java Message Service_Windows_ActiveMQ_ActiveMQ_JMS_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_48173665]

以上是把ActiveMQ作为单独的组件（系统子模块）拆分出来加载使用。

在Spring boot里面，ActiveMQ作为JMS的实现，Spring boot内嵌、可直接使用。

定义一个POJO的消息类：

public class SimpleMsg {
        private String to;
        private String body;
    
        public SimpleMsg() {
    
        }
    
        public SimpleMsg(String to, String body) {
            this.to = to;
            this.body = body;
        }
    
        public String getTo() {
            return to;
        }
    
        public void setTo(String to) {
            this.to = to;
        }
    
        public String getBody() {
            return body;
        }
    
        public void setBody(String body) {
            this.body = body;
        }
    
        @Override
        public String toString() {
            return "SimpleMsg{" +
                    "to='" + to + '\'' +
                    ", body='" + body + '\'' +
                    '}';
        }
    }

SimpleMsg将作为spring boot程序中消息的实体传输。

定义一个spring boot的消息接收器：

import org.springframework.jms.annotation.JmsListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class MsgReceiver {
        //destination的值和在application里面发送制定的目的地值需要相同才能收到
        //containerFactory的变量名对应在app里面定义的JmsListenerContainerFactory
        @JmsListener(destination = "@zhangphil", containerFactory = "myAppContainerFactory")
        public void receiveMessage(SimpleMsg msg) {
            System.out.println("收到消息->");
            System.out.println(msg);
            System.out.println("收到消息<-");
        }
    }

完成spring boot的应用application：

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
    import org.springframework.context.ConfigurableApplicationContext;
    import org.springframework.context.annotation.Bean;
    import org.springframework.jms.annotation.EnableJms;
    import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
    import org.springframework.jms.config.JmsListenerContainerFactory;
    
    import javax.jms.ConnectionFactory;
    
    import org.springframework.jms.core.JmsTemplate;
    import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
    import org.springframework.jms.support.converter.MessageConverter;
    import org.springframework.jms.support.converter.MessageType;
    
    @SpringBootApplication
    @EnableJms
    public class SpringJmsApplication {
        @Bean
        public JmsListenerContainerFactory<?> myAppContainerFactory(ConnectionFactory connectionFactory,
                                                                 DefaultJmsListenerContainerFactoryConfigurer configurer) {
            DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
            configurer.configure(factory, connectionFactory);
            return factory;
        }
    
        @Bean
        public MessageConverter jmsMessageConverter() {
            MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
            converter.setTargetType(MessageType.TEXT);
            converter.setTypeIdPropertyName("_type");
            return converter;
        }
    
        public static void main(String[] args) {
            ConfigurableApplicationContext context = SpringApplication.run(SpringJmsApplication.class, args);
    
            JmsTemplate jmsTemplate = context.getBean(JmsTemplate.class);
    
            SimpleMsg msg = new SimpleMsg("zhangfly", "Hello,world!");
            System.out.println("发送消息:" + msg);
            jmsTemplate.convertAndSend("@zhangphil", msg);
            System.out.println("发送结束");
        }
    }

以上完成后，运行SpringJmsApplication，如果成功，控制台输出：

*发送消息:SimpleMsg\{to='zhangfly', body='Hello,world!'\}  
发送结束  
收到消息->  
SimpleMsg\{to='zhangfly', body='Hello,world!'\}  
收到消息<-*

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[MQTT_-_ActiveMQ_Zhang Phil-CSDN_mqtt_MQTT_-_ActiveMQActiveMQ_MQTT_ActiveMQ_JMS_ActiveMQ_http_activemq.apache.org_download.htmlActiveMQ_ActiveMQ_ActiveMQ_Java_..._favicon32.ico_https_zhangphil.blog.csdn.net_article_details_94759508]: https://zhangphil.blog.csdn.net/article/details/94759508
[ActiveMQ_Zhang Phil-CSDN_Zhang Phil_ActiveMQ_ActiveMQ_JMS_Java Message Service_Windows_ActiveMQ_ActiveMQ_JMS_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_48173665]: https://blog.csdn.net/zhangphil/article/details/48173665