Ignite TcpCommunicationSpi :可以根据文档将 slowClientQueueLimit 设置为与 messageQueueLimit 相同的值吗?
Ignite TcpCommunicationSpi : Can slowClientQueueLimit be set to same value as messageQueueLimit as per docs?
我不完全确定 slowClientQueueLimit 和 messageQueueLimit 之间的含义或相互作用。
根据文档,理想情况下应将它们设置为相同的值,https://ignite.apache.org/releases/2.4.0/javadoc/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.html#setSlowClientQueueLimit-int-
但是,当我设置为在日志中看到这个时,这是检查中的一个小错误还是我应该更改它?
[WARN ] 2018-06-27 22:32:18.429 [main] org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi - Slow client queue limit is set to a value greater than message queue limit (slow client queue limit will have no effect) [msgQueueLimit=1024, slowClientQueueLimit=1024]
谢谢
从代码来看警告是正确的,但 javadoc 不是。 slowClientQueueLimit
必须小于 msgQueueLimit
,因为在准备发送消息时,首先检查背压限制,然后才检查 slowClientQueueLimit
。如果这两个数字相等,发送方线程将在进行慢速客户端检查之前被背压阻塞。什么意思客户端不会被丢弃。
将 slowClientQueueLimit
设置为 msgQueueLimit - 1
或更少,我会建议社区修复文档。
我不完全确定 slowClientQueueLimit 和 messageQueueLimit 之间的含义或相互作用。
根据文档,理想情况下应将它们设置为相同的值,https://ignite.apache.org/releases/2.4.0/javadoc/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.html#setSlowClientQueueLimit-int-
但是,当我设置为在日志中看到这个时,这是检查中的一个小错误还是我应该更改它?
[WARN ] 2018-06-27 22:32:18.429 [main] org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi - Slow client queue limit is set to a value greater than message queue limit (slow client queue limit will have no effect) [msgQueueLimit=1024, slowClientQueueLimit=1024]
谢谢
从代码来看警告是正确的,但 javadoc 不是。 slowClientQueueLimit
必须小于 msgQueueLimit
,因为在准备发送消息时,首先检查背压限制,然后才检查 slowClientQueueLimit
。如果这两个数字相等,发送方线程将在进行慢速客户端检查之前被背压阻塞。什么意思客户端不会被丢弃。
将 slowClientQueueLimit
设置为 msgQueueLimit - 1
或更少,我会建议社区修复文档。