Web聊天室

朴灿烈づ我的快乐病毒、 2023-09-30 12:49 19阅读 0赞

**目录**

一，简介

二，开发环境

三，涉及的技术

四，主要功能

1.注册功能

2.登录功能

3.异地登陆（第一次登录网页会被强制退出）

4.发送消息

5.接收消息

6.注销登录

五，准备工作

1.引入开发需要的依赖包

2.设计数据库以及表关系

3.设计实体类

4.设计工具类

数据库连接类

公共方法类

六.注册功能

1）从前端获取用户输入的数据

2）后端获取前端传输的数据

3）判断数据库中是否有相同的账号昵称

4）如果没有将注册数据插入并返回后端提示给前端

5）前端接受后端的响应（注册成功或者是失败）

七，登录功能

1）从前端接收用户输入的用户名和密码（以json字符串形式）

2）后端接收json字符串

3）进行用户登录验证并返回响应

4）前端返回登录成功或是失败的提示（成功还需要跳转）

八，在线聊天页面（核心）

1）对前端需要填充刷新的地方进行修改

2）静态添加群组和用户，完成点击并跳转新的群聊

3）Ajax发送请求，返回数据库中真实的群聊列表和当前的登录用户

4）后端验证是否是登陆用户并返回群聊列表

5）处理响应，并填充到前端

6）使用websocket技术进行前后端的消息推送

7）踢掉使用相同账号登录的网页用户

8）登录用户获取到从上次注销之后到现在登陆之间没有查看的消息（返回个前端并展示）

9）某个用户断开连接时保存退出时间，并删除session和更新到数据库

10）接收消息（即发送消息）

九，注销登录

十，部分包下的源码

1.api（接口包）

2.dao包（数据库方法包）

3.model（实体类包）

4.util（工具类包）

--------------------

## 一，简介 ##

web聊天室为用户提供一个网页版的即时在线聊天平台，同时支持新用户注册登录，老用户登录查看历史消息

## 二，开发环境 ##

JDK1.8，IDEA开发工具，Maven管理工具，MySQL数据库

## 三，涉及的技术 ##

Ajax技术，WebSocket协议，Http协议，单例模式

## 四，主要功能 ##

#### 1.注册功能 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16][]

#### 2.登录功能 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

#### 3.异地登陆（第一次登录网页会被强制退出） ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

#### 4.发送消息 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

#### 5.接收消息 ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 4][]

#### 6.注销登录 ####

## 五，准备工作 ##

### 1.引入开发需要的依赖包 ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>org.example</groupId>
        <artifactId>chatroom</artifactId>
        <version>1.0-SNAPSHOT</version>
        
        <packaging>war</packaging>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>javax.servlet</groupId>
                <artifactId>javax.servlet-api</artifactId>
                <version>3.1.0</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.49</version>
            </dependency>
            <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-databind</artifactId>
                <version>2.12.3</version>
            </dependency>
            
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.13.1</version>
            </dependency>
        </dependencies>
    
        
        <build>
            <finalName>chatroom</finalName>
        </build>
    
    </project>

### 2.设计数据库以及表关系 ###

drop database if exists chatroom;
    create database chatroom character set utf8mb4;
    
    use chatroom;
    
    create table user(
        id int primary key auto_increment,
        username varchar(20) not null unique comment '账号',
        password varchar(50) not null comment '密码',
        nickname varchar(20) not null comment '昵称',
        head varchar(50) comment '头像url（相对路径）',
        logout_time datetime comment '退出登录时间'
    ) comment '用户表';
    
    insert into user(username, password, nickname, logout_time) values('a', '123', '张三', '2019-01-01 00:00:00');
    insert into user(username, password, nickname, logout_time) values('b', '123', '李四', '2019-01-01 00:00:00');
    insert into user(username, password, nickname, logout_time) values('c', '123', '王五', '2019-01-01 00:00:00');
    
    create table channel(
        id int primary key auto_increment,
        name varchar(20) not null unique comment '频道名称'
    ) comment '频道';
    
    insert into channel(name) values ('群聊一');
    insert into channel(name) values ('群聊二');
    insert into channel(name) values ('群聊三');
    
    create table message(
        id int primary key auto_increment,
        user_id int comment '消息发送方：用户id',
        user_nickname varchar(20) comment '消息发送方：用户昵称（历史消息展示需要）',
        channel_id int comment '消息接收方：频道id',
        content varchar(255) comment '消息内容',
        send_time datetime comment '消息发送时间',
        foreign key (user_id) references user(id),
        foreign key (channel_id) references channel(id)
    ) comment '发送的消息记录';

### 3.设计实体类 ###

![454e5fd72be44a349207f7dceedf5a08.png][]

**作用：**

/*
      * 数据库实体类：
      * http请求可能把请求数据转为一个实体类对象
      * http响应可能把实体类对象/List<实体类>返回给客户端
      * 数据库CRUD操作，都可能使用到实体类对象来进行操作
      * 查询返回一个或多个实体类对象
      * 插入修改就是使用实体类对象的属性来作为插入/修改的值
    */

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 5][]

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_16_color_FFFFFF_t_70_g_se_x_16][]

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 6][]

### 4.设计工具类 ###

![f6de1e5bf15a44879d6302cba9fb9b0b.png][]

**作用：**

编写一些公用的方法，或者是数据连接，后续在后端中只需通过类名调用即可

#### **数据库连接类** ####

package org.example.util;
    
    import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
    import org.junit.Test;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class DBUtil {
        //定义一个单例的数据源/连接池对象
        private static final MysqlDataSource DS = new MysqlDataSource();
    
        static {
            DS.setURL("jdbc:mysql://127.0.0.1:3306/chatroom");
            DS.setUser("root");
            DS.setPassword("111111");
            DS.setUseSSL(false);
            DS.setUseUnicode(true);
            DS.setCharacterEncoding("UTF-8");
        }
    
        //获取数据库连接
        public static Connection getConnection(){
            try {
                return DS.getConnection();
            } catch (SQLException e) {
                throw new RuntimeException("获取数据库连接失败", e);
            }
        }
    
        //释放jdbc操作数据库资源
        public static void close(Connection c, Statement s, ResultSet r){
            try {
                if (r != null){
                    r.close();
                }
                if(s != null){
                    s.close();
                }
                if(c != null){
                    c.close();
                }
            } catch (SQLException e) {
                throw new RuntimeException("数据库jdbc释放数据库资源出错", e);
            }
        }
        public static void close(Connection c, Statement s){
            close(c,s,null);
        }
    
        @Test
        public void getConnectionTest(){
            System.out.println(getConnection());
        }
    }

