pb2tarsgo

用法

  1. go get github.com/TarsCloud/TarsGo/tars
  2. go get  github.com/golang/protobuf/{proto,protoc-gen-go}
  3. install protoc
  • Add tarsrpc plugin for protoc-gen-go
  1.     cd $GOPATH/src/github.com/golang/protobuf/protoc-gen-go &&  cp -r $GOPATH/src/github.com/TarsCloud/TarsGo/tars/tools/pb2tarsgo/protoc-gen-go/{link_tarsrpc.go, tarsrpc} .
  2.     go build .
  3.     cp protoc-gen-go $GOPATH/bin
  4.     export PATH=$PATH:$GOPATH/bin

示例

  • proto 文件
  1. syntax = "proto3";
  2. package helloworld;
  4. // The greeting service definition.
  5. service Greeter {
  6.   // Sends a greeting
  7.   rpc SayHello (HelloRequest) returns (HelloReply) {}
  8. }
  10. // The request message containing the user's name.
  11. message HelloRequest {
  12.   string name = 1;
  13. }
  15. // The response message containing the greetings
  16. message HelloReply {
  17.   string message = 1;
  18. }
  • 生成代码
  1. protoc --go_out=plugins=tarsrpc:. helloworld.proto
  • 服务端
  1. package main
  3. import (
  4.     "github.com/TarsCloud/TarsGo/tars"
  5.     "helloworld" 
  6. )
  8. type GreeterImp  struct {
  9. }
  11. func (imp *GreeterImp) SayHello(input helloworld.HelloRequest)(output helloworld.HelloReply, err error) {
  12.     output.Message = "hello" +  input.GetName() 
  13.     return output, nil 
  14. }
  16. func main() { //Init servant
  18.     imp := new(GreeterImp)                                    //New Imp
  19.     app := new(helloworld.Greeter)                            //New init the A JCE
  20.     cfg := tars.GetServerConfig()                              //Get Config File Object
  21.     app.AddServant(imp, cfg.App+"."+cfg.Server+".GreeterTestObj") //Register Servant
  22.     tars.Run()
  23. }
  • 客户端
  1. package main
  3. import (
  4.     "fmt"
  5.     "github.com/TarsCloud/TarsGo/tars"
  6.     "helloworld"
  7. )
  9. func main() {
  10.     comm := tars.NewCommunicator()
  11.     obj := fmt.Sprintf("StressTest.HelloPbServer.GreeterTestObj@tcp -h 127.0.0.1  -p 10014  -t 60000")
  12.     app := new(helloworld.Greeter)
  13.     comm.StringToProxy(obj, app)
  14.     input := helloworld.HelloRequest{Name: "sandyskies"}
  15.     output, err := app.SayHello(input)
  16.     if err != nil {
  17.         fmt.Println("err: ", err)
  18.     }   
  19.     fmt.Println("result is:", output.Message)
  20. }