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

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

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

HTTP API 調(diào)用

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

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

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

定義Refit API接口

示例只簡(jiǎn)單的返回string，實(shí)際使用時(shí)可定義對(duì)應(yīng)的Model。

注冊(cè)IRabbitMQApi

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

注入和調(diào)用

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

運(yùn)行效果

說(shuō)明

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

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

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

最新評(píng)論