#### 公共方法类 ####

序列化与反序列化，获取session中保存的用户信息等方法

package org.example.util;
    
    import com.fasterxml.jackson.core.JsonProcessingException;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import org.example.model.User;
    import org.junit.Test;
    
    import javax.servlet.http.HttpSession;
    import java.io.IOException;
    import java.io.InputStream;
    
    public class WebUtil {
    
        private static final ObjectMapper M = new ObjectMapper();
    
        //序列化：提供将Java对象转换为json字符串的方法
        public static String write(Object o){
            try {
                return M.writeValueAsString(o);
            } catch (JsonProcessingException e) {
                throw new RuntimeException("转换Java对象为json字符串出错", e);
            }
        }
    
        //反序列化：将json字符串转换为Java对象
        //提供两个重载方法，InputStream和String来转换
        public static <T> T read(InputStream is,Class<T> clazz){
            try {
                return M.readValue(is,clazz);
            } catch (IOException e) {
                throw new RuntimeException("转换输入流json字符串为Java对象出错", e);
            }
        }
    
        public static <T> T read(String str,Class<T> clazz){
            try {
                return M.readValue(str,clazz);
            } catch (IOException e) {
                throw new RuntimeException("转换输入流json字符串为Java对象出错", e);
            }
        }
    
        //获取session中保存的用户信息
        public static User getLoginUser(HttpSession session){
            if(session != null){
                //session不为空，返回session中获取的用户
                //获取时的键，需要和登录时保存的一致
                return (User) session.getAttribute("user");
            }
            return null;
        }
    
        @Test
        public void writeTest(){
            User user = new User();
            user.setId(1);
            user.setUsername("abc");
            user.setPassword("123");
            user.setNickname("张三");
            System.out.println(write(user));
        }
    
        @Test
        public void readTest(){
            String s = "{\"id\":1,\"username\":\"abc\",\"password\":\"123\",\"nickname\":\"张三\",\"logoutTime\":null}";
            System.out.println(read(s,User.class));
        }
    }

## 六.注册功能 ##

#### 1）从前端获取用户输入的数据 ####

**有用户名，密码，昵称，图像四个字段**

首先处理图像字段

//注册选择头像，显示预览图片
    //e时传入的事件对象
    showHead: function (e){
    //获取选择的文件:文件控件可以配置为选择多个文件
    let headFile = e.target.files[0];
    //先保存
    app.head.file = headFile;
    //生成图片url（客户端本地）
    app.head.src = URL.createObjectURL(headFile);

提交格式以form-data格式提交（因为有图像，是以图片文件传入的）

//注册功能
    //使用FormData对象作为form-data格式上传的数据
    let formData = new FormData();
    //添加数据：append(key,value)
    formData.append("username",app.username);
    formData.append("password",app.password);
    formData.append("nickname",app.nickname);
    if(app.head.file != null)
    formData.append("headFile",app.head.file);

#### 2）后端获取前端传输的数据 ####

protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
            //设置请求正文的编码
            req.setCharacterEncoding("UTF-8");
            //获取form-data格式的数据，有上传文件，加servlet注解
            String username = req.getParameter("username");
            String password = req.getParameter("password");
            String nickname = req.getParameter("nickname");
            Part headFile = req.getPart("headFile");
    
            //注册需要把数据插入到数据库，先把数据设置到User对象属性中
            User user = new User();
            user.setUsername(username);
            user.setPassword(password);
            user.setNickname(nickname);
    
            //保存上传的图像在服务端本地的一个路径（不在项目的路径中）
            if(headFile != null){
                //使用一个随机字符串作为保存在服务端本地的文件名
                //先获取上传文件的名称后缀
                String fileName = headFile.getSubmittedFileName();
                String suffix = fileName.substring(fileName.lastIndexOf("."));
                //UUID是一个随机字符串（和机器，时间戳相关）
                //这个文件名需要保存在数据库
                fileName = UUID.randomUUID().toString() + suffix;
                //保存文件
                headFile.write(WebUtil.LOCAL_HEAD_PATH + "/" +fileName);
                //数据库保存图像路径：/+fileName
                user.setHead("/"+fileName);
            }

#### 3）判断数据库中是否有相同的账号昵称 ####

//保存user到数据库：需要考虑账号是否已经存在
    //先校验账号昵称是否已存在（username == ？ or nickname = ？）
    User exist = UserDao.checkIfExist(username,nickname);

#### 4）如果没有将注册数据插入并返回后端提示给前端 ####

//如果存在，响应返回错误信息，如果不存在，注册（插入数据）
    //构造响应对象
    JsonResult result = new JsonResult();
    if(exist != null){
       result.setOk(false);//可以省略，new出来时就是false（ok是基础字段）
       result.setReason("账号或昵称已经存在");
    }else{
       int n = UserDao.insert(user);
       result.setOk(true);
    }
    
    //返回给http响应给前端
    resp.setContentType("application/json;charset=utf-8");
    String body = WebUtil.write(result);
    resp.getWriter().write(body);

#### 5）前端接受后端的响应（注册成功或者是失败） ####

ajax({
        method: "post",
        url: "../register",
        //上传文件，使用form-data格式
        body: formData,
        callback: function (status,responseText) {
            if(status != 200){
                alert("出错了，响应状态码："+ status);
                return;
            }
            let body = JSON.parse(responseText);
            if(body.ok){
                alert("注册成功！");
                window.location.href = "../index.html";
            }else{
                //注册失败
                app.errorMessage = body.reason;
            }
        }
    });

## 七，登录功能 ##

### 1）从前端接收用户输入的用户名和密码（以json字符串形式） ###

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 7][]

