WebSocket与Java

素颜马尾好姑娘i 2022-09-19 10:42 166阅读 0赞

本文来源于我在InfoQ中文站原创的文章，原文地址是：http://www.infoq.com/cn/news/2013/12/websocket-and-java

[Bozhidar Bozhanov][]是Ontotext AD的高级软件工程师，拥有多年的从业经验，也是stackoverflow上的活跃用户。他精通于Java与Java技术栈，如Spring、JPA、JavaEE等，同时还是[http://computoser.com][http_computoser.com]与[http://welshare.com][http_welshare.com]的创始人。曾开发过爱立信的项目、保加利亚电子政务项目以及大型招聘平台等。近日Bozhidar[撰文][Link 1]谈到了WebSocket与Java，并给出了相应的代码示例。Bozhidar在文中详细分析了WebSocket的原理、适用范围，以及如何通过Java来使用WebSocket。

WebSocket是一个很酷的新技术，可以实现浏览器与服务器之间实时、双向的通信，几乎没有任何额外的代价。我这里要做的事情就是提供一个非常简洁，但却内容丰富的概览，介绍如何开始使用这门技术。首先读者需要了解如下一些事情：

*  首先在浏览器与服务器之间需要开启一个TCP Socket连接，每一方都可以向对方发送消息（比如说，服务器可以在有数据时将其推送出去，无需使用轮询、长轮询、iframes等技术）。
 *  并不是所有浏览器都支持WebSocket技术，IE 10是首个支持WebSocket的IE版本，Android依然还存在着一些问题。幸好有[SockJS][]，在不支持WebSocket的情况下，它会退回到其他的推送技术。
 *  并不是所有的代理服务器都支持或是允许WebSocket，因此这时还是需要退回到其他的推送技术。
 *  WebSocket适合于游戏、交易型应用，事实上，它适合于任何服务器要向浏览器推送数据的场景。
 *  Java有标准API（[JSR-356][]），你可以在服务端通过它来处理WebSocket连接。
 *  Spring在Java API的基础之上提供了一个[API][]。对于Spring提供的支持来说，好消息是它对SockJS提供了服务器端的支持，你也可以毫无压力地使用依赖注入。Spring还对消息驱动的架构[提供了STOMP支持][STOMP]。上面的两篇Spring文章都给出了GitHub上示例项目的链接，我强烈建议大家看看。
 *  长久以来，[Atmosphere框架][Atmosphere]一直是服务器推送技术的解决方案。[这里][Link 2]是WebSocket上手指南。另外，Cometd也提供了[WebSocket支持][WebSocket]。

在给出具体的示例代码前，我首先来介绍一下Socket的生命周期，包括客户端的与服务器端的：

1.  浏览器发出一个HTTP请求，带有一个特殊的Upgrade头，其值是“websocket”。
2.  如果服务器能够“理解”WebSocket，那么它会使用状态101进行应答——交换协议。从现在开始，我们就不再使用HTTP了。
3.  当服务器接收这个TCP Socket连接后，一个初始化方法会得到调用，当前的WebSocket Session会被传递进来。每个Socket都有唯一一个Session id。
4.  当浏览器向服务器发送消息时，另一个方法会得到调用，你在这里获得Session与消息负载。
5.  根据某个负载参数，应用代码会执行一个动作。负载的格式完全取决于开发者。一般来说会使用JSON序列化的对象。
6.  当服务器需要发送消息时，它需要获得这个Session对象，然后通过它来发送消息。
7.  当浏览器关闭连接时，服务器会得到通知，这样它就可以清理与特定Session关联的一些资源了。

目前，还没有任何一个API或框架能够支持基于注解的路由。Java API支持基于注解的端点处理器，不过每个连接URL需要一个类来处理，通常情况下，你希望在单个连接上执行多个操作。也就是说，你连接到ws://yourserver.com/game/，然后想要传递“joinGame”和“leaveGame”等消息。类似地，服务器需要发送回多种类型的消息。我使用了枚举来实现这一点，枚举中包含了所有可能的动作与事件类型，然后使用switch来确定该调用哪一个。

因此，我决定为我的[算法音乐作曲家][Link 3]开发一个[简单的游戏][Link 4]。它使用了Spring API，感兴趣的读者可以看看这个[介绍][Link 5]，这是我在公司所做的一次演讲。下面是一些示例代码：

@Component
    public class GameHandler extends WebSocketHandlerAdapter {
       private Map
     
       players = new ConcurrentHashMap<>();
       private Map
      
        playerGames = new ConcurrentHashMap<>();
    
       @Override
       public void afterConnectionEstablished(WebSocketSession session) throws Exception {
           Player player = new Player(session);
           players.put(session.getId(), player);
       }
    
    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        leaveGame(session.getId());
    }
    
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage textMessage) throws Exception {
       try {
          GameMessage message = getMessage(textMessage); //deserializes the JSON payload
    
          switch(message.getAction()) {
            case INITIALIZE: initialize(message, session); break;
            case JOIN: join(message.getGameId(), message.getPlayerName(), session); break;
            case LEAVE: leave(session.getId()); break;
            case START: startGame(message); break;
            case ANSWER: answer(message, session.getId()); break;
          }
        } catch (Exception ex) {
        logger.error("Exception occurred while handling message", ex);
      }
    }

