SpringBoot整合Socket实战案例，实现单点群发，

　　作者：小目标青年
　　来源：https：blog。csdn。netqq35387940本篇内容：
　　后端前端简单HTML页面功能场景点：群发，所有人都能收到局部群发，部分人群都能收到单点推送，指定某个人的页面
　　惯例，先看看本次实战示例项目结构：
　　可以看到内容不多，也就是说，springboot整合socket，跟着我学，轻轻松松。
　　不多说，开始：pom引入核心依赖dependenciesdependencygroupIdcom。alibabagroupIdfastjsonartifactIdversion1。2。75versiondependencydependencygroupIdcom。corundumstudio。socketiogroupIdnettysocketioartifactIdversion1。7。7versiondependencydependencygroupIdorg。springframework。bootgroupIdspringbootstarterwebartifactIddependencydependencygroupIdorg。springframework。bootgroupIdspringbootstartertestartifactIdscopetestscopedependencydependenciesyml加上配置项server：port：8089socketio：host：localhostport：8503maxFramePayloadLength：1048576maxHttpContentLength：1048576bossCount：1workCount：100allowCustomRequests：trueupgradeTimeout：10000pingTimeout：60000pingInterval：25000创建socket配置加载类MySocketConfig。javaimportcom。corundumstudio。socketio。SocketConfig；importcom。corundumstudio。socketio。SocketIOServer；importcom。corundumstudio。socketio。annotation。SpringAnnotationScanner；importorg。springframework。beans。factory。annotation。Value；importorg。springframework。context。annotation。Bean；importorg。springframework。context。annotation。Configuration；Author：JCcccDescription：Date：2022061321：50ConfigurationpublicclassMySocketConfig｛Value（｛socketio。host｝）privateStringhost；Value（｛socketio。port｝）privateIntegerport；Value（｛socketio。bossCount｝）privateintbossCount；Value（｛socketio。workCount｝）privateintworkCount；Value（｛socketio。allowCustomRequests｝）privatebooleanallowCustomRequests；Value（｛socketio。upgradeTimeout｝）privateintupgradeTimeout；Value（｛socketio。pingTimeout｝）privateintpingTimeout；Value（｛socketio。pingInterval｝）privateintpingInterval；BeanpublicSocketIOServersocketIOServer（）｛SocketConfigsocketConfignewSocketConfig（）；socketConfig。setTcpNoDelay（true）；socketConfig。setSoLinger（0）；com。corundumstudio。socketio。Configurationconfignewcom。corundumstudio。socketio。Configuration（）；buildSocketConfig（socketConfig，config）；returnnewSocketIOServer（config）；｝扫描nettysocketIo的注解（OnConnect、OnEvent等）BeanpublicSpringAnnotationScannerspringAnnotationScanner（）｛returnnewSpringAnnotationScanner（socketIOServer（））；｝privatevoidbuildSocketConfig（SocketConfigsocketConfig，com。corundumstudio。socketio。Configurationconfig）｛config。setSocketConfig（socketConfig）；config。setHostname（host）；config。setPort（port）；config。setBossThreads（bossCount）；config。setWorkerThreads（workCount）；config。setAllowCustomRequests（allowCustomRequests）；config。setUpgradeTimeout（upgradeTimeout）；config。setPingTimeout（pingTimeout）；config。setPingInterval（pingInterval）；｝｝创建消息实体MyMessage。javaAuthor：JCcccDate：202207239：05Description：publicclassMyMessage｛privateStringtype；privateStringcontent；privateStringfrom；privateStringto；privateStringchannel；publicStringgetType（）｛returntype；｝publicvoidsetType（Stringtype）｛this。typetype；｝publicStringgetContent（）｛returncontent；｝publicvoidsetContent（Stringcontent）｛this。contentcontent；｝publicStringgetFrom（）｛returnfrom；｝publicvoidsetFrom（Stringfrom）｛this。fromfrom；｝publicStringgetTo（）｛returnto；｝publicvoidsetTo（Stringto）｛this。toto；｝publicStringgetChannel（）｛returnchannel；｝publicvoidsetChannel（Stringchannel）｛this。channelchannel；｝｝
　　代码简析：
　　创建sockethandler负责记录客户端连接、下线
　　MySocketHandler。javaimportcom。corundumstudio。socketio。SocketIOClient；importcom。corundumstudio。socketio。SocketIOServer；importcom。corundumstudio。socketio。annotation。OnConnect；importcom。corundumstudio。socketio。annotation。OnDisconnect；importcom。socket。mysocket。util。SocketUtil；importorg。springframework。beans。factory。annotation。Autowired；importjavax。annotation。PostConstruct；importjavax。annotation。PreDestroy；importorg。slf4j。Logger；importorg。slf4j。LoggerFactory；importorg。springframework。stereotype。Component；Author：JCcccDescription：Date：202262321：21ComponentpublicclassMySocketHandler｛privatefinalLoggerlogLoggerFactory。getLogger（this。getClass（））；AutowiredprivateSocketIOServersocketIoServer；PostConstructprivatevoidstart（）｛try｛socketIoServer。start（）；｝catch（Exceptione）｛e。printStackTrace（）；｝｝PreDestroyprivatevoiddestroy（）｛try｛socketIoServer。stop（）；｝catch（Exceptione）｛e。printStackTrace（）；｝｝OnConnectpublicvoidconnect（SocketIOClientclient）｛StringuserFlagclient。getHandshakeData（）。getSingleUrlParam（userFlag）；SocketUtil。connectMap。put（userFlag，client）；log。info（客户端userFlag：userFlag已连接）；｝OnDisconnectpublicvoidonDisconnect（SocketIOClientclient）｛StringuserFlagclient。getHandshakeData（）。getSingleUrlParam（userFlag）；log。info（客户端userFlag：userFlag断开连接）；SocketUtil。connectMap。remove（userFlag，client）；｝｝
　　代码简析：
　　封装的socket小函数
　　SocketUtil。javaimportcom。alibaba。fastjson。JSON；importcom。alibaba。fastjson。JSONObject；importcom。corundumstudio。socketio。AckRequest；importcom。corundumstudio。socketio。SocketIOClient；importcom。corundumstudio。socketio。annotation。OnEvent；importorg。slf4j。Logger；importorg。slf4j。LoggerFactory；importorg。springframework。beans。factory。annotation。Autowired；importorg。springframework。stereotype。Component；importorg。springframework。util。StringUtils；importjava。util。Map；importjava。util。Objects；importjava。util。concurrent。ConcurrentHashMap；importjava。util。concurrent。ConcurrentMap；Author：JCcccDescription：Date：202262321：28ComponentpublicclassSocketUtil｛privatefinalLoggerlogLoggerFactory。getLogger（this。getClass（））；暂且把用户客户端信息存在缓存publicstaticConcurrentMapString，SocketIOClientconnectMapnewConcurrentHashMap（）；OnEvent（valueCHANNELSYSTEM）publicvoidsystemDataListener（StringreceiveMsg）｛if（！StringUtils。hasLength（receiveMsg））｛return；｝JSONObjectmsgObject（JSONObject）JSON。parse（receiveMsg）；StringuserFlagString。valueOf（msgObject。get（from））；StringcontentString。valueOf（msgObject。get（content））；log。info（收到用户：｛｝推送到系统频道的一条消息：｛｝，userFlag，content）；｝publicvoidsendToAll（MapString，Objectmsg，StringsendChannel）｛if（connectMap。isEmpty（））｛return；｝给在这个频道的每个客户端发消息for（Map。EntryString，SocketIOCliententry：connectMap。entrySet（））｛entry。getValue（）。sendEvent（sendChannel，msg）；｝｝publicvoidsendToOne（StringuserFlag，MapString，Objectmsg，StringsendChannel）｛拿出某个客户端信息SocketIOClientsocketClientgetSocketClient（userFlag）；if（Objects。nonNull（socketClient））｛单独给他发消息socketClient。sendEvent（sendChannel，msg）；｝｝识别出客户端paramuserFlagreturnpublicSocketIOClientgetSocketClient（StringuserFlag）｛SocketIOClientclientnull；if（StringUtils。hasLength（userFlag）！connectMap。isEmpty（））｛for（Stringkey：connectMap。keySet（））｛if（userFlag。equals（key））｛clientconnectMap。get（key）；｝｝｝returnclient；｝｝
　　代码简析：
　　写1个接口，模拟场景，前端页面调用后端接口，做消息推送
　　TestController。javaimportcom。socket。mysocket。dto。MyMessage；importcom。socket。mysocket。util。SocketUtil；importorg。springframework。beans。factory。annotation。Autowired；importorg。springframework。web。bind。annotation。；importjava。util。HashMap；importjava。util。Map；Author：JCcccDescription：Date：2022061321：50RestControllerpublicclassTestController｛publicfinalstaticStringSENDTYPEALLALL；publicfinalstaticStringSENDTYPEALONEALONE；AutowiredSocketUtilsocketUtil；PostMapping（testSendMsg）publicStringtestSendMsg（RequestBodyMyMessagemyMessage）｛MapString，ObjectmapnewHashMap（）；map。put（msg，myMessage。getContent（））；群发if（SENDTYPEALL。equals（myMessage。getType（）））｛socketUtil。sendToAll（map，myMessage。getChannel（））；returnsuccess；｝指定单人if（SENDTYPEALONE。equals（myMessage。getType（）））｛socketUtil。sendToOne（myMessage。getTo（），map，myMessage。getChannel（））；returnsuccess；｝returnfail；｝｝
　　代码简析：
　　好了，7步了。一切已经就绪了。前端简单页面
　　接下来搞点前端HTML页面，玩一玩看看效果：
　　第一个页面：
　　TestClientStudentJC。html！DOCTYPEhtmlhtmlheadmetahttpequivContentTypecontenttexthtml；charsetutf8title我要连SOCKETtitlebasestylebody｛padding：20px；｝console｛height：450px；overflow：auto；｝。msgcolor｛color：green；｝styleheadbodylabal给系统推消息labalinputtypetextidcontentbuttonidbtnSendToSystemonclicksendSys（）；发送buttonbodyhtml
　　代码简析：
　　第二个页面，跟第一个基本一样，改一下用户唯一标识：
　　TestClientStudentPU。html！DOCTYPEhtmlhtmlheadmetahttpequivContentTypecontenttexthtml；charsetutf8title我要连SOCKETtitlebasestylebody｛padding：20px；｝console｛height：450px；overflow：auto；｝。msgcolor｛color：green；｝styleheadbodylabal给系统推消息labalinputtypetextidcontentbuttonidbtnSendToSystemonclicksendSys（）；发送buttonbodyhtml
　　OK，把项目跑起来，开始玩。
　　直接访问客户端页面模拟学生JC连接socket：
　　http：127。0。0。1：8089TestClientStudentJC。html
　　可以看到服务端有监测到：
　　这里监测的：
　　先试试客户端给系统推消息先：
　　可以看到服务端成功收到消息：
　　这种方式，其实是因为服务监听了相关的频道：
　　前端使用JS推到这个系统频道：
　　ps：其实前端给服务端推消息，其实调用接口就可以。
　　OK，进入核心应用场景1：群发，所有人都能收到
　　系统给连上的客户端都推送消息
　　｛type：ALL，content：你们好，这是一条广播消息，全部人都能收到，channel：CHANNELSYSTEM｝
　　看看效果：
　　然后是场景2，局部群发，部分人群都能收到
　　其实也就是通过HTML客户端监听主题做区分就好：
　　直接拉人口，升3：
　　模拟2个学生，1个老师都连接上了socket
　　当然，老师监听的是老师频道：
　　然后我们模拟推送一下消息到指定的老师频道：
　　｛
　　type：ALL，
　　content：给老师们推一条消息！！！，
　　channel：CHANNELTEACHER
　　｝
　　最后一个场景，也就是单点推送，指定某个人收到
　　模拟学生PU给学生JC推消息：
　　可以看到在学生频道的JC正常收到了PU的消息：
　　好了，该篇就到这吧。