### 2）后端接收json字符串 ###

req.setCharacterEncoding("UTF-8");
    //解析json数据，使用输入流
    User input = WebUtil.read(req.getInputStream(),User.class);
    //校验账号密码
    //可以先校验账号是否存在（username=？）如果不存在，提示账号不存在，如果存在，再校验密码
    User exist = UserDao.checkIfExist(input.getUsername(),null);

### 3）进行用户登录验证并返回响应 ###

//准备返回的数据
    JsonResult result = new JsonResult();
    if(exist == null){
        result.setReason("账号不存在");
    }else{
        //校验用户输入的密码和该账号在数据库的密码是否一致
        if(!exist.getPassword().equals(input.getPassword())){
            result.setReason("账号或密码错误");
        }else{
            //校验成功：创建session并保存用户信息
            HttpSession session = req.getSession(true);
            session.setAttribute("user",exist);//保存数据库查询的用户
            result.setOk(true);
        }
    }
    resp.setContentType("application/json; charset=utf-8");
    String body = WebUtil.write(result);
    resp.getWriter().write(body);

### 4）前端返回登录成功或是失败的提示（成功还需要跳转） ###

methods: {
                login: function (){
                    ajax({
                        method: "post",
                        url: "login",
                        contentType: "application/json",
                        body: JSON.stringify({
                            username: app.username,
                            password: app.password,
                        }),
                        callback: function (status,responseText) {
                            if(status != 200){
                                alert("出错了，响应状态码："+ status);
                                return;
                            }
                            let body = JSON.parse(responseText);
                            if(body.ok){
                                alert("登录成功！");
                                window.location.href = "views/message.html";
                            }else{
                                //登陆失败
                                app.errorMessage = body.reason;
                            }
                        }
                    });
                },
            },

## 八，在线聊天页面（核心） ##

### 1）对前端需要填充刷新的地方进行修改 ###

