Teleport 2.0 一个 Golang TCP Socket 的全新框架
发布于 2017-08-28 02:49:51 | 239 次阅读 | 评论: 0 | 来源: 网友投递
Teleport Golang高并发SocketAPI框架
Teleport是一款适用于分布式系统的高并发API框架，它采用socket全双工通信，实现S/C对等工作，支持长、短两种连接模式，支持断开后自动连接与手动断开连接，支持身份验证，内部数据传输格式为JSON。
Teleport2.0 实现了一个全新的Golang TCP Socket框架，它通用、高效、灵活！可被用于Peer-Peer对等通信、RPC、长连接网关、微服务、推送服务，游戏服务等领域。
1. 特性
-
服务器和客户端之间对等通信，两者API方法基本一致
-
底层通信数据包包含Header和Body两部分
-
支持单独定制Header和Body编码类型，例如JSON Protobuf
-
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
历史版本 :
Teleport 2.4 版本发布，先进的 SSH 服务器
Teleport v2.5发布，支持限制包大小与自定义包协议
Teleport 2.0 一个 Golang TCP Socket 的全新框架