如何响应不同线程上的事件

Question

我已经实现了一个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
    }
}

Answer 1

我正在不同的线程上运行队列轮询部分代码

据我所知，.NET 客户端不支持此功能。