TSimpleServer的工作模式只有一个工作线程,循环监听新请求的到来并完成对请求的处理,只用于测试 TSimpleServer的工作模式采用最简单的阻塞IO,实现方法简洁明了,便于理解,但是一次只能接收和处理一个socket连接,效率比较低,主要用于演示Thrift的工作过程,在实际开发过程中很少用到它。 服务端代码: private static void simpleServer() throws TTransportException {
TServerSocket serverSocket=new TServerSocket(8888);
ISayHello.Iface sayHelloService = new SayHelloImpl();
Processor<Iface> processor = new ISayHello.Processor<Iface>(sayHelloService);
TServer.Args serverParams=new TServer.Args(serverSocket);
serverParams.protocolFactory(new TBinaryProtocol.Factory());
serverParams.processor(processor);
TServer server=new TSimpleServer(serverParams); //简单的单线程服务模型,常用于测试
server.serve();
}
客户端代码:
|
|