金数字网站建设,建设银行网站的目的是什么意思,庆元县住房和城乡建设局网站,wordpress培训插件目录
一、引言
二、延迟插件安装
2.1. 下载插件
2.2. 安装插件
2.3. 确认插件是否生效
三、核心代码 四、运行效果
五、总结 一、引言
上一章我们讲到通过死信队列组合消息过期时间来实现延迟消息#xff0c;但相对而言这并不是比较好的方式。它的代码实现相对来说比…目录
一、引言
二、延迟插件安装
2.1. 下载插件
2.2. 安装插件
2.3. 确认插件是否生效
三、核心代码 四、运行效果
五、总结 一、引言
上一章我们讲到通过死信队列组合消息过期时间来实现延迟消息但相对而言这并不是比较好的方式。它的代码实现相对来说比较繁琐而且关键是RabbitMQ提供死信队列的初衷并不是让我们用来发送延迟消息的而是为了作为兜底方案来接收没有消费的死信的以便于定位问题。那么本章节我们就开始讲解通过延迟消息插件来实现延迟消息。
延迟消息插件可以将普通交换机改造为支持延迟消息功能的交换机当消息投递到交换机后可以暂存一定时间到期后再投递到队列。 这个插件可以将普通交换机改造为支持延迟消息功能的交换机当消息投递到交换机后可以暂存一定时间到期后再投递到队列。 发送消息时需要通过消息头x-delay来设置过期时间 二、延迟插件安装
在Mac上安装RabbitMQ延迟消息插件时确保你已经安装了RabbitMQ并且它正在运行操作步骤如下Linux安装步骤和方法类似此处不做赘述
2.1. 下载插件
从RabbitMQ官方GitHub仓库或者通过以下命令直接下载我这里是最新版本
wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/download/v4.0.2/rabbitmq_delayed_message_exchange-4.0.2.ez
2.2. 安装插件 将下载的插件拷贝到RabbitMQ的plugins目录使用RabbitMQ插件管理命令安装下载的插件 sudo rabbitmq-plugins enable rabbitmq_delayed_message_exchange 如果你的RabbitMQ是以Docker容器的方式运行的你可以将插件下载步骤和安装步骤合并为一个Docker命令例如
docker run -d --name rabbitmq -e RABBITMQ_PLUGINSrabbitmq_delayed_message_exchange rabbitmq:3-management
这个命令会启动一个带有RabbitMQ管理插件的容器并且会自动安装延迟消息插件。
2.3. 确认插件是否生效
安装成功后RabbitMQ的浏览器界面上exchange交换机在创建时Type多了x-delayed-message选项。 请注意具体的RabbitMQ版本和插件版本可能会更新因此请根据实际情况下载相应的版本。
三、核心代码
package com.example.publisher;import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageBuilder;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.boot.test.context.SpringBootTest;import java.nio.charset.StandardCharsets;/*** 生产者*/
Slf4j
SpringBootTest
class PublisherApplicationTests {Resourceprivate RabbitTemplate rabbitTemplate;Testvoid test() {String content 生活不易所以保持足够的努力对自己要有信心积极地去面对工作生活的挑战;Message message MessageBuilder.withBody(content.getBytes(StandardCharsets.UTF_8)).build();message.getMessageProperties().setDelayLong(10000L);rabbitTemplate.convertAndSend(delay.direct,delay, message);}
}package com.example.consumer;import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;import java.nio.charset.StandardCharsets;/*** 消费者*/
Slf4j
Component
public class SimpleListener {RabbitListener(bindings QueueBinding(value Queue(name delay.queue, durable true),exchange Exchange(name delay.direct, delayed true),key delay))public void listener1(Message message) throws Exception {String msg new String(message.getBody(), StandardCharsets.UTF_8); ;System.out.println(延迟消息人生是个不断攀登的过程【 msg 】);}
}四、运行效果
我们可以看到消息在延时10秒后消费 五、总结
虽然延迟插件让我们在消息延迟发送的代码实现上已经非常简洁但是在使用延迟消息中还有一个问题就是延迟消息比较损耗性能我们在RabbitMQ上使用延迟消息时它的内部就会维护一个时钟每当我们定义一个新的延迟消息它就会创建一个新的时钟。如果一个任务的延迟时间特别长比如一小时甚至一天将非常耗性能。所以延迟消息比较适用于延迟的时间比较短的场景比如10分钟未支付取消订单。
但是我们如果直接设定10分钟后发送延迟消息也不是最优解我们将在下一章对延迟消息做近一步的优化
