开篇语

哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛

  今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。

  我是一名后端开发爱好者，工作日常接触到最多的就是Java语言啦，所以我都尽量抽业余时间把自己所学到所会的，通过文章的形式进行输出，希望以这种方式帮助到更多的初学者或者想入门的小伙伴们，同时也能对自己的技术进行沉淀，加以复盘，查缺补漏。

小伙伴们在批阅的过程中，如果觉得文章不错，欢迎点赞、收藏、关注哦。三连即是对作者我写作道路上最好的鼓励与支持！

前言

WebSocket是HTML5引入的一种通信协议，旨在建立一个持久的、双向的通信通道，在客户端与服务器之间进行实时数据交换。与传统的HTTP请求-响应模型不同，WebSocket允许在客户端和服务器之间进行持久化连接，实现低延迟的双向通信。本文将介绍WebSocket协议、Java的WebSocket支持、Java WebSocket API的使用，以及WebSocket在实时应用中的应用。

1. WebSocket协议与Java支持

WebSocket协议

WebSocket协议是一种基于TCP的全双工通信协议，它在客户端和服务器之间建立了一个持久化的连接，通过该连接可以实现双向通信。WebSocket允许客户端与服务器之间无需频繁建立新的连接即可实时交换数据。

• 建立连接：WebSocket连接通过HTTP握手建立。客户端向服务器发送一个HTTP请求，并通过请求头中的Upgrade字段请求协议升级。一旦握手成功，HTTP协议就变成了WebSocket协议。
• 持久连接：一旦WebSocket连接建立，客户端与服务器之间的通信不再需要不断重新建立连接，而是保持一个持久的、双向的通道。
• 双向通信：WebSocket支持客户端和服务器同时发送消息，这使得它特别适合实时应用。
• 数据格式：WebSocket支持文本数据和二进制数据的传输。

WebSocket协议的优点

• 低延迟：建立连接后，不需要重新握手，减少了延迟。
• 双向通信：客户端和服务器都可以随时发送数据，而不仅仅是服务器向客户端推送数据。
• 节省资源：持久连接使得资源消耗更少，尤其是对于需要频繁交互的实时应用。

Java对WebSocket的支持

Java从Java EE7开始引入了WebSocket API（JSR 356），使得Java开发者可以更方便地在Web应用中使用WebSocket进行双向通信。Java WebSocket API通过javax.websocket包提供了相关功能，支持WebSocket的客户端和服务器端编程。

Java WebSocket API基于以下组件：

• @ClientEndpoint：用于标注WebSocket客户端端点。
• @ServerEndpoint：用于标注WebSocket服务器端点。
• Session：表示一个WebSocket会话，用于与客户端或服务器进行通信。

2. Java WebSocket API的使用

WebSocket服务器端编程

在服务器端，使用@ServerEndpoint注解来标注WebSocket端点类。每个WebSocket端点都可以处理客户端的连接请求、接收消息以及发送消息。

创建WebSocket服务器端

1. 添加依赖：使用Java EE7及更高版本的容器（如Tomcat 8以上版本）支持WebSocket，或通过依赖添加WebSocket支持（如javax.websocket）。

2. 创建WebSocket端点：

   import javax.websocket.*;
   import javax.websocket.server.ServerEndpoint;
   
   @ServerEndpoint("/chat")
   public class ChatEndpoint {
   
       @OnOpen
       public void onOpen(Session session) {
           System.out.println("New connection: " + session.getId());
       }
   
       @OnMessage
       public void onMessage(String message, Session session) {
           System.out.println("Received message: " + message);
           // 发送消息到客户端
           session.getAsyncRemote().sendText("Echo: " + message);
       }
   
       @OnClose
       public void onClose(Session session) {
           System.out.println("Connection closed: " + session.getId());
       }
   
       @OnError
       public void onError(Session session, Throwable throwable) {
           throwable.printStackTrace();
       }
   }
   

   在上面的例子中，@ServerEndpoint("/chat")标注了WebSocket端点，onOpen、onMessage、onClose和onError方法分别处理连接的打开、消息的接收、连接的关闭以及错误处理。

3. 部署WebSocket端点：将上述ChatEndpoint类部署到支持Java EE的容器中（如Tomcat、GlassFish、WildFly等），并确保WebSocket服务已启用。

WebSocket客户端编程

在客户端，可以使用Java提供的WebSocket客户端API来连接WebSocket服务器，并发送接收消息。

创建WebSocket客户端

