https://github.com/snow-seamless/mykob/tree/38bf415defbe0e320cd188d9c627078957420bb3

6.3 实现匹配系统微服务

项目流程

1. 改变项目结构

• 新建一个backendcloud，进行一些配置并添加spring-cloud依赖
• 新建模块matchingsystem，添加一些依赖
• 修改每个模块的端口
• 新建backend将之前项目的src拿过来，配置pom（与之前项目一样）

2. 编写matchingsystem模块后端

• 添加MatchingService的接口，用MatchingServiceImpl实现接口，再实现一个MatchingController
• 包括添加用户和删除用户
• Controller中的map要使用MultiValueMap
• 添加spring-security依赖进行权限控制，添加config.SecurityConfig类，只允许本地访问
• 将Main改为MatchingSystemApplication，并加注解@SpringBootApplication
• 使用SpringApplication.run(MatchingSystemApplication.class, args)运行

3. 将匹配系统和后端对接

• 将matchpool的所有操作放入matchingsystem
• 新建backend.config.filter.RestTemplate，添加注解@Bean，未来使用时直接Autowired即可，用来在matchingsystem和backend之间进行通信
• backend.consumer.WebSocketServer中向matchingsystem发送请求
  • 
  • matchingsystem中需要有controller和对应的url

4. matchingsystem中实现匹配（多线程）

• 思想：初始玩家只能匹配分差为0的对手，随时间推移，允许匹配的对手分差逐渐变大
• 创建matchingsystem.service.impl.utils.matchingpool，matchingsystem.service.impl.utils.Player
• matchingpool是多线程类，需要extends Thread，并重载run()
• 将所有用户存储起来：List<Player> players，多个线程共用，涉及读写冲突问题，需要加锁
• 实现addPlayer()和removePlayer()
  • 实现删除逻辑：枚举所有player，创建一个新List将没被删的存下来，赋给原始players
• 匹配逻辑
• 在MatchingPool的run()中，写一个死循环，每sleep一秒，将所有玩家的等待时间+1
• 再用matchPlayers()来匹配玩家，通过checkMatched()判断玩家是否满足配对条件，匹配成功后从匹配池中删除玩家
• 将匹配结果通过sendResult返回给backend
  • backend中需要写一个controller和对应Url来接收结果：StartGameController及对应的Service；记得放行接口
  • matchingsystem通过Restemplate发送匹配结果，需要在MatchingPool这个类上加@component，注入时要使用set方法注入
• 在MatchingServiceImpl中往matchpool添加或删除玩家
• 在MatchingSystemApplication中启动匹配线程，即在springboot启动时就启动匹配系统

5. 优化逻辑

当一名玩家在匹配时关闭页面，会报错

原因：玩家关闭页面没有从匹配池中将玩家删除，此时WebSocketServer中会得到一个空的玩家

因此在所有含有users.get(x.getId())的地方需要判空