当前位置：首页 > 软件库 > 程序开发 > 高性能网络开发库 >

go-netty

高性能网络库

授权协议 Apache

开发语言 Google Go

所属分类程序开发、高性能网络开发库

软件类型开源软件

地区国产

投递者支嘉祥

操作系统跨平台

开源组织无

适用人群未知

软件官网

官方下载

安全指数

软件概览

go-netty 是大量参考了netty的设计并融合Golang本身的协程特性而开发的一款高性能网络库

Feature (特性)

可扩展多种传输协议，并且默认实现了 TCP, KCP, Websocket
可扩展多种解码器，默认实现了常见的编解码器
基于责任链模型的流程控制
核心库零依赖

Documentation (文档)

GoDoc

Examples (示例)

使用

创建bootstrap, 用于提供服务或者对外建立连接

var bootstrap = netty.NewBootstrap()

配置服务连接的处理器 (同样还有一个ClientInitializer 对应客户端连接处理器配置)

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(EchoHandler{"Server"})
})

配置服务器(客户端)所使用的传输协议

bootstrap.Transport(tcp.New())

开始监听端口并开始提供服务，直到收到指定信号后退出

bootstrap.Listen("tcp://0.0.0.0:6565").RunForever(os.Kill, os.Interrupt)

LogHandler 处理器

type EchoHandlerstruct {
    role string
}

func (l EchoHandler) 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 EchoHandler) HandleRead(ctx netty.InboundContext, message netty.Message) {
    fmt.Println(l.role, "->", "handle read:", message)

    // 向后续的handler传递控制权
    // 如果是最后一个handler或者需要中断请求可以不用调用
    ctx.HandleRead(message)
}

func (l EchoHandler) HandleInactive(ctx netty.InactiveContext, ex netty.Exception) {
    fmt.Println(l.role, "->", "inactive:", ctx.Channel().RemoteAddr(), ex)

    // 向后续的handler传递控制权
    // 如果是最后一个handler或者需要中断请求可以不用调用
    ctx.HandleInactive(ex)
}

使用案例

dubbo--netty

Exchange Transport 层用到的netty 消费者使用 NettyClient，提供者使用 NettyServer，Provider 启动的时候，会开启端口监听，使用我们平时启动 Netty 一样的方式。而 Client 在 Spring getBean 的时候，会创建 Client，当调用远程方法的时候，将数据通过 dubbo 协议编码发送到 NettyServer，然后 Nett
Reactive响应式编程系列：解密reactor-netty如何实现响应式

我们都说 Netty 是一款基于异步事件驱动来设计和实现的高性能IO框架，它之所以高性能，重要的原因之一是其线程模型的设计，Netty 的线程模型是基于 Reactor 设计模式的，它主要包含两个线程池：一个是 Boss 线程池，另一个是 Worker 线程池。Boss 线程池主要负责接受客户端连接请求，并将连接请求注册到 Worker 线程池中的某个线程的 Selector 上。
dubbo-netty

Active NettyServerHandler -> AbstractServer -> AbstractPeer -> AbstractChannelHandlerDelegate -> HeartbeatHandler -> AllChannelHandler -> ChannelEventRunnable -> HeaderExchangeHandler -> DubboProtocol
Netty-Netty模型-taskQueue自定义任务，Netty模型再说明，异步模型

Netty模型-taskQueue自定义任务任务队列中的Task有3种典型使用场景用户程序自定义的普通任务 package com.jl.java.web.nettyserver; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandlerCon
使用golang实现类java的netty异步通信编程，也即是回调通知基于事件的模型设计...

代码 package main import ( "encoding/json" "fmt" "net/http" "sync" ) var dirEngineChan sync.Map func main() { dHandler := dagHandler{} http.Handle("/v1/dagScan", dHandler) cH
JAVA(7)-netty-client

客户端也就4步,上代码 public void client() throws Exception { //1.创建管道和管理 EventLoopGroup workerGroup =new NioEventLoopGroup(1); Bootstrap b=new Bootstrap(); b.group(workerGro

go-netty

Feature (特性)

Documentation (文档)

Examples (示例)

使用

同类工具

相关阅读

相关文章

相关问答

相关文档