ketcup git地址：https://github.com/simple-gr/ketchup
rabbitmq 安裝
1.docker pull rabbitmq:management
2.docker run -itd --name rabbitmq --restart=always -p 5672:5672 -p 15672:15672 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=qwe123QWE rabbitmq:management
RABBITMQ_DEFAULT_USER：默認登陸名稱，RABBITMQ_DEFAULT_PASS：默認登陸密碼
3.http://ip:15672 web頁面登陸
出現該頁面就代表安裝成功
ketchup 中 配置 rabbitmq
"RabbitMQ": { "Host": "192.168.190.4",//ip地址 "UserName": "admin",//用戶名 "Password": "qwe123QWE",//密碼 "RetryCount": 3,//重試執行次數 "FailCount": 1//失敗執行次數 }
1.定義event物體
public class UserEvent : EventHandler { public string Name { get; set; } public string Job { get; set; } }
2.實作eventhandler
QueueConsumerMode.Normal：一般訊息
QueueConsumerMode.Retry：重試佇列
QueueConsumerMode.Fail：死信佇列
[QueueConsumer(nameof(HelloEventHandler), QueueConsumerMode.Normal, QueueConsumerMode.Retry, QueueConsumerMode.Fail)] public class HelloEventHandler : BaseEventHandler<UserEvent> {
//實作一般佇列與重試佇列 public override Task Handle(UserEvent @event) { Console.WriteLine($"消費，{@event.Name}---{@event.Job}"); throw new Exception(); } //實作一般佇列與重試佇列 public override Task Handled(EventContext context) { Console.WriteLine($"呼叫{context.Count}次，型別:{context.Type}"); var model = context.Content as UserEvent; return Task.CompletedTask; } //實作死信佇列方法 public override Task FailHandler(EventContext context) { Console.WriteLine($"呼叫{context.Count}次，私信佇列方法 ，方法,型別:{context.Type}"); return base.FailHandler(context); } }
3.啟動程式
rabbitmq 中已經顯示出佇列的資訊
發布訊息
ServiceLocator.GetService<IEventBus>().Publish(new UserEvent() { Name = "simple", Job = "it" });
日志顯示消費
寫在最后
QQ群：592407137 期待大家一起研究，學習~~
如果喜歡，請給予一個Start 給予支持，謝謝！
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/27025.html
標籤：.NET Core