我已经实现了一个rabbitMQ侦听器，它本质上只是坐在一个循环中等待消息到达。当消息到达时，我希望触发一个事件并运行一些代码。
然而，我似乎并不总是收到这个事件，我想知道这是否是因为我在不同的线程上运行代码的队列轮询部分。
它似乎最初的工作虽然，所以它是可能的线程是不是问题。有人能给我一个给予意见吗？

• 酒店预订：**

public void CreateQueueListener<T>() where T : IPubSubEvent
    {            

        var mqServer = new RabbitMqServer(m_RabbitMqAddress);
        var mqClient = (RabbitMqQueueClient)mqServer.MessageFactory.CreateMessageQueueClient();

        var channel = mqClient.Channel;
        string queueName = mqClient.GetTempQueueName();

        channel.QueueBind(queueName, m_EventExchange, routingKey: QueueNames<T>.In);

        var consumer = new RabbitMqBasicConsumer(channel);
        channel.BasicConsume(queue: queueName, autoAck: true, consumer: consumer);
        Task.Run(() =>
        {
            while (true)
            {
                BasicGetResult basicGetResult;
                try
                {
                    basicGetResult = consumer.Queue.Dequeue();
                }

                catch (Exception ex)
                {
                    throw;
                }
                var message = basicGetResult.ToMessage<T>();
                PublishEvent?.Invoke(this, new PubSubEventArgs { EventData = message.GetBody().EventName });                    
            }
        });
    }

消费类

public class MyClass
{
 public MyClass(IEventClient eventClient)
    {
        eventClient.CreateQueueListener<AuthoriseEvent>();
        eventClient.PublishEvent += OnPublishEvent;
    }

    private async void OnPublishEvent(object sender, PubSubEventArgs e)
    {
        if (e.EventData == "AuthoriseEvent")
            //dostuff
    }
}