SpringBoot整合ActiveMQ案例

迈不过友情╰ 2021-10-14 02:52 410阅读 0赞

### 一、引入相关jar ###

<parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.4.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-starter</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-activemq</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.5</version>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>

###  二、创建两个Maven项目，一个生产者项目，一个消费者项目 ###

生产者目录结构：

![20190817180413771.png][]

消费者目录结构：

![20190817180524691.png][]

### 三、两个项目相同的代码部分  ###

1）、application.yml配置内容

spring:
      activemq:
        broker-url: tcp://127.0.0.1:61616
        user: admin
        password: admin
    queue: zhq.test.activemq

2）、App启动类

/**
     * @program: springbootproducer
     * @description:
     * @author: hq.zheng
     * @create: 2019-08-17 16:33
     */
    @SpringBootApplication
    public class APP {
        public static void main(String[] args) {
            SpringApplication.run(APP.class,args);
        }
    }

### 四、生产者相关案例代码  ###

配置一个定时任务，周期性创建用户，模拟生产者

@Configuration
    public class QueueConfig {
        @Value("${queue}")
        private String queue;
    
        @Bean
        public Queue logQueue() {
            return new ActiveMQQueue(queue);
        }
    
    }

@Component
    @EnableScheduling
    public class Producer {
        @Autowired
        private JmsMessagingTemplate jmsMessagingTemplate;
    
        @Autowired
        private Queue queue;
    
        @Scheduled(fixedDelay = 5000)
        public void send() {
            Random random = new Random(System.currentTimeMillis());
            User user=new User(System.currentTimeMillis(),UUID.randomUUID().toString(),random.nextInt(100)+1);
            jmsMessagingTemplate.convertAndSend(queue, JSON.toJSONString(user));
        }
    
    }

启动后运行结果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70][]

### 五、消费者相关代码  ###

@Configuration
    public class Consumer {
        @JmsListener(destination = "${queue}")
        public void receive(String msg) {
            System.out.println("监听器收到msg:" + msg);
        }
    }

运行结果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 1][]

[20190817180413771.png]: /images/20211013/e29dde70556346b8af850a298b415df0.png
[20190817180524691.png]: /images/20211013/913a68f3c6ee4a259e040683571da4c2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70]: /images/20211013/4bc7494abd79435a890f5b2c3e0b068c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 1]: /images/20211013/50d4f7ed4810479b9a79c87abf09d0a3.png