消息队列MQ

基于MassTransit.RabbitMQ的延时消息队列

本文主要是介绍基于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的延时消息队列的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
                    


                


                
                
 

                
                

                    

                        
您可能喜欢

                        
                    

                

                

            

             
            
            
            
        

        
        

        

            

                
栏目导航