WebSocket Day02 : 握手连接

前言

握手连接是WebSocket建立通信的第一步，通过客户端和服务器之间的一系列握手操作，确保了双方都支持WebSocket协议，并达成一致的通信参数。握手连接的过程包括客户端发起握手请求、服务器响应握手请求以及双方完成握手连接。完成握手连接后，客户端和服务器之间建立了一个持久性的双向通信链路，可以进行实时的数据传输。

本次案例，使用 servlet 实现一个用户登录进入聊天室聊天。

一、前期准备

1、新建项目，结构如下

2、导入依赖

<!-- websocket 依赖 --><dependency><groupId>javax.websocket</groupId><artifactId>javax.websocket-api</artifactId><version>1.1</version><scope>provided</scope></dependency><!-- 打印日志 --><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.3.8</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.24</version></dependency><!-- ch02 --><dependency><groupId>javax.servlet</groupId><artifactId>javax.servlet-api</artifactId><version>4.0.1</version><scope>provided</scope></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.14.2</version></dependency>

让我逐个解释这些依赖项的作用：

javax.websocket-api: 这是Java WebSocket API的依赖项，用于在Java应用程序中实现WebSocket通信。

logback-classic: 这是Logback日志框架的经典实现，用于打印日志。

lombok: 这是一个Java库，用于通过注解减少Java代码的样板代码量，提高代码的可读性和简洁性。

javax.servlet-api: 这是Java Servlet API的依赖项，用于开发基于Java的Web应用程序。

jackson-databind: 这是Jackson JSON处理库的依赖项，用于在Java应用程序中进行JSON数据的序列化和反序列化操作。

二、使用 servlet 实现登录功能

1、新建一个 loginServlet

