Teleport2.0 实现了一个全新的Golang TCP Socket框架，它通用、高效、灵活！可被用于Peer-Peer对等通信、RPC、长连接网关、微服务、推送服务，游戏服务等领域。
1. 特性
- 服务器和客户端之间对等通信，两者API方法基本一致
- 底层通信数据包包含
Header和Body两部分 - 支持单独定制
Header和Body编码类型，例如JSONProtobuf -
Body支持gzip压缩 -
Header包含状态码及其描述文本 - 支持推、拉、回复等通信模式
- 支持插件机制，可以自定义认证、心跳、微服务注册中心、统计信息插件等
- 无论服务器或客户端，均支持都优雅重启、优雅关闭
- 支持实现反向代理功能
- 日志信息详尽，支持打印输入、输出消息的详细信息（状态码、消息头、消息体）
- 支持设置慢操作报警阈值
- 底层连接使用I/O缓冲区
- 端点间通信使用I/O多路复用技术
teleport-server-peer
AB Testing 1: [Mac 4CPU 8GB] [single-process single-conn] teleport: QPS 37550
AB Testing 2: [Mac 4CPU 8GB] [single-process single-conn] teleport/socket: QPS 55419
2. 架构
2.1 名称解释
- Peer：通信端点，可以是客户端或客户端
- Session：连接会话，具有推、拉、回复、关闭等操作
- Context：处理收到的或发送的数据包
- Pull-Launch：从对端Peer拉数据
- Pull-Handle：处理和回复对端Peer的拉请求
- Push-Launch：将数据推送到对端Peer
- Push-Handle：处理同伴的推送
- Router：Handler注册路由
2.2 执行层次
Peer -> Connection -> Socket -> Session -> Context
2.3 数据包
HeaderLength | HeaderCodecId | Header | BodyLength | BodyCodecId | Body
注意：
- HeaderLength: uint32, 4 bytes, big endian
- BodyLength: uint32, 4 bytes, big endian
- HeaderCodecId: uint8, 1 byte
- BodyCodecId: uint8, 1 byte
type Packet struct {
// HeaderCodec header codec name
HeaderCodec string `json:"header_codec"`
// BodyCodec body codec name
BodyCodec string `json:"body_codec"`
// header content
Header *Header `json:"header"`
// body content
Body interface{} `json:"body"`
// header length
HeaderLength int64 `json:"header_length"`
// body length
BodyLength int64 `json:"body_length"`
// HeaderLength + BodyLength
Length int64 `json:"length"`
}
2.4 头信息
type Header struct {
// Packet id
Id string
// Service type
Type int32
// Service URI
Uri string
// Body encoding type
Gzip int32
// As reply, it indicates the service status code
StatusCode int32
// As reply, it indicates the service status text
Status string
}
3. 开源项目
项目地址：https://github.com/henrylee2cn/teleport
授权协议：Apache2.0
