業務背景

在我們的日常開發中，經常需要調用第三方接口來進行數據傳遞，在調用接口的過程中，會因為各種原因導致調用的失敗。這時我們希望能有一種機制實現對失敗的接口的重復調用，并且能夠實現人工干預。

實現思路

1、當接口調用失敗，記錄相關數據到數據庫，采用輪詢的方式對數據庫的記錄進行掃描

本文采用的方式是第二種，接口調用流程如下圖：

RabbitMQ

RabbitMQ 可以通過 TTL(Time To Live)、DLX(Dead Letter Exchanges) 特性實現延遲隊列。其原理是給消息設置過期時間，在消息隊列上為過期消息指定轉發器，這樣消息過期后會轉發到與指定轉發器匹配的隊列上，就實現了延時隊列。消息流轉如下圖：

生產者代碼

static?void?Main(string[]?args) {var?factory?=?new?ConnectionFactory()?{?HostName?=?"127.0.0.1",?UserName?=?"oec2003",?Password?=?"123456"?};using?(var?connection?=?factory.CreateConnection())while?(Console.ReadLine()?!=?null){using?(var?channel?=?connection.CreateModel()){var?arguments?=?new?Dictionary<string,?object>();arguments.Add("x-dead-letter-exchange",?"exchange-2");arguments.Add("x-dead-letter-routing-key",?"rk-2");channel.QueueDeclare("queue-1",true,false,false,arguments);channel.ExchangeDeclare("exchange-2",?"direct");channel.QueueDeclare("queue-2",?false,?false,?false,?null);channel.QueueBind("queue-2",?"exchange-2",?"rk-2",?null);var?message?=?"Hello?oec2003!";var?body?=?Encoding.UTF8.GetBytes(message);var?properties?=?channel.CreateBasicProperties();properties.Persistent?=?true;properties.Expiration?=?"5000";channel.BasicPublish("",?"queue-1",?properties,?body);Console.WriteLine($"發送：?{message}");}}Console.ReadKey(); }

消費者代碼

static?void?Main(string[]?args) {var?factory?=?new?ConnectionFactory()?{?HostName?=?"127.0.0.1",?UserName?=?"oec2003",?Password?=?"123456"?};using?(var?connection?=?factory.CreateConnection())using?(var?channel?=?connection.CreateModel()){channel.QueueDeclare("queue-2",?false,?false,?false,?null);var?consumer?=?new?EventingBasicConsumer(channel);consumer.Received?+=?(model,?ea)?=>{var?body?=?ea.Body;var?message?=?Encoding.UTF8.GetString(body);?Console.WriteLine("已接收：?{0}",?message);???};channel.BasicConsume("queue-2",?false,?consumer);}Console.ReadLine();? }

數據庫

在數據庫中需要存儲接口調用的相關信息，有以下幾個用途：

• 記錄失敗次數，作為消息發送時的依據

• 超過最大的重試次數，需要人工來進行手動重新調用

上面表中只是基礎的一些字段，在真實業務中可以根據實際情況進行字段的增加。數據庫表設計見下圖：

最后

本文提供一種很簡單的實現接口補償的方式，希望對您有所幫助，也歡迎私信討論。

文中示例代碼：https://github.com/oec2003/StudySamples/tree/master/RabbitMQDLXDemo

總結

以上是生活随笔為你收集整理的使用RabbitMQ实现接口补偿的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。