/*** @Date 2023-11-01* @Author qiu* 用户登录*/
@WebServlet("/login")
public class LoginServlet extends HttpServlet {@Overrideprotected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {String userName = req.getParameter("userName");// 将用户名保存到 HttpSessionreq.getSession().setAttribute("user",userName);// 重定向到聊天的首页resp.sendRedirect("chat.html");}
}

让我来逐行解释这段代码的功能：

@WebServlet("/login")：这是一个Servlet注解，指定了该Servlet对应的URL路径为"/login"。当客户端发送带有"/login"路径的请求时，Servlet容器将调用该Servlet来处理请求。

public class LoginServlet extends HttpServlet：这是一个命名为LoginServlet的Java类，它继承自HttpServlet类，表示它是一个Servlet。

protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException：这是Servlet的service方法，它负责处理客户端的请求并返回响应。HttpServletRequest对象提供了关于HTTP请求的信息，而HttpServletResponse对象用于设置HTTP响应。

String userName = req.getParameter("userName");：从HTTP请求中获取名为"userName"的参数值，并将其存储在一个名为userName的字符串变量中。这里假设前端通过HTTP请求将用户名作为参数传递给后端。

req.getSession().setAttribute("user",userName);：使用HttpServletRequest的getSession()方法获取当前会话的HttpSession对象，并使用setAttribute()方法将用户名存储在名为"user"的属性中。这样，在整个会话期间，可以通过getAttribute()方法来访问和使用该属性。

resp.sendRedirect("chat.html");：使用HttpServletResponse的sendRedirect()方法将响应重定向到"chat.html"页面。这意味着登录成功后，用户将被重定向到聊天页面。

以上就是这段代码的功能。它通过获取用户输入的用户名，并将其保存到会话中，实现了用户登录的功能。然后，通过重定向将用户导航到聊天页面。

2、新建一个 html 页面实现登录

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>Title</title>
</head>
<body>
<h1>用户登录</h1>
<form name="f1" method="post" action="login">
Name:<input type="text" name="userName"/>
<input type="submit" value="登录">
</form>
</body>
</html>

让我来逐行解释这段代码的功能：

<form name="f1" method="post" action="login">：这是一个表单（form标签），用于接收用户输入的登录信息，并将其提交到名为"login"的URL路径。

Name:<input type="text" name="userName"/>：这是一个文本输入框（input标签），用于用户输入用户名。name属性指定了该输入框的名称为"userName"，以便后端能够通过该名称获取用户输入的值。

<input type="submit" value="登录">：这是一个提交按钮（input标签），用于提交表单数据。当用户点击该按钮时，表单中的数据将被发送到服务器进行处理。

三、握手连接

1、新建一个消息对象实体类


@Data
@AllArgsConstructor
@NoArgsConstructor
public class Message {/*** 发送人*/private String fromUser;/*** 发送时间*/private String sendTime;/*** 发送内容*/private String content;}

让我来逐行解释这段代码的功能：

@Data：这是一个Lombok注解，自动生成getter、setter、equals、hashCode和toString方法等常见的代码。

@AllArgsConstructor：这是一个Lombok注解，自动生成一个包含所有属性的构造函数。

@NoArgsConstructor：这是一个Lombok注解，自动生成一个无参构造函数。

public class Message：这是一个命名为Message的Java类。

private String fromUser;：这是一个私有的字符串类型变量，表示消息的发送人。

private String sendTime;：这是一个私有的字符串类型变量，表示消息的发送时间。

private String content;：这是一个私有的字符串类型变量，表示消息的内容。

以上就是这段代码的功能。它定义了一个Message类，用于表示一条消息的数据结构。该类包含了发送人、发送时间和发送内容三个属性，并使用Lombok注解简化了相应的代码编写工作。通过创建Message对象，可以方便地操作和传递消息的相关信息。

2、握手连接处理类


public class WebSocketHandshake extends Configurator {/*** 重写握手处理方法* @param sec* @param request  请求对象* @param response 响应对象*/@Overridepublic void modifyHandshake(ServerEndpointConfig sec, HandshakeRequest request, HandshakeResponse response) {// 获取 HttpSession 对象HttpSession httpSession = (HttpSession)request.getHttpSession();// 获取用户名String userName = (String) httpSession.getAttribute("user");// 将用户名保存到当前用户连接 websocket 的 session 中sec.getUserProperties().put("user",userName);}}

让我来逐行解释这段代码的功能：

public class WebSocketHandshake extends Configurator：这是一个命名为WebSocketHandshake的Java类，继承了Configurator类。

@Override：这是一个注解，表示该方法重写了父类或接口的方法。

public void modifyHandshake(ServerEndpointConfig sec, HandshakeRequest request, HandshakeResponse response)：这是一个公共的无返回值方法，用于修改WebSocket握手过程中的处理逻辑。它接受三个参数：

sec：ServerEndpointConfig对象，用于配置WebSocket端点。
request：HandshakeRequest对象，表示握手请求。
response：HandshakeResponse对象，表示握手响应。

HttpSession httpSession = (HttpSession)request.getHttpSession();：获取握手请求中的HttpSession对象，用于获取用户相关的会话信息。

String userName = (String) httpSession.getAttribute("user");：从HttpSession对象中获取名为"user"的属性，即用户名。

sec.getUserProperties().put("user",userName);：将获取到的用户名保存到当前用户连接WebSocket的session中。通过sec.getUserProperties()可以获取到与当前用户连接相关的会话属性，这里将用户名保存在"user"属性中。

以上就是这段代码的功能。它通过重写WebSocket握手处理方法，在握手过程中获取并保存了用户名，以便后续在WebSocket连接中使用。

1）为什么需要这个类握手处理类

这个类是用于在WebSocket握手过程中获取并保存用户名的。WebSocket是一种基于TCP协议的全双工通信协议，它通过在客户端和服务器之间建立持久连接，实现实时的双向通信。

在实际应用中，往往需要对连接WebSocket的用户进行身份验证和权限控制。而在WebSocket握手过程中，可以通过HTTP协议传递一些额外的信息，比如用户的身份信息。为了在后续的WebSocket连接中能够对用户进行身份验证和权限控制，我们需要将用户相关的信息保存起来。

这个WebSocketHandshake类的作用就是在WebSocket握手过程中，获取用户的身份信息（这里是用户名），并将其保存到当前用户连接的WebSocket会话中。通过在握手过程中获取用户名，并将其保存在WebSocket的session中，我们可以在后续的WebSocket连接中使用这个信息进行身份验证和权限控制。

因此，这个类的存在是为了方便在WebSocket应用中获取和保存用户信息，以便后续进行进一步的处理和控制。

3、服务端


@Slf4j
@ServerEndpoint(value = "/connect",configurator = WebSocketHandshake.class)
public class ChatServer {// 用户列表，key 为用户 id 或者是 name,// value 则是每一个客户端的 Sessionprivate static Map<String,Session> users = new HashMap<>();@OnOpenpublic void onOpen(Session session){// 添加用户到用户列表String userName = (String) session.getUserProperties().get("user");// 添加到用户列表中users.put(userName,session);}@OnMessagepublic void onMessage(String message,Session session) throws Exception {// 获取发送人String formUser = (String) session.getUserProperties().get("user");// 创建发送时间String sendTime = new SimpleDateFormat("hh:mm").format(new Date());// 封装消息对象并序列化为 JSONMessage msg = new Message(formUser,sendTime,message);String jsonMessage = new ObjectMapper().writeValueAsString(msg);log.info(jsonMessage);// 群发给所有人for (String userName : users.keySet()){Session s = users.get(userName);s.getBasicRemote().sendText(jsonMessage);}}@OnClosepublic void onClose(Session session){// 将用户移除在线列表String userName = (String) session.getUserProperties().get("user");users.remove(userName);}}

这是一个基于Java实现的WebSocket聊天室后端代码。

首先，在websocket包下，使用了@ServerEndpoint(value = "/connect")注解声明了一个WebSocket服务端，对应的WebSocket地址为/connect。

接下来，代码中定义了一个静态变量users，用来存储所有连接到该WebSocket服务端的用户Session。在用户连接WebSocket服务器时，通过@OnOpen注解声明的方法将用户Session添加到用户列表中。

在@OnMessage注解声明的方法中，当WebSocket服务端接收到客户端发送的消息时，先获取发送人和发送时间，然后封装成一个Message对象并序列化成JSON格式。然后遍历用户列表，将消息发送给每一个客户端。

最后，在@OnClose注解声明的方法中，当一个用户关闭连接时，将其从用户列表中移除。

需要注意的是，在上述代码中还使用了@ServerEndpoint注解的configurator参数，通过自定义WebSocketHandshake类实现了WebSocket握手过程的一些特殊处理。具体可查看WebSocketHandshake类的实现。

总的来说，这是一个简单的WebSocket聊天室后端实现，通过Java提供的WebSocket API完成了对WebSocket连接的管理和消息的广播。

4、新建一个客户端聊天页面

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>Title</title><script src="js/JQuery文件.txt.js"></script>
</head>
<body>
<h1>聊天室</h1>
<div id="msg"><input type="text" id="message"/><input type="button" value="发送"/><br></div><script>// 创建 WebSocket 对象var ws = new WebSocket("ws://localhost:8080/connect");// 接受服务端的信息ws.onmessage = function (event) {// 将消息填充到 div 中let data = event.data;// 将 json 字符串 转换为 json 对象data = $.parseJSON(data);$('#msg').append(data.fromUser + " : " + data.sendTime + "<br>");$('#msg').append(data.content + "<br>");}$(function () {$(':button').on('click',function () {let msg = $('#message').val();// 发送消息ws.send(msg);// 发送完之后清空消息框$('#message').val('');})})</script></body>
</html>

这是一个简单的前端实现，用于创建一个基本的聊天室界面，并通过WebSocket协议与服务器进行通信。下面逐行详细讲解代码的功能和实现。

<script src="js/JQuery文件.txt.js"></script>：引入一个JavaScript文件，其中包含了JQuery库的代码。

<h1>聊天室</h1>：在页面中插入一个标题，显示为"聊天室"。

<div id="msg">：定义一个div元素，用于显示聊天消息。

<input type="text" id="message"/>：创建一个文本输入框，用户可以在其中输入消息。

<input type="button" value="发送"/><br>：创建一个按钮，用于发送消息。

<script>：JavaScript代码的开始标签。

var ws = new WebSocket("ws://localhost:8080/connect");：创建一个WebSocket对象，连接到指定的服务器地址(这里是"ws://localhost:8080/connect")。

ws.onmessage：WebSocket对象的onmessage事件，用于接收从服务器发送的消息。

let data = event.data;：将接收到的消息内容存储在变量data中。

data = $.parseJSON(data);：使用JQuery库中的parseJSON函数，将接收到的json格式消息转换为json对象。

$('#msg').append(data.fromUser + " : " + data.sendTime + "<br>");：将消息发送者和发送时间显示在页面上。

$('#msg').append(data.content + "<br>");：将消息内容显示在页面上。

$('button').on('click', function () {：当用户点击按钮时触发一个匿名函数。

let msg = $('#message').val();：获取文本输入框中的消息内容，并存储在变量msg中。

ws.send(msg);：通过WebSocket发送消息给服务器。

$('#message').val('');：清空文本输入框。

</script>：JavaScript代码的结束标签。