.Net RabbitMQ實戰指南——HTTP API介面調用
RabbitMQ Management插件還提供了基於RESTful風格的HTTP API介面來方便調用。一共涉及4種HTTP方法:GET、PUT、DELETE和POST。GET方法一般用來獲取如集群、節點、隊列、交換器等資訊。PUT方法用來創建資源,如交換器、隊列之類的。DELETE方法用來刪除資源。POST方法也是用來創建資源的,與PUT不同的是,POST創建的是無法用具體名稱的資源。比如綁定關係(bindings)和發布消息(publish)無法指定一個具體的名稱。
點擊Web管理介面左下角的「HTTP API」即可跳轉到相應的「RabbitMQ Management HTTP API」幫助頁面(//localhost:15672/api/index.html),裡面有詳細的介面資訊。
藉助提供HTTP API介面可以實現自己的中台或者前端做一些調用等。
HTTP API 調用
官網文檔給的curl示例
調用HTTP API可以藉助RabbitMqHttpApiClient(//github.com/kuanysh-nabiyev/RabbitMqHttpApiClient)或者自己實現Http請求。
本文藉助Refit庫實現RabbitMQ HTTP API調用,只有一個//localhost:15672/api/vhosts 示例。關於Refit庫的使用可以參考://github.com/reactiveui/refit
定義Refit API介面
示例只簡單的返回string,實際使用時可定義對應的Model。
註冊IRabbitMQApi
AddRefitClient方法需要添加Refit.HttpClientFactory包。通過AuthorizationHeaderValueGetter增加RabbitMQ HTTP API調用的身份認證,對應IRabbitMQApi的Headers(“Authorization: Basic”)部分
注入和調用
在控制的構造函數中注入IRabbitMQApi,並在對應方法中調用。
運行效果
說明
示例源碼://github.com/MayueCif/RabbitMQ
本意是想學習完整個RabbitMQ系列在看其他內容。無奈考慮換份工作到某寶在線面試碰壁,主要是mysql基礎薄弱、集群相關以及.Net Core一些機制的實現原理沒有深究。因為一直都是用EF來操作資料庫,所以會做一些EF操作千萬級別數據的嘗試。