ketchup 消息隊列rabbitmq使用

来源:https://www.cnblogs.com/alangur/archive/2020/05/20/12922571.html

ketcup git地址:https://github.com/simple-gr/ketchup rabbitmq 安裝 1.docker pull rabbitmq:management 2.docker run -itd --name rabbitmq --restart=always -p ...


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 給予支持。謝謝!


您的分享是我們最大的動力!

更多相關文章
  • 一、簡單介紹 Quartz.NET是一個強大、開源、輕量的作業調度框架,是 OpenSymphony 的 Quartz API 的.NET移植,用C#改寫,可用於WinForm和ASP.NET應用中。它靈活而不複雜,可以為執行一個作業而創建簡單或複雜的作業調度。它有很多特征,如:資料庫支持、集群、插 ...
  • 0. 前言 今天是NHibernate的第二篇內容,通過上一篇的內容,我們初步瞭解了NHibernate的創建和使用。這一篇,我繼續探索NHibernate背後的秘密。嗯,就是這樣。 1. NHibernate結構 先給小伙伴們放個圖: 這是NHibernate的整體結構圖。NHibernate通過 ...
  • 隨著信息技術對人們工作生活的影響越來越大,人們對於應用程式的依賴性也越來越大,越來越多的人使用應用程式來解決自己工作和生活中的問題,這也導致應用程式的開發需求越來越高,傳統的應用程式開發方法已經沒有辦法滿足市場的需求,低代碼開發平臺在這樣的背景下誕生了。 力軟低代碼開發平臺可以減少開發成本,代碼、功 ...
  • C#手動建立Table後,並設置列和賦值 public DataTable CreateTable() { //創建Table1 DataTable dt = new DataTable(); //對Table1添加列名,並設置列值類型 DataTable dt1 = new DataTable() ...
  • C#中的關於Table的Merge() 簡介: Merge()方法可以實現對兩個table具有相同欄位的進行Morge,也可以實現對兩個table具有不同欄位的進行Merge。但是實現後的結果可能不太一樣。 一、對兩個table具有相同的欄位進行Merge的時候,所得到Merge後的table行數小 ...
  • 倉儲物流的過程中往往少不了一些使用熱敏印表機或者碳帶印表機列印一些條碼、信息貼在實物或者包裹上 最好的實現方式不過於直接使用熱敏代碼形成文本直接輸出到印表機做列印 但是熱敏代碼也是一門需要特殊的語言,需要學習 故為了更快更方便的實現,就用到了畫布繪製後形成image輸出到印表機 而image也是有要 ...
  • 關於讀取Excel模板對模板讀寫操作 1.根據文件名稱(帶盤符的文件目錄),建立SLDocument對象 SLDocument sldocument = new SLDocument(filename); sldocument.SelectWorksheet("Sheet1"); 2.讀取某一單元格 ...
  • 上一篇文章(https://www.cnblogs.com/meowv/p/12913676.html)我們用Code First的方式創建了博客所需的實體類,生成了資料庫表,完成了對EF Core的封裝。 本篇說一下自定義倉儲的實現方式,其實在abp框架中已經預設給我們實現了預設的通用(泛型)倉儲 ...
一周排行
  • C#6.0新特性 C#7.0新特性 C#8.0新特性 ...
  • out變數 可以直接在方法中使用out申明變數 int.TryParse("123", out var result); 元組 元組的申明 var alphaBetaStart = (alpha: "a", beta: "b"); Console.WriteLine($"{alphaBetaStar ...
  • 在我們的項目中,通常會把數據存儲到關係型資料庫中,比如Oracle,SQL Server,Mysql等,但是關係型資料庫對於併發的支持並不是很強大,這樣就會造成系統的性能不佳,而且存儲的數據多為結構化數據,對於非結構數據(比如文本)和半結構化數據(比如JSon) 就顯得不夠靈活,而非關係型資料庫則很 ...
  • 這幾天終於弄懂了async和await的模式,也搞明白了一直在心裡面積壓著的許多問題,所以寫一篇博客來和大家分享一下。 關於非同步機制我認為只要記住的以下幾點,就可以弄明白了: 1.我認為async和awwait兩個修飾符中最關鍵的是await,async是由於方法中包含await修飾符之後才在方法定 ...
  • 實現WCF的步驟如下: 設計服務協議 實現服務協議 配置服務 托管服務 生成客戶端(這步可有可無) 設計或定義服務協議要麼使用介面,要麼使用類。建議介面,使用介面好處一堆例如修改介面的實現,但是服務協定有無需改變。 設計服務協議,介面上使用 ServiceContractAttribute ,方法上 ...
  • 什麼鬼,我的CPF快寫好了,你居然也要搞跨平臺UI框架?什麼Maui? 之前怎麼不早說要搞跨平臺UI框架呢?看到谷歌搞flutter眼紅了?明年年底發佈?又搞這種追別人屁股的爛事情。 什麼MVU模式?模仿Dart?用C#代碼直接寫UI的模式和我的CPF很像啊。 當初我考慮過XML,Json來描述UI ...
  • 寫在前面 Docker作為開源的應用容器引擎,可以讓我們很輕鬆的構建一個輕量級、易移植的容器,通過Docker方式進行持續交付、測試和部署,都是極為方便的,並且對於我們開發來說,最直觀的優點還是解決了日常開發中的環境配置與部署環境配置上的差異所帶來的種種疑難雜症,從此推脫產品的措辭也少了——“我電腦 ...
  • 一、前言 回顧:認證授權方案之授權初識 從上一節中,我們在對授權系統已經有了初步的認識和使用,可以發現,asp.net core為我們提供的授權策略是一個非常強大豐富且靈活的認證授權方案,能夠滿足大部分的授權場景。 在ConfigureServices中配置服務:將授權服務添加到容器 public ...
  • 項目背景: 工作之餘兼職一家公司(方向是工業4.0)給做IM系統,主要功能包括:文字、 圖片、文件傳輸、遠程協助、視頻語音等等。這些功能都是基於群會話, 比如工廠操作工人遇到問題,請求遠程專家,這個初級專家不能解決問題,會邀請一個高級專家進來解決。開發過程中主要遇到的問題是視頻和語音這一塊,像其他的... ...
  • 基礎概念 Microsoft中間語言(MSIL),也成為通用中間語言(CIL),是一組與平臺無關的指令,由特定於語言的編譯器從源代碼生成。MSIL是獨立於平臺的,因此,他可以在任何公共語言基礎架構支持特定的環境上執行。 通過JIT編譯器將MSIL轉換為特定電腦環境的特定機器代碼。這是在執行MSIL ...