Error handling improvement in AbstractSockJsSession
Backport of e17736dd0a.
Closes gh-24986
This commit is contained in:
@@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2002-2018 the original author or authors.
|
* Copyright 2002-2020 the original author or authors.
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
@@ -17,8 +17,8 @@
|
|||||||
package org.springframework.web.socket.sockjs.transport.session;
|
package org.springframework.web.socket.sockjs.transport.session;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
|
import java.util.Collections;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
@@ -26,6 +26,7 @@ import java.util.Map;
|
|||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
import java.util.concurrent.ScheduledFuture;
|
import java.util.concurrent.ScheduledFuture;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
@@ -58,7 +59,7 @@ public abstract class AbstractSockJsSession implements SockJsSession {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* Log category to use on network IO exceptions after a client has gone away.
|
* Log category to use on network IO exceptions after a client has gone away.
|
||||||
* <p>Servlet containers dn't expose a a client disconnected callback, see
|
* <p>Servlet containers don't expose a client disconnected callback; see
|
||||||
* <a href="https://github.com/eclipse-ee4j/servlet-api/issues/44">eclipse-ee4j/servlet-api#44</a>.
|
* <a href="https://github.com/eclipse-ee4j/servlet-api/issues/44">eclipse-ee4j/servlet-api#44</a>.
|
||||||
* Therefore network IO failures may occur simply because a client has gone away,
|
* Therefore network IO failures may occur simply because a client has gone away,
|
||||||
* and that can fill the logs with unnecessary stack traces.
|
* and that can fill the logs with unnecessary stack traces.
|
||||||
@@ -121,7 +122,7 @@ public abstract class AbstractSockJsSession implements SockJsSession {
|
|||||||
* @param id the session ID
|
* @param id the session ID
|
||||||
* @param config the SockJS service configuration options
|
* @param config the SockJS service configuration options
|
||||||
* @param handler the recipient of SockJS messages
|
* @param handler the recipient of SockJS messages
|
||||||
* @param attributes attributes from the HTTP handshake to associate with the WebSocket
|
* @param attributes the attributes from the HTTP handshake to associate with the WebSocket
|
||||||
* session; the provided attributes are copied, the original map is not used.
|
* session; the provided attributes are copied, the original map is not used.
|
||||||
*/
|
*/
|
||||||
public AbstractSockJsSession(String id, SockJsServiceConfig config, WebSocketHandler handler,
|
public AbstractSockJsSession(String id, SockJsServiceConfig config, WebSocketHandler handler,
|
||||||
@@ -162,6 +163,7 @@ public abstract class AbstractSockJsSession implements SockJsSession {
|
|||||||
|
|
||||||
// Message sending
|
// Message sending
|
||||||
|
|
||||||
|
@Override
|
||||||
public final void sendMessage(WebSocketMessage<?> message) throws IOException {
|
public final void sendMessage(WebSocketMessage<?> message) throws IOException {
|
||||||
Assert.state(!isClosed(), "Cannot send a message when session is closed");
|
Assert.state(!isClosed(), "Cannot send a message when session is closed");
|
||||||
Assert.isInstanceOf(TextMessage.class, message, "SockJS supports text messages only");
|
Assert.isInstanceOf(TextMessage.class, message, "SockJS supports text messages only");
|
||||||
@@ -376,20 +378,45 @@ public abstract class AbstractSockJsSession implements SockJsSession {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void delegateMessages(String... messages) throws SockJsMessageDeliveryException {
|
public void delegateMessages(String... messages) throws SockJsMessageDeliveryException {
|
||||||
List<String> undelivered = new ArrayList<>(Arrays.asList(messages));
|
for (int i = 0; i < messages.length; i++) {
|
||||||
for (String message : messages) {
|
|
||||||
try {
|
try {
|
||||||
if (isClosed()) {
|
if (isClosed()) {
|
||||||
throw new SockJsMessageDeliveryException(this.id, undelivered, "Session closed");
|
logUndeliveredMessages(i, messages);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
else {
|
this.handler.handleMessage(this, new TextMessage(messages[i]));
|
||||||
this.handler.handleMessage(this, new TextMessage(message));
|
}
|
||||||
undelivered.remove(0);
|
catch (Exception ex) {
|
||||||
|
if (isClosed()) {
|
||||||
|
if (logger.isTraceEnabled()) {
|
||||||
|
logger.trace("Failed to handle message '" + messages[i] + "'", ex);
|
||||||
|
}
|
||||||
|
logUndeliveredMessages(i, messages);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
throw new SockJsMessageDeliveryException(this.id, getUndelivered(messages, i), ex);
|
||||||
}
|
}
|
||||||
catch (Throwable ex) {
|
}
|
||||||
throw new SockJsMessageDeliveryException(this.id, undelivered, ex);
|
}
|
||||||
}
|
|
||||||
|
private void logUndeliveredMessages(int index, String[] messages) {
|
||||||
|
List<String> undelivered = getUndelivered(messages, index);
|
||||||
|
if (logger.isTraceEnabled() && !undelivered.isEmpty()) {
|
||||||
|
logger.trace("Dropped inbound message(s) due to closed session: " + undelivered);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private static List<String> getUndelivered(String[] messages, int i) {
|
||||||
|
switch (messages.length - i) {
|
||||||
|
case 0:
|
||||||
|
return Collections.emptyList();
|
||||||
|
case 1:
|
||||||
|
return (messages[i].trim().isEmpty() ?
|
||||||
|
Collections.emptyList() : Collections.singletonList(messages[i]));
|
||||||
|
default:
|
||||||
|
return Arrays.stream(Arrays.copyOfRange(messages, i, messages.length))
|
||||||
|
.filter(message -> !message.trim().isEmpty())
|
||||||
|
.collect(Collectors.toList());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2002-2016 the original author or authors.
|
* Copyright 2002-2020 the original author or authors.
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
@@ -27,7 +27,6 @@ import org.springframework.web.socket.CloseStatus;
|
|||||||
import org.springframework.web.socket.TextMessage;
|
import org.springframework.web.socket.TextMessage;
|
||||||
import org.springframework.web.socket.WebSocketHandler;
|
import org.springframework.web.socket.WebSocketHandler;
|
||||||
import org.springframework.web.socket.handler.ExceptionWebSocketHandlerDecorator;
|
import org.springframework.web.socket.handler.ExceptionWebSocketHandlerDecorator;
|
||||||
import org.springframework.web.socket.sockjs.SockJsMessageDeliveryException;
|
|
||||||
import org.springframework.web.socket.sockjs.SockJsTransportFailureException;
|
import org.springframework.web.socket.sockjs.SockJsTransportFailureException;
|
||||||
import org.springframework.web.socket.sockjs.frame.SockJsFrame;
|
import org.springframework.web.socket.sockjs.frame.SockJsFrame;
|
||||||
|
|
||||||
@@ -118,18 +117,13 @@ public class SockJsSessionTests extends AbstractSockJsSessionTests<TestSockJsSes
|
|||||||
willThrow(new IOException()).given(this.webSocketHandler).handleMessage(sockJsSession, new TextMessage(msg2));
|
willThrow(new IOException()).given(this.webSocketHandler).handleMessage(sockJsSession, new TextMessage(msg2));
|
||||||
|
|
||||||
sockJsSession.delegateConnectionEstablished();
|
sockJsSession.delegateConnectionEstablished();
|
||||||
try {
|
sockJsSession.delegateMessages(msg1, msg2, msg3);
|
||||||
sockJsSession.delegateMessages(msg1, msg2, msg3);
|
|
||||||
fail("expected exception");
|
verify(this.webSocketHandler).afterConnectionEstablished(sockJsSession);
|
||||||
}
|
verify(this.webSocketHandler).handleMessage(sockJsSession, new TextMessage(msg1));
|
||||||
catch (SockJsMessageDeliveryException ex) {
|
verify(this.webSocketHandler).handleMessage(sockJsSession, new TextMessage(msg2));
|
||||||
assertEquals(Collections.singletonList(msg3), ex.getUndeliveredMessages());
|
verify(this.webSocketHandler).afterConnectionClosed(sockJsSession, CloseStatus.SERVER_ERROR);
|
||||||
verify(this.webSocketHandler).afterConnectionEstablished(sockJsSession);
|
verifyNoMoreInteractions(this.webSocketHandler);
|
||||||
verify(this.webSocketHandler).handleMessage(sockJsSession, new TextMessage(msg1));
|
|
||||||
verify(this.webSocketHandler).handleMessage(sockJsSession, new TextMessage(msg2));
|
|
||||||
verify(this.webSocketHandler).afterConnectionClosed(sockJsSession, CloseStatus.SERVER_ERROR);
|
|
||||||
verifyNoMoreInteractions(this.webSocketHandler);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|||||||
Reference in New Issue
Block a user