Rabbitmq無法監聽后續消息

現象：

消息隊列在處理完一條消息后，無法繼續監聽后續消息。

首先，系統啟動時要啟動接收方法如下：

        protected void Application_Start()
        {
            RouteTable.Routes.MapHubs();
            AreaRegistration.RegisterAllAreas();

            RegisterGlobalFilters(GlobalFilters.Filters);
            RegisterRoutes(RouteTable.Routes);
            Register(GlobalConfiguration.Configuration);
            //GlobalHost.ConnectionManager.GetHubContext<ProcessMonitoring>().Clients.All.receive("ss");
            //RouteTable.Routes.MapHubs();
            ReceiveSuccessMessage();
        }

其次，接收方法如下，

         /// <summary>
         /// 反饋成功的消息隊列
         /// </summary>
         public static void ReceiveSuccessMessage()
         {
             ConnectionFactory factory = CreateConnectionFactory();
             using (var connection = factory.CreateConnection())
             {
                 using (var channel = connection.CreateModel())
                 {
                     //輸入1，那如果接收一個消息，但是沒有應答，則客戶端不會收到下一個消息
                     channel.BasicQos(0, 1, false);
                     var consumer = new EventingBasicConsumer(channel);
                     channel.BasicConsume(receiveQueueSuccess, false, consumer);
                     consumer.Received += (model, ea) =>
                     {
                         try
                         {
                             var body = ea.Body;
                             var message = Encoding.UTF8.GetString(body);
 
                             //反饋信息處理
                             ProcessFeedbackInfoForQueue(message);
                             channel.BasicAck(ea.DeliveryTag, false);
                         }
                         catch (Exception ex)
                         {
                             Yingu.Common.SysLog.Write("接受消息隊列失敗：", string.Format("反饋成功消息隊列  時間:{0} ：失敗原因{1}", DateTime.Now, ex.Message + ex.StackTrace));
                             channel.BasicAck(ea.DeliveryTag, false);
                         }
                     };
 
                 };
 
             };
         }

 解決方法：

將第二個方法改為

        /// <summary>
        /// 反饋成功的消息隊列
        /// </summary>
        public static void ReceiveSuccessMessage()
        {
            ConnectionFactory factory = CreateConnectionFactory();
            var connection = factory.CreateConnection();
            var channel = connection.CreateModel();
            //輸入1，那如果接收一個消息，但是沒有應答，則客戶端不會收到下一個消息
            channel.BasicQos(0, 1, false);
            var consumer = new EventingBasicConsumer(channel);
            channel.BasicConsume(receiveQueueSuccess,false,consumer);
            consumer.Received += (model, ea) =>
            {
                try
                {
                    var body = ea.Body;
                    var message = Encoding.UTF8.GetString(body);

                    //反饋信息處理
                    ProcessFeedbackInfoForQueue(message);
                    channel.BasicAck(ea.DeliveryTag, false);
                }
                catch (Exception ex)
                {
                    Yingu.Common.SysLog.Write("接受消息隊列失敗：", string.Format("反饋成功消息隊列  時間:{0} ：失敗原因{1}", DateTime.Now, ex.Message + ex.StackTrace));
                    channel.BasicAck(ea.DeliveryTag, false);
                }
            };
        }

原因是每次處理一條消息后，接收方法會斷開連接，無法繼續監聽后續消息。