thrift在go中的初步使用
- 新建文件夹thrift-test,然后执行go mod init thrift-test初始化
- 在thrift-test根目录下新建文件: example.thrift 然后将下面代码粘进入
namespace go com.example // 定义所使用的命名空间 struct Person { // 定义一个结构体 1: required string name, // 姓名字段 2: optional i32 age // 年龄字段 } service ExampleService { // 定义一个服务接口 void sayHello(1: string name) // sayHello方法,接收一个姓名参数 }
- 执行 go get github.com/apache/thrift/lib/go/thrift, 然后到go.mod中查看版本号,再去cmd执行thrift --version 查看thrift的版本号,如果相差很大就要降低thrift的版本,不然会报错,我这里都是thrift是0.18.0,而go-thrift是0.18.1,相差不大,则没有问题
- 执行thrift --gen go example.thrift 命令,会生成gen-go文件夹,点开看下,有可能导包错误,修改导包路径即可,如果不是导包路径的错误,则是thrift和go-thrift版本不对应的问题
- 新建service文件夹,在下面新建example_impl.go
package main import ( "context" "fmt" ) type ExampleServiceImpl struct{ } func (e *ExampleServiceImpl) SayHello(ctx context.Context, name string) (err error) { fmt.Printf("Hello, %s! ", name) return nil }
然后在service文件夹下新建server.go
package main import ( "github.com/apache/thrift/lib/go/thrift" "thrift-test/gen-go/com/example" ) func main() { handler := &ExampleServiceImpl{ } processor := example.NewExampleServiceProcessor(handler) // 创建服务器传输对象 transportFactory := thrift.NewTTransportFactory() confN := &thrift.TConfiguration{ } protocolFactory := thrift.NewTBinaryProtocolFactoryConf(confN) serverTransport, err := thrift.NewTServerSocket(":9090") if err != nil { panic(err) } // 创建简单的单线程服务器 server := thrift.NewTSimpleServer4(processor, serverTransport, transportFactory, protocolFactory) println("Starting the server...") server.Serve() }
- 新建client文件夹,在client下新建client.go
package main import ( "context" "fmt" "github.com/apache/thrift/lib/go/thrift" "thrift-test/gen-go/com/example" ) func main() { conf := &thrift.TConfiguration{ } transport := thrift.NewTSocketConf("localhost:9090", conf) // 创建客户端协议 confN := &thrift.TConfiguration{ } protocolFactory := thrift.NewTBinaryProtocolFactoryConf(confN) client := example.NewExampleServiceClientFactory(transport, protocolFactory) // 打开连接 if err := transport.Open(); err != nil { panic(err) } defer transport.Close() // 调用远程服务 if err := client.SayHello(context.Background(), "world"); err != nil { panic(err) } fmt.Println("Done!") }
- 然后分别运行服务端和客户端查看调用是否成功
- demo结构如下