using (var conn = RabbitmqHelper.GetConnection())

            {

                using (var channel = conn.CreateModel())

                {

                    //这两个事件如果是using写法要写到创建交换器和队列并且进行绑定之前，否则不会触发

                    channel.BasicNacks += (sender, e) =>

                    {

                        //生产者发送消息到broker（服务器）后失败被生产者的listener监听到，就走无应答方法

                        Console.WriteLine(" --no ack-- ");

                    };

                    channel.BasicAcks += (sender, e) =>

                    {

                        //有应答

                        Console.WriteLine(" --ack-- ");

                    };

                    channel.ExchangeDeclare("log_topic", ExchangeType.Topic);

                    var msg = $"send {(args.Length == 0 ? "default" : args[0] ?? "default")} topic message";

                    var body = Encoding.UTF8.GetBytes(msg);

                    channel.ConfirmSelect();//不管是串行还是并行，都要加入声明确认这句话

                    channel.BasicPublish("log_topic", (args.Length <  ? "#" : args[] ?? "#"), null, body);

                    Console.WriteLine(" [x] Sent {0}", msg);

                    //串行的写法

                    //if (channel.WaitForConfirms())

                    //{

                    //    Console.WriteLine("[x] Sent success");

                    //}

                    //else

                    //{

                    //    Console.WriteLine("[x] Sent faild");

                    //}

                    Console.WriteLine(" Press [enter] to exit.");

                    Console.ReadLine();

                }

            }