启动多个service

Server端有时需要定义多个Service，并在服务启动时在一个进程同时启动，共用端口。

gRPC

1. 在.proto文件中定义新的service

+message MeowRequest {
+}

+message MeowResponse {
+  string message = 1;
+}

+service CatService {
+  rpc meow (MeowRequest) returns (MeowResponse) {}
+}

2. 修改service.yaml，添加新API

config:
-  grpc_service_name: TestService
+  grpc_service_name: TestService,CatService
urlmapping:
+ - GET /cat/meow CatService Meow

3. 重新生成代码

$ turbo generate package/path/to/yourservice -r grpc -I ~/package/path/to/yourservice

4. 在Server端，编写实现新service

func RegisterServer(s *grpc.Server) {
       proto.RegisterTestServiceServer(s, &TestService{})
+      proto.RegisterCatServiceServer(s, &CatService{})
}

+type CatService struct {
+}

+func (c *CatService) Meow(ctx context.Context, req *proto.MeowRequest) (*proto.MeowResponse, error) {
+      return &proto.MeowResponse{Message: "Meow!"}, nil
+}

5. 在HTTP端，注册新service

func GrpcClient(conn *grpc.ClientConn) map[string]interface{} {
       return map[string]interface{}{
               "TestService": proto.NewTestServiceClient(conn),
+              "CatService": proto.NewCatServiceClient(conn),
       }
}

完成！

Thrift

1. 在.thrift文件中定义新的service

+struct MeowResponse {
+ 1: string message,
+}

+service CatService {
+  MeowResponse Meow (1:string msg)
+}

2. 修改service.yaml，添加新API

config:
-  thrift_service_name: TestService
+  thrift_service_name: TestService,CatService
urlmapping:
+ - GET /cat/meow CatService Meow

3. 重新生成代码

$ turbo generate package/path/to/yourservice -r thrift -I ~/package/path/to/yourservice

4. 在Server端，编写实现新service

func TProcessor() map[string]thrift.TProcessor {
       return map[string]thrift.TProcessor{
               "TestService": gen.NewTestServiceProcessor(TestService{}),
+              "CatService": gen.NewCatServiceProcessor(CatService{}),
       }
}

+type CatService struct {
+}

+func (c CatService) Meow(msg string) (r *gen.MeowResponse, err error) {
+      return &gen.MeowResponse{Message: msg}, nil
+}

5. 在HTTP端，注册新service

func ThriftClient(trans thrift.TTransport, f thrift.TProtocolFactory) map[string]interface{} {
       iprot := f.GetProtocol(trans)
       return map[string]interface{}{
               "TestService": t.NewTestServiceClientProtocol(trans, iprot, thrift.NewTMultiplexedProtocol(iprot, "TestService")),
+              "CatService": t.NewCatServiceClientProtocol(trans, iprot, thrift.NewTMultiplexedProtocol(iprot, "CatService")),
       }
}

完成！