1. 创建客户端端点：

   import javax.websocket.*;
   import java.net.URI;
   
   @ClientEndpoint
   public class ChatClient {
   
       @OnOpen
       public void onOpen(Session session) {
           System.out.println("Connected to server");
       }
   
       @OnMessage
       public void onMessage(String message) {
           System.out.println("Received message: " + message);
       }
   
       @OnClose
       public void onClose() {
           System.out.println("Disconnected from server");
       }
   
       @OnError
       public void onError(Throwable throwable) {
           throwable.printStackTrace();
       }
   
       public static void main(String[] args) {
           try {
               WebSocketContainer container = ContainerProvider.getWebSocketContainer();
               container.connectToServer(ChatClient.class, URI.create("ws://localhost:8080/chat"));
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   }
   

2. 连接WebSocket服务器：在main方法中，我们使用WebSocketContainer连接到服务器端点ws://localhost:8080/chat。客户端可以通过onMessage方法接收来自服务器的消息。

3. 运行客户端：运行客户端程序后，它将连接到WebSocket服务器并进行双向通信。

3. 与客户端的双向通信

WebSocket的最大优势之一就是它支持双向通信。服务器可以主动推送数据到客户端，客户端也可以发送数据到服务器。

双向通信示例

• 客户端发送消息：客户端可以向服务器发送消息，服务器在接收到消息后可以进行处理并返回响应。
• 服务器推送消息：服务器可以主动推送消息给客户端，通常用于实时通知或更新。

客户端发送消息到服务器：

session.getAsyncRemote().sendText("Hello, Server!");

服务器推送消息到客户端：

session.getAsyncRemote().sendText("Hello, Client!");

这种双向通信机制非常适合实时应用，如聊天系统、在线游戏和股票价格更新等。

4. WebSocket在实时应用中的应用（聊天室、在线游戏）

WebSocket在聊天室中的应用

WebSocket非常适合用来实现实时聊天室应用。客户端可以发送消息到服务器，服务器将消息广播给所有连接的客户端。

简单的聊天室实现：

1. WebSocket服务器端：服务器接收到一个客户端的消息后，会将该消息转发给所有连接的客户端。

   @ServerEndpoint("/chat")
   public class ChatEndpoint {
   
       private static Set<Session> clients = Collections.synchronizedSet(new HashSet<>());
   
       @OnOpen
       public void onOpen(Session session) {
           clients.add(session);
           System.out.println("New connection: " + session.getId());
       }
   
       @OnMessage
       public void onMessage(String message, Session session) {
           // 广播消息给所有客户端
           synchronized (clients) {
               for (Session client : clients) {
                   if (client != session) {
                       client.getAsyncRemote().sendText(message);
                   }
               }
           }
       }
   
       @OnClose
       public void onClose(Session session) {
           clients.remove(session);
           System.out.println("Connection closed: " + session.getId());
       }
   
       @OnError
       public void onError(Throwable throwable) {
           throwable.printStackTrace();
       }
   }
   

   在这个聊天室示例中，服务器接收到消息后将其广播到所有连接的客户端，其他客户端也能实时收到新消息。

WebSocket在在线游戏中的应用

WebSocket在在线游戏中也有广泛应用，尤其是需要实时交互和快速更新游戏状态的场景。通过WebSocket，游戏服务器可以快速向客户端推送游戏状态、玩家动作、对战信息等。

• 实时游戏同步：通过WebSocket，游戏服务器可以将实时的游戏状态和玩家动作同步给所有参与游戏的玩家。
• 多人实时互动：WebSocket使得游戏中的多人实时互动更加流畅，降低延迟，提高游戏体验。

总结

WebSocket作为一种高效的、低延迟的通信协议，适用于需要实时数据交换的应用场景。通过WebSocket，客户端和服务器可以实现持久化的双向通信，消除了传统HTTP协议的频繁连接开销，适合用于聊天室、在线游戏、实时通知等应用。Java WebSocket API提供了简洁易用的编程接口，开发者可以快速构建高效的实时应用。

… …

文末

好啦，以上就是我这期的全部内容，如果有任何疑问，欢迎下方留言哦，咱们下期见。

… …

学习不分先后，知识不分多少；事无巨细，当以虚心求教；三人行，必有我师焉！！！

wished for you successed ！！！

⭐️若喜欢我，就请关注我叭。

⭐️若对您有用，就请点赞叭。
⭐️若有疑问，就请评论留言告诉我叭。

版权声明：本文由作者原创，转载请注明出处，谢谢支持！