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

news2024/11/19 3:35:47

前言

我最近一个月一直在寻找能够快速开发实时通讯的简单好用的模块,所以我就去寻找了一下相关的内容.在此之前我使用的是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导入依赖

 <!--t-io依赖-->
 <dependency>
     <groupId>org.t-io</groupId>
     <artifactId>tio-websocket-spring-boot-starter</artifactId>
     <version>3.6.0.v20200315-RELEASE</version>
 </dependency>

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 你可以不会，但你不能不知道
*/
@Component
public 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 你可以不会，但你不能不知道
*/
@Component
public 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 {}