让我首先描述给定的情况。
我有一个 Angular JavaScript前端。我需要使用websockets,因此我使用“sockjs”和“stomp-websocket”。
var socket,
client;
socket = new SockJS('http://localhost:8080/stomp');
client = Stomp.over(socket);
client.connect({}, function () {
client.subscribe('/dummy/message', function (message) {
console.log('subscribed');
}
});
我的后端是一个Spring Boot应用程序:
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/dummy");
registry.setApplicationDestinationPrefixes("/app");
}
@Override
public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
stompEndpointRegistry
.addEndpoint("/stomp")
.setAllowedOrigins("*")
.withSockJS()
.setSessionCookieNeeded(false);
}
}
此设置可以正常工作。即使我在firefox中禁用了websocket,它仍然可以正常工作(在这种情况下,后备工作)。
当我启动更多后端实例并使用nginx时,我的问题就开始了。
我的nginx配置是:
upstream ws_be {
server localhost:8081;
server localhost:8082;
}
server {
listen 8080;
location / {
proxy_pass http://ws_be;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
}
}
当我将此设置与多个后端一起使用时,websocket仍然可以按预期的方式工作,但是如果我在浏览器中禁用了websocket,则后备功能将不再起作用。它只是保持连接并立即断开连接。
浏览器控制台中的错误:
Opening Web Socket... stomp.min.js:8:1893
Web Socket Opened... stomp.min.js:8:1893
>>> CONNECT
accept-version:1.1,1.0
heart-beat:10000,10000
<<< CONNECTED
version:1.1
heart-beat:0,0
connected to server undefined stomp.min.js:8:1893
>>> SUBSCRIBE
id:sub-0
destination:/dummy/message
Whoops! Lost connection to undefined
在后端,我收到IO管道中断错误:
org.apache.catalina.connector.ClientAbortException: java.io.IOException: Datenübergabe unterbrochen (broken pipe)
在这一点上,我不知道如何配置nginx或后端才能在给定的设置下正常工作。
现在,我希望有人对这个问题有想法或提示。
最佳答案
我找到了一种解决方案,可能对其他人也有用。它适用于粘性 session (http://nginx.org/en/docs/http/ngx_http_upstream_module.html#ip_hash)
upstream ws_be {
ip_hash;
server localhost:8081;
server localhost:8082;
}
不幸的是,我不允许使用粘性 session 。因此,我的搜索是连续的。