---

前言

DeveloperSharp.RabbitMQ 是一個專為.NET開發者設計的高階封裝庫，旨在極大簡化RabbitMQ的集成與操作流程。它通過抽象底層復雜配置，提供極簡API，讓開發者無需深入理解AMQP協議細節即可快速實現消息隊列功能。

一、核心特性與設計理念

極簡API設計

• 僅需掌握三個核心方法即可覆蓋大部分消息場景：
  • SendMessage：同步發送消息至指定隊列。
  • GetMessage：從隊列獲取單條消息（立即返回）。
  • UseMessage：持續消費隊列消息（長連接模式），通過回調函數處理每條消息。

  // 發送消息
  RabbitMQHelper.SendMessage("orderQueue", "訂單創建:12345");// 單次獲取消息
  var msg = RabbitMQHelper.GetMessage("orderQueue").Message;// 持續消費
  RabbitMQHelper.UseMessage("orderQueue", message => {ProcessOrder(message);return true; // 確認刪除消息
  });
  

二、使用步驟

1.配置 RabbitMQ 連接（配置文件設置）

• 位置要求：配置文件必須位于程序執行目錄（如 bin/Debug/netx.x）或項目根目錄
• 文件類型：appsettings.json

  {"DeveloperSharp.RabbitMQ": [{"HostName": "your-rabbitmq-ip","VirtualHost": "/",        // 可選，默認為 "/""UserName": "your-user","Password": "your-password","Port": 5672               // 默認 5672}]
  }
  

2.發送消息（在 Controller 中）

1. 在 API 接口中發送消息到指定隊列：

   using DeveloperSharp.RabbitMQ;
   using Microsoft.AspNetCore.Http;
   using Microsoft.AspNetCore.Mvc;namespace DeveloperSharpRabbitMQSend.Controllers
   {[Route("api/[controller]/[action]")][ApiController]public class MessageController : ControllerBase{[HttpPost]public IActionResult SendMessage(string msg){//同步發送RabbitMQHelper.SendMessage("orderQueue",msg);// 異步發送（高并發推薦）// await RabbitMQHelper.SendMessageAsync("orderQueue", text);return Ok($"消息已發送：{msg}");}}
   }

3.消費消息（后臺服務）

1. 使用 IHostedService 實現后臺持續消費，避免阻塞 API 線程：

   using DeveloperSharp.RabbitMQ;
   using Microsoft.Extensions.Hosting;
   namespace DeveloperSharpRabbitMQSend.HostService
   {public class MyBackgroundService : BackgroundService{private readonly ILogger<MyBackgroundService> _logger;public MyBackgroundService(ILogger<MyBackgroundService> logger){_logger = logger;}protected override Task ExecuteAsync(CancellationToken stoppingToken){RabbitMQHelper.UseMessage("orderQueue", message =>{try{// 處理消息（如寫入數據庫）_logger.LogInformation($"收到消息: {message.Message}");return true; // 確認處理成功，刪除消息}catch{return false; // 處理失敗，丟棄消息// return null; // 重試消息（重新入隊）}});return Task.CompletedTask;}}
   }

4.注冊托管服務

• 代碼示例

  builder.Services.AddHostedService<MyBackgroundService>();
  

三、消息生命周期控制

• 在UseMessage回調中通過返回值決定消息去向：
  • return true：處理成功，刪除消息。
  • return false：處理失敗，刪除消息（可記錄日志）。
  • return null：消息重新入隊，供其他消費者處理。
  • 異常拋出：中斷消費流程（需進程重啟）。

四、高級用法

延時隊列 & 死信隊列

1. 示例：實現消息過期后轉入死信隊列
   • 60秒內未消費 → 消息轉入死信隊列 → 觸發CancelOrder邏輯。
   • 60秒后，D盤下生成文件aa.txt，并記錄消息。

   // 創建過期時間為 60 秒的隊列
   var orderQueue = RabbitMQHelper.SetQueue("orders_dead", 60000);// 獲取死信隊列并消費
   var deadLetterQueue = RabbitMQHelper.GetQueue("orders_dead");
   deadLetterQueue.UseMessage(msg =>
   {File.AppendAllText("D:/aa.txt", msg.Message);return true;
   });// 發送訂單消息
   orderQueue.SendMessage("延時消息");
   

五、適用場景與優勢

• 快速集成：適合中小項目快速引入消息隊列，無需搭建復雜架構
• 高并發處理：支持億級數據量項目
• 跨平臺部署：兼容.NET Framework 4.5+ 與 .NET Core 2.0+，支持Docker/Linux/Windows
• 運維簡化：自帶長連接管理，減少資源泄漏風險（需注意進程銷毀）

六、注意事項

• 生產環境安全
  • 必須啟用SSL/TLS加密傳輸，避免密碼明文暴露
  • 避免使用默認guest賬號，需按角色分配權限
• 資源沖突規避
  • SendMessage/GetMessage/UseMessage務必分離部署（如獨立微服務），避免同一進程內資源競爭
• 消息順序保證
  • 異步發送（SendMessageAsync）可能導致消息亂序，需業務層設計冪等處理

總結

DeveloperSharp.RabbitMQ 通過屏蔽RabbitMQ底層復雜性，為.NET開發者提供了一套“開箱即用”的消息隊列解決方案。
適合需快速構建異步解耦、流量削峰（如電商秒殺）或跨系統聯動的應用場景。對于超大規模集群（日處理億級以上消息），建議結合原生RabbitMQ集群策略進一步優化