当队列有n个待处理消息时，ActiveMQ不返回消息

Question

环境/背景：

使用PHP Stomp库从ActiveMQ（v5.4.3）发送和接收消息。

步骤：

1. 客户端发送消息并回复至

当没有挂起消息或挂起消息时，上述步骤可以正常工作

<?php

// make a connection
$con = new Stomp("tcp://localhost:61616");
// Set read timeout.
$con->setReadTimeout(10);

// Prepare request variables.
$correlation_id = rand();    
$request_queue = '/queue/com.domain.service.request';
$response_queue = '/queue/com.domain.service.response';
$selector =  "JMSCorrelationID='$correlation_id'";
$headers = array('correlation-id' => $correlation_id, 'reply-to' => $response_queue);
$message = '<RequestBody></RequestBody>';

// send a message to the queue.
$con->send($request_queue, $message, $headers);

// subscribe to the queue
$con->subscribe($response_queue, array('selector' => $selector, 'ack' => 'auto'));

// receive a message from the queue
$msg = $con->readFrame();

// do what you want with the message
if ( $msg != null) {
    echo "Received message with body\n";
    var_dump($msg);
    // mark the message as received in the queue
    $con->ack($msg);
} else {
    echo "Failed to receive a message\n";
}
unset($con);

其他发现：

>

允许在同一个请求队列中发送超过1000条消息（并最终处理并放置在响应队列中）。所以它看起来不像内存问题。

有趣的是，在等待超时时，如果我在管理UI上浏览队列，我会得到响应。

默认情况下，我使用的stomp代理将预取大小设置为1。

Answer 1

回答我自己的问题。

我面临的问题正是http://trenaman.blogspot.co.uk/2009/01/message-selectors-and-activemq.html中描述的，解决方案是增加ActiveMQ和maxPageSize中指定的maxPageSize

正如您可以匹配的那样，200不是一个可变的数字，而是maxPageSize的默认值。

更多参考资料：

>

http://activemq.2283324.n4.nabble.com/Consumer-is-not-able-to-pick-messages-from-queue-td2531722.html

https://issues.apache.org/jira/browse/AMQ-2217

https://issues.apache.org/jira/browse/AMQ-2745

Answer 2

在不了解更多信息的情况下，我猜测您有多个消费者，其中一个正在其预取缓冲区中占用消息，我认为默认大小为1000。要调试这样的情况，通常最好查看web控制台或连接jconsole并检查队列MBean，以查看正在传输的消息的统计信息、消费者数量等。