springboot 集成 activemq 使用

官网下载地址
https://activemq.apache.org/

下载参考这篇文章吧
https://juejin.cn/post/6955035607236100104

首先添加依赖

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

启动类开启注解

@EnableJms

添加配置

spring:
  activemq:
    broker-url: tcp://127.0.0.1:61616
    user: admin
    password: admin
    jms:
      pub-sub-domain: true # 默认为 false:queue 一对一   true:topic 一对多
    queue: queue_mq # 点对点消费名字
    topic: topic_mq # 订阅式消费名字
   

发布者 与 接收

import com.manhua.comic.backEnd.mq.ConvertAndSendService;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
public class ConvertAndSend{

    @Resource
    private JmsMessagingTemplate jmsMessagingTemplate;


    public void send(String queue,String number) {
        jmsMessagingTemplate.convertAndSend("data", number);
        //方法一：添加消息到消息队列
        //jmsMessagingTemplate.ConvertAndSend(queue, name);
        //方法二：这种方式不需要手动创建queue，系统会自行创建名为test的队列
        //jmsMessagingTemplate.ConvertAndSend("test", name);
    }

    @JmsListener(destination = "data")
    public void JmsListeneryuan(String text) {
        System.err.println("消费了data：" + text);
    }

}