共计 3401 个字符,预计需要花费 9 分钟才能阅读完成。
Tio.java 简介
- 为了让用户缩小查找 API 的工夫,t-io 把罕用 API 以静态方法的模式会集于一个类,这就是 Tio.java
- Tio.java 自身并不实现过简单的业务,各业务实现依然散布在其它类中,Tio.java 只是把用户关怀的 API 集中起来,便于用 IDE 查找而已
- 具体请参考:https://www.tiocloud.com/doc/tio/245
业务数据绑定
- 资源绑定是指把业务相干的数据和 Tcp 连贯(即 ChannelContext)关联起来,譬如 ChannelContext- A 代表了用户张三,张三的 userid 是 333,就用上面的代码进行绑定
Tio.bindUser(ChannelContext-A, "333")
-
t-io 目前内置了 4 种资源绑定,当然用户能够灵便应用这些绑定从而解决业务层所有的资源绑定问题,譬如能够给 group 加前缀”ios-“,从而标记这个用户应用的是 ios,譬如
Tio.bindGroup(ChannelContext-A, "333"); Tio.bindGroup(ChannelContext-A, "ios-" + "333");
- 内置的 4 种资源绑定办法中,一个 ChannelContext 是能够绑定到多个 groupid 的,其它三个绑定都是一对一或多对一的关系,也就是说一个 ChannelContext 能够同时属于 group-a,group-b… …group-n
-
上面贴一下这 4 个资源绑定的源代码
/** * 绑定业务 id * @param channelContext * @param bsId * @author tanyaowu */ public static void bindBsId(ChannelContext channelContext, String bsId) {channelContext.tioConfig.bsIds.bind(channelContext, bsId); } /** * 绑定群组 * @param channelContext * @param group * @author tanyaowu */ public static void bindGroup(ChannelContext channelContext, String group) {channelContext.tioConfig.groups.bind(group, channelContext); } /** * 绑定 token * @param channelContext * @param token * @author tanyaowu */ public static void bindToken(ChannelContext channelContext, String token) {channelContext.tioConfig.tokens.bind(token, channelContext); } /** * 绑定用户 * @param channelContext * @param userid * @author tanyaowu */ public static void bindUser(ChannelContext channelContext, String userid) {channelContext.tioConfig.users.bind(userid, channelContext); }
业务数据解绑
-
既然有绑定,就必定会有解绑,这是个和绑定相同的操作,所以话不多说,间接贴出不长的源代码
/** * 解绑业务 id * @param channelContext * @author tanyaowu */ public static void unbindBsId(ChannelContext channelContext) {channelContext.tioConfig.bsIds.unbind(channelContext); } /** * 与所有组解除解绑关系 * @param channelContext * @author tanyaowu */ public static void unbindGroup(ChannelContext channelContext) {channelContext.tioConfig.groups.unbind(channelContext); } /** * 与指定组解除绑定关系 * @param group * @param channelContext * @author tanyaowu */ public static void unbindGroup(String group, ChannelContext channelContext) {channelContext.tioConfig.groups.unbind(group, channelContext); } /** * 解除 channelContext 绑定的 token * @param channelContext * @author tanyaowu */ public static void unbindToken(ChannelContext channelContext) {channelContext.tioConfig.tokens.unbind(channelContext); } // org.tio.core.TioConfig.ipBlacklist /** * 解除 channelContext 绑定的 userid * @param channelContext * @author tanyaowu */ public static void unbindUser(ChannelContext channelContext) {channelContext.tioConfig.users.unbind(channelContext); } /** * 解除 userid 的绑定。个别用于多地登录,踢掉后面登录的场景 * @param tioConfig * @param userid * @author: tanyaowu */ public static void unbindUser(TioConfig tioConfig, String userid) {tioConfig.users.unbind(tioConfig, userid); }
异步发送
- 异步发送,指的是业务层把 Packet 丢给 t -io 后立刻返回,返回时 Packet 并没有被发送,而只是提交到了待发送队列
- 异步发送都是以 send 结尾的,这个 API 有点多,贴代码有点长,用图片展现更舒服些
阻塞发送 - 阻塞发送:t-io 把 Packet 送给对方后才返回
- 阻塞发送都是以 bSend 结尾的,这个 API 有点多,贴代码有点长,用图片展现更舒服些
如何获取 ChannelContext - 后面的业务数据绑定,一个重要的目标就是要依据那些业务标识来获取 ChannelContext,譬如你绑定了一个 userid,那么前面就能够通过这个 userid 来获取 ChannelContext
- 获取 ChannelContext 的 API 都是以 get 结尾的,这个 API 有点多,贴代码有点长,用图片展现更舒服些
断开连接和移除连贯 - 断开连接都是以 close 结尾的办法,指的是把以后曾经连上的 TCP 连贯断开掉
- 移除连贯都是以 remove 结尾的办法,指的是彻底摈弃这个连贯
留神 - 如果是用 t -io 做 TCP 服务器端
下面两个办法是等价的,因为服务器不存在重连一说 - 如果是用 t -io 做 TCP 客户端,并且没有配置重连
下面两个办法也是等价的,因为不须要重连,tio 断开连接后就会开释该连贯全副资源 - 如果是用 t -io 做 TCP 客户端,并且配置了重连规定,下面两个办法才是有区别的,区别如下
close():不开释相干资源,并且会进行重连
remove():齐全开释相干资源,不再进行重连
集群告诉 - t-io 是内置集群性能的,作为与业务不相干的 io 框架,内置集群性能是件费劲却不见得讨好的事(为啥不讨好?譬如会减少代码复杂度、会升高 tio-mvc 在 TFB 上的跑分排名),但 t -io 思考到宽广用户的呼声,还是内置了集群性能
- 目前 t -io 提供的音讯发送性能,都是反对集群的,这个从 Tio.java 的源代码中就能看进去
- 集群告诉类 API 都是以 notifyCluster 结尾的,见图
t-io 拉黑 IP -
简略到极致,只须要一行代码
Tio.IpBlacklist.add(tioConfig, channelContext.getClientNode().getIp());
正文完