发布一款高性能网络框架 go-netty

limpo1989 · · 3255 次点击 · 开始浏览    置顶
这是一个创建于 的主题,其中的信息可能已经有所发展或是发生改变。

# GO-NETTY [github.com/go-netty/go-netty](https://github.com/go-netty/go-netty "go-netty") ## Introduction (介绍) go-netty is heavily inspired by [netty](https://github.com/netty/netty) go-netty 大量参考了netty的设计并融合Golang本身的协程特性而开发的一款高性能网络库 ## Feature (特性) * Extensible multi-transport protocol support, default support TCP, KCP, Websocket * 可扩展多种传输协议,并且默认实现了 TCP, KCP, Websocket * Extensible multi-codec support * 可扩展多种解码器,默认实现了常见的编解码器 * Based on responsibility chain model * 基于责任链模型的流程控制 ## TODO (待完成) * test case * docs * examples ## Examples (例子) * [chat_server (基于websocket的聊天室)](./example/chat_server/main.go) * [file_server (基于http的文件浏览器)](./example/file_server/main.go) * [tcp_server (自义定tcp服务器)](./example/tcp_server/main.go) ## Usage (使用) > 创建bootstrap, 用于提供服务或者对外建立连接 ```go var bootstrap = netty.NewBootstrap() ``` > 配置服务连接的处理器 (同样还有一个ClientInitializer 对应客户端连接处理器配置) ```go bootstrap.ChildInitializer(func(channel netty.Channel) { channel.Pipeline(). // 按照自定义协议解码帧(2字节的长度字段) AddLast(frame.LengthFieldCodec(binary.LittleEndian, 1024, 0, 2, 0, 0)). // 消息内容为文本格式(可自定义为 json,protobuf 等编解码器) AddLast(format.TextCodec()). // 处理消息 AddLast(LogHandler{"Server"}) }) ``` > 配置服务器(客户端)所使用的传输协议 ```go bootstrap.Transport(tcp.New()) ``` > 开始监听端口并开始提供服务,直到收到指定信号后退出 ```go bootstrap.Listen("tcp://0.0.0.0:6565").RunForever(os.Kill, os.Interrupt) ``` > LogHandler 处理器 ```go type LogHandler struct { role string } func (l LogHandler) HandleActive(ctx netty.ActiveContext) { fmt.Println(l.role, "->", "active:", ctx.Channel().RemoteAddr()) // 给对端发送一条消息,将进入如下流程(视编解码配置) // Text -> TextCodec -> LengthFieldCodec -> Channel.Write // 文本 文本编码 组装协议格式(长度字段) 网络发送 ctx.Write("Hello I'm " + l.role) // 向后续的handler传递控制权 // 如果是最后一个handler或者需要中断请求可以不用调用 ctx.HandleActive() } func (l LogHandler) HandleRead(ctx netty.InboundContext, message netty.Message) { fmt.Println(l.role, "->", "handle read:", message) // 向后续的handler传递控制权 // 如果是最后一个handler或者需要中断请求可以不用调用 ctx.HandleRead(message) } func (l LogHandler) HandleInactive(ctx netty.InactiveContext, ex netty.Exception) { fmt.Println(l.role, "->", "inactive:", ctx.Channel().RemoteAddr(), ex) // 向后续的handler传递控制权 // 如果是最后一个handler或者需要中断请求可以不用调用 ctx.HandleInactive(ex) } ```

有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:701969077

3255 次点击  
加入收藏 微博
2 回复  |  直到 2019-11-28 20:09:19
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传