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

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

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

HTTP API 調(diào)用

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

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

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

定義Refit API接口

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

注冊IRabbitMQApi

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

注入和調(diào)用

在控制的構(gòu)造函數(shù)中注入IRabbitMQApi，并在對應(yīng)方法中調(diào)用。

運行效果

說明

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

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

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

最新評論