JavaEE Websocket:关闭浏览器选项卡将关闭所有会话，无论浏览器如何

Question

我有一个websocket端点

@ServerEndpoint("/tweets")
public class TweetStreamServer {
    private static final Logger LOGGER = LoggerFactory.getLogger(TweetStreamServer.class);
    @OnMessage
    public void tweets(final String message, final Session session) throws IOException, InterruptedException {
        System.out.println("session id:" + session.getId() + ", search term: " + message);
        final Client twitterClient = TwitterHoseBird.getInstance(message);
        while (!session.getOpenSessions().isEmpty()) {
            for (final Session s : session.getOpenSessions()) {
                if (twitterClient.isDone()) {
                    System.out.println("Twitter Client Done, waiting ...");
                }
                s.getBasicRemote().sendText(TwitterHoseBird.getMsgQueue().take());
            }
        }
    }
}

我将其部署在WildFly 8.1.0 Final上。然后在Chrome, Safari上打开多个选项卡并运行以下

var connection = new WebSocket('ws://127.0.0.1:8080/tweetstream-1.0-SNAPSHOT/tweets');
connection.onopen = function () {
  connection.send('germany');
};
connection.onerror = function (error) {
  console.log('WebSocket Error ' + error);
};
connection.onmessage = function (e) {
  console.log('Server: ' + e.data);
};
connection.onclose = function (e) {
  console.log('closing session');
};

然后所有选项卡开始接收来自服务器的数据。

• 然后，当我在其中一个选项卡上执行connection.close();时，只有该连接中断，而所有其他选项卡仍在接收数据
• 但是如果我关闭其中一个选项卡(在任何浏览器中)，在所有其他选项卡中打开的所有会话都会关闭会话，closing session消息

如果用户在一个浏览器中关闭一个选项卡，所有其他选项卡应该仍然接收数据，这不是一个有效的用例吗?
-你看到我在做什么错误/问题吗?
-我该如何解决这个问题?

谢谢

Answer 1

不使用

s.getBasicRemote().sendText(TwitterHoseBird.getMsgQueue().take());  

改为

s.getAsyncRemote().sendText(TwitterHoseBird.getMsgQueue().take());  

和其他东西都可以正常运行