测试连接

DeepSeek V3 中英对照 Testing Connections

在某些场景下，在连接首次建立时发送某种健康检查请求会很有用。例如，当使用 TCP 故障转移客户端连接工厂 时，如果选定的服务器允许连接打开但报告其自身不健康，我们可以通过这种方式进行故障转移。

为了支持此功能，请在客户端连接工厂中添加一个 connectionTest。

/**
 * Set a {@link Predicate} that will be invoked to test a new connection; return true
 * to accept the connection, false the reject.
 * @param connectionTest the predicate.
 * @since 5.3
 */
public void setConnectionTest(@Nullable Predicate<TcpConnectionSupport> connectionTest) {
    this.connectionTest = connectionTest;
}

要测试连接，请在测试中为连接附加一个临时监听器。如果测试失败，连接将被关闭并抛出异常。当与 TCP 故障转移客户端连接工厂 一起使用时，这会触发尝试下一个服务器。

important

只有来自服务器的第一条回复会发送到测试监听器。

在以下示例中，当我们发送 PING 时，如果服务器回复 PONG，则认为服务器是健康的。

Message<String> ping = new GenericMessage<>("PING");
byte[] pong = "PONG".getBytes();
clientFactory.setConnectionTest(conn -> {
    CountDownLatch latch = new CountDownLatch(1);
    AtomicBoolean result = new AtomicBoolean();
    conn.registerTestListener(msg -> {
        if (Arrays.equals(pong, (byte[]) msg.getPayload())) {
            result.set(true);
        }
        latch.countDown();
        return false;
    });
    conn.send(ping);
    try {
        latch.await(10, TimeUnit.SECONDS);
    }
    catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    return result.get();
});