let app = new Vue({
            el: "#app",
            data: {
                //当前登录用户
                currentUser:{
                    nickname: "",
                    head: "",
                },
                //频道/群列表：先写静态数据验证前端代码，后续从servlet获取
                channels:[
                    {
                        id: 1,
                        name:"相亲相爱",
                        //每个频道有自己的历史消息
                        historyMessages:[],
                        //每个频道有自己输入框的内容
                        inputMessageContent: "",
                    },
                    {
                        id: 2,
                        name:"一家人",
                        //每个频道有自己的历史消息
                        historyMessages:[],
                        //每个频道有自己输入框的内容
                        inputMessageContent: "",
                    },
                ],
                //当前频道
                currentChannel:{
                    id: 2,
                    name:"一家人",
                    //每个频道有自己的历史消息
                    historyMessages:[],
                    //每个频道有自己输入框的内容
                    inputMessageContent: "",
                },
            },

### 2）静态添加群组和用户，完成点击并跳转新的群聊 ###

//点击切换频道：channel是点击的频道
    changeChannel:function (channel) {
    //如果点击的频道不是当前频道，才切换
        if(channel.id != app.currentChannel.id){
            app.currentChannel = channel;
        }
    },

### 3）Ajax发送请求，返回数据库中真实的群聊列表和当前的登录用户 ###

ajax({
        method: "get",
        url: "../channelList",
        callback: function (status,responseText) {
            if(status != 200){
                alert("出错了，响应状态码："+ status);
                return;
            }
            let body = JSON.parse(responseText);
            //返回的channel是不带historyMessages和inputMessageContent
            app.currentUser = body.user;
            for(let i = 0;i < body.channels.length;i++){
                body.channels[i].historyMessages = [];
                body.channels[i].inputMessageContent ="";
                //默认切换到第一个频道
                if(i == 0){
                    app.currentChannel = body.channels[0];
                }
            }
        }
    });

### 4）后端验证是否是登陆用户并返回群聊列表 ###

protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws                                 
                                                   ServletException, IOException {
            //必须登录返回频道列表及登录用户信息
    
            //校验是否登录
            User loginUser = WebUtil.getLoginUser(req.getSession(false));
            if(loginUser == null){//没有登陆，不允许访问
                //设置http响应状态码403（禁止访问）
                resp.setStatus(403);
                return;
            }
    
            //登陆成功，获取频道列表数据
            List<Channel> channels = ChannelDao.selectAll();
            //返回的响应正文json字符串结构，前后端相同即可
            Map<String,Object> map = new HashMap<>();
            map.put("user",loginUser);
            map.put("channels",channels);
    
            //返回响应数据
            String body = WebUtil.write(map);
            resp.setContentType("application/json;charset=utf-8");
            resp.getWriter().write(body);
    }

### 5）处理响应，并填充到前端 ###

*  **填充用户信息**
 *  **将数据库真实的群聊列表提供给前端并填充**
 *  **默认是以数据库第一个群聊/频道**

callback: function (status,responseText) {
            if(status != 200){
                alert("出错了，响应状态码："+ status);
                return;
            }
            let body = JSON.parse(responseText);
            //返回的channel是不带historyMessages和inputMessageContent
            app.currentUser = body.user;
            //遍历显示群聊信息
            for(let i = 0;i < body.channels.length;i++){
                body.channels[i].historyMessages = [];
                body.channels[i].inputMessageContent ="";
                //默认切换到第一个频道
                if(i == 0){
                    app.currentChannel = body.channels[0];
                }
            }
            //将后端返回的真实的数据库填充到群聊数组
            app.channels = body.channels;
        }

### 6）使用websocket技术进行前后端的消息推送 ###

*  前端（客户端）先创建websocket对象来进行建立连接的操作（并且在客户端发送Ajax请求之后，在回调函数中初始化）

initWebSocket:function () {
        //先创建一个websocket对象，用来建立连接，客户端收发数据
        //url格式————协议名://ip:port/contextPath/资源路径
        //contextPath是部署的项目名/项目路径，websocket协议名ws
        let protocol = location.protocol;//读取当前地址栏的url的协议名
        let url = location.href;
        //截取需要的字符串
        url = url.substring((protocol+"//").length,url.indexOf("/views/message.html"));
        let ws = new WebSocket("ws://"+url+"/message");
        //为websocket对象绑定事件（事件发生的时候，由浏览器自动调用事件函数）
        //建立连接的事件: e就是事件对象
        ws.onopen = function(e){
            console.log("客户端建立连接")
        }
        //关闭连接的事件：关闭可能是先由服务端关闭，或者先由客户端关闭
        ws.onclose = function(e){
            let reason = e.reason;
            if(reason){
                alert(reason)
            }
        }
        //发生错误时的事件
        ws.onerror = function(e){
            console.log("websocket出错了")
        }
        //接收到消息时的事件
        ws.onmessage = function(e){//服务端推送消息给客户端时，执行这个函数
            // console.log(e.data)//通过事件对象.data就可以获取到服务端推送的消息（可以是二进制数据，或字符串）
            //遍历频道列表，如果频道id和获取到的消息中channelId相同，放到历史消息数组中
            let m = JSON.parse(e.data);
            for(let channel of app.channels){
                if(channel.id == m.channelId){
                    channel.historyMessages.push(m);
                }
            }
        }
        //刷新/关闭页面，也需要关闭websocket关闭
        window.onbeforeunload = function (e) {//当前窗口关闭前执行的函数
            //主动关闭websocket连接
            ws.close();
        }
        app.websocket = ws;
    },

后端也进行四个函数的注册，并且构建websocket的配置类

*  配置类的作用：简单点说，就是在websocket建立连接之前（执行onOpen方法之前）先完成一些工作

//websocket的一些配置类，建立连接之前，定义一个配置
    public class WebSocketConfigurator extends ServerEndpointConfig.Configurator {
    
        //进行握手阶段的一些配置：在客户端与服务端建立websocket连接时，服务端就可以使用这个配置来完成一些初始化工作
        @Override
        public void modifyHandshake(ServerEndpointConfig sec, HandshakeRequest request, HandshakeResponse response) {
            //定义好配置，websocket建立连接时，先执行配置的代码，然后执行onOpen
            HttpSession httpSession = (HttpSession) request.getHttpSession();
            //保存HttpSession数据
            if(httpSession != null){
                sec.getUserProperties().put("HttpSession",httpSession);
            }
            //之后onOpen建立websocket连接，就可以通过websocket的session来获取保存的httpSession
        }
    }

*  在这里的作用是：将httpsession保存下来，在执行onOpen方法的时候判断这个用户是否登录

//先使用websocket的session获取httpSession
    HttpSession httpSession = (HttpSession) session.getUserProperties().get("HttpSession");
    
    //校验是否登录
    User user = WebUtil.getLoginUser(httpSession);
    if(user == null){//没有登录，关闭连接
        CloseReason reason = new CloseReason(CloseReason.CloseCodes.NORMAL_CLOSURE,"没有登录，不允许发送消息");
        session.close(reason);
        return;
    }

### 7）踢掉使用相同账号登录的网页用户 ###

//踢掉相同账号登录的用户：找到相同用户的session，然后关闭websocket session
    Session prevSession = onLineUsers.get(user.getId());
    if(prevSession != null){
        //所有key中，是否包含用户的id，做法：踢出上个用户
        CloseReason reason = new CloseReason(CloseReason.CloseCodes.NORMAL_CLOSURE,"账号在别处登            录");
        prevSession.close(reason);
        //这里关闭的是之前登陆的会话，当前建立的会话是允许的
    }

### 8）登录用户获取到从上次注销之后到现在登陆之间没有查看的消息（返回个前端并展示） ###

//建立websocket连接之后，都要接收所有的历史消息
    List<Message> messages = MessageDao.query(user.getLogoutTime());
    for(Message m : messages){
        //遍历历史消息，全部发送到当前用户的websocket
        String json = WebUtil.write(m);
        session.getBasicRemote().sendText(json);
    }

### 9）某个用户断开连接时保存退出时间，并删除session和更新到数据库 ###

@OnClose
        public void onClose(){
            System.out.println("断开连接");
            //关闭连接：删除map中的当前会话，记录当前用户的注销时间
            onLineUsers.remove(loginUser.getId());
            loginUser.setLogoutTime(new java.util.Date());
            int n = UserDao.updateLogoutTime(loginUser);
        }

### 10）接收消息（即发送消息） ###

*  当客户端的用户点击发送后，后端接收到新的消息
 *  后端接收到后，将前端页面需要的字段获取到后先返回给前端，然后将历史消息存放到数据库

前端获取到用户的发送的消息

sendMessage:function () {
      let content = app.currentChannel.inputMessageContent;
      if(content){
          //后台需要插入数据库，客户端发送的消息
          app.websocket.send(JSON.stringify({
              channelId:app.currentChannel.id,
              content:content,
          }));
      }
    },

后端接收到消息进行处理（并且立即返回给前端页面）

public void onMessage(String message) throws IOException {
            Message m = WebUtil.read(message,Message.class);
            m.setUserId(loginUser.getId());
            m.setUserNickname(loginUser.getNickname());
            //给所有在线用户，发送消息（服务端主动发）
            for(Session session : onLineUsers.values()){
                int n = MessageDao.insert(m);
                String json = WebUtil.write(m);
                session.getBasicRemote().sendText(json);
            }
        }

## 九，注销登录 ##

依次删除session，记录退出时间，并返回至登陆界面

public class LogoutServlet extends HttpServlet {
        @Override
        protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
            HttpSession session = req.getSession(false);
            User user = WebUtil.getLoginUser(session);
            if(user == null){
                resp.setStatus(403);
                return;
            }
            session.removeAttribute("user");
            //记录了上次用户注销时间
            user.setLogoutTime(new java.util.Date());
            UserDao.updateLogoutTime(user);
            resp.sendRedirect("index.html");
        }
    }

## 十，部分包下的源码 ##

### 1.api（接口包） ###

package org.example.api;
    
    import org.example.dao.ChannelDao;
    import org.example.model.Channel;
    import org.example.model.User;
    import org.example.util.WebUtil;
    
    import javax.servlet.ServletException;
    import javax.servlet.annotation.WebServlet;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import java.io.IOException;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    @WebServlet("/channelList")
    public class ChannelListServlet extends HttpServlet {
        @Override
        protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
            //必须登录返回频道列表及登录用户信息
    
            //校验是否登录
            User loginUser = WebUtil.getLoginUser(req.getSession(false));
            if(loginUser == null){
                //没有登录不允许访问
                //设置响应状态码
                resp.setStatus(403);
                return;
            }
    
            //登陆成功：获取频道列表数据
            List<Channel> channels = ChannelDao.selectAll();
            //返回的响应正文json字符串结构
            Map<String,Object> map = new HashMap<>();
            map.put("user",loginUser);
            map.put("channels",channels);
    
            //返回响应数据
            String body = WebUtil.write(map);
            resp.setContentType("application/json;charset=utf-8");
            resp.getWriter().write(body);
        }
    }

