Install-Package Lails.MQClient

string consumername1 = "consumer1", consumername2 = "consumer1";    //独立订阅
//string consumername1 = "consumer", consumername2 = "consumer";    //共同订阅
MQClient consumer1 = new RabbitMQClient("mq.lails.cc", "root", "Lxs@rabbitmq", consumername1);
MQClient consumer2 = new RabbitMQClient("mq.lails.cc", "root", "Lxs@rabbitmq", consumername2);
consumer1.Connect();
consumer1.Subscribe("msg", data => 
{
    Console.WriteLine($"订阅1接收消息：{Encoding.UTF8.GetString(data)}");
    consumer1.UnSubscribe("msg");
    Console.WriteLine("退订consumer1");
    return true; //ACK
});
consumer2.Connect();
consumer2.Subscribe("msg", data =>
{
    Console.WriteLine($"订阅2接收消息：{Encoding.UTF8.GetString(data)}");
    consumer1.UnSubscribe("msg");
    Console.WriteLine("退订consumer1");
    return true; //ACK
});

MQClient publisher = new RabbitMQClient("mq.lails.cc", "root", "Lxs@rabbitmq", "publisher1");
publisher.Connect();
string message = "Rabbitmq Message";
byte[] body1 = Encoding.UTF8.GetBytes(message + "_01");
byte[] body2 = Encoding.UTF8.GetBytes(message + "_02");
publisher.Publish("msg", body1);
publisher.Publish("msg", body2);
Console.WriteLine($"发送消息：{message}");

Console.Read();

(string topic, Func<MessageData, bool> subscribe, MessageArgs arg = null)
# MessageData
public class MessageData
{
    public byte[] Data { get; set; }
    public string Topic { get; set; }
}