public class DemoServer extends TcpServer {
       
      	public static void main(String[] args) {
		                                       
            MessageDispatcher.register(DomeServerHandler.class);
		
            new DemoServer().listen(9000).start();
		
       }
}
    

public class DemoClient extends TcpClient {

	public DemoClient(String hosts, int port) {
		super(hosts, port);
	}
	
  public static void main(String[] args) {
     
        MessageDispatcher.register(DomeClientHandler.class);
		 
        DemoClient client = new DemoClient("127.0.0.1",9000);
	   
        client.start();
        
	      Protobuf.TestData.Builder data = Protobuf.TestData.newBuilder();
	      data.setName("我是客户端");
		 
        client.writeAndFlush(new Message((short)11,data.build().toByteArray()));
    
  }