source: class NettyServerTransportTest {
  
  	@Test
  	public void testStart() throws InterruptedException {
  
target: 		int port = 8888;
  		int workerIoThreads = 4;
  		int allIdleTimeSeconds = 60;
  		JavaTransportProtocol transportCodec = new JavaTransportProtocol();
  		ReceiveMessageHandler<Request, Response> receiveMessageHandler = new NettyServerReceiveMessageHandlerTest();
  		NettyServerTransport<Response,Request> serverTransport = new NettyServerTransport<>(port,workerIoThreads, allIdleTimeSeconds);
  		serverTransport.setTransportCodec(transportCodec);
  		serverTransport.setReceiveMessageHandler(receiveMessageHandler);
  		serverTransport.start();
  		System.out.println("netty服务端启动成功");
  		synchronized (NettyServerTransportTest.class) {
  			NettyServerTransportTest.class.wait();
  		}
  	}
  
  }