Teleport 2.0 一个 Golang TCP Socket 的全新框架

栏目: 软件资讯 · 发布时间: 6年前

内容简介:Teleport2.0 实现了一个全新的Golang TCP Socket框架,它通用、高效、灵活!可被用于Peer-Peer对等通信、RPC、长连接网关、微服务、推送服务,游戏服务等领域。 1. 特性 服务器和客户端之间对等通信,两者API方法...

Teleport2.0 实现了一个全新的Golang TCP Socket框架,它通用、高效、灵活!可被用于Peer-Peer对等通信、RPC、长连接网关、微服务、推送服务,游戏服务等领域。

1. 特性

  • 服务器和客户端之间对等通信,两者API方法基本一致

  • 底层通信数据包包含Header和Body两部分

  • 支持单独定制Header和Body编码类型,例如JSON Protobuf

  • Body支持gzip压缩

  • Header包含状态码及其描述文本

  • 支持推,拉,回复等通信方式

  • 支持插件机制,可以自定义认证、心跳、微服务注册中心、统计信息插件等

  • 无论服务器或客户端,均支持都优雅重启、优雅关闭

  • 支持实现反向代理功能

  • 日志信息详尽,支持打印输入、输出消息的详细信息(状态码、消息头、消息体)

  • 支持设置慢操作报警阈值

  • 底层连接使用I/O缓冲区

  • 端点间通信使用I/O多路复用技术

Teleport 2.0 一个 Golang TCP Socket 的全新框架

teleport-server-peer

Teleport 2.0 一个 Golang TCP Socket 的全新框架

AB Testing 1: [Mac 4CPU 8GB] [single-process single-conn] teleport: QPS 37550

Teleport 2.0 一个 Golang TCP Socket 的全新框架

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


【声明】文章转载自:开源中国社区 [http://www.oschina.net]


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

Bulletproof Ajax中文版

Bulletproof Ajax中文版

Jeremy Keith / 刘申、宋薇 / 人民邮电出版社 / 2007-11 / 39.00元

本书介绍了如何构建无懈可击的Ajax Web应用程序,重点讲述如何在已有Web站点使用Ajax增强网站用户体验,从而尽可能地保证网站拥有最大限度的可移植性和亲和力,这正是目前大多数网站面临的需求。书中主要介绍了JavaScript、DOM、XMLHttpRequest、数据格式等,同时还提出了一种Hijax方法,即可以让Web应用程序平稳退化的方法。 本书适合各层次Web开发和设计人员阅读......一起来看看 《Bulletproof Ajax中文版》 这本书的介绍吧!

JSON 在线解析
JSON 在线解析

在线 JSON 格式化工具

HTML 编码/解码
HTML 编码/解码

HTML 编码/解码

正则表达式在线测试
正则表达式在线测试

正则表达式在线测试