TcpOutboundGateway: Невозможно сопоставить ответ - нет ожидающего ответа для Cached

Question

Я использую весеннюю интеграцию для подключения к серверу сокетов tcp / ip, я создал фиктивный сервер на основе telnet-mock https://github.com/maltempi/telnet-mock. и я могу отправлять и получать сообщения, но когда я выключаю фиктивный сервер, в основном приложении возникает циклическая ошибка, которая занимает все время процессора:

ERROR 13942 --- [pool-4-thread-1] o.s.i.ip.tcp.TcpOutboundGateway : Cannot correlate response - no pending reply for Cached:localhost:3002:46550:f6234e17-c486-4506-82c8-a757a08ba73d.

Как я могу решить эту проблему? Мой конфиг класс:

@EnableIntegration
@RequiredArgsConstructor
@Configuration
public class StpClientConfiguration {

private static final String REQUEST_CHANNEL = "toStp";
private static final String OUTPUT_CHANNEL = "resultToMap";
private static final String CRLF = "\\0";

private final ApplicationProperties applicationProperties;
private final ApplicationContext context;

private static String readUntil(InputStream inputStream, String stopWord) throws IOException {
    StringBuilder sb = new StringBuilder();
    BufferedReader buffer = new BufferedReader(new InputStreamReader(inputStream));
    int r;
    while ((r = buffer.read()) != -1) {
        char c = (char) r;
        sb.append(c);
        if (sb.toString().endsWith(stopWord)) {
            break;
        }
    }
    return sb.toString();
}

@Bean
public CachingClientConnectionFactory connectionFactory() {
    TcpNetClientConnectionFactory factory = new TcpNetClientConnectionFactory(
            applicationProperties.getHost(), applicationProperties.getPort());

    factory.setApplicationEventPublisher(this.context);
    factory.setTcpSocketSupport(new DefaultTcpSocketSupport());
    factory.setDeserializer((InputStream inputStream) -> readUntil(inputStream, CRLF));

    return new CachingClientConnectionFactory(factory, applicationProperties.getPoolSize());
}

/**
 * Creates the tcp gateway for service activation.
 *
 * @return the message handler
 */
@Bean
@ServiceActivator(inputChannel = REQUEST_CHANNEL)
public MessageHandler outboundGateway() {
    TcpOutboundGateway gateway = new TcpOutboundGateway();
    gateway.setConnectionFactory(connectionFactory());
    gateway.setOutputChannelName(OUTPUT_CHANNEL);

    return gateway;
}

@MessagingGateway(defaultRequestChannel = REQUEST_CHANNEL)
public interface RequestGateway {

    Map<String, String> send(String message);
}

@Bean
@Transformer(inputChannel = OUTPUT_CHANNEL)
public ObjectToMapTransformer objectToMapTransformer() {
    return new ObjectToMapTransformer();
}

}

Answer 1

Ваш десериализатор выглядит подозрительно; Сообщения Telnet заканчиваются на \r\nне \\0,

Использовать десериализатор по умолчанию для telnet (по умолчанию ByteArrayCrLfSerializer).

Когда десериализатор обнаруживает нормальный конец потока (-1), между сообщениями, он должен бросить SoftEndOfStreamException сказать рамке сокет закрыт. Ваш код продолжает возвращать строку нулевой длины,

/**
 * Used to communicate that a stream has closed, but between logical
 * messages.
 */
public class SoftEndOfStreamException extends IOException {

Или, как я уже сказал, используйте десериализатор по умолчанию.