thrift rpc 案例

梦里梦外; 2022-08-30 12:54 192阅读 0赞

### 定义`.proto`文件 ###

namespace java com.zjw.thrift.helloworld.gen
    
    service  GreetingService {
      string sayHello(1:string name)
    }

### 生成代码 ###

thrift -r --gen java java/com/zjw/thrift/helloworld/hello.thrift

### Maven依赖 ###

<dependency>
     <groupId>org.apache.thrift</groupId>
     <artifactId>libthrift</artifactId>
     <version>0.13.0</version>
    </dependency>

### Java代码 ###

*  Server

package com.zjw.thrift.helloworld;
    
    import com.zjw.thrift.helloworld.gen.GreetingService;
    import java.util.logging.Logger;
    import org.apache.thrift.TException;
    import org.apache.thrift.TProcessor;
    import org.apache.thrift.protocol.TBinaryProtocol;
    import org.apache.thrift.server.TServer;
    import org.apache.thrift.server.TServer.Args;
    import org.apache.thrift.server.TSimpleServer;
    import org.apache.thrift.server.TThreadPoolServer;
    import org.apache.thrift.transport.TServerSocket;
    import org.apache.thrift.transport.TServerTransport;
    import org.apache.thrift.transport.TTransportException;
    
    public class GreetingServer { 
    
      private static final Logger logger = Logger.getLogger(GreetingServer.class.getName());
    
      public static void main(String[] args) { 
        try { 
          TServerSocket serverTransport = new TServerSocket(9090);
          TBinaryProtocol.Factory proFactory = new TBinaryProtocol.Factory();
    
          // 关联处理器与GreetingService服务实现
          TProcessor processor = new GreetingService.Processor(new GreetingServiceImpl());
    
          TThreadPoolServer.Args serverArgs = new TThreadPoolServer.Args(serverTransport);
          serverArgs.processor(processor);
          serverArgs.protocolFactory(proFactory);
          TServer server = new TThreadPoolServer(serverArgs);
          logger.info("Start server on port 9090...");
    
          server.serve();
        } catch (TTransportException e) { 
          e.printStackTrace();
        }
      }
      static class GreetingServiceImpl implements GreetingService.Iface { 
    
        private static final Logger logger =  Logger.getLogger(GreetingServiceImpl.class.getName());
    
        public String sayHello(String name) throws TException { 
          logger.info(String.format("调用sayHello方法的参数name = {%s}", name));
    
          return "Hello, " + name;
        }
    
      }
    }

*  Client