thrift rpc 服务时间统计
2016/05/16 14:44:19 add 24.21µs true <nil>
2016/05/16 14:44:19 add 16.186µs true <nil>
2016/05/16 14:44:19 add 15.003µs true <nil>
2016/05/16 14:44:19 add 23.475µs true <nil>
2016/05/16 14:44:19 add 19.16µs true <nil>
2016/05/16 14:44:19 add 30.473µs true <nil>
2016/05/16 14:44:19 add 18.909µs true <nil>
2016/05/16 14:44:19 add 15.044µs true <nil>
2016/05/16 14:44:19 add 15.306µs true <nil>
2016/05/16 14:44:19 add 16.332µs true <nil>
2016/05/16 14:44:19 add 29.563µs true <nil>
2016/05/16 14:44:19 add 16.499µs true <nil>
2016/05/16 14:44:19 add 26.008µs true <nil>
2016/05/16 14:44:19 add 25.315µs true <nil>
2016/05/16 14:44:19 add 17.123µs true <nil>
2016/05/16 14:44:19 add 29.919µs true <nil>
2016/05/16 14:44:19 add 21.628µs true <nil>
2016/05/16 14:44:19 add 19.308µs true <nil>
2016/05/16 14:44:19 add 35.516µs true <nil>
2016/05/16 14:44:19 add 15.68µs true <nil>
使用方法
package main
import (
"log"
"time"
"git.apache.org/thrift.git/lib/go/thrift"
thriftx "github.com/chanxuehong/thrift"
"github.com/chanxuehong/thrift/test/go.thrift/test"
)
func main() {
var (
ThriftListenAddr = ":9999"
ThriftTransportBufferSize = 1024
)
processor := thriftx.NewServiceProcessor(test.NewTestServiceProcessor(&serviceHandler{})) // NOTE: 就是在这里
serverTransport, err := thrift.NewTServerSocketTimeout(ThriftListenAddr, time.Second*5)
if err != nil {
log.Println(err)
return
}
transportFactory := thrift.NewTBufferedTransportFactory(ThriftTransportBufferSize)
protocolFactory := thrift.NewTBinaryProtocolFactoryDefault()
server := thrift.NewTSimpleServer4(processor, serverTransport, transportFactory, protocolFactory)
if err = server.Serve(); err != nil {
log.Println(err)
return
}
}