JAVA WebSocket技术应用

r囧r小猫 2022-07-13 03:28 149阅读 0赞

# JAVA WebSocket技术 #

之前在一片有关webSocket的技术博客（[JAVA Sokcet(服务端)连接WebSocket个人总结][JAVA Sokcet_WebSocket]）上有提到在Web上使用此技术，很多朋友让我上一波JAVA网页上 WebSocket技术的应用场景。

下面我来说说jAVAweb上怎么使用WebSocket的技术与前端建立tcp连接实时消息推送。

首先由于HTML5的强大支持WebSocket连接，JAVA也推送出了一个与之配套的开源工具javaee-api 7.0，这样可以在页面上写出Socket服务与后台交互。

那既然来学习的首先先上代码：

package com.cx.web;
    
    import java.io.IOException;
    
    import javax.websocket.OnClose;
    import javax.websocket.OnMessage;
    import javax.websocket.OnOpen;
    import javax.websocket.Session;
    import javax.websocket.server.ServerEndpoint;
    
    @ServerEndpoint("/websocket")
    public class WebSocketServlet {
    
      @OnMessage
      public void onMessage(String message, Session session) 
        throws IOException, InterruptedException {
      
        System.out.println("Received: " + message);
      
        session.getBasicRemote().sendText("This is the first server message");
      
        int sentMessages = 0;
        while(sentMessages < 5){
          Thread.sleep(3000);
          session.getBasicRemote().
            sendText("This is an intermediate server message. Count: " 
              + sentMessages);
          sentMessages++;
        }
      
        session.getBasicRemote().sendText("This is the last server message");
      }
      
      @OnOpen
      public void onOpen() {
        System.out.println("Client connected");
      }
    
      @OnClose
      public void onClose() {
        System.out.println("Connection closed");
      }
    }

在具体使用之前我们先了解一下上面注解的具体意思：

**@ServerEndpoint** 注解是一个类层次的注解，它的功能主要是将目前的类定义成一个websocket服务器端。

注解的值将被用于监听用户连接的终端访问URL地址；

**@OnOpen**和**@OnClose** 这两个注解的作用：他们定义了当一个新用户连接和断开的时候所调用的方法；

**@OnMessage**这个注解定义了当服务器接收到客户端发送的消息时所调用的方法；

几个最基础的注解已经讲解完毕，大家理解之后应该也差不多会玩了吧。

我们来了解一下WebSocket握手：

客户端和服务端的TCP连接建立在HTTP协议握手发生之后。通过HTTP流量调试，很容易观察到握手。

客户端一创建WebSocket实例，就会出现如下的请求和服务器端响应：

**请求:**

GET /byteslounge/websocket HTTP/1.1   
Connection: Upgrade   
Upgrade: websocket   
Sec-WebSocket-Key: wVlUJ/tu9g6EBZEh51iDvQ==

**响应:**