增加春兔心跳值

Question

我的设置面临一些问题，我正在尝试增加心跳间隔，以测试可能的修复。我正在使用

Spring boot 1.3.2.RELEASE
Spring rabbit 1.5.3.RELEASE

下面是实例化连接工厂的代码

RabbitConnectionFactoryBean connectionFactoryBean = new RabbitConnectionFactoryBean();
connectionFactoryBean.setUseSSL(useSsl);
connectionFactoryBean.setHost(rabbitHostname);
connectionFactoryBean.setVirtualHost(rabbitVhost);
connectionFactoryBean.setUsername(rabbitUsername);
connectionFactoryBean.setPassword(rabbitPassword);
connectionFactoryBean.setConnectionTimeout(900000);
connectionFactoryBean.setRequestedHeartbeat(900);
connectionFactoryBean.afterPropertiesSet();

CachingConnectionFactory cf = new CachingConnectionFactory(connectionFactoryBean.getObject());
cf.setChannelCacheSize(40);
return cf;

问题是心跳间隔没有改变。我在AMQConnection中快速查看以下内容

int heartbeat = negotiatedMaxValue(this.requestedHeartbeat,
                                   connTune.getHeartbeat());


private static int negotiatedMaxValue(int clientValue, int serverValue) {
        return (clientValue == 0 || serverValue == 0) ?
            Math.max(clientValue, serverValue) :
            Math.min(clientValue, serverValue);
}

来自服务器的值是60。方法negotiatedMaxValue将不尊重客户端的首选项（不能禁用心跳信号，也不能增加心跳信号）。我错过什么了吗？

Answer 1

你是对的。AMQConnection将根据该方法确定心跳值，然后使用TuneOk方法将该值发送到服务器(https://www.rabbitmq.com/amqp-0-9-1-reference.html#connection.tune-好的）。您可以看到，它将negotiatedMaxValue（）的结果发送到您看到对该方法调用的位置以下几行：

_channel0.transmit(new AMQP.Connection.TuneOk.Builder()
    .channelMax(channelMax)
    .frameMax(frameMax)
    .heartbeat(heartbeat)
    .build());

根据代码的逻辑，似乎只能减少心跳，但最大心跳将是服务器发送的任何内容，不能再增加了。RabbitMQ文档对于能够增加服务器最初发送的心跳信号的细节有点模糊，但确实说它可以被覆盖：https://www.rabbitmq.com/heartbeats.html

我查看了最新版本的SpringRabbit，它仍然具有相同的配置，因此看起来不会很快改变。

检查RabbitMQ GitHub不会显示有关将心跳值设置为大于服务器发送值的任何现有问题。也许在那里提交一个问题，看看开发人员怎么说？https://github.com/rabbitmq/rabbitmq-java-client/issues?utf8=✓