当TopShelf作为Windows服务使用时，RabbitMQ未收到消息

Question

我试图将我的RabbitMQ微服务转换为Windows服务。我已经使用TopShelf进行转换。我的RabbitMQ微服务完全可以自行完成，但是当我将它作为服务运行时，它不再接收消息。在我public static void Main(string[] args)我：

HostFactory.Run(host => 
       { 
        host.Service<PersonService>(s =>      
        { 
         s.ConstructUsing(name => new PersonService()); 
         s.WhenStarted(tc => tc.Start());    
         s.WhenStopped(tc => tc.Stop());    
        }); 
        host.SetDescription("Windows service that provides database access totables."); 
        host.SetDisplayName("Service");     
        host.SetServiceName("Service"); 
       }); 
      } 

然后在我的PersonService类我有

public void Start() { 
      ConsumeMessage(); 
     } 

最后我ConsumeMessage功能：

private static void ConsumeMessage() { 
     MessagingConfig.SetInstance(new MessagingConstants()); 
     IMessageFactory pmfInst = MessageFactory.Instance; 

     //message worker 
     var factory = new ConnectionFactory() { 
      HostName = MessagingConfig.Instance.GetBrokerHostName(), 
      UserName = MessagingConfig.Instance.GetBrokerUserName(), 
      Password = MessagingConfig.Instance.GetBrokerPassword() 
     }; 

     var connection = factory.CreateConnection(); 

     using (var channel = connection.CreateModel()) { 
      channel.QueueDeclare(queue: MessagingConfig.Instance.GetServiceQueueName(), 
           durable: true, 
           exclusive: false, 
           autoDelete: false, 
           arguments: null); 

      channel.BasicQos(0, 1, false); 

      var consumer = new EventingBasicConsumer(channel); 

      channel.BasicConsume(queue: MessagingConfig.Instance.GetServiceQueueName(), 
           noAck: false, 
           consumer: consumer); 

      Console.WriteLine("Service."); 
      Console.WriteLine(" [x] Awaiting RPC requests"); 


      // Code Below Is Not Executed In Service 
      consumer.Received += (model, ea) => { 

       string response = null; 

       var body = ea.Body; 
       var props = ea.BasicProperties; 
       var replyProps = channel.CreateBasicProperties(); 
       replyProps.CorrelationId = props.CorrelationId; 

       string receivedMessage = null; 

       try { 
        receivedMessage = Encoding.UTF8.GetString(body); 
        response = ProcessMessage(receivedMessage); 
       } 
       catch (Exception e) { 
        // Received message is not valid. 
        WinLogger.Log.Error(
         "Errror Processing Message: " + receivedMessage + " :" + e.Message); 

        response = ""; 
       } 
       finally { 

        var responseBytes = Encoding.UTF8.GetBytes(response); 
        channel.BasicPublish(exchange: "", routingKey: props.ReplyTo, 
        basicProperties: replyProps, body: responseBytes); 
        channel.BasicAck(deliveryTag: ea.DeliveryTag, 
        multiple: false); 
       } 
      }; 
      Console.ReadLine(); 
     } 

在A similar SO question它看起来像它寻找有事与Windows服务是想要返回，但我不知道如何致电ConsumeMessage所以consumer.Received += (model, ea) => {...};被执行。

编辑：它看起来像我的拦截机制Console.ReadLine();被服务忽略，所以它只是继续和处置的消费者。那么我该如何阻止消息被接收呢？

Answer 1

您的代码使用using结构，这意味着当您的OnStart方法返回时，您的channel将实际处置。该docs建议做OnStart你的初始化，所以创建channel和consumer存在，但不使用using：

this.connection = factory.CreateConnection(); 

this.channel = connection.CreateModel(); 
this.consumer = new EventingBasicConsumer(this.channel); 

那么这些对象将继续存在OnStart方法完成之后。您应该在OnStop方法中处理它们。