Cliente Java SockJS Spring y tamaño del mensaje
Utilizando el cliente Java SockJS, estoy tratando de conectarme al servidor Spring sockjs y obtengo el error 1009 para mensajes (sin encabezados) de ~ 20Kb. La biblioteca Javascript funciona bien.
Transport closed with CloseStatus[code=1009, reason=The decoded text message was too big
for the output buffer and the endpoint does not support partial messages] in WebSocketClientSockJsSession
[id='9fa30eb453e14a8c8612e1064640646a, url=ws://127.0.0.1:8083/user]
Tengo un par de clases de configuración en el servidor (no sé por el momento si estoy configurando estas cosas más veces de lo necesario):
@Configuration
@EnableWebSocket
public class WebSocketTransportConfig implements WebSocketConfigurer {
// Important web socket setup. If big message is coming through, it may overflow the buffer and this will lead in disconnect.
// All messages that are coming through normally (including snapshots) must be order of magnitude smaller, or connection will be broken
// sometimes
// There is also MaxBinaryMessageSize that we do not employ as we use Stomp, but for completeness it is also set to same values.
// Javadoc http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/web/socket/adapter/jetty/JettyWebSocketSession.html#setTextMessageSizeLimit-int-
public static final int MAX_TEXT_MESSAGE_SIZE = 2048000; // 2 Megabytes.
public static final int BUFFER_SIZE = MAX_TEXT_MESSAGE_SIZE * 5;
private static final Logger LOGGER = LogManager.getLogger(WebSocketTransportConfig.class);
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
}
@Bean
public DefaultHandshakeHandler handshakeHandler() {
LOGGER.info("Websocket buffer size: " + BUFFER_SIZE + " bytes.");
WebSocketPolicy policy = new WebSocketPolicy(WebSocketBehavior.SERVER);
policy.setMaxTextMessageBufferSize(BUFFER_SIZE);
policy.setMaxTextMessageSize(MAX_TEXT_MESSAGE_SIZE);
policy.setMaxBinaryMessageBufferSize(BUFFER_SIZE);
policy.setMaxBinaryMessageSize(MAX_TEXT_MESSAGE_SIZE);
policy.setInputBufferSize( BUFFER_SIZE);
policy.setIdleTimeout(600000);
return new DefaultHandshakeHandler(
new JettyRequestUpgradeStrategy(new WebSocketServerFactory(policy)));
}
}
y
@Configuration
@EnableWebSocketMessageBroker
@EnableScheduling
public class WebSocketBrokerConfig extends WebSocketMessageBrokerConfigurationSupport implements WebSocketMessageBrokerConfigurer {
@Override
public void configureWebSocketTransport(WebSocketTransportRegistration registry) {
// Increase buffers.
// Too little buffers may result in fatal errros when transmitting relatively large messages.
registry.setMessageSizeLimit(WebSocketTransportConfig.MAX_TEXT_MESSAGE_SIZE);
registry.setSendBufferSizeLimit(WebSocketTransportConfig.BUFFER_SIZE);
super.configureWebSocketTransport(registry);
}
}
De acuerdo aStomp spring web socket message excede el límite de tamaño eso debería ayudar, pero cuando conecto el cliente Java Spring SockJS, sigo recibiendo el error 1009 (mensaje demasiado grande).
Sospecho que, por lo tanto, puedo tener uno de dos problemas:
El cliente Java SockJS también debe configurarse para RECIBIR mensajes más grandes.O bien, todavía estoy mal configurado en el servidor.¿Cómo puedo aumentar el tamaño del búfer en el cliente Java SockJS Spring?