我在两个spring微服务之间遇到了一个缓慢的stomp连接，客户端需要大约5分钟来发送connect stomp消息。两个微服务都在同一个节点上运行。
spring-boot版本：2.1.3.release
websocket服务器的配置方式如下：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws-subscribe").setAllowedOrigins("*").withSockJS();
    }
}

客户端的配置方式如下：

@Component
public class WebsocketClient {

    private GlobalConfiguration globalConfiguration;
    private WebsocketListener websocketListener;

    private WebSocketStompClient stompClient;

    @Autowired
    private JwtTokenGenerator jwtTokenGenerator;

    private ApplicationContext appContext;

    private Logger LOGGER = LoggerFactory.getLogger(WebsocketClient.class);

    @Autowired
    public WebsocketClient(ApplicationContext context,GlobalConfiguration globalConfiguration) {
        Transport webSocketTransport = new WebSocketTransport(new StandardWebSocketClient());
        List<Transport> transports = Collections.singletonList(webSocketTransport);

        SockJsClient sockJsClient = new SockJsClient(transports);
        sockJsClient.setMessageCodec(new Jackson2SockJsMessageCodec());

        this.stompClient = new WebSocketStompClient(sockJsClient);

        this.globalConfiguration = globalConfiguration;
        this.websocketListener = new WebsocketListener(context);
    }

    public ListenableFuture<StompSession> connectToWebsocket(){
       String url = globalConfiguration.getOrchestratorWs();

        StompHeaders connectHeaders = new StompHeaders();

        WebSocketHttpHeaders webSocketHttpHeaders = new WebSocketHttpHeaders();
        webSocketHttpHeaders.add("Authorization",jwtTokenGenerator.token);

        LOGGER.info("webSocketHttpHeaders: " + webSocketHttpHeaders.toString());
        LOGGER.info("url: " + url);

        this.stompClient.setMessageConverter(new MappingJackson2MessageConverter());
        return stompClient.connect(url,webSocketHttpHeaders,connectHeaders, websocketListener);
    }
}

客户端有一个websocket监听器：

public class WebsocketListener extends StompSessionHandlerAdapter {

    private static final Logger LOGGER = LoggerFactory.getLogger(WebsocketListener.class);

    private GlobalConfiguration globalConfiguration;
    private ApplicationContext appContext;

    public WebsocketListener(ApplicationContext appContext) {
        this.appContext = appContext;
        this.globalConfiguration = appContext.getBean(GlobalConfiguration.class);
    }

    @Override
    public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
        LOGGER.info("New session established : " + globalConfiguration.getId());
        session.subscribe("/topic/injections/"+globalConfiguration.getId(), this);
        LOGGER.info("Subscribed to /topic/injections/"+globalConfiguration.getId());
      //  session.send("/app/chat", getSampleMessage());
      //  logger.info("Message sent to websocket server");
    }

    @Override
    public void handleException(StompSession session, StompCommand command, StompHeaders headers, byte[] payload, Throwable exception) {
        LOGGER.error("Got an exception", exception);
    }

    @Override
    public Type getPayloadType(StompHeaders headers) {
        return Map.class;
    }

    @Override
    public void handleFrame(StompHeaders headers, Object payload) {
        LOGGER.info("Injection Received : " + payload);
        InjectionHandler injectionHandler = new InjectionHandler(appContext,(HashMap) payload);
        injectionHandler.start();
    }
}

在ws://10.2.0.43:7071/ws subscribe/513/8306a7ac3578478795b040450fb6c5/websocket之后大约5分钟调用afterconnected
在查看stomp库的源代码时，我看到，在这5分钟内，微服务保持不变的代码如下：

public ListenableFuture<StompSession> connect(URI url, @Nullable WebSocketHttpHeaders handshakeHeaders, @Nullable StompHeaders connectHeaders, StompSessionHandler sessionHandler) {
    Assert.notNull(url, "'url' must not be null");
    ConnectionHandlingStompSession session = this.createSession(connectHeaders, sessionHandler);
    WebSocketStompClient.WebSocketTcpConnectionHandlerAdapter adapter = new WebSocketStompClient.WebSocketTcpConnectionHandlerAdapter(session);
    this.getWebSocketClient().doHandshake(adapter, handshakeHeaders, url).addCallback(adapter);
    return session.getSessionFuture();
}

特别是session.getsessionfuture（）调用。你知道是什么导致客户端发送的connect消息延迟吗？