{

  "Logging": {

    "LogLevel": {

      "Default": "Information",

      "Microsoft.AspNetCore": "Warning"

    }

  },

  "AllowedHosts": "*",

  "DeveloperSharp.RabbitMQ":[{

    "HostName":"135.208.12.236",

    "UserName":"sa",

    "Password":"aevin.gang",

    "Port":5672

  }]

}

<appSettings>

<add key="RabbitMQConnectionString" value="hostName=135.208.12.236,port=5672,userName=sa,password=aevin.gang" />

</appSettings>

using DeveloperSharp.RabbitMQ;

--------------------------

static void Main(string[] args)

{

//發(fā)送5個消息（使用SendMessage）

RabbitMQHelper.SendMessage("aa", "世界1，你好！");

RabbitMQHelper.SendMessage("aa", "世界2，你好！");

RabbitMQHelper.SendMessage("aa", "世界3，你好！");

RabbitMQHelper.SendMessage("aa", "世界4，你好！");

RabbitMQHelper.SendMessage("aa", "世界5，你好！");

//獲取1個消息（使用GetMessage）

string OneMessage = RabbitMQHelper.GetMessage("aa").Message;

Console.WriteLine(OneMessage);

//向fj.txt這個文本文件中寫入4個消息（使用UseMessage）

RabbitMQHelper.UseMessage("aa", t => 

{

System.IO.File.AppendAllText("D:/fj.txt", t.Message);

return true;

});

}

（1）發(fā)送一個消息

void SendMessage(string QueueName, string Message, Dictionary<string, object> Header = null)

//異步方法：SendMessageAsync

（2）獲取一個消息

RabbitMQMessage GetMessage(string QueueName)

//異步方法：GetMessageAsync

（3）使用一個消息（連續(xù)使用）

void UseMessage(string QueueName, Func<RabbitMQMessage, bool?> Use)

//異步方法：UseMessageAsync

附加說明：

    （I）Use返回值為true時，代表當前消息已被有效處理并會被服務器刪除。然后程序自動進入下一條消息的使用。

         若Use返回值為false時，代表當前消息未被有效處理但仍會被服務器刪除。然后程序自動進入下一條消息的使用。

         若Use返回值為null時，代表當前消息會被服務器重新隊列分配到其它可用的實例上再處理。然后程序自動進入下一條消息的使用。

         若Use內部發(fā)生未被處理的異常，程序會停止。

    （II）RabbitMQMessage對象定義如下：

          public class RabbitMQMessage

          {

             public string Message;

             public IDictionary<string, object> Header;

             public string Id; //此處系統(tǒng)自動生成的Id具有UUID的特性。

          }

using DeveloperSharp.RabbitMQ;//從NuGet引用DeveloperSharp.RabbitMQ包

--------------------------

//定義bbq隊列，其中存放的消息會在60秒后過期

var myQ = RabbitMQHelper.SetQueue("bbq", 60000);

//定義與bbq隊列對應的死信隊列

var expQ = RabbitMQHelper.GetQueue("bbq");

//向BB.txt這個文本文件中連續(xù)寫入死信隊列中的消息

expQ.UseMessage(t =>

{

System.IO.File.AppendAllText("D:/BB.txt", t.Message);

return true;

});

//向bbq隊列發(fā)送3個消息

myQ.SendMessage("jinA");

myQ.SendMessage("jinB");

myQ.SendMessage("jinC");

/*

//【附加題】：若去掉注釋讓此語句執(zhí)行，死信隊列中將不會獲得消息(為啥？自己推理)

RabbitMQHelper.UseMessage("bbq", t =>

{

return true;//若此處返回false，死信隊列將會獲得消息

});

*/