RabbitMQ Management插件還提供了基于RESTful風格的HTTP API接口來方便調用。一共涉及4種HTTP方法：GET、PUT、DELETE和POST。GET方法一般用來獲取如集群、節(jié)點、隊列、交換器等信息。PUT方法用來創(chuàng)建資源，如交換器、隊列之類的。DELETE方法用來刪除資源。POST方法也是用來創(chuàng)建資源的，與PUT不同的是，POST創(chuàng)建的是無法用具體名稱的資源。比如綁定關系（bindings）和發(fā)布消息（publish）無法指定一個具體的名稱。

點擊Web管理界面左下角的“HTTP API”即可跳轉到相應的“RabbitMQ Management HTTP API”幫助頁面（http://localhost:15672/api/index.html），里面有詳細的接口信息。

借助提供HTTP API接口可以實現(xiàn)自己的中臺或者前端做一些調用等。

HTTP API 調用

官網(wǎng)文檔給的curl示例

調用HTTP API可以借助RabbitMqHttpApiClient（https://github.com/kuanysh-nabiyev/RabbitMqHttpApiClient）或者自己實現(xiàn)Http請求。

本文借助Refit庫實現(xiàn)RabbitMQ HTTP API調用，只有一個http://localhost:15672/api/vhosts 示例。關于Refit庫的使用可以參考：https://github.com/reactiveui/refit

定義Refit API接口

示例只簡單的返回string，實際使用時可定義對應的Model。

注冊IRabbitMQApi

AddRefitClient方法需要添加Refit.HttpClientFactory包。通過AuthorizationHeaderValueGetter增加RabbitMQ HTTP API調用的身份認證，對應IRabbitMQApi的Headers("Authorization: Basic")部分

注入和調用

在控制的構造函數(shù)中注入IRabbitMQApi，并在對應方法中調用。

運行效果

說明

示例源碼：https://github.com/MayueCif/RabbitMQ

本意是想學習完整個RabbitMQ系列在看其他內容。無奈考慮換份工作到某寶在線面試碰壁，主要是mysql基礎薄弱、集群相關以及.Net Core一些機制的實現(xiàn)原理沒有深究。因為一直都是用EF來操作數(shù)據(jù)庫，所以會做一些EF操作千萬級別數(shù)據(jù)的嘗試。

到此這篇關于.Net RabbitMQ實現(xiàn)HTTP API接口調用的文章就介紹到這了,更多相關.Net RabbitMQ HTTP API接口調用內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論