SpringBoot整合ActiveMQ

本文介绍: 监听器收到消息后，不仅可以消费消息，还可以将当前方法的返回值，在转发给下一个消息队列。消息怎么会手工点击消费呢，哈哈哈，肯定是收到消息赶紧处理，必须交给机器处理啦！所以改造一下我们的监听器。jms的消息模型有两种。

Spr in gBo o t整合Act i v eMQ

导坐标

        &lt;dependency&gt;
            &lt;groupId&gt;org.springframework.boot</groupId&gt;
            <artifactId&gt;spring-boot-starter-activemq</artifactId&gt;
        </dependency&gt;

改配置，默认的保存 位置

spring:
  activemq:
    broker-url: tcp://localhost:61616
  jms:
    template:
      default-destination: itheima

生产与消费消息

在这里插入图片描述

@Service
public class MessageServiceActivemqImpl implements MessageService {

    @Autowired
    private JmsMessagingTemplate messagingTemplate;
    @Override
    public void sendMessage(String id) {
        System.out.println("待发送短信的订单已经纳入队列：id=" + id);
        messagingTemplate.convertAndSend("order.queue.id",id);
        // 发消息的时候设定存储位置
    }

    @Override
    public String doMessage() {
        String id = messagingTemplate.receiveAndConvert("order.queue.id",String.class);
        System.out.println("已完成短信发送业务，id:"+id);
        return id;
    }
}

消息怎么会手工点击消费呢，哈哈哈，肯定是收到消息赶紧处理，必须交给机器处理啦！

实现 监听类——实现消息自动消费

在这里插入图片描述

@Component
public class MessageListener {

    @JmsListener(destination = "order.queue.id")
    public void reveive(String id){
        System.out.println("已完成短信发送业务，id:"+id);
    }
}

监听器收到消息后，不仅可以消费消息，还可以将当前方法的返回值，在转发给下一个消息队列。
所以改造一下我们的监听器

监听器转发消息：流程性业务消息消费完转入下一个消息队列

在这里插入图片描述

@Component
public class MessageListener {

    @JmsListener(destination = "order.queue.id")
    @SendTo("order.other.queue.id")
    public String reveive(String id){
        System.out.println("已完成短信发送业务，id:"+id);
        return "new:" + id;
    }
}

jms的消息模型有两种

点对点
发布订阅
目前使用的是点对点的模型，要想更换，做一个配置 pub–su b–domain: true

server:
  port: 80

spring:
  activemq:
    broker-url: tcp://localhost:61616
  jms:
    template:
      default-destination: itheima
    
    pub-sub-domain: true