golang使用thrift的鉴权和多路复用

最近梳理公司的服务时,决定把基础组件抽离出来服务化。因为公司里有多种语言开发的服务,决定使用thrift来解决跨语言通讯。

启动一个server

thriftgolang的支持已经很好了,官方包里提供了一个server基类和一个简单服务simple_server.go.自己可以实现server来做鉴权和其它统计操作.
server定义了一个TServer接口和一些方法,源码如下:

type TServer interface {
    ProcessorFactory() TProcessorFactory          //服务
    ServerTransport() TServerTransport            //连接
    InputTransportFactory() TTransportFactory     //输入
    OutputTransportFactory() TTransportFactory    //输出
    InputProtocolFactory() TProtocolFactory       //协议
    OutputProtocolFactory() TProtocolFactory      //协议

    // Starts the server
    Serve() error
    // Stops the server. This is optional on a per-implementation basis. Not
    // all servers are required to be cleanly stoppable.
    Stop() error
}

Server方法进行监听,接受请求,调度处理.下面是simple_server.goServer方法.

func (p *TSimpleServer) Serve() error {
    err := p.Listen()
    if err != nil {
        return err
    }
    p.AcceptLoop()
    return nil
}
func (p *TSimpleServer) AcceptLoop() error {
    for {
        client, err := p.serverTransport.Accept()
        if err != nil {
            select {
            case <-p.quit:
                return nil
            default:
            }
            return err
        }
        if client != nil {
            go func() {
                if err := p.processRequests(client); err != nil {
                    log.Println("error processing request:", err)
                }
            }()
        }
    }
}

只要自己实现相关接口方法,在方法中就可以进行相关鉴权/统计等处理了。

关于多路复用idl写法的问题

golang的多路复用是要把service写在一个idl文件里的,而java就不需要。这个在刚开始的时候耽误了点时间。

标签: golang, thrift, 多路复用

已有 3 条评论

  1. 建议试试 hprose:https://github.com/hprose/hprose-golang/wiki。

    接口比 thrift 和 grpc 都简洁的多。而且是无侵入式服务。

  2. 建议试试grpc
    接口比thrift简洁

    1. 嗯,看了下grpc,用做对外接口还是极好的。

添加新评论