package org.example.api;
    
    import org.example.dao.UserDao;
    import org.example.model.User;
    import org.example.util.WebUtil;
    
    import javax.servlet.ServletException;
    import javax.servlet.annotation.WebServlet;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import javax.servlet.http.HttpSession;
    import java.io.IOException;
    
    @WebServlet("/logout")
    public class LogoutServlet extends HttpServlet {
        @Override
        protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
            HttpSession session = req.getSession(false);
            User user = WebUtil.getLoginUser(session);
            if(user == null){
                resp.setStatus(403);
                return;
            }
            session.removeAttribute("user");
            //记录了上次用户注销时间
            user.setLogoutTime(new java.util.Date());
            UserDao.updateLogoutTime(user);
            resp.sendRedirect("index.html");
        }
    }

package org.example.api;
    
    import org.example.dao.MessageDao;
    import org.example.dao.UserDao;
    import org.example.model.Message;
    import org.example.model.User;
    import org.example.util.WebSocketConfigurator;
    import org.example.util.WebUtil;
    
    import javax.servlet.http.HttpSession;
    import javax.websocket.*;
    import javax.websocket.server.ServerEndpoint;
    import java.io.IOException;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    @ServerEndpoint(value="/message", configurator = WebSocketConfigurator.class)
    public class MessageEndpoint {
    
        //当前客户端websocket的会话
        private Session session;
        //当前登录的用户对象
        private User loginUser;
    
        //使用一个共享的数据结构来保存所有客户端websocket会话
    //    private static List<Session> onlineUsers = new ArrayList<>();
        private static Map<Integer,Session> onlineUsers = new HashMap<>();
    
        //session对象，是建立连接的客户端websocket的会话（建立连接到关闭连接就是某个客户端的一次会话）
        //这个session和登录时，使用HttpSession是不同，
        // 但可以通过配置里边，先使用websocket session保存httpSession，
        // 然后建立连接时获取到httpSession
        @OnOpen
        public void onOpen(Session session) throws IOException {
            //先使用websocket session获取httpSession
            HttpSession httpSession = (HttpSession) session.getUserProperties()
                    .get("HttpSession");
            //校验：是否已登录
            User user = WebUtil.getLoginUser(httpSession);
            if(user == null){//没有登录：关闭连接
                //CloseCodes是设置websocket的状态码
                CloseReason reason = new CloseReason(CloseReason.CloseCodes.NORMAL_CLOSURE,
                        "没有登录，不允许发送消息");
                session.close(reason);
                return;
            }
            this.loginUser = user;
            //踢掉使用相同账号登录的用户：找到相同用户的session，然后关闭websocket session
            Session preSession = onlineUsers.get(user.getId());
            if(preSession != null){
                //相同账号重复登录
                CloseReason reason = new CloseReason(CloseReason.CloseCodes.NORMAL_CLOSURE,
                        "账号在别处登录");
                preSession.close(reason);
                //这里关闭的是之前登录的会话，当前建立的会话是允许的
            }
            //保存session到成员变量，后边的事件方法就可以使用session来获取信息、发送消息
            this.session = session;
            //后续服务端接收到一个消息时，还需要把消息发送给所有在线用户：需要保存所有客户端会话
            onlineUsers.put(user.getId(),session);
    
            //建立websocket连接后，客户端需要接收所有的历史消息
            List<Message> messages = MessageDao.query(user.getLogoutTime());
            for(Message m : messages){//遍历历史消息，全发送到当前用户的websocket
                //先把这个对象message转换为json字符串，在发送消息
                String json = WebUtil.write(m);
                session.getBasicRemote().sendText(json);
            }
        }
    
        @OnClose
        public void onClose(){
            System.out.println("断开连接");
            //关闭连接：删除map中的当前会话，记录当前用户的上次注销时间
            onlineUsers.remove(loginUser.getId());
            loginUser.setLogoutTime(new java.util.Date());
            int n = UserDao.updateLogoutTime(loginUser);
        }
    
        @OnError
        public void onError(Throwable t){
            t.printStackTrace();
            //出现异常删除map中的当前会话
            onlineUsers.remove(loginUser.getId());
        }
    
        @OnMessage//服务端接收到消息
        public void onMessage(String message) throws IOException {
            Message m = WebUtil.read(message,Message.class);
            m.setUserId(loginUser.getId());
            m.setUserNickname(loginUser.getNickname());
            System.out.println("服务端接收到消息："+message);
            //给所有在线用户，发送消息（消息推送：服务端主动发）
            for(Session session : onlineUsers.values()){
                int n = MessageDao.insert(m);
                String json = WebUtil.write(m);
                session.getBasicRemote().sendText(json);
            }
        }
    
    }

