JavaEE 7教程

WebSocket详解

   WebSocket可提供一个在 单一TCP连接全双工双向通信协议。全双工意味着客户端和服务器可以独立发送信息给 对方。双向意味着客户端可以向服务器发送信息, 反之亦然。

  WebSocket是定义于IETF RFC 6455协议和W3C JavaScript API。该协议在TCP层定义了一个开放的握手和基本的讯息。该API允许Web页使用WebSocket协议双向 与远程主机通信。 

   不同于HTTP,它不需要创建一个新的TCP连接就能发送一个消息,可以持久不断地用于客户端和服务器之间的每一个交换。一旦最初通过HTTP 握手),客户端 和服务器可以独立互相发送信息。 

  客户端和服务器之间的通信是对称的,但有两个 差异:

  • 客户端发起连接到服务器,是监听一个WebSocket请求。
  • 客户端使用URI连接到一个服务器。一个服务器可以监听同一个URI多个客户端。

   客户端和服务器来回传输数据的单位称消息。消息可以是文本或二进制数据。 还携带用于协议级的信令数据。


  Java API定义了WebSocket应用的标准API ,支持:

  • 使用注释和接口创造一个WebSocket客户端和服务器端点
  • 生产和消费WebSocket的文本,二进制,和控制消息
  • 发起和拦截WebSocket的生命周期事件
  • WebSocket会话配置和管理,如超时,重试等
  • WebSocket应用如何在Java EE 安全模型上工作


注释服务器端点

  可以将一个普通Java对象(POJO)使用@serverendpoint作为WebSocket服务器的端点 。这个端点也被称为注释的终点:
@ServerEndpoint("/chat")
public class ChatServer {
  @OnMessage
  public String receiveMessage(String message) {
   //. . .
  }
}

注释的类必须有一个公共的 无参数构造函数。

   @onMessage注解的Java方法用于接收传入的WebSocket信息。 这个信息可以是文本,二进制。

接受字符串信息:
public void receiveMessage(String s) {
//. . .
}

接受Java原始类型信息:
public void receiveMessage(int i) {
//. . .
}

接受一个大文本,如果接收到最后一部分是布尔参数为真,否则为假。
public void receiveBigText(String message, boolean last) {
//. . .
}

使用一个Reader接收整个文本消息阻塞流:
@OnMessage
public void processReader(Reader reader) {
//. . .
}

使用字节[ ]或字节缓冲区接收整个二进制消息:
public void receiveMessage(ByteBuffer b) {
//. . .
}

使用字节[ ]和字节缓冲接受大的二进制,如果接收到的最后一部分是布尔参数为真:
public void receiveBigBinary(ByteBuffer buf, boolean last) {
//. . .
}

使用InputStream得到完整的二进制消息作为阻塞流:
public void processStream(InputStream stream) {
//. . .
}

使用pongmessage接受pong消息:
public void processPong(PongMessage pong) {
//. . .
}

使用了Java的字符串:
@ServerEndpoint("/chat/{room}")
public class MyEndpoint {
@OnMessage
public void receiveMessage(String message, @PathParam("room")String room) {
//. . .
}
}
“pathparam用于标注方法参数,获取在服务器端点URI/chat/{room}的room参数值

public void receiveMessage(String message, Session session) {
//. . .
}
Session表明两个WebSocket端点对话 连接的另一端。在这种情况下,响应到客户端可能
返回:
public void receiveMessage(String message, Session session) {
session.getBasicRemote().sendText(...);
}

参数可以以任何顺序列出。该方法可以有一个void返回类型。这一消息是消耗在终点 没有返回响应。


MaxMessageSize属性可以被用来定义 消息字节最大大小:
@Message(maxMessageSize=6)
public void receiveMessage(String s) {
//. . .
}
在这个程序中,如果超过6个字节的信息被接收,就报告错误 和连接关闭。 使用@OnClose生命周期回调拦截,你还可以得到精确的错误代码和消息的。默认值为1指示 没有最大值。

MaxMessageSize属性不适用使用流 或reader获取的传入消息。

高级定制

@OnOpen
public void open(Session s) {
//. . .
}
@OnClose
public void close(CloseReason c) {
//. . .
}
@OnError
public void error(Throwable t) {
//. . .
}

OnOpen在这个端点一个新的连接建立时被调用。 参数提供了连接的另一端的更多细节。
OnClose在连接被终止时被调用,。参数c 提供更多细节,为什么一个WebSocket连接关闭。

在Java EE平台部署端点,符合CDI规范描述支持完全依赖注入, 。可在所有的WebSocket端点类实现字段,方法和构造器注入。
@ServerEndpoint("/chat")
public class ChatServer {
@Inject User user;
//. . .
}

端点类继承:

@ServerEndpoint("/chat")
public class ChatServer {
}
public class CustomChatServer extends ChatServer {
//. . .
}
在这段代码中,该chatserver类被确定为一个WebSocket端点;然而, customchatserver不是。如果它需要被公认为一个WebSocket端点,然后 必须明确标有@serverendpoint注释。

下页

在Jetty 9.1运行Java WebSockets