/// <summary>
  /// 生产者
  /// </summary>
  /// <param name="change"></param>
  private static void ProducerMessage(MyMessage msg)
  {
   var advancedBus = CreateAdvancedBus();

   if (advancedBus.IsConnected)
   {
    var exchange = advancedBus.ExchangeDeclare("user", ExchangeType.Fanout);

    advancedBus.Publish(exchange, "", false, new Message<MyMessage>(msg));
   }
   else
   {
    Console.WriteLine("Can't connect");
   }

  }

  /// <summary>
  /// 消费者
  /// </summary>
  private static void ConsumeMessage()
  {
   var advancedBus = CreateAdvancedBus();
   var exchange = advancedBus.ExchangeDeclare("user", ExchangeType.Fanout);

   var queue = advancedBus.QueueDeclare("user.notice.wangwu");
   advancedBus.Bind(exchange, queue, "user.notice.wangwu");
   advancedBus.Consume(queue, registration =>
   {
    registration.Add<MyMessage>((message, info) => { Console.WriteLine("Body: {0}", message.Body); });
   });
  }

/// <summary>
  /// 生产者
  /// </summary>
  /// <param name="change"></param>
  private static void ProducerMessage(MyMessage msg)
  {
   var advancedBus = CreateAdvancedBus();

   if (advancedBus.IsConnected)
   {
    var queue = advancedBus.QueueDeclare("user.notice.zhangsan");

    advancedBus.Publish(Exchange.GetDefault(), queue.Name, false, new Message<MyMessage>(msg));
   }
   else
   {
    Console.WriteLine("Can't connect");
   }

  }

  /// <summary>
  /// 消费者
  /// </summary>
  private static void ConsumeMessage()
  {
   var advancedBus = CreateAdvancedBus();

   var exchange = advancedBus.ExchangeDeclare("user", ExchangeType.Direct);

   var queue = advancedBus.QueueDeclare("user.notice.lisi");

   advancedBus.Bind(exchange, queue, "user.notice.lisi");

   advancedBus.Consume(queue, registration =>
   {
    registration.Add<MyMessage>((message, info) =>
    {
     Console.WriteLine("Body: {0}", message.Body);
    });
   });
  }

　　　　　/// <summary>
  /// 生产者
  /// </summary>
  /// <param name="change"></param>
  private static void ProducerMessage(MyMessage msg)
  {
   //// 创建消息bus
   IBus bus = CreateBus();

   try
   {
    bus.Publish(msg, x => x.WithTopic(msg.MessageRouter));
   }
   catch (EasyNetQException ex)
   {
    //处理连接消息服务器异常 
   }

   bus.Dispose();//与数据库connection类似，使用后记得销毁bus对象
  }

  /// <summary>
  /// 消费者
  /// </summary>
  private static void ConsumeMessage(MyMessage msg)
  {
   //// 创建消息bus
   IBus bus = CreateBus();

   try
   {
    bus.Subscribe<MyMessage>(msg.MessageRouter, message => Console.WriteLine(msg.MessageBody), x => x.WithTopic("user.notice.#"));
   }
   catch (EasyNetQException ex)
   {
    //处理连接消息服务器异常 
   }
  }