package org.example.api;
    
    
    import org.example.dao.UserDao;
    import org.example.model.JsonResult;
    import org.example.model.User;
    import org.example.util.WebUtil;
    
    import javax.servlet.ServletException;
    import javax.servlet.annotation.MultipartConfig;
    import javax.servlet.annotation.WebServlet;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import javax.servlet.http.Part;
    import java.io.IOException;
    import java.util.UUID;
    
    @WebServlet("/register")
    @MultipartConfig//表示上传文件时（form-data）
    public class RegisterServlet extends HttpServlet {
        @Override
        protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
            //设置请求正文的编码
            req.setCharacterEncoding("UTF-8");
            //获取form-data格式的数据，有上传文件，加servlet注解
            String username = req.getParameter("username");//页面必填，非空
            String password = req.getParameter("password");//页面必填，非空
            String nickname = req.getParameter("nickname");//页面必填，非空
            Part headFile = req.getPart("headFile");//页面选填，可能为空
    
            //注册需要把数据插入数据库，先把数据设置到User对象属性中
            User user = new User();
            user.setUsername(username);
            user.setPassword(password);
            user.setNickname(username);
    
    
            //保存上传的头像在服务端本地的一个路径（不要在项目的路径中，项目要打包部署到tomcat运行）
            if(headFile != null){
                //使用一个随机字符串作为保存在服务端本地的文件名，文件的后缀需要和上传的文件的后缀一样
                //先获取上传文件的名称后缀
                String fileName = headFile.getSubmittedFileName();//上传文件名
                String suffix = fileName.substring(fileName.lastIndexOf("."));
                //UUID是一个随机字符串（和机器，时间戳有关）
                fileName = UUID.randomUUID() + suffix;
                //保存文件
                headFile.write(WebUtil.LOCAL_HEAD_PATH+"/"+fileName);
                //数据库保存头像路径：/+fileName
                user.setHead("/"+fileName);
            }
    
            //保存数据到数据库：需要考虑是否账号昵称已经存在，不允许插入
            //先校验账号昵称是否已经存在(username = ? or nickname = ?)
            User exist = UserDao.checkIfExist(username,nickname);
    
            //如果存在，响应返回错误信息，如果不存在，注册（插入数据）
            //构造响应对象
            JsonResult result = new JsonResult();
            if (exist != null){
                result.setOk(false);
                result.setReason("账号或昵称已存在");
            }else{
                int n = UserDao.insert(user);
                result.setOk(true);
            }
    
            //返回http响应给前端
            resp.setContentType("application/json;charset=utf-8");
            String body = WebUtil.write(result);
            resp.getWriter().write(body);
        }
    }

### 2.dao包（数据库方法包） ###

package org.example.dao;
    
    import org.example.model.Channel;
    import org.example.util.DBUtil;
    import org.junit.Test;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;
    
    public class ChannelDao {
    
        //查询所有频道
        public static List<Channel> selectAll() {
            Connection c = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
            try {
                c = DBUtil.getConnection();
                String sql = "select * from channel order by id";
                ps = c.prepareStatement(sql);
                rs = ps.executeQuery();
                List<Channel> channels = new ArrayList<>();
                while (rs.next()){
                    //每一行数据转换为一个channel对象
                    Channel channel = new Channel();
                    int id = rs.getInt("id");
                    String name = rs.getString("name");
                    channel.setId(id);
                    channel.setName(name);
                    channels.add(channel);
                }
                return channels;
            } catch (SQLException e) {
                throw new RuntimeException("查询频道列表出错", e);
            } finally {
                DBUtil.close(c,ps,rs);
            }
        }
    
        @Test
        public void selectAllTest(){
            System.out.println(selectAll());
        }
    }

package org.example.dao;
    
    import org.example.model.Message;
    import org.example.util.DBUtil;
    import org.junit.Test;
    
    import java.sql.*;
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.List;
    
    public class MessageDao {
    
        //查询用户上次注销后的历史消息
        public static List<Message> query(Date logoutTime) {
            Connection c = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
            try {
                c = DBUtil.getConnection();
                String sql = "select * from message";
                if(logoutTime != null){
                    sql += " where send_time > ?";
                }
                ps = c.prepareStatement(sql);
                if (logoutTime != null){
                    ps.setTimestamp(1, new Timestamp(logoutTime.getTime()));
                }
                rs = ps.executeQuery();
                List<Message> messages = new ArrayList<>();
                while (rs.next()){
                    Message m = new Message();
                    Integer id = rs.getInt("id");
                    String content = rs.getString("content");
                    Integer userId = rs.getInt("user_id");
                    String userNickname = rs.getString("user_nickname");
                    Integer channelId = rs.getInt("channel_id");
                    Timestamp sendTime = rs.getTimestamp("send_time");
    
                    //设置到message对象中
                    m.setId(id);
                    m.setContent(content);
                    m.setUserId(userId);
                    m.setUserNickname(userNickname);
                    m.setChannelId(channelId);
                    m.setSendTime(new Date(sendTime.getTime()));
    
                    messages.add(m);
                }
                return messages;
            } catch (SQLException e) {
                throw new RuntimeException("查询历史消息jdbc出错", e);
            } finally {
                DBUtil.close(c, ps, rs);
            }
        }
    
        public static int insert(Message m) {
            Connection c = null;
            PreparedStatement ps = null;
            try{
                c = DBUtil.getConnection();
                String sql = "insert into message (content,user_id,user_nickname,channel_id,send_time) values (?,?,?,?,now())";
                ps = c.prepareStatement(sql);
                ps.setString(1,m.getContent());
                ps.setInt(2,m.getUserId());
                ps.setString(3,m.getUserNickname());
                ps.setInt(4,m.getChannelId());
                m.setSendTime(new Date());
                return ps.executeUpdate();
            } catch (SQLException e) {
                throw new RuntimeException("保存发送的消息jdbc出错", e);
            } finally {
                DBUtil.close(c, ps);
            }
        }
    
        @Test
        public void insertTest(){
            Message m = new Message();
            m.setUserId(1);
            m.setContent("测试一下");
            m.setUserNickname("哈哈");
            m.setChannelId(2);
            insert(m);
        }
    }

