我正在使用RabbitMQ Stomp的持久订阅（这里留档）。根据留档，当客户端使用相同的id重新连接（订阅）时，他应该得到所有排队的消息。然而，即使消息在服务器端排队，我也无法取回任何东西。下面是我正在使用的代码：

RabbitMQ版本：3.6.0

客户代码：

var sock;
var stomp;
var messageCount = 0;
var stompConnect = function() {

sock = new SockJS(options.url);

stomp = Stomp.over(sock);
stomp.connect({}, function(frame) {
debug('Connected: ', frame);
console.log(frame);

var id = stomp.subscribe('<url>' + options.source + "." + options.type + "." + options.id, function(d) {
    console.log(messageCount);
    messageCount = messageCount + 1;
}, {'auto-delete' : false, 'persistent' : true , 'id' : 'unique_id', 'ack' : 'client'});
}, function(err) {
console.log(err);
debug('error', err, err.stack);
setTimeout(stompConnect, 10);
});
};

服务器代码：

public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
    @Override
    public void configureMessageBroker(final MessageBrokerRegistry config) {
        config.enableStompBrokerRelay("<endpoint>", "<endpoint>").setRelayHost(host)
        .setSystemLogin(username).setSystemPasscode(password).setClientLogin(username)
                .setClientPasscode(password);
    }

    @Override
    public void registerStompEndpoints(final StompEndpointRegistry registry) {
        registry.addEndpoint("<endpoint>").setAllowedOrigins("*").withSockJS();
    }
}

我正在执行的步骤：

• 在客户端运行脚本，它发送订阅请求。
• 在服务器端创建一个队列（名称为跺脚订阅-*），所有消息都被推送到队列中，客户端能够流式传输这些消息。
• 杀死脚本，这会导致断开连接。服务器日志显示客户端已断开连接，消息开始排队。
• 使用相同的id再次运行脚本。它以某种方式设法连接到服务器，但是，没有从服务器返回任何消息。该队列上的消息计数保持不变（此外，RabbitMQ管理控制台不会显示该队列的任何消费者）。
• 10秒后，连接被断开，并在客户端日志中打印以下内容：

哎呀！失去了连接

• 服务器也显示相同的消息（即客户端断开连接）。如客户端代码所示，它会在10秒后尝试建立连接，然后再次重复相同的循环。

我尝试了以下方法：

1. 删除了'ack'：'client'标头。这导致所有消息都被排挤出队列，但是没有一条到达客户端。我在完成这个SO答案后添加了这个标头。
2. 添加d. ack（）；在函数中，在递增message ageCount之前。这会导致服务器端在会话关闭后尝试ack消息时出错（由于断开连接）。

此外，在某些情况下，当我重新连接排队消息的数量少于100时，我能够获得所有消息。然而，一旦它超过100，什么都不会发生（不确定这是否与问题有关）。

我不知道问题是否存在于服务器端或客户端。有输入吗？