Thrift 个人实战--Thrift 网络服务模型（转）

2

3

4

5

6

7

8

9

10

11

12

13

14

15

public abstract class TServer {

　　public static class Args extends AbstractServerArgs<Args> {

　　　　public Args(TServerTransport transport) {

　　　　　　super(transport);

　　　　}

　　}

　　public static abstract class AbstractServerArgs<T extends AbstractServerArgs<T>> {

　　　　public AbstractServerArgs(TServerTransport transport);

　　　　public T processorFactory(TProcessorFactory factory);

　　　　public T processor(TProcessor processor);

　　　　public T transportFactory(TTransportFactory factory);

　　　　public T protocolFactory(TProtocolFactory factory);

　　}

}

2

3

4

5

6

7

public abstract class TServer {

　　public abstract void serve();

　　public void stop();

　　public boolean isServing();

　　public void setServerEventHandler(TServerEventHandler eventHandler);

}

2

3

4

5

6

7

8

9

10

11

12

13

14

// *) server socket进行监听

serverSocket.listen();

while ( isServing() ) {

　　// *) 接受socket链接

　　client = serverSocket.accept();

　　// *) 封装处理器

　　processor = factory.getProcess(client);

　　while ( true ) {

　　　　// *) 阻塞处理rpc的输入/输出

　　　　if ( !processor.process(input, output) ) {

　　　　　　break;   

　　　　}  

　　}

}

2

3

4

5

6

7

8

9

private static ExecutorService createDefaultExecutorService(Args args) {

  SynchronousQueue<Runnable> executorQueue =

    new SynchronousQueue<Runnable>();

  return new ThreadPoolExecutor(args.minWorkerThreads,

                                args.maxWorkerThreads,

                                60,

                                TimeUnit.SECONDS,

                                executorQueue);

}

2

3

4

5

6

7

8

9

setServing(true);

while (!stopped_) {

　　try {

　　　　TTransport client = serverTransport_.accept();

　　　　WorkerProcess wp = new WorkerProcess(client);

　　　　executorService_.execute(wp);

　　} catch (TTransportException ttx) {

　　}

}

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

private void select() {

　　try {

　　　　selector.select();  // wait for io events.

　　　　// process the io events we received

　　　　Iterator<SelectionKey> selectedKeys = selector.selectedKeys().iterator();

　　　　while (!stopped_ && selectedKeys.hasNext()) {

　　　　　　SelectionKey key = selectedKeys.next();

　　　　　　selectedKeys.remove();

　　　　　　if (key.isAcceptable()) {

　　　　　　　　handleAccept(); // deal with accept

　　　　　　} else if (key.isReadable()) {

　　　　　　　　handleRead(key);    // deal with reads

　　　　　　} else if (key.isWritable()) {

　　　　　　　　handleWrite(key); // deal with writes

　　　　　　}

　　　　}

　　} catch (IOException e) {

　　}

}