package org.example.dao;
    
    import org.example.model.User;
    import org.example.util.DBUtil;
    import org.junit.Test;
    
    import java.sql.*;
    
    public class UserDao {
    
        //注册检查账号，昵称是否已存在;登陆校验账号是否存在
        public static User checkIfExist(String username, String nickname) {
            Connection c = null;
            PreparedStatement ps = null;
            ResultSet rs = null;
            try {
                c = DBUtil.getConnection();
                String sql = "select * from user where username=?";
                if(nickname != null){
                    sql += " or nickname=?";
                }
                ps = c.prepareStatement(sql);
                ps.setString(1,username);
                if(nickname != null){
                    ps.setString(2,nickname);
                }
                rs = ps.executeQuery();
                User query = null;
                while(rs.next()){
                    query = new User();
                    Integer id = rs.getInt("id");
                    String loginNickname = rs.getString("nickname");
                    String password = rs.getString("password");
                    String head = rs.getString("head");
                    java.sql.Timestamp logoutTime = rs.getTimestamp("logout_time");
    
                    query.setId(id);
                    query.setUsername(username);
                    query.setPassword(password);
                    query.setNickname(loginNickname);
                    query.setHead(head);
                    if(logoutTime != null){
                        long l = logoutTime.getTime();
                        query.setLogoutTime(new java.util.Date(l));
                    }
                }
                return query;
            } catch (SQLException e) {
                throw new RuntimeException("注册检查账号昵称是否存在jdbc出错", e);
            } finally {
                DBUtil.close(c,ps,rs);
            }
        }
    
        public static int updateLogoutTime(User loginUser) {
            Connection c = null;
            PreparedStatement ps = null;
            try{
                c = DBUtil.getConnection();
                String sql = "update user set logout_time=? where id = ?";
                ps = c.prepareStatement(sql);
                ps.setTimestamp(1,new Timestamp(loginUser.getLogoutTime().getTime()));
                ps.setInt(2,loginUser.getId());
                return ps.executeUpdate();
            } catch (SQLException e) {
                throw new RuntimeException("更新用户上次注销时间jdbc时间出错", e);
            } finally {
                DBUtil.close(c, ps);
            }
        }
    
        @Test
        public void checkTest(){
            //注册测试
    //        User user = checkIfExist("abc","");
            User user = checkIfExist("abc",null);
            System.out.println(user);
        }
    
        public static int insert(User user) {
            Connection c = null;
            PreparedStatement ps = null;
            try{
                c = DBUtil.getConnection();
                String sql = "insert into user(username, password, nickname, head) values(?,?,?,?)";
                ps = c.prepareStatement(sql);
                ps.setString(1, user.getUsername());
                ps.setString(2, user.getPassword());
                ps.setString(3, user.getNickname());
                ps.setString(4, user.getHead());
                return ps.executeUpdate();
            } catch (SQLException e) {
                throw new RuntimeException("注册插入用户数据jdbc出错", e);
            } finally {
                DBUtil.close(c, ps);
            }
        }
    
        @Test
        public void insertTest(){
            User u = new User();
            u.setUsername("ttl");
            u.setPassword("wjxbb");
            u.setNickname("草莓甜甜圈");
            insert(u);
        }
    }

### 3.model（实体类包） ###

package org.example.model;
    
    
    public class Channel {
        private Integer id;
        private String name;
    
        @Override
        public String toString() {
            return "Channel{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    '}';
        }
    
        public Integer getId() {
            return id;
        }
    
        public void setId(Integer id) {
            this.id = id;
        }
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    }

package org.example.model;
    
    
    public class JsonResult {
    
        private boolean ok;//是否操作成功
        private String reason;//ok=false,表示错误信息
        private Object data;//ok=true,返回给前端的业务数据
    
        @Override
        public String toString() {
            return "JsonResult{" +
                    "ok=" + ok +
                    ", reason='" + reason + '\'' +
                    ", data=" + data +
                    '}';
        }
    
        public boolean isOk() {
            return ok;
        }
    
        public void setOk(boolean ok) {
            this.ok = ok;
        }
    
        public String getReason() {
            return reason;
        }
    
        public void setReason(String reason) {
            this.reason = reason;
        }
    
        public Object getData() {
            return data;
        }
    
        public void setData(Object data) {
            this.data = data;
        }
    }

package org.example.model;
    
    
    import java.util.Date;
    
    public class Message {
        private Integer id;
        private Integer userId;
        private String userNickname;
        private String content;
        private Integer channelId;
        private java.util.Date sendTime;
    
        @Override
        public String toString() {
            return "Message{" +
                    "id=" + id +
                    ", userId=" + userId +
                    ", userNickname='" + userNickname + '\'' +
                    ", content='" + content + '\'' +
                    ", channelId='" + channelId + '\'' +
                    ", sendTime=" + sendTime +
                    '}';
        }
    
        public Integer getId() {
            return id;
        }
    
        public void setId(Integer id) {
            this.id = id;
        }
    
        public Integer getUserId() {
            return userId;
        }
    
        public void setUserId(Integer userId) {
            this.userId = userId;
        }
    
        public String getUserNickname() {
            return userNickname;
        }
    
        public void setUserNickname(String userNickname) {
            this.userNickname = userNickname;
        }
    
        public String getContent() {
            return content;
        }
    
        public void setContent(String content) {
            this.content = content;
        }
    
        public Integer getChannelId() {
            return channelId;
        }
    
        public void setChannelId(Integer channelId) {
            this.channelId = channelId;
        }
    
        public Date getSendTime() {
            return sendTime;
        }
    
        public void setSendTime(Date sendTime) {
            this.sendTime = sendTime;
        }
    }

package org.example.model;
    
    import java.util.Date;
    
    public class User {
        private Integer id;
        private String username;
        private String password;
        private String nickname;
        private String head;
        private java.util.Date logoutTime;
    
        @Override
        public String toString() {
            return "User{" +
                    "id=" + id +
                    ", username='" + username + '\'' +
                    ", password='" + password + '\'' +
                    ", nickname='" + nickname + '\'' +
                    ", head='" + head + '\'' +
                    ", logoutTime=" + logoutTime +
                    '}';
        }
    
        public Integer getId() {
            return id;
        }
    
        public void setId(Integer id) {
            this.id = id;
        }
    
        public String getUsername() {
            return username;
        }
    
        public void setUsername(String username) {
            this.username = username;
        }
    
        public String getPassword() {
            return password;
        }
    
        public void setPassword(String password) {
            this.password = password;
        }
    
        public String getNickname() {
            return nickname;
        }
    
        public void setNickname(String nickname) {
            this.nickname = nickname;
        }
    
        public String getHead() {
            return head;
        }
    
        public void setHead(String head) {
            this.head = head;
        }
    
        public Date getLogoutTime() {
            return logoutTime;
        }
    
        public void setLogoutTime(Date logoutTime) {
            this.logoutTime = logoutTime;
        }
    }

