服务器

有句话说的好，远在天边，尽在眼前。
想要制作这个主题时，google了半天也没有一个靠谱的。实在没办法了，翻了翻test项目，哈哈，就有了现在的服务端。

package main

import (
    "fmt"
    "net/http"
    "testgo/mathservice"

    "git.apache.org/thrift.git/lib/go/thrift"
)

const (
    NetWorkAddr = "127.0.0.1:9090"
)

type Mymathservice struct {
}

func (this *MymathservicE) Add(A int32,B int32) (r int32,err error) {
    r = A + B
    err = nil
    fmt.Println("Add",A,B)
    return
}

func main() {
    handler := &Mymathservice{}
    processor := mathservice.NewMathserviceProcessor(handler)
    protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()

    http.HandleFunc("/",thrift.NewThriftHandlerFunc(processor,protocolFactory,protocolFactory))
    fmt.Println("thrift server in http://",NetWorkAddr)
    http.ListenAndServe(fmt.Sprintf(":%d", 9090),nil)
}

这里借用了net/http库的handleFunc功能，实际上，使用gin/beego/...等Web框架也是可以这样的。完美！！

客户端

package main

import (
    "fmt"
    "os"
    "testgo/mathservice"

    "git.apache.org/thrift.git/lib/go/thrift"
)

func main() {
    client_transport,_ := thrift.NewThttpClient("http://127.0.0.1:9090")
    protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()

    client := mathservice.NewMathserviceClientFactory(client_transport,protocolFactory)

    if err := client_transport.open(); err != nil {
        fmt.Fprintln(os.Stderr,"Error opening socket",err)
        os.Exit(1)
    }
    defer client_transport.Close()

    for i := int32(0); i < 100; i++ {
        nRet,_ := client.Add(i,i)
        fmt.Println(i,"Add",nRet)
    }
    fmt.Println("Over!")
}