golang thrift 客户端/服务端代码记录

1，客户端

package thrift

import (
   "fmt"
   "git.apache.org/thrift.git/lib/go/thrift"
   "net"
   "os"
   "test/idlgen/HelloWorld"
)

func Client1()  {
   transportFactory := thrift.NewTBufferedTransportFactory(8192)
   protocolFactory := thrift.NewTCompactProtocolFactory()

   transport, err := thrift.NewTSocket(net.JoinHostPort("127.0.0.1", "9999"))

   if err != nil{
      fmt.Println("err")
      os.Exit(1)
   }

   useTransport := transportFactory.GetTransport(transport)
   client := HelloWorld.NewHelloGoClientFactory(useTransport, protocolFactory)
   if err = transport.Open(); err != nil{
      fmt.Println("err")
      os.Exit(1)
   }
   defer transport.Close()

   res, err := client.Hello("hello")
   if err != nil{
      fmt.Println("err")
      os.Exit(1)
   }
   fmt.Println(res)
}

2，服务端

package thrift

import (
   "fmt"
   "git.apache.org/thrift.git/lib/go/thrift"
   "test/idlgen/HelloWorld"
)

func Server1()  {
   transport, err := thrift.NewTServerSocket(":9999")
   if err != nil{
      fmt.Println("err")
   }

   handler := &HelloGo{}

   processor := HelloWorld.NewHelloGoProcessor(handler)

   transportFactory := thrift.NewTBufferedTransportFactory(8192)
   protocolFactory := thrift.NewTCompactProtocolFactory()

   server := thrift.NewTSimpleServer4(processor, transport, transportFactory, protocolFactory)

   if err := server.Serve(); err != nil{
      fmt.Println("err")
   }
}

3，实现类

package thrift

type HelloGo struct {
   
}

func (hg *HelloGo) Hello(name string) (string, error) {
   return name, nil
}

4，idl定义

namespace php Idlgen.HelloWorld
namespace java Idlgen.HelloWorld
namespace go idlgen.HelloWorld



service HelloGo{
    string hello(1:string name),
}