void

matchQueueList.get(index);//对操作的队列加锁保证线程安全synchronized

(queue)

{queue.offer(user);queue.notify();}System.out.println(用户

user.getUsername()

matchQueueList.get(index);synchronized

(queue)

{queue.remove(user);}System.out.println(把用户

user.getUsername()

handleTextMessage(WebSocketSession

session,

session.getAttributes().get(user);MatchRequest

request

objectMapper.readValue(message.getPayload(),

MatchRequest.class);MatchResponse

response

MatchResponse();if(request.getMessage().equals(startMatch))

{//开始匹配把用户加入匹配队列matcher.add(user);response.setOk(true);response.setMessage(startMatch);}else

if(request.getMessage().equals(stopMatch))

{//取消匹配从匹配队列中移除用户matcher.remove(user);response.setOk(true);response.setMessage(stopMatch);}else{response.setOk(false);response.setErrMsg(非法请求);}//返回响应session.sendMessage(new

TextMessage(objectMapper.writeValueAsString(response)));}

由于存在在匹配中途断开连接的情况所有我们还要在断开连接代码中增加退出队列的代码进行

void

handleTransportError(WebSocketSession

session,

(User)session.getAttributes().get(user);//防止重复登录时删除正常登录的在线信息if(onlineUser.getFromHall(user.getId()).equals(session))

{onlineUser.exitGameHall(user.getId());System.out.println(用户

user.getUsername()

已下线);}//用户可能还在匹配队列中matcher.remove(user);}catch

{e.printStackTrace();MatchResponse

response

MatchResponse();response.setOk(false);response.setErrMsg(用户未登录);session.sendMessage(new

TextMessage(objectMapper.writeValueAsString(response)));}}//连接正常断开后执行Overridepublic

void

afterConnectionClosed(WebSocketSession

session,

(User)session.getAttributes().get(user);//防止重复登录时删除正常登录的在线信息if(onlineUser.getFromHall(user.getId()).equals(session))

{onlineUser.exitGameHall(user.getId());System.out.println(用户

user.getUsername()

已下线);}//用户可能还在匹配队列中matcher.remove(user);}catch

{e.printStackTrace();MatchResponse

response

MatchResponse();response.setOk(false);response.setErrMsg(用户未登录);session.sendMessage(new

TextMessage(objectMapper.writeValueAsString(response)));}}

实现匹配功能

我们为每个匹配队列创建一个线程用来实现匹配功能我们在构造方法中创建线程

public

LinkedList());}//每个队列创建一个线程扫描完成匹配功能for(QueueUser

matchQueueList)

{//调用handlerMatch()完成匹配功能handlerMatch(q);}});}}

3.2

{//1.检测队列中是否有两个元素while(matchQueue.size()

{matchQueue.wait();}//2.从队列中取出两个玩家User

user1

matchQueue.poll();//3.获取到两个玩家的会话信息WebSocketSession

session1

onlineUserManager.getFromHall(user1.getId());WebSocketSession

session2

onlineUserManager.getFromHall(user2.getId());//4.todo

把两个玩家放到一个游戏房间中//5.给用户返回匹配成功的响应MatchResponse

response

MatchResponse();response.setOk(true);response.setMessage(success);String

json

objectMapper.writeValueAsString(response);session1.sendMessage(new

TextMessage(json));session2.sendMessage(new

(IOException