前言
为什么说网上搜不到，因为对于聊天回合制的计划作者自己快把百度搜秃噜了也没找到，好在最终是公司一个关系不错的大佬帮提供了点思路，最终作者将其残缺实现了进去。
分享进去大家能够珍藏，万一你哪天也碰到这样的需要，可不就节俭大把工夫了吗。
场景
先说下我这边的场景，读过我文章的同好都晓得，我是做互联网医疗行业的，咱们的我的项目中是蕴含聊天性能的，咱们服务的对象次要是医院的医生，患者在网上找医生问诊时，往往会呈现不停问的状况。
医生目前惟一的做法是本人完结这个征询，或期待零碎主动完结，这就带来了一个问题，不论是零碎完结还是医生手动完结，患者都喜爱投诉和打差评，导致医生不敢擅自完结，问烦了又不好不回复，不回复也要被投诉。
最终聊天回合制这个需要就摆出来了，被动通知患者咱们的聊天是有回合的，所以你要一次问分明，回合数满了咱们不会再回复，如果患者硬要投诉，医生也能够说，这是做这个产品的公司本人设定的。
结下来就是，咱们要把锅端好。
实际上，聊天回合制的诞生，基本上都和这个场景的诉求相似，为了缩小用户频繁且无休止的征询。
思路
联合redis可能很好的实现聊天回合制，当然也能够间接通过数据库来实现，但显然redis操作更简略性能更优越。
总体思路如下：
1）、redis中存储两个key，一个是示意对象，申明为chat-who:consultId，value为对象标识，比方这里就是医生和患者，医生用D标识，患者用P标识；另一个key是示意回合数，申明为chat-num:consultId，value就是以后回合数。这里的consultId是动静的，示意这个征询的id，能够依据本人的业务来定；
2）、这两个key的过期工夫咱们都定为2天，具体过期工夫要依据本人业务规定来适配；
3）、咱们在特定的地位进行初始化，只有是进入聊天之前都能够，比方这里的场景，就是患者发动征询胜利后才开始聊天，咱们就在发动胜利后的办法中初始化聊天回合数为默认值6个回合，这个默认值还能够做成配置的模式进行动静读取的；
4）、咱们在发消息的办法中做一个判断，获取redis中的chat-who:consultId，看是否存在，存在就往下执行，不存在就阐明发的是第一条音讯，那就创立chat-who:consultId这个key到redis中，value为以后发消息人D或者P；
5）、承接4，如果chat-who存在，咱们持续将以后发消息的对象和redis的chat-who存储的对象值进行比拟，如果一样，则跳过不论，如果不一样，更新chat-who的值为以后发消息的人。同时，咱们判断以后发消息的人是不是医生也就是D，是D的话才更新回合数，执行-1操作，这样做的目标是把医生作为回合数更新的维度，维度只能有一个，这样能力保障回合数更新最精确。
实现
接下来，我应用伪代码把整个思路写进去。
1、定义redis-key
/** * 聊天回合制常量 */public final class ChatRoundConstants { /** * 聊天回合数key前缀 */ public static final String CHAT_NUM = "chat-num:"; /** * 聊天对象key前缀 */ public static final String CHAT_WHO = "chat-who:"; /** * redis-key过期工夫 */ public static final Long EXPIRE_TIME = 48 * 3600L; /** * 聊天对象value值，医生-D，患者-P。 */ public static final String DOCTOR = "D"; public static final String PATIENT = "P";}2、初始化聊天回合数
在聊天之前初始化，这里咱们我的项目的场景是患者发动征询胜利后，就在这个胜利后的办法中初始化。
/** * 发动征询胜利 */public void consultSuccess() { // ....其余业务逻辑解决 // 初始化聊天回合数 initChatRoundNum(ConsultDTO consultDTO);}/** * 初始化聊天回合数 * -- 过期工夫48小时 * @param consultDTO 征询信息 */private void initChatRoundNum(ConsultDTO consultDTO) { // 初始6回合 int chatNum = 6; // 获取系统配置的默认回合数，这里是伪代码依据本人须要编写。 ParameterDTO parameterDTO = getConfigValue(); if(!ObjectUtils.isEmpty(parameterDTO)) { chatNum = parameterDTO.getPvalue(); } // 初始化到redis，key是chat-num:consultId redisService.set(ChatRoundConstants.CHAT_NUM + consultDTO.getId(), chatNum, ChatRoundConstants.EXPIRE_TIME);}3、更新回合数
这里是外围逻辑，次要分为两步：初始化chat-who:consultId，更新chat-num:consultId。
/** * 发消息 */public void sendMsg() { // ....其余业务逻辑 // 更新聊天回合数 handleChatRoundNum(consultDTO, consultDetailInfoDTO);}/** * 解决聊天回合数 * @param consultDTO 征询信息 * @param consultDetailInfoDTO 聊天信息 */private void handleChatRoundNum(ConsultDTO consultDTO, ConsultDetailInfoDTO consultDetailInfoDTO) { // 获取redis保留的医生患者标识key String chatWhoKey = ChatRoundConstants.CHAT_WHO + consultDTO.getId(); // 获取以后发消息的人对应的标识 String current = ChatWhoEnum.getCodeById(consultDetailInfoDTO.getSource()); // chat-who:consultId是否存在 if(redisService.exists(chatWhoKey)) { String chatWhoValue = (String) redisService.get(chatWhoKey); // 判断以后发消息的人和chatWho的值是否雷同，如果不同，更新chatWho为以后发消息的人。 if(!Objects.equals(ChatWhoEnum.getIdByCode(chatWhoValue), consultDetailInfoDTO.getSource())) { // 更新chatWho为以后发消息的人 redisService.setRange(chatWhoKey, current, 0); // 判断以后发消息的人是否为D，是D的话才更新回合数。 if(Objects.equals(ChatWhoEnum.DOCTOR.getId(), consultDetailInfoDTO.getSource())) { // 更新chatNum-1 String chatNumKey = ChatRoundConstants.CHAT_NUM + consultDTO.getId(); int chatNumValue = Integer.parseInt( (String) redisService.get(chatNumKey) ); if(redisService.exists(chatNumKey) && chatNumValue > 0) { redisService.decr(chatNumKey); } } } } else { // 不存在阐明是第一条音讯，创立这个key。 redisService.set(chatWhoKey, current, ChatRoundConstants.EXPIRE_TIME); }}定义的发消息对象枚举
/** * 聊天对象起源的枚举类 */public enum ChatWhoEnum { // 起源 ： // 0 医生 // 1 患者 DOCTOR(0, "D", "医生"), PATIENT(1, "P", "患者"); private final int id; private final String code; private final String label; ChatWhoEnum(final int id, final String code, final String label) { this.id = id; this.code = code; this.label = label; } public int getId() { return id; } public String getCode() { return code; } public String getLabel() { return label; } public static String getCodeById(int id) { for(ChatWhoEnum type: ChatWhoEnum.values()) { if(type.getId() == id) { return type.getCode(); } } return null; } public static Integer getIdByCode(String code) { for(ChatWhoEnum type: ChatWhoEnum.values()) { if(code.equalsIgnoreCase(type.getCode())) { return type.getId(); } } return null; }}总结
其实写起来很简略，思路也不难，但突然间让你来实现这个小性能的话还是挺吃力的，理不分明就会始终卡在外面，理分明了霎时就念头通达。
这个性能目前曾经上线，并且运行稳固没有任何问题，感兴趣的能够珍藏起来，如果有一天做聊天相干业务的话，说不定就会遇到相似的需要。
自己原创文章纯手打，感觉有一滴滴帮忙就请点个赞和珍藏吧~
自己继续分享理论工作教训和支流技术，喜爱的话能够关注下哦~
更多最新技术文章可关注GZH：【Java分享客栈】