本项目里面只是浅述了一下基本实现步骤，很多细节的地方都在注释中标注了，如需完整代码请去博主码云哦。zqy (zhang-qinyang1) - Gitee.com

目录

一、用到的关键技术点

二、主要模块

1.使用mybatis操作连接数据库

1.1修改spring配置文件

1.2创建实体类User

1.3创建Mapper接口

1.4实现mybatis相关的xml的配置

2.用户模块

2.1登录功能

2.2注册功能

2.3获取自身信息功能

3.匹配模块

3.1匹配功能

4.对战模块

4.1对战功能

先演示一下项目完成后的样子：

①登录页面：

  ②登录后进入的游戏大厅：

③我们在另一个浏览器上登录另一个用户李四，来实现博弈：

 1.准备好双方：

2.双方开始匹配，并且开始博弈分出胜负：

3.比赛场数和天梯分数的变化：

一、用到的关键技术点

本文主要用到的关键技术点有：

Java,Spring/Spring Boot/Spring MVC,HTML,CSS,JS,AJAX,MySQL,MyBatis,WebSocket

然后在这里面我们很多内容我们在之前已经详细讲解过了，今天这里着重介绍一下WebSocket。

①为什么这里要用websocket:

因为我们之前学过的服务器开发，主要是以客户端发出请求，服务器响应这样的方式来进行的，如果客户端不发出请求，那么服务器是不会主动联系客户端的。而在我们这个五子棋项目中就会存在这样的问题，当客户端1下好了棋的位置的时候，就需要告诉服务器下在哪里了，而这个时候，如果靠客户端2每隔一段时间给服务器发送请求看客户端1是否下了棋的话，这样的开销将是很大的，就会浪费很多资源，我们就想着可不可以在服务器接收到客户端1棋的位置后，主动将位置发给客户端2。而websocket正是实现这种消息推送的一个主要方式。

②websocket的报文格式：

其中，我们主要对红色部分内容进行讲解：

（1）opcode:

描述了当前这个报文是什么类型。（比如说是一个文本帧，还是一个二进制帧，是一个ping帧，还是一个pong帧）

（2）Payload len:

表示的是当前数据报携带的数据载荷的长度，这个字段是非常长的，而websocket数据报能承载的载荷长度也是相当长的。

（3） Payload data：

表示的是报文实际要传输的数据载荷

③websocket握手建立连接的过程：

使用网页端，尝试和服务器建立websocket连接，网页端会先给服务器发送一个HTTP请求，这个请求会带有特殊的header，分别是Connection：Upgrade；Upgrade：Websocket；这两个header实际就是在告诉服务器，我们要进行协议的升级，如果这个时候，服务器支持websocket，就会返回一个特殊的HTTP响应，而这个响应的状态码就是101（切换协议），至此，客户端和服务器之间就开始使用websocket来进行通信了。

④实现一个简单的websocket代码：

（1）编写服务器（java）

1.现在java中创建一个类：（名为TestAPI的类）

a.让其继承自TextWebSocketHandler类，这个类是spring中提供的websocket类

b.继承好后，重写四个方法，分别是连接建立，客户端和服务器之间的交互，传输异常，连接被关闭这四个方法：

 2.将刚刚创建这个TestAPI这个类注入到spring中去，我们创建一个新的类，命名为WebSocketConfig:

 a.让这个类实现WebSocketConfigurer接口：

b.并在这个类中实现registerWebSocketHandlers这个方法，这个方法的含义就是能够注册一些handler到这个框架中去：

这行代码的含义就是当客户端连接这样一个路径的时候，就会触发到TestAPI(),然后调用执行到TestAPI中的相关方法。

除此之外，我们需要在这个类外添加两个注解，这样spring才能找到这个类，才能真正处理到这些websocket响应的请求：（第二个注解是开启websocket的关键注解）

 （2）编写客户端（Js）

1.要保证这个路径和前端websocket中的路径保持一致：

2.需要给实例挂载一些回调函数，这里与前面服务器中的代码是非常相似的。

（此时和前端的四个部分是相互对应的，只是名字不同罢了）

 3.实现点击按钮后通过websocket发送请求

（通过send（）方法实现发送消息）

二、主要模块

1.使用mybatis操作连接数据库

创建User表，用来表示用户的个人信息：

create database if not exists java_chess;
use java_chess;
drop table if exists user;
create table user(
userId int primary key auto_increment,
username varchar(20) unique,
password varchar(50),
score int,--天梯积分
totalCount int,--比赛总场数
winCount int --获胜场数
);
insert into user values(null,'zhangsan','123',1000,0,0);
insert into user values(null,'lisi','123',1000,0,0);
insert into user values(null,'wangwu','123',1000,0,0);

1.1修改spring配置文件

这里要是在前面就引入了mybatis就没必要重复了，而下面这个是整体引入完善后的pom.xml:

4.0.0org.springframework.bootspring-boot-starter-parent2.7.5 com.examplejava_chess0.0.1-SNAPSHOTjava_chessDemo project for Spring Boot1.8org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-websocketorg.mybatis.spring.bootmybatis-spring-boot-starter2.2.2org.springframework.bootspring-boot-devtoolsruntimetruecom.mysqlmysql-connector-jruntimeorg.projectlomboklomboktrueorg.springframework.bootspring-boot-starter-testtestorg.springframework.bootspring-boot-maven-pluginorg.projectlomboklombok

1.2创建实体类User

创建实体类model.User:

package com.example.java_chess.model;import lombok.Data;@Data
public class User {private int userId;private  String username;private String password;private int score;private int totalCount;private int winCount;
}

1.3创建Mapper接口

①创建一个model.UserMapper接口，并向其中插入后续用到的功能：

package com.example.java_chess.model;import org.apache.ibatis.annotations.Mapper;@Mapper
public interface UserMapper {//向数据库中插入一个用户，用于注册功能void insert(User user);//用于登录，根据用户名，来查询用户的详细信息User selectByname(String username);//用于判断获胜的场次，每获胜一次，天梯分数加30//总比赛场数+1,获胜场数+1，天梯分数+30void userWin(int userId);//用于判断失败的场次，每失败一次，天梯分数减30//总比赛场数+1,获胜场数不变，天梯分数-30void userLose(int userId);
}

②同时在resource目录下创建一个mapper.UserMapper.xml文件，和上述内容进行匹配：

