tio-websocket-spring-boot-starter的最简单实例,看完你一定有所收获

前言

���最近一个月一直在寻找能够快速开发实时通讯的简单好用的模块,所以我就去寻找了一下相关的内容.在此之前我使用的是Spring原生的webSocket,她有个弊端就是设置组不容易设置,而且配置上也稍微复杂一点,需要配置拦截器和处理器,还需要把它放入到Springboot的启动容器里面,也有个好处就是,服务端口是单服务的,而且定制性强,就是很多东西都需要自己来主动配置,让我头疼的就是组的配置

在此之后我就去找寻能让我写的代码最少,而且还易用的服务,就发现了TIO,下面先看一下简介

TIO

极致打磨的底层集群能力，可无缝解决IM、物联网等大型产品的集群需求

易学易用，让刚毕业的大学生也能轻易驾驭

全方位开箱即用的监控能力

实战中仍表现出卓越的性能，不用实验室数据忽悠智慧的大众

内置协议适配能力，让多协议接入不再难

内置ack消息能力，让RPC等场景轻松实现

自创同步锁、同步安全线程池、同步数据结构等工具库，为业务应用提供丰富的开箱即用API

内置半包粘包处理

丰富的生态，目前已经用t-io实现了http、websocket、mqtt及大量私有协议

内置慢攻击防御机制，帮助应用自动拉黑嫌疑IP

看了上面的话,大概意思就是,简单易学,而且是国人开发的,内部有自动处理半包和粘包处理机制,无需再重新处理粘包,接下来就是Tio的具体配置代码

正文

但是今天我们要用的并不是tio-websocket-server而是另外一个更加简单的服务,不过这个已经在2020年停止更新了,好像是最后一版java1.8版本的,我看了Tio最新版都是用java17的了,如果还在用java1.8的兄弟们可以使用这个依赖tio-websocket-spring-boot-starter,下面是依赖的完整展示

1.POM导入依赖

       org.t-io     tio-websocket-spring-boot-starter     3.6.0.v20200315-RELEASE 

2.YML配置文件中放入以下配置

# Tio 配置信息tio: websocket:   server:     port: 9876     #心跳超时时间     heartbeat-timeout: 60000     #是否支持集群，集群开启需要redis   cluster:     enabled: false   redis:     ip: localhost     port: 6379

3.启动类加入注解

注解:@EnableTioWebSocketServer

4.创建处理器

package com.xssq.handler;import com.xssq.service.ApiService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import org.tio.core.ChannelContext;import org.tio.core.Tio;import org.tio.http.common.HttpRequest;import org.tio.http.common.HttpResponse;import org.tio.websocket.common.WsRequest;import org.tio.websocket.server.handler.IWsMsgHandler;/*** tio网络套接字味精处理程序** @author xssq* @version 1.0.0* @date 2023/09/26* @wisdom 你可以不会，但你不能不知道*/@Componentpublic class TioWebSocketMsgHandler implements IWsMsgHandler {   @Autowired   private ApiService apiService;   /**    * 握手    *    * @param httpRequest    http请求    * @param httpResponse   http响应    * @param channelContext 渠道上下文    * @return {@link HttpResponse}    */   @Override   public HttpResponse handshake(HttpRequest httpRequest, HttpResponse httpResponse, ChannelContext channelContext) {       String token = httpRequest.getParam("token");       channelContext.setToken(token);       Tio.bindGroup(channelContext, "1");       Tio.bindUser(channelContext, "1");       System.out.println("handshake握手方法");       return httpResponse;   }   /**    * 握手后打开    *    * @param httpRequest    http请求    * @param httpResponse   http响应    * @param channelContext 渠道上下文    */   @Override   public void onAfterHandshaked(HttpRequest httpRequest, HttpResponse httpResponse, ChannelContext channelContext) {       System.out.println("onAfterHandshaked握手后打开的");   }   /**    * 在字节上    *    * @param wsRequest      ws请求    * @param bytes          字节    * @param channelContext 渠道上下文    * @return {@link Object}    */   @Override   public Object onBytes(WsRequest wsRequest, byte[] bytes, ChannelContext channelContext) {       System.out.println("onBytes方法");       return null;   }   /**    * 关闭    *    * @param wsRequest      ws请求    * @param bytes          字节    * @param channelContext 渠道上下文    * @return {@link Object}    */   @Override   public Object onClose(WsRequest wsRequest, byte[] bytes, ChannelContext channelContext) {       System.out.println("onClose关闭方法");       return null;   }   /**    * 在文本上    *    * @param wsRequest      ws请求    * @param channelContext 渠道上下文    * @param message        信息    * @return {@link Object}    */   @Override   public Object onText(WsRequest wsRequest, String message, ChannelContext channelContext) {       if ("心跳包".equals(message)) {           return null;       }       apiService.sendMsg(channelContext, message);       return null;   }}

5.创建监听器

package com.xssq.listener;import org.springframework.stereotype.Component;import org.tio.core.ChannelContext;import org.tio.core.intf.GroupListener;/*** spring boot组侦听器** @author xssq* @version 1.0.0* @date 2023/10/05* @wisdom 你可以不会，但你不能不知道*/@Componentpublic class SpringBootGroupListener implements GroupListener {   /**    * 绑定后打开    *    * @param channelContext 信道上下文    * @param s              s    */   @Override   public void onAfterBind(ChannelContext channelContext, String s) {       System.out.println("绑定后打开");   }   /**    * 在解除绑定后打开    *    * @param channelContext 信道上下文    * @param s              s    */   @Override   public void onAfterUnbind(ChannelContext channelContext, String s) {       System.out.println("在解除绑定后打开");   }}

6.到此整个教程也就结束了,其实那个监听器也可以不要,不过用于方便绑定组下面是一些绑定组的语法

/*绑定组*/Tio.bindGroup(channelContext, "1");/*绑定userId*/Tio.bindUser(channelContext, "1");.........

其实还有很多绑定的,还有绑定业务方法,绑定token的,很多,下面是一些服务说明

//最主要的逻辑处理类，必须要写，否则 抛异常public class MyWebSocketMsgHandler  implements IWsMsgHandler {}//可不写public class SpringBootAioListener extends WsServerAioListener {}//可不写public class SpringBootGroupListener implements GroupListener {}//可不写public class SpringBootIpStatListener implements IpStatListener {}

后记

操作完上面的内容就可以正常使用了,感谢大家观看

如果我的博客帮助到了您,您可以到我的博客https://blog.csdn.net/weixin_57228276或者微信公众号搜索幸识SQ,在那里可以找到我,里面也有更多的优秀文章