springboot集成activeMq实战

ゞ浴缸里的玫瑰 2022-05-27 08:05 200阅读 0赞

### 1.首先搭建好activeMq服务器 ###

参考我的上一篇文章：[Linux搭建activMq服务][Linux_activMq]

### 2. 创建springboot项目 ###

参考我的文章：[springboot实战][springboot]

### 3. 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>

### 4.application.properties文件配置 ###

# activemq配置  
    spring.activemq.broker-url=tcp://IP:61616
    spring.activemq.user=admin
    spring.activemq.password=admin
    spring.jms.pub-sub-domain=false
    spring.activemq.pool.enabled=true
    spring.activemq.pool.max-connections=50
    spring.activemq.pool.expiry-timeout=10000
    spring.activemq.pool.idle-timeout=30000
    #注意 对象传输需开启包白名单 否则会报错- -
    spring.activemq.packages.trust-all=true

### 5. 生产者代码 ###

@Component
    public class JMSProducer {
    	@Autowired
        private JmsMessagingTemplate jmsMessagingTemplate;
    
    	public void sendMessage(Destination destination,String message) {
            this.jmsMessagingTemplate.convertAndSend(destination,message);
        }
    	public void send(String message) {
    		Destination destination = new ActiveMQQueue("com.xue.demo");
    		jmsMessagingTemplate.convertAndSend(destination, message);
        }
    }

### 6.消费者代码 ###

@Component
    public class JMSConsumer {
        private final static Logger logger = LoggerFactory.getLogger(JMSConsumer.class);
    
        @JmsListener(destination = "com.xue.demo")
        public void receive(String message) {
        	logger.info("接收到消息：{}",message);
            System.out.println("收到的 message 是：" + message);
        }
    }

### 7.测试类代码 ###

@Autowired
    	private JMSProducer jp;
    	
    	@RequestMapping("/send")
    	public String send() {
    		jp.send("i am producer");
    		logger.info("i am producer");  
    		return "success";
    	}

### 8.结果 ###

![70][]

[Linux_activMq]: https://blog.csdn.net/u010938610/article/details/79939517
[springboot]: https://blog.csdn.net/u010938610/article/details/79448354
[70]: /images/20220527/36bd3879887547c78047508bbd0b4359.png