方式一、Redis：用setnx命令，做消息id判断。

方式三、数据库：做唯一索引，消息id能插入就可以处理，所以重复消费就会失败。

1、可以通过对文件的独占打开和释放，来达到进程间的锁。

2、可以通过对剪贴版的读写，来达到进程间的锁。

A：对消息进行hash，取hash值做为唯一ID（无法避免，有一定概念产生相同的hash）。

B：对每一个发送的消息，都产生一个GUID，这样在获取消息的时候，就可以拿到消息对应的唯一ID。

using (var channel = Rabbit.Instance.DefaultConnection.CreateModel())
{
    channel.BasicReturn += (sender, e) =>
    {
        //通过交换机发送过去，但没发送到指定的队列，数据丢失
        //do .....
        Console.WriteLine("消息没发到指定队列：" + Encoding.UTF8.GetString(e.Body.ToArray()));
    };
    channel.ConfirmSelect();
    channel.QueueDeclare("FirstQueue", false, false, false);
    var pro = channel.CreateBasicProperties();
    pro.MessageId = Guid.NewGuid().ToString();
    channel.BasicPublish("", "FirstQueue", true, pro, Encoding.UTF8.GetBytes("这是要发送的内容"));
    if (channel.WaitForConfirms(TimeSpan.FromSeconds(10)))
    {
        //发送确认成功
    }
    else
    {
        //超时或失败，需要处理是否重发消息。
    }
}

var channel = Rabbit.Instance.DefaultConnection.CreateModel();
 
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
    var message = Encoding.UTF8.GetString(ea.Body.ToArray());
   
    Console.WriteLine("收到默认消息 {0}", message);
    Console.WriteLine("收到默认消息GUID {0}", ea.BasicProperties.MessageId);
    try
    {
        channel.BasicAck(ea.DeliveryTag, false);
    }
    catch (Exception err)
    {

       //处理确认失败的情况。
    }
   
   
};
channel.BasicConsume(queue: "FirstQueue",
                      autoAck: false,
                      consumer: consumer);