我在我的应用程序中使用javax.websocket API。我从服务器发送消息到客户机,如下所示:
Future<Void> messageFuture = session.getAsyncRemote().sendText(message);
messageFutures.add(messageFuture); // List<Future<Void>> messageFutures
我使用异步API是因为我非常关心性能,并且不能让服务器等到每条消息被传递后再使用,因为服务器确实是这样的:
for (i = 1..N) {
result = do