Время ожидания метода MSMQ Receive()

Ответ 1

Любая конкретная причина, по которой вы не используете обработчик событий для прослушивания очередей? Библиотека System.Messaging позволяет присоединить обработчик к очереди, а не, если я понимаю, что вы делаете правильно, цикл Получите каждые 10 секунд. Попробуйте что-то вроде этого:

class MSMQListener
{
    public void StartListening(string queuePath)
    {
        MessageQueue msQueue = new MessageQueue(queuePath);
        msQueue.ReceiveCompleted += QueueMessageReceived;
        msQueue.BeginReceive();
    }

    private void QueueMessageReceived(object source, ReceiveCompletedEventArgs args)
    {
        MessageQueue msQueue = (MessageQueue)source;

        //once a message is received, stop receiving
        Message msMessage = null;
        msMessage = msQueue.EndReceive(args.AsyncResult);

        //do something with the message

        //begin receiving again
        msQueue.BeginReceive();
    }
}

Ответ 2

Мы также используем NServiceBus и имели аналогичную проблему внутри нашей сети.

В основном MSMQ использует UDP с двухфазными фиксациями. После получения сообщения оно должно быть подтверждено. Пока он не будет подтвержден, он не может быть получен на стороне клиента, поскольку транзакция приема не была завершена.

Это было вызвано разными событиями в разное время для нас: - как только это произошло из-за того, что координатор распределенных транзакций не смог установить связь между машинами в качестве неправильной конфигурации брандмауэра - в другой раз мы использовали клонированные виртуальные машины без sysprep, которые сделали внутренние идентификаторы MSMQ не уникальными и заставили его получать сообщение на одну машину и ссылаться на другую. В конце концов, MSMQ показывает все, но это занимает довольно много времени.

Надеюсь, что это поможет.

Ответ 3

Попробуйте это

общий прием сообщений (тайм-аут TimeSpan, курсор)

перегруженная функция.

Чтобы получить курсор для MessageQueue, вызовите метод CreateCursor для этой очереди.

Курсор используется с такими методами, как Peek (TimeSpan, Cursor, PeekAction) и Receive (TimeSpan, Cursor), когда вам нужно читать сообщения, которые не находятся в передней части очереди. Это включает в себя чтение сообщений синхронно или асинхронно. Курсоры не должны использоваться для чтения только первого сообщения в очереди.

При чтении сообщений в транзакции Message Queuing не откатывает движение курсора, если транзакция прервана. Например, предположим, что есть очередь с двумя сообщениями: A1 и A2. Если вы удалите сообщение A1 во время транзакции, Message Queuing переместит курсор на сообщение A2. Однако, если транзакция прерывается по какой-либо причине, сообщение A1 вставляется обратно в очередь, но курсор остается указывать на сообщение A2.

Чтобы закрыть курсор, вызовите Close.

Ответ 4

Если вы хотите использовать что-то полностью синхронное и без события, вы можете протестировать этот метод

public object Receive(string path, int millisecondsTimeout)
{
    var mq = new System.Messaging.MessageQueue(path);
    var asyncResult = mq.BeginReceive();
    var handles = new System.Threading.WaitHandle[] { asyncResult.AsyncWaitHandle };
    var index = System.Threading.WaitHandle.WaitAny(handles, millisecondsTimeout);
    if (index == 258) // Timeout
    {
        mq.Close();
        return null;
    }
    var result = mq.EndReceive(asyncResult);
    return result;
}