开源中国

我们不支持 IE 10 及以下版本浏览器

It appears you’re using an unsupported browser

为了获得更好的浏览体验,我们强烈建议您使用较新版本的 Chrome、 Firefox、 Safari 等,或者升级到最新版本的IE浏览器。 如果您使用的是 IE 11 或以上版本,请关闭“兼容性视图”。
t-io首页、文档和下载 - 让网络编程更轻松和有趣 - 开源中国社区
全部项目分类
Apache
Java
跨平台
talent-tan
分享
收藏
1865 人收藏
收录时间:2017-03-31
t-io 详细介绍

t-io: 让天下没有难开发的网络编程

旧时王谢堂前燕,飞入寻常百姓家----当年那些王谢贵族们才拥有的"百万级即时通讯"应用,将因为t-io的诞生,纷纷飞入普通人家的屋檐下。

t-io是啥

  • 大家口中的t-io一般是指tio-core,它是基于java aio的网络编程框架,和netty属于同类

  • 基于tio-core来开发IMTCP私有协议RPC游戏服务器端推送服务实时监控物联网将会变得空前的简单

  • t-io家族除了tio-core外,还有tio-websocket-server、tio-http-server、tio-webpack-core、tio-flash-policy-server等,后面所列都是基于tio-core开发的应用层组件

  • 列一下t-io家族成员:

    • tio-core:基于java aio的网络编程框架。使用示例:tio-showcase

    • tio-websocket-server:基于tio-core开发的websocket服务器。使用示例:tio-websocket-showcase

    • tio-http-server:基于tio-core开发的http服务器。使用示例:tio-http-server-showcase

    • tio-webpack-core:基于tio-core开发的js/css/html编译压缩工具,代码已经开源,但尚无使用文档和示例,暂时属于内用阶段,使用案例:http://www.nb350.com

    • tio-flash-policy-server:基于tio-core开发的flash-policy-server,代码已经开源,但尚无使用文档和示例

  • 列一下tio-core应用场景的一些案例