### 4.util（工具类包） ###

package org.example.util;
    
    import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
    import org.junit.Test;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class DBUtil {
        private static volatile MysqlDataSource DS = null;
    
        public static MysqlDataSource getDs(){
            if(DS == null){
                synchronized (DBUtil.class){
                    if(DS == null){
                        DS = new MysqlDataSource();
                    }
                }
            }
            return DS;
        }
    
        static {
            getDs();
            DS.setURL("jdbc:mysql://127.0.0.1:3306/chatroom");
            DS.setUser("root");
            DS.setPassword("111111");
            DS.setUseSSL(false);
            DS.setUseUnicode(true);
            DS.setCharacterEncoding("UTF-8");
        }
    
        public static Connection getConnection(){
            try {
                return DS.getConnection();
            } catch (SQLException e) {
                throw new RuntimeException("获取数据库连接失败",e);
            }
        }
    
        //释放jdbc操作数据库资源
        public static void close(Connection c, Statement s, ResultSet rs){
            try {
                if(rs != null) rs.close();
                if(s != null) s.close();
                if(c != null) c.close();
            } catch (SQLException e) {
                throw new RuntimeException("jdbc释放资源出错",e);
            }
        }
    
        public static void close(Connection c, Statement s){
            close(c, s, null);
        }
    
        @Test
        public void Connection(){
            System.out.println(getConnection());
        }
    
    }

package org.example.util;
    
    
    import javax.servlet.http.HttpSession;
    import javax.websocket.HandshakeResponse;
    import javax.websocket.server.HandshakeRequest;
    import javax.websocket.server.ServerEndpointConfig;
    
    public class WebSocketConfigurator extends ServerEndpointConfig.Configurator {
            //进行握手阶段的一些配置：在客户端与服务端建立websocket连接时，
            // 服务端就可以使用这个配置来完成一些初始化工作
            @Override
            public void modifyHandshake(ServerEndpointConfig sec, HandshakeRequest request, HandshakeResponse response) {
                //定义好配置，websocket建立连接时，先执行配置的代码，然后再执行OnOpen
                HttpSession httpSession = (HttpSession) request.getHttpSession();
                //保存HttpSession数据
                if(httpSession != null){
                    sec.getUserProperties().put("HttpSession", httpSession);
                }
                //之后OnOpen建立websocket连接，就可以通过websocket的session来获取保存的HttpSession
        }
    }

package org.example.util;
    
    import com.fasterxml.jackson.core.JsonProcessingException;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import org.example.model.User;
    import org.junit.Test;
    
    import javax.servlet.http.HttpSession;
    import java.io.IOException;
    import java.io.InputStream;
    import java.text.DateFormat;
    import java.text.SimpleDateFormat;
    
    public class WebUtil {
    
        //服务端保存上传图像的一个路径
        public static final String LOCAL_HEAD_PATH = "/root/upload";
    
        private static final ObjectMapper M = new ObjectMapper();
    
        //需要把消息中的日期，转换为年-月-日 时：分：秒
        static {
            DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            M.setDateFormat(df);
        }
        //序列化，提供将Java对象转换为json字符串的方法
        public static String write(Object o){
            try {
                return M.writeValueAsString(o);
            } catch (JsonProcessingException e) {
                throw new RuntimeException("转换Java对象为json字符串出错", e);
            }
        }
    
        //反序列化，将json字符串转换为Java对象
        //提供一个重载的方法：InputStream和String来转换
    
        public static <T> T read(InputStream is,Class<T> clazz){
            try {
                return M.readValue(is,clazz);
            } catch (IOException e) {
                throw new RuntimeException("将json字符串转换为Java对象出错",e);
            }
        }
    
        public static <T> T read(String str,Class<T> clazz){
            try {
                return M.readValue(str,clazz);
            } catch (IOException e) {
                throw new RuntimeException("将json字符串转换为Java对象出错",e);
            }
        }
    
        //获取session中保存的用户信息
        public static User getLoginUser(HttpSession session){
            if(session != null){
                return  (User) session.getAttribute("user");
            }
            return null;
        }
    
        @Test
        public void testWrite(){
            User u = new User();
            u.setId(1);
            u.setUsername("abc");
            u.setPassword("123456");
            u.setNickname("张三");
            System.out.println(write(u));
        }
    
        @Test
        public void testRead(){
            System.out.println(read("{\"id\":1,\"username\":\"abc\",\"password\":\"123456\",\"nickname\":\"张三\",\"logoutTime\":null}",User.class));
        }
    }

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/0a52a34cf8dc41e2a05acc5670f05eed.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/723d5136db31450ab875da232316c017.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/31bc22fe7b2c42d9b5ba36912de4c0e8.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/d8c7aa5becf14398affafef4fec3eee5.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 4]: https://img-blog.csdnimg.cn/4e034bcf5d5b425a954c31a2e9638f7b.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16
[454e5fd72be44a349207f7dceedf5a08.png]: https://img-blog.csdnimg.cn/454e5fd72be44a349207f7dceedf5a08.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 5]: https://img-blog.csdnimg.cn/d76c582f46f0430680f049d7a8505c02.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_16_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/12a40671b8f4415abad1a7e583b7c1c5.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_16,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 6]: https://img-blog.csdnimg.cn/8761708b4e774eeaa087afc97664190b.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16
[f6de1e5bf15a44879d6302cba9fb9b0b.png]: https://img-blog.csdnimg.cn/f6de1e5bf15a44879d6302cba9fb9b0b.png
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAb2hhbmHvvIE_size_20_color_FFFFFF_t_70_g_se_x_16 7]: https://img-blog.csdnimg.cn/310610d672dd44faa35ed3e1392eb1e6.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAb2hhbmHvvIE=,size_20,color_FFFFFF,t_70,g_se,x_16