SpringBoot整合ActiveMQ的简单应用（1）

- 日理万妓 2021-09-17 19:10 316阅读 0赞

1、首先是从官网下载

![20190116145112666.png][]

然后打开

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70][]

运行起来，这时候要根据自己的电脑运行什么样的位数，本人电脑是64位的，所以运行64位的程序，这时候会显示一个界面

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 1][]

说明启动成功了，然后在电脑浏览器中输入地址：[http://localhost:8161/admin/queues.jsp][http_localhost_8161_admin_queues.jsp]

进行登录，用户名和密码都是admin,这个时候就能看到消息队列了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 2][]

我这里有三个消息队列

maven中导包

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-activemq</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.apache.activemq</groupId>
    			<artifactId>activemq-pool</artifactId>
    		</dependency>

之后就在项目中编写生产者和消费者了

![20190116145752571.png][]

生产者：

import org.apache.activemq.command.ActiveMQQueue;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.jms.core.JmsMessagingTemplate;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    
    import javax.jms.Destination;
    import javax.jms.Queue;
     
    /**
     * describe:
     *
     * @author DCX
     * @date 2019-1-16
     */
    @Component
    @EnableScheduling
    public class PromoteActProducer {
     
        @Autowired
        private JmsMessagingTemplate jmsMessagingTemplate;
     
       // @Scheduled(cron = "0/3 * * * * ?")    // 每3s执行1次
        public void sendMsg(String destinationNmae,String msg) {
        	Destination destination = new ActiveMQQueue(destinationNmae);
            this.jmsMessagingTemplate.convertAndSend(destination, msg);
        }
    }

消费者

import org.springframework.jms.annotation.JmsListener;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
     
    /**
     * describe:
     *
     * @author DCX
     * @date 2019-1-16
     */
    @Component
    public class PromoteActConsumer {
     
        /**
         * 客户端消费
         * @param consumer
         * @throws InterruptedException 
         */
    	
        @JmsListener(destination = "任务名称")
        public void receiveQueue(String consumer) throws InterruptedException {
        	Thread.sleep(4000);
            System.out.println(consumer+"--这条消息已经消费了");
        }
    }

这个消费者要注意一下， @JmsListener(destination = "任务名称")，这个注解是监听我创建的destination的名称叫做“任务名称”的一个消息，它才会去消费

消费者这里是自动监听消费的，但是生产者的生产消息不是自动的，这时我才用手动方式来增加队列消息，在控制层编写一个测试![20190116150256566.png][]

内容为：

import javax.annotation.Resource;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    import cn.xtkj.entity.common.Result;
    import cn.xtkj.mq.PromoteActProducer;
    import io.swagger.annotations.Api;
    import io.swagger.annotations.ApiOperation;
    import io.swagger.annotations.ApiParam;
    
    @RestController
    @RequestMapping("/testActiveMQ")
    @Api(tags = "任务测试", description = "TestTask")
    public class TestTaskController {
    	@Resource
    	private PromoteActProducer producer;
    	
    	@PostMapping("createMsg")
    	@ApiOperation(value = "生产者创建消息", response = Result.class)
    	private Object createMsg(
    			@ApiParam(value = "内容", required = false) @RequestParam(required = false) String destinationNmae,
    			@ApiParam(value = "任务信息", required = false) @RequestParam(required = false) String msg) {
    		
    		for (int i = 0; i < 10; i++) {
    			producer.sendMsg(destinationNmae, msg);
    		}
    		
    		return "生产顺利";
    	}
    
    }

然后在配置文件中配置信息

spring.activemq.broker-url=tcp://localhost:61616
    spring.activemq.in-memory=false
    #true表示使用连接池
    spring.activemq.pool.enabled=true
    #连接池最大连接数
    spring.activemq.pool.max-connections=5
    #空闲的连接过期时间，默认为30秒
    spring.activemq.pool.idle-timeout=30000
    #强制的连接过期时间，与idleTimeout的区别在于：idleTimeout是在连接空闲一段时间失效，而expiryTimeout不管当前连接的情况，只要达到指定时间就失效。默认为0，never
    spring.activemq.pool.expiry-timeout=0

最后启动项目，

![20190116150512678.png][]

本人采用swagger-ui接口调试

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 3][]

传入参数之后，生产者会生产十个消息，这时候再去页面看下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 4][]

刚刚新建的十条队列消息已经在队列中

[20190116145112666.png]: /images/20210708/b8ca008a0e144781ae47d8667d7c7609.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70]: /images/20210708/ca1b090967ad45159cccbece10429997.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 1]: /images/20210708/809e8c6eb8824e368b2b93fee98a12ff.png
[http_localhost_8161_admin_queues.jsp]: http://localhost:8161/admin/queues.jsp
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 2]: /images/20210708/a27035d5ec5a4996951c8cc48ffd511e.png
[20190116145752571.png]: /images/20210708/8021e960482d44a08b350d1b1b9686bc.png
[20190116150256566.png]: /images/20210708/9c9ef16b1c554c409c4496fd1fc85941.png
[20190116150512678.png]: /images/20210708/6de8a4c5e32f4ef58624b3b5441d6850.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 3]: /images/20210708/4b62ca9f86a849d0882988123c20aeb0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MTc4OTk4_size_16_color_FFFFFF_t_70 4]: /images/20210708/de148ab357404f8784fca4130f50edf6.png