tio-core提供了哪些功能

  • 内置对半包和粘包的处理:源码分析见:https://my.oschina.net/talenttan/blog/1610690

  • ChannelContext资源维护:会话资源维护是个工程量大,复杂度高的活,尤其是涉及到各种资源绑定、解绑、遍历时,极易出错和OOM,不过这些复杂的事件tio-core全部给你做好了,除非你要自己额外去绑定资源

  • 心跳检测(防止不良客户端占着TCP连接无所事事)

  • 心跳发送(client)

  • 断链重连(client)

  • 流量监控统计,既提供单条ChannelContext流量统计,又提供所有ChannelContext流量统计,下面所列为部分监控数据,详情请见:ChannelStat.javaGroupStat.java

    • 已接收的字节数

    • 已接收了多少次TCP数据包

    • 已接收的packet数

    • 已处理的字节数

    • 已处理的packet数

    • 处理消息包耗时,单位:毫秒。拿这个值除以handledPackets,就是处理每个消息包的平均耗时

    • 已发送的字节数

    • 已发送的packet数

    • 最近一次收到业务消息包的时间(一个完整的业务消息包,一部分消息不算)

    • 最近一次发送业务消息包的时间(一个完整的业务消息包,一部分消息不算)

    • 最近一次收到业务消息包的时间:收到字节就算

    • 最近一次发送业务消息包的时间:发送字节就算

    • 第一次连接成功的时间

    • 进入重连队列时间

  • userid绑定(将ChannelContext和业务中的userid绑定,并提供查询、发送、解绑等API供业务端使用,一个userid可以绑定多个ChannelContext)

    • org.tio.core.Tio.bindUser(ChannelContext channelContext, String userid):将ChannelContext和userid绑定

    • org.tio.core.Tio.sendToUser(GroupContext groupContext, String userid, Packet packet):基于userid异步发送消息

    • org.tio.core.Tio.bSendToUser(GroupContext groupContext, String userid, Packet packet):基于userid阻塞发送消息

    • org.tio.core.Tio.getChannelContextsByUserid(GroupContext groupContext, String userid):通过userid获取ChannelContext

    • org.tio.core.Tio.unbindUser(GroupContext groupContext, String userid):解绑指定的userid

    • org.tio.core.Tio.unbindUser(ChannelContext channelContext):解绑所有的userid

  • token绑定(将ChannelContext和业务中的token绑定,并提供查询、发送、解绑等API供业务端使用,一个token可以绑定多个ChannelContext)

    • 方法基本同userid绑定,不一一列举

  • group绑定(将ChannelContext和群组绑定,并提供查询、发送、解绑等API供业务端使用,一个group可以绑定多个ChannelContext,如果你有IM群聊场景,这个功能会大大减少你的业务端代码)

    • 方法基本同userid绑定,不一一列举

  • bsId绑定(将ChannelContext和业务id绑定,并提供查询、发送、解绑等API供业务端使用,一个bsId只能绑定一个ChannelContext)

    • 方法基本同userid绑定,不一一列举

  • 框架内置自动和ip绑定(将ChannelContext和对端ip绑定,并提供查询、发送等API供业务端使用)

    • org.tio.core.Tio.sendToIp(GroupContext groupContext, String ip, Packet packet, ChannelContextFilter channelContextFilter)

    • org.tio.core.Tio.sendToIp(GroupContext groupContext, String ip, Packet packet)

    • org.tio.core.Tio.bSendToIp(GroupContext groupContext, String ip, Packet packet, ChannelContextFilter channelContextFilter)

    • org.tio.core.Tio.bSendToIp(GroupContext groupContext, String ip, Packet packet)

  • 框架内置自动和ip:port绑定(将ChannelContext和对端ip:port绑定,并提供查询、发送等API供业务端使用)

    • org.tio.core.Tio.send(GroupContext groupContext, String ip, int port, Packet packet)

    • org.tio.core.Tio.bSend(GroupContext groupContext, String ip, int port, Packet packet)

  • 框架内置自动和唯一uuid绑定(将ChannelContext和对端uuid绑定,并提供查询、发送等API供业务端使用)

    • org.tio.core.Tio.sendToId(GroupContext groupContext, String channelId, Packet packet)

    • org.tio.core.Tio.bSendToId(GroupContext groupContext, String channelId, Packet packet)

  • 提供IP拉黑功能

    • org.tio.core.Tio.IpBlacklist.add(GroupContext groupContext, String ip):把指定ip拉黑

    • org.tio.core.Tio.IpBlacklist.remove(GroupContext groupContext, String ip):从黑名单中移除

    • org.tio.core.Tio.IpBlacklist.isInBlacklist(GroupContext groupContext, String ip):是否在黑名单中

    • org.tio.core.Tio.IpBlacklist.clear(GroupContext groupContext):清除黑名单

  • 提供了分页查询会话功能

    • Page org.tio.core.Tio.getPageOfAll(GroupContext groupContext, Integer pageIndex, Integer pageSize)

    • Page org.tio.core.Tio.getPageOfAll(GroupContext groupContext, Integer pageIndex, Integer pageSize, Converter converter)

    • Page org.tio.core.Tio.getPageOfGroup(GroupContext groupContext, String group, Integer pageIndex, Integer pageSize

    • Page org.tio.core.Tio.getPageOfGroup(GroupContext groupContext, String group, Integer pageIndex, Integer pageSize, Converter converter)

  • 异步发送能力(把packet丢到队列即返回)

    • Tio.java中以send开头的方法,譬如sendToAll()、sendToUser()、sendToGroup()等

  • 阻塞发送能力(确认把packet发送到对端后再返回)

    • Tio.java中以bSend开头的方法,譬如bSendToAll()、bSendToUser()、bSendToGroup()等

  • 同步发送能力(相当于act机制,需要业务端配合设置synSeq才能完成此功能)

    • org.tio.core.Tio.synSend(ChannelContext channelContext, Packet packet, long timeout)

  • 基于t-io已经实现了tio-http-server

  • 基于t-io已经实现了tio-websocket-server

  • 基于t-io已经实现了IM能力

  • 提供UDP能力

  • 内置SSL能力,业务层只需要添加一行:https://my.oschina.net/talenttan/blog/1587197

    • groupContext.useSsl("/cert/xxx.jks", "/cert/xxx.jks", "******");

  • 内置集群能力,这里也有一篇关于tio集群的文章,可以参考:https://my.oschina.net/zyw205/blog/1827495

    • org.tio.core.GroupContext.setTioClusterConfig(TioClusterConfig tioClusterConfig)

  • 内置群组成员排序能力,一般用在直播间成员排序显示、IM群组排序显示等需要排序的场景

    • groupContext.groups.setChannelContextComparator(Comparator channelContextComparator)

t-io性能

t-io生态

引入t-io

  • 如果你只是想用tio-core,只需引入

dependency>groupId>org.t-iogroupId>artifactId>tio-coreartifactId>version>3.0.6.v20180626-RELEASEversion>dependency>
  • 如果你想用tio-websocket-server,只需引入

dependency>groupId>org.t-iogroupId>artifactId>tio-websocket-serverartifactId>version>3.0.6.v20180626-RELEASEversion>dependency>
  • 如果你想用tio-http-server,只需引入

dependency>groupId>org.t-iogroupId>artifactId>tio-http-serverartifactId>version>3.0.6.v20180626-RELEASEversion>dependency>

用于学习t-io各组件的showcase工程

t-io番外

学习tio-core的步骤

  • 熟练掌握ByteBuffer的使用,这是所有基于aio/nio编程的必修课程,这个懒没人躲得掉

  • 下载tio-core示范程序:tio-showcase

  • 导入到eclipse或其它ide中

  • 对照helloworld例子和t-io的hello world走一遍

  • 下载t-io源代码:t-io

  • 简单地扫一下:org.tio.core.ChannelContext.java

  • 简单地扫一下:org.tio.core.GroupContext.java

  • 简单地扫一下:org.tio.core.Tio.java

  • 最好要掌握org.tio.utils.lock.ObjWithLock及其子类(因为多线程环境下,对集合的遍历、元素删除、元素添加等操作必须是线程安全的)

  • 我的个人博客可以关注一下,上面有不少t-io的文章:三流程序员的博客

  • 忠告:tio-core已经封装了大量网络开发细节,如果你连上面的步骤都不愿意走一遍,建议你还是继续你的CRUD编程。

t-io推荐

t-io

选择将代码托管在码云
你还在等什么

可能是中国最大最好的代码托管平台


大家对 t-io 的评论 (全部 135 条评论)
{{repayCom.userName}}
精灵007
这个框架就是很好入门,又稳定,我这用在短连接,一天的请求量是5千万到1亿笔,跑了这么久都好好的.当时上线时我们架构师还怀疑,下面是当时与我们架构师对话.

陈庆国 2017/3/14 11:30:34
感觉这个api要完,用了nio吗
kleen
感谢谭总,解决我们硬件(C语言)与t-io通讯协议问题;之前使用netty做服务端,遇到的各种坑,不能自动重连,没有心跳处理,硬着头皮写了一个,各种超时、不稳定、异常; 一怒一下抱着试试t-io的心态,才发觉t-io 让我们的项目的讯通问题变得如此简单,只需要更多关注业务上的处理;由于t-io 太简单,我都可以放手让几个刚毕业同事进行业务上的处理;
1.使用t-io 心得, 把通讯协议编解码搞定 也就是 decode,encode 这两个方法写一下,其他就如使用spirngmvc 一样简单暴力.
talent-tan
#t-io#有人要帮t-io出教程了,而且是开源中国认证过的权威人士,他看了下t-io的代码,用了两个词形容----风骚。。。跟昨天的“码云骚起来”遥相呼应。
小徐同学
感谢谭总,现在我一个用上t-io框架的智能家居项目已正式上线,稳定可靠,接下来再上另一个项目。
轨迹_
tio是开源中国目前最让我热衷、着迷、痴狂的项目,而且性能强悍的吓人!会一直挺下去,强烈支持谭总!加油...tio
t-io 相关博客
顶部