基于MassTransit.RabbitMQ的延时消息队列
2022/6/3 23:23:17
本文主要是介绍基于MassTransit.RabbitMQ的延时消息队列,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
1 nuget包
<PackageReference Include="MassTransit.RabbitMQ" Version="8.0.2" />
注意事项
本次使用的是docker来运行RabbitMQ
命令是:
docker run -d -p 15672:15672 -p 5672:5672 -p 5671:5671 --hostname my-rabbitmq --name my-rabbitmq-container rabbitmq:3-management
上面的命令使用的镜像是 rabbitmq:3-management,这个镜像没有安装对应的延时队列的插件,会弹出以下错误:
根据官方的文档的介绍,可以看到它们有提供内置延时队列插件的镜像,镜像的名字是:masstransit/rabbitmq,那么我们更换镜像后的命令如下:
docker run -d -p 15672:15672 -p 5672:5672 -p 5671:5671 --hostname my-rabbitmq --name my-masstransit-container masstransit/rabbitmq
2注册
3生产者
4消费者
这篇关于基于MassTransit.RabbitMQ的延时消息队列的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-08「布道师系列文章」解析 AutoMQ 对象存储中的文件存储格式
- 2024-05-08「布道师系列文章」小红书黄章衡:AutoMQ Serverless 基石-秒级分区迁移
- 2024-05-08AutoMQ 系统测试体系揭秘
- 2024-03-14AutoMQ 携手阿里云共同发布新一代云原生 Kafka,帮助得物有效压缩 85% Kafka 云支出!
- 2024-02-22kafka partitioner
- 2024-01-24AutoMQ生态集成 - 将数据从 AutoMQ Kafka 导入 RisingWave 数据库
- 2024-01-13消息队列面试题:为什么要使用消息队列?
- 2024-01-08"基于 XHAMQ 的消息队列系统实现"
- 2023-11-24全网最全图解Kafka适用场景
- 2023-09-19RabbitMQ 消息应答