代码如下：

insert into user values(null,#{username},#{password},1000,0,0);

select * from user where username=#{username};update user set totalCount=totalCount+1,winCount=winCount+1,score=score+30where userId=#{userId}update user set totalCount=totalCount+1,score=score-30where userId=#{userId}

③注意：

（1）namespace位置的实现要到其mapper接口创建的位置：

（2）查询中resultType的位置需要返回实体类所在的那个类的位置：

1.4实现mybatis相关的xml的配置 

①这里我们还是创建一个主的application.xml配置如下：(这样就实现了数据库和mybatis之间的连接)

# 配置数据库信息
spring:datasource:url: jdbc:mysql://127.0.0.1:3306/java_chess?characterEncoding=utf8username: rootpassword: 123456# 版本8之前版本的数据库使用 com.mysql.jdbc.Driver# 版本8以及之后版本的数据库使用 com.mysql.cj.jdbc.Driverdriver-class-name: com.mysql.cj.jdbc.Driver
# 配置 mybatis xml 保存路径
mybatis:mapper-locations: classpath:mapper/**Mapper.xml

②注意的点：

（1）数据库的名称与密码的正确性：

（2）mybatis.xml的保存路径必须在mapper路径下以**.Mapper.xml结尾的文件才会生效

2.用户模块

2.1登录功能

①前后端交互：

②前端代码：（我们登录的时候，只需要传入用户名和密码，所以这里数据我们就只传入了username和password）核心就在ajax部分，因为是通过ajax来实现前后端的交互的。

五子棋对战
登录
用户名
密码
登录
注册

③后端代码： （主要通过userMapper去看数据库中是否有这个用户且密码是否正确，都无误后保存user的信息在httpSession中，以便后续可以拿到信息）

@Resourceprivate UserMapper userMapper;@PostMapping("/login")@ResponseBodypublic Object login( String username,String password, HttpServletRequest req){//关键操作。就是根据username在数据中进行查询User user=userMapper.selectByname(username);System.out.println("[login] username="+username);if (user==null || !user.getPassword().equals(password)){//登录失败System.out.println("登陆失败");return new User();}//保存用户的各项信息，将user保存在里面
//这里的true是没有会话的话就创建一个会话，有的话就直接得到会话HttpSession httpSession=req.getSession(true);
//然后将user的信息保存在这个会话中httpSession.setAttribute("user",user);return user;}

2.2注册功能

①前后端交互：

②前端代码：（核心也是ajax实现前后端的一个交互）

五子棋对战
注册
用户名
密码
提交

③后端代码：(因为是注册，就是原来没有的，那么我们直接创建User这个实体的user对象,调用其中的set方法来设定username和password，设置好后用userMapper来往数据库中插入这个对象，如果用户名已经存在，那么就捕捉异常，抛出一个新的空user对象即可)

 @Resourceprivate UserMapper userMapper;@PostMapping("/register")@ResponseBodypublic Object register(String username,String password){try{User user=new User();user.setUsername(username);user.setPassword(password);userMapper.insert(user);return user;}catch (org.springframework.dao.DuplicateKeyException e){//如果用户名重复，就设置抛出异常User user  =new User();return user;}}

2.3获取自身信息功能

①前后端交互：

(此功能是为了通过session保存用户的登录信息，以便用户随时可以通过这个接口来访问服务器，从而获取到本身的信息 )

②后端代码：（这里就是直接获取httpSession已经存入的对象信息，因为这个信息是在登录的时候就存取了的，而在后面的操作中，我们极有可能存入了新的值，所以这个时候我们就通过在数据库中再次访问该用户的username的形式来更新这个数据，从而拿到最新的数据。）

 @GetMapping("/userInfo")@ResponseBodypublic Object getuserInfo(HttpServletRequest req){try{HttpSession httpSession=req.getSession(false);User user=(User)httpSession.getAttribute("user");//拿到user对象后去数据库中找到最新的数据User newUser=userMapper.selectByname(user.getUsername());return newUser;}catch (NullPointerException e){return new User();}}

3.匹配模块

实现匹配模块，实际上是为了让多个用户在游戏大厅中能够根据得分相近的情况进行两两匹配对战的过程。而这个过程实际上是依赖消息推送机制的，我们可以想到，当玩家1开始匹配就会给服务器发送消息，当匹配到玩家2时，会把这个信息返回给玩家1，同时也得把这个信息返回给玩家2。所以接下来约定的前后端接口，实际上是基于websocket来进行实现的，而我们知道websocket既可以传递文本数据，也可以传递二进制数据，这里我们直接设计让websocket传入json格式的文本数据即可

①注意：

JSON字符串和JS对象的转换：
JSON字符串转成JS对象：JSON.parse()
JS对象转成JSON字符串：JSON.stringify()

JSON字符串和Java对象的转换：
JSON字符串转换成java对象：ObjectMapper.readValue();
Java对象转换成JSON字符串：ObjectMapper.writeValueAsString()

②约定前后端交互：（注意：在websocket传输请求数据的时候，数据中是不必带有用户的身份信息，因为当前用户的身份信息在前面登录完成之后，就已经保存在HttpSession中了，此时websocket中，也是能拿到之前登录好的HttpSession中的信息的）

③前后端进行交互的过程：（下面的内容是核心实现websocket的交互步骤）

通过这个url实现前后端的交互过程 ，然后由上图所见，由MatchAPI这个类来处理匹配功能中的websocket请求。

④MatchAPI来处理websocket的请求：

首先让这个类继承自TextWebSocketHandler

 然后重写这个类中的四个方法，

 同时在前端中也要做出同样的处理，以便在前端控制台可以打印出响应数据供我们判断是否连接上了：

⑤后端封装的内容如何通过websocket传给前端的？

（我们这里举一个例子：以实现处理开始匹配和停止匹配为例）

（1）先建立一个websocket的匹配请求和响应：

匹配请求：

package com.example.java_chess.game;
import lombok.Data;
//这是一个websocket的匹配请求
@Data
public class MatchRequest {private String message="";
}

匹配响应：

package com.example.java_chess.game;
import lombok.Data;
//这是一个websocket的匹配响应
@Data
public class MatchResponse {private boolean ok;private String reason;private String message;
}

 (2)当客户端给服务器发送请求时（这里就是它点击了开始匹配这个按钮）

（3）服务器对客户端传来的websocket数据载荷进行解析：

（4）服务器响应的对象转换成JSON格式的字符串，通过session发送回去：

 （5）客户端接收到了服务器的响应后作出的反应：

 以上就是一个完整的通过websocket来实现的由前端发出请求后，服务器作出响应并返回给前端，前端收到响应后作出一系列反应的过程。

3.1匹配功能

主要就是根据客户端对不同的按钮进行点击，从而来判断属于哪一个范畴：

①客户端代码：（此时的功能实现是在游戏大厅中，所以此时应该是game_hall.html）

开始匹配

②服务器代码：

（1）通过websocket作出响应的MatchAPI代码：（这个代码主要是分为四个部分）

在进行这四项之前我们要对其它问题作出相应的处理：首先我们得判断该玩家是否已经登录了，也就是得拿到当前玩家的登录状态，以及他的相关信息，所以这个时候我们新建一个哈希表通过key,value的形式来实现当前在线与否，在线即可拿到玩家的相关信息：

a.这段代码就实现了查询用户的在线状态，以及进入离开游戏大厅，返回当前玩家信息的相关方法操作：

package com.example.java_chess.game;import org.springframework.stereotype.Component;
import org.springframework.web.socket.WebSocketSession;import java.util.HashMap;
import java.util.concurrent.ConcurrentHashMap;@Component
public class OnlineUserManager {//此处哈希表的作用是表示当前用户在游戏大厅的在线状态//多个线程访问一个HashMap就会出现线程相关的安全问题，所以我们这个时候用ConcurrentHashMap来解决这个问题private ConcurrentHashMap gameHall=new ConcurrentHashMap<>();//这个哈希表用来表示当前用户在游戏房间中的在线状态。private ConcurrentHashMapgameRoom=new ConcurrentHashMap<>();//进入游戏大厅public void enterGameHall(int userId,WebSocketSession webSocketSession){gameHall.put(userId,webSocketSession);}//离开游戏大厅public void exitGameHall(int userId){gameHall.remove(userId);}//根据userId查询找到当前键值对，返回当前的信息public WebSocketSession  getFromGameHall(int userId){return gameHall.get(userId);}public void enterGameRoom(int userId,WebSocketSession webSocketSession){gameRoom.put(userId,webSocketSession);}public void exitGameRoom(int userId){gameRoom.remove(userId);}public WebSocketSession getFromGameRoom(int userId){return gameRoom.get(userId);}
}

b.即表示匹配器，实现匹配与匹配有关的相关功能:

除此之外，我们也要实现，当用户在线就进入匹配队列，玩家下线或者出现异常就退出匹配队列的操作，这个我们用Matcher类来进行实现：

package com.example.java_chess.game;import com.example.java_chess.model.User;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;import javax.annotation.Resource;
import java.io.IOException;
import java.util.LinkedList;
import java.util.Queue;//这个类表示“匹配器”,通过这个类完成整个匹配的功能
@Component
public class Matcher {private ObjectMapper objectMapper=new ObjectMapper();//创建三个匹配队列private QueuenormalQueue=new LinkedList<>();private QueuehighQueue=new LinkedList<>();private QueueveryHighQueue=new LinkedList<>();//引入房间管理器@Autowiredprivate RoomManager roomManager;//玩家的当前的状态信息@Resourceprivate OnlineUserManager onlineUserManager;//操作匹配队列的方法//把玩家放入匹配队列中public void add(User user){if (user.getScore()<2000){synchronized (normalQueue){normalQueue.offer(user);normalQueue.notify();}System.out.println("把玩家"+user.getUsername()+"加入到了normalQueue的匹配队列中");}else if (user.getScore()>=2000&&user.getScore()<3000){synchronized (highQueue){highQueue.offer(user);highQueue.notify();}System.out.println("把玩家"+user.getUsername()+"加入到了highQueue的匹配队列中");}else{synchronized (veryHighQueue){veryHighQueue.offer(user);veryHighQueue.notify();}System.out.println("把玩家"+user.getUsername()+"加入到了veryHighQueue的匹配队列中");}}//把玩家移除匹配队列中public void remove(User user){if (user.getScore()<2000){synchronized (normalQueue){normalQueue.remove(user);}System.out.println("把玩家"+user.getUsername()+"移除了normalQueue的匹配队列中");}else if (user.getScore()>=2000&&user.getScore()<3000){synchronized (highQueue){highQueue.remove(user);}System.out.println("把玩家"+user.getUsername()+"移除了highQueue的匹配队列中");}else{synchronized (veryHighQueue){veryHighQueue.remove(user);}System.out.println("把玩家"+user.getUsername()+"移除了veryHighQueue的匹配队列中");}}public Matcher(){//创建三个线程，分别针对这三个匹配队列来进行操作Thread t1=new Thread(){@Overridepublic void run() {//扫描normalQueuewhile (true){handlerMatch(normalQueue);}}};t1.start();Thread t2=new Thread(){@Overridepublic void run() {//扫描highQueuewhile (true){handlerMatch(highQueue);}}};t2.start();Thread t3=new Thread(){@Overridepublic void run() {//扫描veryHighQueuewhile (true){handlerMatch(veryHighQueue);}}};t3.start();}private void handlerMatch(Queue matchQueue) {synchronized (matchQueue){try {//扫描方法//①检测队列元素个数是否达到2//因为我们五子棋至少得匹配两个人，要是少于两个人的话，压根没有必要去匹配//往队列中添加一个元素，这个时候，后续仍然是不能进行后续匹配操作的，因此，这里使用while是更加合理的while (matchQueue.size() < 2) {matchQueue.wait();//唤醒后再判断条件，所以我们这里用while}//②尝试从队列中取出两个玩家User player1 = matchQueue.poll();User player2 = matchQueue.poll();//加入日志，方便观察System.out.println("匹配出两个玩家：" + player1.getUsername() + "," + player2.getUsername());//③获取到玩家websocket的会话，告诉玩家，你排到了WebSocketSession session1 = onlineUserManager.getFromGameHall(player1.getUserId());WebSocketSession session2 = onlineUserManager.getFromGameHall(player2.getUserId());//理论来说，匹配中的一定是在线的，前面逻辑已经进行了处理，但是为了保证出现情况，我们就双重判定if (session1 == null) {//如果玩家1不在线了，就把玩家二放回到匹配队列matchQueue.offer(player2);return;}if (session2 == null) {//如果玩家2不在线了，就把玩家1放回到匹配队列matchQueue.offer(player1);return;}//当前两个玩家是同一个用户的情况，理论上不会存在//1、玩家下线就会移除，又禁止了玩家多开，所以一个玩家不会入队两次，不能自己排到自己//但是仍然多进行一次判定，保证以下if (session1 == session2) {//把其中的一个玩家放回匹配队列matchQueue.offer(player1);return;}//④把两个玩家放在一个游戏房间中Room room=new Room();roomManager.add(room,player1.getUserId(),player2.getUserId());//⑤给玩家返回信息：你匹配到对手了，此处是通过WebSocket返回一个message为‘matchSuccess’这样的响应//此处是给两个玩家都返回“匹配成功”这样的信息MatchResponse response1 = new MatchResponse();response1.setOk(true);response1.setMessage("matchSuccess");//将其返回成json数据格式String json1 = objectMapper.writeValueAsString(response1);session1.sendMessage(new TextMessage(json1));MatchResponse response2=new MatchResponse();response2.setOk(true);response2.setMessage("matchSuccess");//将其返回成json数据格式String json2 = objectMapper.writeValueAsString(response2);session2.sendMessage(new TextMessage(json2));}catch (IOException | InterruptedException e){e.printStackTrace();}}}
}

c.匹配到两个实力相当的玩家后需要把他们放入同一个房间，所以我们这里用RoomManager类来实现对房间的管理：（其中包括了添加删除查找房间号）

package com.example.java_chess.game;import org.springframework.stereotype.Component;import java.util.concurrent.ConcurrentHashMap;//房间管理器
@Component
public class RoomManager {//是管理roomId到room的唯一映射private ConcurrentHashMap rooms =new ConcurrentHashMap<>();//根据Integer对应的userId作为key,该userId对应的房间号作为value来进行返回。通过userId,找到该用户所在的房间号private  ConcurrentHashMap userIdToRoomId=new ConcurrentHashMap<>();//添加房间号(我们在加入房间号的同时，把userId也加入到第二个哈希表中)public void add(Room room,int userId1,int userId2){rooms.put(room.getRoomId(), room);//以key,value的形式存储userIdToRoomId.put(userId1, room.getRoomId());userIdToRoomId.put(userId2, room.getRoomId());}//删除房间号public void remove(String roomId,int userId1,int userId2){rooms.remove(roomId);userIdToRoomId.remove(userId1);userIdToRoomId.remove(userId2);}//查找房间号public  Room getRoomById(String roomId){return  rooms.get(roomId);}public Room getRoomByUserId(int userId){String roomId=userIdToRoomId.get(userId);if (roomId==null){//说明此userId到roomId的映射是不存在的，直接返回nullreturn null;}return  rooms.get(roomId);}
}

d.而要进入房间管理器的条件是先要本身有一个room，所以我们实现room的代码如下：

public class Room {//使用字符串类型来表示，方便生成唯一值private String roomId;private User user1;private User user2;private static final int MAX_ROW = 15;private static final int MAX_COL = 15;//创建ObjectMapper用来转换JSONprivate ObjectMapper objectMapper = new ObjectMapper();private OnlineUserManger onlineUserManger;// 引入 RoomManager, 用于房间销毁private RoomManger roomManager;private UserMapper userMapper;//那个玩家是先手（先手方的玩家id）private int whiteUser;public Room(){//构造room的时候生成一个唯一的字符串来表示房间id//使用UUID来作为房间idroomId = UUID.randomUUID().toString();//通过入口类中的context来手动获取前面的onlineUserManger和RoomManageronlineUserManger = DemoApplication.context.getBean(OnlineUserManger.class);roomManager = DemoApplication.context.getBean(RoomManger.class);userMapper = DemoApplication.context.getBean(UserMapper.class);}

对于这个类而言，不能注入spring中的@Component等注解，因为这里涉及到很多玩家的房间，不应该是单例，所以我们这里通过注入@Bean的形式来进行注入：

此时在启动类JavaChessApplication中加入context：

package com.example.java_chess;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;@SpringBootApplication
public class JavaChessApplication {public static ConfigurableApplicationContext context;public static void main(String[] args) {context=SpringApplication.run(JavaChessApplication.class, args);}}

然后在room类进行调用即可：（以下三个类都是需要注入的）

在处理完上述内容后，我们就看我们之前提到的通过MatchAPI来实现websocket这个类的四大板块：（代码中有详解，不多说）

package com.example.java_chess.api;import com.example.java_chess.game.MatchRequest;
import com.example.java_chess.game.MatchResponse;
import com.example.java_chess.game.Matcher;
import com.example.java_chess.game.OnlineUserManager;
import com.example.java_chess.model.User;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;
@Controller
//通过这个类来处理匹配功能中的websocket请求
public class MatchAPI extends TextWebSocketHandler {@Autowiredprivate Matcher matcher;private ObjectMapper objectMapper=new ObjectMapper();@Autowiredprivate OnlineUserManager onlineUserManager;@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {//玩家上线，加入到onlineUserManager中//①先获取到当前用户身份信息(who)//此处的代码之所以能够拿到getAtrributes,全靠了在注册websocket的时候加上的// .addInterceptors(new HttpSessionHandshakeInterceptor())//这个逻辑就把HttpSession中的Attribute都拿到webSocketSession中了//在HTTP登录逻辑中，往HttpSession中存储了User对象： httpSession.setAttribute("user",user);//此时就可以在WebSocketSession中把之前HttpSession里存的User对象给拿到了//此处的user有可能为空，用户之前没有通过HTTP进行登录，直接通过/game_hall.html这个url来访问这个页面try{User user=(User)session.getAttributes().get("user");//②先判断当前用户是否已经登录了，即是否已经在线，在线的话就不该继续进行后续逻辑if (onlineUserManager.getFromGameHall(user.getUserId())!=null|| onlineUserManager.getFromGameRoom(user.getUserId())!=null){//当前用户已经登录了，要告诉客户端，你这里重复登录了MatchResponse response=new MatchResponse();response.setOk(true);response.setReason("当前禁止多开");response.setMessage("repeatConnection");session.sendMessage(new TextMessage(objectMapper.writeValueAsString(response)));//此处直接关闭太过激进，我们还是返回一个特殊的message，由客户端来进行处理//session.close();return;}//③拿到身份信息后，将玩家设置为在线状态onlineUserManager.enterGameHall(user.getUserId(),session);System.out.println("玩家进："+user.getUsername()+"进入游戏大厅");}catch (NullPointerException e){System.out.println("[MatchAPI.afterConnectionEstablished]当前用户未登录");//出现空指针异常，说明用户尚未登录。身份信息为空MatchResponse matchResponse=new MatchResponse();matchResponse.setOk(false);matchResponse.setReason("您尚未登录，不能进行后续匹配");//先通过objectMapper把MatchResponse对象转换成json字符串，然后再包装上一层TextMessage，再进行传输//TextMessage就表示一个文本格式的websocket数据包session.sendMessage(new TextMessage(objectMapper.writeValueAsString(matchResponse)));}}@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {//实现处理开始匹配和停止匹配的请求User user=(User)session.getAttributes().get("user");//获取到客户端给服务器发送的数据String payload=message.getPayload();//解析当前这个json格式的字符串，转换成java对象，这里的话就是指MatchRequest//从客户端读取的数据MatchRequest request=objectMapper.readValue(payload, MatchRequest.class);//从客户端返回的数据MatchResponse response=new MatchResponse();if (request.getMessage().equals("startMatch")){//进入匹配队列//TODD先创建一个类表示匹配队列，给当前用户加入matcher.add(user);//把玩家信息放入匹配队列之后，就会返回一个响应给客户端response.setOk(true);response.setMessage("startMatch");}else if (request.getMessage().equals("stopMatch")){//退出匹配队列//TODD先创建一个类表示匹配队列，把当前用户从队列中移除matcher.remove(user);response.setOk(true);response.setMessage("stopMatch");}else{//非法情况response.setOk(false);response.setMessage("非法的匹配请求");}//将response对象转成json格式的字符串，再通过session给发送回去String jsonString= objectMapper.writeValueAsString(response);//对应一个websocket数据报，发送给客户端session.sendMessage(new TextMessage(jsonString));}@Overridepublic void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {//玩家下线，从onlineUserManager中删除//①拿到user对象try{User user=(User)session.getAttributes().get("user");//②退出(这应该是针对多开的情况)WebSocketSession session1=onlineUserManager.getFromGameHall(user.getUserId());if (session1==session) {onlineUserManager.exitGameHall(user.getUserId());}//玩家正在匹配中，websocket直接断开，这个时候要从匹配队列中断开matcher.remove(user);}catch (NullPointerException e){System.out.println("[MatchAPI.handleTransportError]当前用户未登录");
//            MatchResponse matchResponse=new MatchResponse();
//            matchResponse.setOk(false);
//            matchResponse.setReason("您尚未登录，不能进行后续匹配");
//            //先通过objectMapper把MatchResponse对象转换成json字符串，然后再包装上一层TextMessage，再进行传输
//            //TextMessage就表示一个文本格式的websocket数据包
//            session.sendMessage(new TextMessage(objectMapper.writeValueAsString(matchResponse)));}}@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {//玩家下线，从onlineUserManager中删除try{User user=(User)session.getAttributes().get("user");WebSocketSession session1=onlineUserManager.getFromGameHall(user.getUserId());if (session1==session) {onlineUserManager.exitGameHall(user.getUserId());}//玩家正在匹配中，websocket直接断开，这个时候要从匹配队列中断开matcher.remove(user);}catch (NullPointerException e){System.out.println("[MatchAPI.afterConnectionClosed]当前用户未登录");//连接关闭之后，不能再尝试把消息发给客户端
//            MatchResponse matchResponse=new MatchResponse();
//            matchResponse.setOk(false);
//            matchResponse.setReason("您尚未登录，不能进行后续匹配");
//            //先通过objectMapper把MatchResponse对象转换成json字符串，然后再包装上一层TextMessage，再进行传输
//            //TextMessage就表示一个文本格式的websocket数据包
//            session.sendMessage(new TextMessage(objectMapper.writeValueAsString(matchResponse)));}}
}

4.对战模块

对战模块的主要功能就是对进入同一个游戏房间的两个玩家来进行胜负的判定，然而，在这里我们由于要下棋，那么客户端1下的棋告诉服务器后，服务器需要同时发送给客户端2这个落子位置，所以这里仍然需要用websocket来建立前后端的连接。由于这里对战的逻辑和匹配的逻辑是不相同的，所以，我们需要使用两套逻辑，即使用两套不同的websocket路径来进行连接处理

①实现前后端的交互：

②前后端实现交互的过程：（现在对战的话实在game_room.html中进行的）

而我们这里把前端的操作封装到js里来：

 这里我们很容易发现，现在是由GameAPI来实现游戏对战中websocket的相关功能：

③前后端还是需要调入以下方法：

（1）后端而言：

（2） 前端而言：

④这个地方我们已经进入了游戏房间：

（1）后端向前端传入响应：

当两个玩家都加入成功后，让服务器都访问一个websocket，来通知游戏双方说准备好了：

（2）前端作出请求：

这里就将java格式的对象转换成JSON字符串格式，然后传入给客户端。

（3） 在执行到initGame（）函数后，客户端会向服务器发送落子请求：

（4）服务器收到落子请求后，判断胜负之后，把winner返回响应给客户端：

4.1对战功能

①客户端：（这里主要是game_room.html和其内部执行的js）

注意：此处引入了 canvas 标签.这个是 HTML5 引入的 “画布”. 后续的棋盘和棋子的绘制, 就依赖这个画布功能。

五子棋对战
等待玩家连接中...

js/script.js代码：

需要注意：
oneStep 函数起到的效果是在一个指定的位置上绘制一个棋子. 可以区分出绘制白字还是黑子. 参数是横坐标和纵坐标, 分别对应列和行.
用 onclick 来处理用户点击事件. 当用户点击的时候通过这个函数来控制绘制棋子。me 变量用来表示当前是否轮到我落子，over 变量用来表示游戏结束.
实现 onmessage 方法. onmessage 先处理游戏就绪响应.

修改 onclick 函数, 在落子操作时加入发送请求的逻辑.
注释掉原有的 onStep 和 修改 chessBoard 的操作, 放到接收落子响应时处理.
实现 send , 通过 websocket 发送落子请求.

在 initGame 中, 修改 websocket 的 onmessage.在 initGame 之前, 处理的是游戏就绪响应, 在收到游戏响应之后, 就改为接收落子响应了.在处理落子响应中要处理胜负手.

let gameInfo = {roomId: null,thisUserId: null,thatUserId: null,isWhite: true,
}//
// 设定界面显示相关操作
//function setScreenText(me) {let screen = document.querySelector('#screen');if (me) {screen.innerHTML = "轮到你落子了!";} else {screen.innerHTML = "轮到对方落子了!";}
}//
// 初始化 websocket
//// 此处写的路径要写作 /game, 不要写作 /game/
let websocketUrl = 'ws://' + location.host + '/game';
let websocket = new WebSocket(websocketUrl);websocket.onopen = function() {console.log("连接游戏房间成功!");
}websocket.close = function() {console.log("和游戏服务器断开连接!");
}websocket.onerror = function() {console.log("和服务器的连接出现异常!");
}window.onbeforeunload = function() {websocket.close();
}// 处理服务器返回的响应数据
websocket.onmessage = function(event) {console.log("[handlerGameReady] " + event.data);let resp = JSON.parse(event.data);if (!resp.ok) {alert("连接游戏失败! reason: " + resp.reason);// 如果出现连接失败的情况, 回到游戏大厅location.assign("/game_hall.html");return;}if (resp.message == 'gameReady') {gameInfo.roomId = resp.roomId;gameInfo.thisUserId = resp.thisUserId;gameInfo.thatUserId = resp.thatUserId;gameInfo.isWhite = (resp.whiteUser == resp.thisUserId);// 初始化棋盘initGame();// 设置显示区域的内容setScreenText(gameInfo.isWhite);} else if (resp.message == 'repeatConnection') {alert("检测到游戏多开! 请使用其他账号登录!");location.replace("/login.html");}
}//
// 初始化一局游戏
//
function initGame() {// 是我下还是对方下. 根据服务器分配的先后手情况决定let me = gameInfo.isWhite;// 游戏是否结束let over = false;let chessBoard = [];//初始化chessBord数组(表示棋盘的数组)for (let i = 0; i < 15; i++) {chessBoard[i] = [];for (let j = 0; j < 15; j++) {chessBoard[i][j] = 0;}}let chess = document.querySelector('#chess');let context = chess.getContext('2d');context.strokeStyle = "#BFBFBF";// 背景图片let logo = new Image();logo.src = "image/science.jpg";logo.onload = function () {context.drawImage(logo, 0, 0, 450, 450);initChessBoard();}// 绘制棋盘网格function initChessBoard() {for (let i = 0; i < 15; i++) {context.moveTo(15 + i * 30, 15);context.lineTo(15 + i * 30, 430);context.stroke();context.moveTo(15, 15 + i * 30);context.lineTo(435, 15 + i * 30);context.stroke();}}// 绘制一个棋子, me 为 truefunction oneStep(i, j, isWhite) {context.beginPath();context.arc(15 + i * 30, 15 + j * 30, 13, 0, 2 * Math.PI);context.closePath();var gradient = context.createRadialGradient(15 + i * 30 + 2, 15 + j * 30 - 2, 13, 15 + i * 30 + 2, 15 + j * 30 - 2, 0);if (!isWhite) {gradient.addColorStop(0, "#0A0A0A");gradient.addColorStop(1, "#636766");} else {gradient.addColorStop(0, "#D1D1D1");gradient.addColorStop(1, "#F9F9F9");}context.fillStyle = gradient;context.fill();}chess.onclick = function (e) {if (over) {return;}if (!me) {return;}let x = e.offsetX;let y = e.offsetY;// 注意, 横坐标是列, 纵坐标是行let col = Math.floor(x / 30);let row = Math.floor(y / 30);if (chessBoard[row][col] == 0) {// 发送坐标给服务器, 服务器要返回结果send(row, col);// 留到浏览器收到落子响应的时候再处理(收到响应再来画棋子)// oneStep(col, row, gameInfo.isWhite);// chessBoard[row][col] = 1;}}function send(row, col) {let req = {message: 'putChess',userId: gameInfo.thisUserId,row: row,col: col};websocket.send(JSON.stringify(req));}// 之前 websocket.onmessage 主要是用来处理了游戏就绪响应. 在游戏就绪之后, 初始化完毕之后, 也就不再有这个游戏就绪响应了.// 就在这个 initGame 内部, 修改 websocket.onmessage 方法~~, 让这个方法里面针对落子响应进行处理!websocket.onmessage = function(event) {console.log("[handlerPutChess] " + event.data);let resp = JSON.parse(event.data);if (resp.message != 'putChess') {console.log("响应类型错误!");return;}// 先判定当前这个响应是自己落的子, 还是对方落的子.if (resp.userId == gameInfo.thisUserId) {// 我自己落的子// 根据我自己子的颜色, 来绘制一个棋子oneStep(resp.col, resp.row, gameInfo.isWhite);} else if (resp.userId == gameInfo.thatUserId) {// 我的对手落的子oneStep(resp.col, resp.row, !gameInfo.isWhite);} else {// 响应错误! userId 是有问题的!console.log('[handlerPutChess] resp userId 错误!');return;}// 给对应的位置设为 1, 方便后续逻辑判定当前位置是否已经有子了.chessBoard[resp.row][resp.col] = 1;// 交换双方的落子轮次me = !me;setScreenText(me);// 判定游戏是否结束let screenDiv = document.querySelector('#screen');if (resp.winner != 0) {if (resp.winner == gameInfo.thisUserId) {screenDiv.innerHTML = 'WIN!';} else if (resp.winner = gameInfo.thatUserId) {screenDiv.innerHTML = 'LOSE!';} else {alert("winner 字段错误! " + resp.winner);}// 回到游戏大厅// location.assign('/game_hall.html');// 增加一个按钮, 让玩家点击之后, 再回到游戏大厅~let backBtn = document.createElement('button');backBtn.innerHTML = '回到大厅';backBtn.onclick = function() {location.replace('/game_hall.html');}let fatherDiv = document.querySelector('.container>div');fatherDiv.appendChild(backBtn);}}
}

②服务器：

（1）通过websocket作出响应的GameAPI代码：（这个代码主要是分为四个部分）

在演示这四个代码部分之前，我们需要做如下一些操作：

1.引入GameRequest类和GameResponse类来明确请求，响应过程中的参数问题：

GameRequest：

package com.example.java_chess.game;
import lombok.Data;
//这个类表示落子请求
@Data
public class GameRequest {private String message;private  int userId;private int row;private int col;
}

GameResponse：

package com.example.java_chess.game;
import lombok.Data;
//这个类表示一个落子响应
@Data
public class GameResponse {private String message;private  int userId;private int row;private int col;private int winner;
}

2.当两个玩家进入了同一个房间后，并且都准备好了，这个时候，就由Room类执行下棋的操作，以及判断最终的胜负：

package com.example.java_chess.game;import com.example.java_chess.JavaChessApplication;
import com.example.java_chess.model.User;
import com.example.java_chess.model.UserMapper;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import javafx.scene.chart.ScatterChart;
import lombok.Data;
import org.apache.ibatis.annotations.Param;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;import java.io.IOException;
import java.util.UUID;//这个类表示一个游戏房间
@Data
//@Component不能这样，因为Component是单例模式，而这里涉及到很多玩家的房间，不应该是单例
public class Room {//引入RoomManager来用于房间的销毁//@Autowiredprivate RoomManager roomManager;//引入onlineUserManager来返回用户的当前信息状态//@Autowiredprivate OnlineUserManager onlineUserManager;//创建，用来转换Json对象private ObjectMapper objectMapper=new ObjectMapper();private UserMapper userMapper;//使用字符串类型来表示，方便设置唯一值private String roomId;private User user1;private User user2;//先手方玩家idprivate int whiteUser;//这个二维数组表示棋盘//做一个约定：1)使用0表示当前位置未落子，初始化好的int数组，就相当于全是0//2)使用1表示user1的落子位置//3)使用2表示user2的落子位置private int [][]board=new int[15][15];//来设置一下该棋盘的最大行数和列数private static final int MAX_ROW=15;private static final int MAX_COL=15;//通过这个方法来处理一次落子操作，要做的为以下几步public void putChess(String reqJson) throws IOException {//1.要记录当前落子的位置//按照GameRequest这个类来进行转换，这个类本身就是用来接收穿过来的request请求的GameRequest request=objectMapper.readValue(reqJson,GameRequest.class);GameResponse response=new GameResponse();//当前这个子是玩家一落的还是玩家2，根据玩家1和玩家2来决定往数组中写1还是写2int chess=request.getUserId()==user1.getUserId()?1:2;//相等是玩家1的子，不相等就是玩家2的子int row=request.getRow();int col=request.getCol();if (board[row][col]!=0){//这种情况一般是不会存在的，因为在客户端已经针对重复落子进行过判定了// 此处是为了保证程序更加没问题，就用服务器进行了再一次的判定System.out.println("当前位置（"+row+","+col+"）已经有子了！");return;}//此处这个位置没有落子，当前得到的值放于该位置board[row][col]=chess;//2.打印出当前的棋盘信息printBoard();//3.进行胜负判断int winner=checkWinner(row,col,chess);//4.给房间中所有客户端返回响应response.setMessage("putChess");response.setUserId(request.getUserId());response.setRow(row);response.setCol(col);response.setWinner(winner);//要想给用户发送websocket数据，需要获取到该用户的websocketsessionWebSocketSession session1=onlineUserManager.getFromGameRoom(user1.getUserId());WebSocketSession session2=onlineUserManager.getFromGameRoom(user2.getUserId());//特殊处理：万一拿到当前玩家的会话为空，即玩家已经下线if (session1==null){//玩家1下线，直接玩家2获胜response.setWinner(user2.getUserId());System.out.println("玩家1掉线");}if (session2==null){response.setWinner(user1.getUserId());System.out.println("玩家2掉线");}//把响应构造成JSON字符串，在通过session进行传输String respJson=objectMapper.writeValueAsString(response);if (session1!=null){session1.sendMessage(new TextMessage(respJson));}if (session2!=null) {session2.sendMessage(new TextMessage(respJson));}//如果当前胜负已分，那么这个房间就失去了意思，我们就可以直接销毁该房间if(response.getWinner()!=0){//胜负已分System.out.println("游戏结束，即将返回！roomId="+roomId+"获胜方为"+response.getWinner());//更新获胜方和失败方的分数int winUserId=response.getWinner();int loseUserId=response.getWinner()==user1.getUserId()?user2.getUserId():user1.getUserId();userMapper.userWin(winUserId);userMapper.userLose(loseUserId);roomManager.remove(roomId,user1.getUserId(),user2.getUserId());}}private void printBoard() {//打印棋盘System.out.println("[打印棋盘信息：]"+roomId);System.out.println("===================");for (int r=0;r=col;r++,c--){try{if (board[r][c]==chess&&board[r+1][c-1]==chess&&board[r+2][c-2]==chess &&board[r+3][c-3]==chess&&board[r+4][c-4]==chess){return chess==1?user1.getUserId():user2.getUserId();}}catch (ArrayIndexOutOfBoundsException e){continue;}}//胜负未分，直接返回0return 0;}public  Room(){//构造room的时候生成一个唯一的字符串来表示房间id//在这里我们使用UUID来作为房间ID（调用任意次的结果都是不相同的）roomId= UUID.randomUUID().toString();//通过入口类中记录的context来手动获取到前面的RoomManager和OnlineManageronlineUserManager= JavaChessApplication.context.getBean(OnlineUserManager.class);roomManager=JavaChessApplication.context.getBean(RoomManager.class);userMapper=JavaChessApplication.context.getBean(UserMapper.class);}
}

3.GameAPI四个部分的代码如下：（注释里面将得很清楚整个逻辑，就不再复述）

package com.example.java_chess.api;import com.example.java_chess.game.*;
import com.example.java_chess.model.User;
import com.example.java_chess.model.UserMapper;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.sun.deploy.security.WSeedGenerator;
import org.omg.CORBA.UserException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;import javax.annotation.Resource;
import java.io.IOException;@Component
public class GameAPI extends TextWebSocketHandler {@Resourceprivate UserMapper userMapper;@Autowiredprivate OnlineUserManager onlineUserManager;@Autowiredprivate RoomManager roomManager;private ObjectMapper objectMapper=new ObjectMapper();@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {GameReadyResponse response=new GameReadyResponse();//①先获取到用户的身份信息(从HttpSession中拿到当前用户的对象）User user =(User)session.getAttributes().get("user");if (user==null){response.setOk(false);response.setReason("用户尚未登录");//把对象转化成json格式的对象session.sendMessage((new TextMessage(objectMapper.writeValueAsString(response))));return;}//②判断当前用户是否已经进入房间（用房间管理器来进行查询）Room room=roomManager.getRoomByUserId(user.getUserId());if (room==null){//该玩家还未匹配到response.setOk(false);response.setReason("当前用户还未匹配到");session.sendMessage(new TextMessage(objectMapper.writeValueAsString(response)));return;}//③判断当前是不是多开，即该用户是不是已经在其他地方登陆了if (onlineUserManager.getFromGameHall(user.getUserId())!=null ||onlineUserManager.getFromGameRoom(user.getUserId())!=null){//如果一个游戏账号一个在游戏房间一个在游戏大厅，也得视为多开response.setOk(true);response.setReason("禁止游戏多开页面");response.setMessage("repeatConnection");session.sendMessage(new TextMessage(objectMapper.writeValueAsString(response)));return;}//④设置玩家上线onlineUserManager.enterGameRoom(user.getUserId(),session);//⑤把两个玩家加入到游戏房间中//当前这个逻辑是在game_room.html页面加载的时候进行的//而前面的创建房间/匹配过程，是在game_hall.html页面中完成的//因此前面匹配到对手后，需要进行页面跳转，来到game_room.html才算正式成功//执行到当前这个逻辑，说明玩家已经页面跳转成功啦//到此，本来就已经进入了一个玩家，我们下面的操作实际上就是说明其是玩家几synchronized (room) {if (room.getUser1() == null) {//第一个玩家还未加入到房间中//但是现在是有一个客户端连接成功了才会调用这个方法，// 所以就把当前连上WebSocket的玩家作为user1,加入到房间中room.setUser1(user);//把先连入房间的玩家作为先手room.setWhiteUser(user.getUserId());System.out.println("玩家:" + user.getUsername() + "已经准备就绪");return;}if (room.getUser2() == null) {//就说明玩家1已经进入了房间//给当前玩家作为玩家2room.setUser2(user);System.out.println("玩家：" + user.getUsername() + "已经准备就绪");//当两个玩家都加入成功后，让服务器都访问一个websocket，来通知游戏双方说都已经准备好了//通知玩家1noticeGameReady(room, room.getUser1(), room.getUser2());//通知玩家2noticeGameReady(room, room.getUser2(), room.getUser1());return;}}//⑥此处如果又有玩家尝试连接同一个房间，就提示报错，理论上是不存在这种情况的，但是此处为了更完善response.setOk(false);response.setReason("当前房间已满！已不能加入！");session.sendMessage(new TextMessage(objectMapper.writeValueAsString(response)));}public void noticeGameReady(Room room,User thisUser,User thatUser) throws IOException {GameReadyResponse resp=new GameReadyResponse();resp.setMessage("gameReady");resp.setOk(true);resp.setReason("");resp.setRoomId(room.getRoomId());resp.setThisUserId(thisUser.getUserId());resp.setThatUserId(thatUser.getUserId());resp.setWhiteUser(room.getWhiteUser());//把当前响应数据传回给对应玩家WebSocketSession webSocketSession = onlineUserManager.getFromGameRoom(thisUser.getUserId());webSocketSession.sendMessage(new TextMessage(objectMapper.writeValueAsString(resp)));}@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {//1.先从session里面拿到当前用户的身份信息User user = (User) session.getAttributes().get("user");if (user == null){System.out.println("[handleTextMessage:]当前玩家尚未登录！");return;}//2.根据玩家id获取到房间对象Room room = roomManager.getRoomByUserId(user.getUserId());//3.通过room对象来处理具体的请求room.putChess(message.getPayload());}@Overridepublic void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {User user=(User)session.getAttributes().get("user");if (user==null){return;//简单处理，断开的时候不给客户端返回响应}WebSocketSession exitSession= onlineUserManager.getFromGameRoom(user.getUserId());if (exitSession==session){//这里是为了避免在多开的情况下，第二个用户退出连接的动作onlineUserManager.exitGameRoom(user.getUserId());}System.out.println("当前用户"+user.getUsername()+"游戏房间连接异常");//通知对手获胜noticeThatUserWin(user);}@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {User user=(User)session.getAttributes().get("user");if (user==null){return;//简单处理，断开的时候不给客户端返回响应}WebSocketSession exitSession= onlineUserManager.getFromGameRoom(user.getUserId());if (exitSession==session){//这里是为了避免在多开的情况下，第二个用户退出连接的动作onlineUserManager.exitGameRoom(user.getUserId());}System.out.println("当前用户"+user.getUsername()+"离开游戏房间");noticeThatUserWin(user);}private void noticeThatUserWin(User user) throws IOException{//1、根据当前玩家，找到玩家所在的房间Room room=roomManager.getRoomByUserId(user.getUserId());if (room==null){//已经不存在，无对手System.out.println("当前房间不存在");return;}//2.根据房间找到对手User thatUser=(user==room.getUser1())? room.getUser2() : room.getUser1();//3.找到对手后，判断该对手的在线状态WebSocketSession webSocketSession=onlineUserManager.getFromGameRoom(thatUser.getUserId());if (webSocketSession==null){//两人均掉线System.out.println("无需判断胜负，均掉线");return;}//4.如果对手在线，那么构造一个响应来通知对手获胜GameResponse response=new GameResponse();response.setMessage("putChess");response.setUserId(thatUser.getUserId());response.setWinner(thatUser.getUserId());webSocketSession.sendMessage(new TextMessage(objectMapper.writeValueAsString(response)));//5.更新玩家的分数信息//这个方法本身就规定了thisUserId是失败方，那么thatUserId就是胜利者int winUserId=thatUser.getUserId();int loseUserId=user.getUserId();userMapper.userWin(winUserId);userMapper.userLose(loseUserId);//6.释放房间对象roomManager.remove(room.getRoomId(), room.getUser1().getUserId(),room.getUser2().getUserId());}}