我们可以有多个订阅者到 websphere MQ 中的同一个队列吗？

Question

我正在尝试让 Windows 服务中的多个线程（任务）连接到与订阅者相同的队列，以便我可以更快地处理我的消息。当我连接到我的队列时，我在我的第一个订阅线程上接收消息，其余的都是空闲的。以下是我用来订阅和接收消息的代码：

private MQQueueManager _queueManager;
private MQQueue _queue;
private MQTopic _topic;
public bool isSubscribed = false;

public void Subscribe()
{
    var queueManagerName = "myQueueManager";
    var properties = new Hashtable();
    //Set all the properties here
    _queueManager = new MQQueueManager(queueManagerName, properties);

    //Conect to Queue
    _queue = _queueManager.AccessQueue("devQueue", MQC.MQOO_INPUT_AS_Q_DEF);

    isSubscribed = true;
    while (isSubscribed)
    {
        if (cancellationToken.IsCancellationRequested)
        {
            isSubscribed = false;
            cancellationToken.ThrowIfCancellationRequested();
        }
        try
        {
            Receive(onMessageReceived);
        }
        catch (Exception ex)
        {
            Console.WriteLine("Exception: {0}", ex);
        }
    }   
}


public override void Receive<T>(Action<T> onMessageReceived)
{
    try
    {
        var dataReceived = new MQMessage();
        _queue.Get(dataReceived);

        T message;
        message = (T)(object)dataReceived;

        onMessageReceived(message);     
        _queueManager.Commit();
    }
    catch (Exception ex)
    {
        throw ex;
    }
}

我还尝试使用MQC.MQOO_INPUT_SHARED 访问队列，但也不起作用。我错过了什么吗？

Answer 1

您引用的代码尝试打开和接收来自名为“devQueue”的队列的消息。如果该代码在多个线程下运行，那么发送到每个线程的消息将部分取决于消息的处理速度以及您连接到的 MQ 版本。

但是，您在问题中提到了订阅者（并且您引用的代码声明了一个主题以及队列）。您是否在应用程序的其他地方创建了对该主题的订阅，然后使用此代码接收发送到该订阅的消息？如果是这样，那么您的“队列接收”线程可能只是打开了一个与保存订阅消息的队列不同的队列。初始订阅是如何创建的？