下面来看一个示例场景，其中服务器需要向客户端发送消息。这就好比一个玩家加入了游戏一样，这时其他所有玩家都会收到有新人加入的通知。系统中的中心类是Game，它拥有一个玩家列表。如你所见，一个Player包含了一个对WebSocket Session的引用。这样，当新的玩家加入时，下面的Game中的方法就会得到调用：

public boolean playerJoined(Player player) {
       for (Player otherPlayer : players.values()) {
          otherPlayer.playerJoined(player);
       }
       players.put(player.getSession().getId(), player);
       return true;
    }

player.playerJoined(..)会在连接之上发送一条消息，通知浏览器有新的玩家加入了：

public void playerJoined(Player player) {
       GameEvent event = new GameEvent(GameEventType.PLAYER_JOINED);
       event.setPlayerId(player.getSession().getId());
       event.setPlayerName(player.getName());
       try {
          session.sendMessage(new TextMessage(event.toJson()));
       } catch (IOException e) {
          new IllegalStateException(e);
       }
    }

从服务器向浏览器发送消息可能还需要一个调度job进行触发。

关键在于你维护了一个所有已连接的浏览器列表，这样就可以向回发送信息了。这个列表可以是个静态属性，不过对于单例的Spring Bean来说就没必要这么做了。

现在，有两个重要的方面需要我们注意——安全与认证。[这是][Link 6]来自于Heroku的一篇很不错的文章，对安全与认证进行了详细的介绍。如果还有其他敏感信息，你就应该使用wss（Websocket over TLS）了。你还应该在服务器端与客户端验证输入，而不应该依赖于Origin头，因为攻击者可以轻而易举地骗过浏览器。

认证可以依赖于HTTP Session cookie，不过显而易见的是，有些人更喜欢实现自己的类cookie工作流，从而获取一个短暂的令牌，它可以用于执行认证操作。

WebSocket使得DDD变得更加自然。你不必再处理贫血对象了，你的对象有各自的状态以及对这些状态的操作。与之相关的是，WebSocket应用的测试变得更加容易了。

在开发WebSocket应用时还有不少需要注意的事情。值得注意的是，你没有必要在任何地方都使用WebSocket，我将其限定在需要“推送”的场景下。

总的来说，WebSocket是一个很棒、很有趣的技术，它非常有希望灭掉所有采用hack手段实现的推送模拟技术。

[Bozhidar Bozhanov]: http://java.dzone.com/users/glamdring
[http_computoser.com]: http://computoser.com
[http_welshare.com]: http://welshare.com
[Link 1]: http://java.dzone.com/articles/websocket-and-java
[SockJS]: https://github.com/sockjs/sockjs-client
[JSR-356]: http://docs.oracle.com/javaee/7/tutorial/doc/websocket.htm
[API]: http://spring.io/blog/2013/05/23/spring-framework-4-0-m1-websocket-support
[STOMP]: http://assets.spring.io/wp/WebSocketBlogPost.html
[Atmosphere]: https://github.com/Atmosphere/atmosphere
[Link 2]: https://github.com/Atmosphere/atmosphere/wiki/Getting-Started-with-The-Atmosphere-Framework-and-WebSocket
[WebSocket]: http://cometd.org/documentation/2.x/howtos/websocket
[Link 3]: http://computoser.com/
[Link 4]: http://computoser.com/game
[Link 5]: http://www.slideshare.net/Bozho/websockets-and-java
[Link 6]: https://devcenter.heroku.com/articles/websocket-security