SpringBoot--JMS（ActiveMQ）异步消息服务

朴灿烈づ我的快乐病毒、 2022-05-22 03:53 144阅读 0赞

目录结构：

![70][]

pom.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    
    
    <groupId>com.roncoo.education</groupId>
    <artifactId>spring-boot-demo-21-1</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>
    
    
    <name>spring-boot-demo-21-1</name>
    <description>Demo project for Spring Boot</description>
    
    
    <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.4.0.RELEASE</version>
    <relativePath /> 
    </parent>
    
    
    <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
    </properties>
    
    
    <dependencies>
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    </dependency>
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-freemarker</artifactId>
    </dependency>
    <dependency>
    <groupId>org.webjars</groupId>
    <artifactId>jquery</artifactId>
    <version>2.1.4</version>
    </dependency>
    
    
    
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
    <dependency>
    <groupId>com.h2database</groupId>
    <artifactId>h2</artifactId>
    <scope>runtime</scope>
    </dependency>
    
    
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    
    
    
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>
    <dependency>
    <groupId>de.flapdoodle.embed</groupId>
    <artifactId>de.flapdoodle.embed.mongo</artifactId>
    </dependency>
    
    
    
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
    </dependency>
    <dependency>
    <groupId>net.sf.ehcache</groupId>
    <artifactId>ehcache</artifactId>
    </dependency>
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-redis</artifactId>
    </dependency>
    
    
    
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>
    
    
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
    </dependency>
    </dependencies>
    
    
    <build>
    <plugins>
    <plugin>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-maven-plugin</artifactId>
    </plugin>
    </plugins>
    </build>
    
    
    
    </project>

application.properties文件：

server.port=8080
    
    
    # ACTIVEMQ (ActiveMQProperties)
    spring.activemq.in-memory=true
    #spring.activemq.broker-url= 
    #spring.activemq.password= 
    #spring.activemq.user= 
    #spring.activemq.packages.trust-all=false
    #spring.activemq.packages.trusted=
    #spring.activemq.pool.configuration.*= 
    #spring.activemq.pool.enabled=false
    #spring.activemq.pool.expiry-timeout=0
    #spring.activemq.pool.idle-timeout=30000
    #spring.activemq.pool.max-connections=1

package com.roncoo.example.util.configuration;
    
    
    import javax.jms.Queue;
    
    
    import org.apache.activemq.command.ActiveMQQueue;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    /**
     * jms 队列配置
     * 
     * @author wujing
     */
    @Configuration
    public class JmsConfiguration {
    
    
    @Bean
    public Queue queue() {
    return new ActiveMQQueue("roncoo.queue");
    }
    
    
    }

package com.roncoo.example.component;
    
    
    import javax.jms.Queue;
    
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.jms.annotation.JmsListener;
    import org.springframework.jms.core.JmsMessagingTemplate;
    import org.springframework.stereotype.Component;
    
    
    /**
     *
     * @author wujing
     */
    @Component
    public class RoncooJmsComponent {
    
    
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    
    @Autowired
    private Queue queue;
    
    
    public void send(String msg) {
    this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
    }
    
    @JmsListener(destination = "roncoo.queue")
    public void receiveQueue(String text) {
    System.out.println("接受到：" + text);
    }
    
    
    
    }

package com.roncoo.example;
    
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.web.servlet.ServletComponentScan;
    import org.springframework.cache.annotation.EnableCaching;
    import org.springframework.jms.annotation.EnableJms;
    
    
    @EnableJms 
    @EnableCaching
    @ServletComponentScan
    @SpringBootApplication
    public class SpringBootDemo211Application {
    
    
    public static void main(String[] args) {
    SpringApplication.run(SpringBootDemo211Application.class, args);
    }
    
    }

测试类：

package com.roncoo.example;
    
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    
    
    import com.roncoo.example.component.RoncooJmsComponent;
    
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class SpringBootDemo211ApplicationTests {
    @Autowired
    private RoncooJmsComponent roncooJmsComponent;
    
    
    @Test
    public void send() {
    roncooJmsComponent.send("hello world");
    }
    
    
    }

![70 1][]

[70]: /images/20220522/9f694922c2d74585b9aa67c1934dc28a.png
[70 1]: /images/20220522/2a5580d0ea004c4ba3edfa4e2cb1cc72.png