SpringBoot整合ActiveMq (简单整合)

ActiveMq 简单介绍

一个消息中间件,常用的消息中间件有RabbitMq、RocketMq、ActiveMq。ActiveMq是Apache推出的一个开源项目 有 点对点 和 发布/订阅 两种模式

        
            org.springframework.boot
            spring-boot-starter-activemq
        

#ActiveMq配置
# 用户名
spring.activemq.user=admin
# 密码
spring.activemq.password=admin
# 是否使用内置mq
spring.activemq.in-memory=false
# 信赖所有包
spring.activemq.packages.trust-all=true
# 通信地址
spring.activemq.broker-url=tcp://127.0.0.1:61616

package com.sora.spring.mq;

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

import javax.jms.Queue;


@Component
public class QueueInit {

    @Bean
    Queue queue() {
        // 将该队列装在到Spring容器
        return new ActiveMQQueue("queue.messaging");
    }
}

package com.sora.spring.mq;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

import javax.jms.Queue;


@Component
public class Producer {

    
    @Autowired
    private Queue queue;

    
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    public void pord(String msg) {
        // 将msg存入消息队列中
        jmsMessagingTemplate.convertAndSend(this.queue,msg);
    }
}

package com.sora.spring.mq;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;


@Component
public class Consumer {

    
    @JmsListener(destination = "queue.messaging")
    public void getMsg(String msg) {
        System.out.println("消息队列中的消息为"+ msg);
    }
}

package com.sora.spring;

import com.sora.spring.mq.Producer;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;


@SpringBootTest
public class ActiveMqTest {

    @Autowired
    private Producer producer;

    @Test
    public void mqTest() {
        producer.pord(" Mq消息队列测试");
    }
}

浏览器地址输入mq网址进入mq管理页面http://localhost:8161/http://localhost:8161/

队列中成功处理完成1条消息 

 至此,一个简单的mq就测试完成了。