tao-1.6.0.zip_Go_ Go_ Go!_go语言 tcp_tao.16_tcp

Tao --- 轻量级TCP异步框架，Go语言实现 1.6.0 =========================================== ## Light-weight TCP Asynchronous gOlang framework ### supported Golang version: 1.9 and above Announcing Tao 1.6.0 - Release Notes -------- 1. Bugfix: writeLoop() drains all pending messages before exit;<br/> writeLoop()函数退出前将所有的网络数据包发送完毕； 2. Renaming getter methods according to Effective Go;<br/> 根据Effective Go重命名getter方法； 3. Bugfix: timer task expired forever due to system clock affected by NTP;<br/> 修复因为受NTP协议校正系统时钟偏差的影响，导致定时任务永远过期的bug； 4. Bugfix: asyncWrite() do not return error if called after ServerConn or ClientConn closes;<br/> 修复网络连接关闭后调用asyncWrite()不返回错误的bug； 5. Providing WorkerSizeOption() for tuning the size of worker go-routine pool;<br/> 提供WorkerSizeOption()来调节工作者线程池大小； 6. Providing BufferSizeOption() for tuning the size of buffered channel;<br/> 提供BufferSizeOption()来调节缓冲通道大小； 7. Providing ReconnectOption() for activating ClientConn's reconnecting mechanism;<br/> 提供ReconnectOption()来启动ClientConn的断线重连机制； 8. Providing CustomCodecOption() for setting self-defined codec;<br/> 提供CustomCodecOption() 来设置自定义编解码器； 9. Providing TLSCredsOption() for running a TLS server;<br/> 提供TLSCredsOption()来运行TLS服务器； 10. Providing OnConnectOption(), OnMessageOption(), OnCloseOption() and OnErrorOption() for setting callbacks of the four situations respectively;<br/> 提供OnConnectOption(), OnMessageOption(), OnCloseOption() 和 OnErrorOption()来设置四种情况下的回调函数； 11. Use the standard sync.Map instead of map guarded by rwmutex;<br/> 使用标准库中的sync.Map替换使用rwmutex保护的map； Announcing Tao 1.5 - Release Notes -------- 1. A Golang-style redesigning of the overall framework, a reduce about 500+ lines of codes;<br/> 按照Go语言风格重新设计的整体框架，精简500多行代码； 2. Providing new Server, ClientConn and ServerConn struct and a WriteCloser interface;<br/> 提供Server，ClientConn和ServerConn三种新结构和WriteCloser新接口； 3. Using standard context package to manage and spread request-scoped data acrossing go-routines;<br/> 使用标准库中的context包在多个Go线程中管理和传播与请求有关的数据； 4. Graceful stopping, all go-routines are related by context, and they will be noticed and exit when server stops or connection closes;<br/> 优雅停机，所有的Go线程都通过上下文进行关联，当服务器停机或连接关闭时它们都会收到通知并执行退出； 5. Providing new type HandlerFunc func(context.Context, WriteCloser) for defining message handlers;<br/> 提供新的HandlerFunc类型来定义消息处理器； 6. Developers can now use NewContextWithMessage() and MessageFromContext() to put and get message they are about to use in handler function's context, this also leads to a more clarified design;<br/> 开发者现在可以通过NewContextWithMessage()和MessageFromContext()函数来在上下文中存取他们将在处理器函数中使用的消息，这样的设计更简洁； 7. Go-routine functions readLoop(), writeLoop() and handleLoop() are all optimized to serve both ServerConn and ClientConn, serveral dead-lock bugs such as blocking on channels are fixed;<br/> 优化Go线程函数readLoop()，writeLoop()和handleLoop()使得它们能同时为ServerConn和ClientConn服务，修复了多个“通道阻塞”的死锁问题； 8. Reconnecting mechanism of ClientConn is redesigned and optimized;<br/> 重新设计和优化ClientConn的断线重连机制； Announcing Tao 1.4 - Release Notes -------- 1. bugfix：TLS重连失败问题；<br/> bugfix: failed to reconnect the TLS connection; 2. bugfix：ConnectionMap死锁问题；<br/> bugfix: ConnectionMap dead-lock problem; 3. 优化TCP网络连接的关闭过程；<br/> Optimize the closing process of TCP connection; 4. 优化服务器的关闭过程；<br/> Optimize the closing process of server; 5. 更优雅的消息处理注册接口；<br/> More elegant message handler register interface; Announcing Tao 1.3 - Release Notes -------- 1. bugfix：修复断线重连状态不一致问题；<br/> bugfix: fixed inconsistent status caused by reconnecting; 2. bugfix：修复ServerConnection和TimingWheel在连接关闭时并发访问导致崩溃问题；<br/> bugfix: fixed a corruption caused by concurrent accessing between ServerConnection and TimingWheel during connection closing; 3. 无锁且线程安全的TimingWheel，优化CPU占用率；<br/> Lock-free and thread-safe TimingWheel, optimized occupancy rate;<br/> 4. bugfix：修复TLS配置文件读取函数；<br/> bugfix: Fixed errors when loading TLS config; 5. 添加消息相关的Context结构；简化消息注册机制，直接注册处理函数到HandlerMap；<br/> A message-related Context struct added; Register handler functions in HandlerMap directly to simplify message registration mechanism; 6. 合并NewClientConnection()和NewTLSClientConnection()，提供一致的API；<br/> Combine NewTLSConnection() into NewClientConnection(), providing a consistent API; 7. 工作者线程池改造成单例模式；<br/> Make WorkerPool a singleton pattern; 8. 使用Holmes日志库代替glog；<br/> Using Holmes logging package instead of glog; 9. 添加metrics.go：基于expvar标准包导出服务器关键信息；<br/> Add metrics.go: exporting critical server information based on expvar standard pacakge; 10. 编写中文版框架设计原理文档，英文版正在翻译中；<br/> A document about framework designing principles in Chinese, English version under developed; Announcing Tao 1.2 - Release Notes -------- 1. 更优雅的消息注册接口；<br/> More elegant message register interface; 2. TCPConnection的断线重连机制；<br/> TCPConnection reconnecting upon closing; 3. bugfix：协议未注册时不关闭客户端连接；<br/> bugfix: Don't close client when messages not registered; 4. bugfix：在readLoop()协程中处理心跳时间戳更新；<br/> bugfix: Updating heart-beat timestamp in readLoop() go-routine; 5. bugfix：Message接口使用Serialize()替代之前的MarshalBinary()，以免框架使用者使用gob.Encoder/Decoder的时候栈溢出；<br/> bugfix: Use Serialize() instead of MarshalBinary() in Message interface, preventing stack overflows when framework users use gob.Encoder/Decoder; 6. bugfix：当应用层数据长度大于0时才对其进行序列化；<br/> bugfix: Serialize application data when its length greater than 0; 7. 新API：SetCodec()，允许TCPConnection自定义编解码器；<br/> New API: SetCodec() allowing TCPConnection defines its own codec; 8. 新API：SetDBInitializer()，允许框架使用者定义数据访问接口；<br/> New API: SetDBInitializer() allowing framework users define data access interface; 9. 允许框架使用者在TCPConnection上设置自定义数据；<br/> Allowing framework users setting custom data on TCPConnection; 10. 为新客户端连接的启动单独开辟一个对应的go协程；<br/> Allocating a corresponding go-routine for newly-connected clients respectively; 11. bugfix：写事件循环在连接关闭时将信道中的数据全部发送出去；<br/> bugfix: writeLoop() flushes all packets left in channel when performing closing; 12. bugfix：服务器和客户端连接等待所有go协程关闭后再退出；<br/> bugfix: Servers and client connections wait for the exits of all go-routines before shutting down; 13. 重构Server和Connection，采用针对接口编程的设计；<br/> Refactoring Server and Connection, adopting a programming-by-interface design; 14. 设置500毫秒读超时，防止readLoop()发生阻塞；<br/> Setting 500ms read-timeout preve