【springboot】整合activemq

小半 • 2023年2月5日上午10:43 • 技术随笔 • 阅读 338

一.图片示例

1.activemq下载界面

2.activemq后台管理界面

二.activemq下载

1.下载地址： https://activemq.apache.org/components/classic/download/
2.后台管理地址：http://127.0.0.1:8161/
3.后台管理账号密码：admin/admin

三.代码示例

1.pom引入坐标

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

2.application配置

spring:
  activemq:
    broker-url: tcp://localhost:61616
  jms:
    template:
      //默认位置
      default-destination: mq-learning

3.实现类

package com.mq.service.impl;

import com.mq.service.MessageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;

/**
 * @Author wangyouhui
 * @Description 消息实现类
 **/
@Service
public class MessageServiceImpl implements MessageService {
    @Autowired
    private JmsMessagingTemplate messagingTemplate;

    @Override
    public void sendMessage(String id) {
        messagingTemplate.convertAndSend(id);
    }

    @Override
    public String handleMessage() {
        return messagingTemplate.receiveAndConvert(String.class);
    }
}

4.测试类

package com.mq;

import com.mq.service.MessageService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * @Author wangyouhui
 * @Description 测试activemq
 **/
@SpringBootTest
public class ActiveMqTest {
    @Autowired
    private MessageService messageService;

    @Test
    public void sendMessage(){
        for(int i=0;i<4;i++){
            messageService.sendMessage(String.valueOf(i));
        }
    }

    @Test
    public void getMessage(){
        for(int i=0;i<4;i++){
            String s = messageService.handleMessage();
            System.out.println(s);
        }
    }
}

5.监听器类

package com.mq.listener;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * @Author wangyouhui
 * @Description 消费消息监听器
 **/
@Component
public class MessageListener {
    // 消费mq_test队列监听器
    @JmsListener(destination = "mq-test")
    // 将消费的结果放入新的队列中
    @SendTo("mq_new_test")
    public String receive(String id){
        System.out.println("消费的消息："+id);
        return "new"+id;
    }
}