服务多元化使用Apache节俭

Question

Server代码：

  TMultiplexedProcessor processor = new TMultiplexedProcessor(); 

      processor.registerProcessor(
       "AddService", 
       new AddService.Processor(new AddHandler())); 

      processor.registerProcessor(
       "MultiplyService", 
       new MultiplyService.Processor(new MultiplyHandler())); 

      TServerTransport serverTransport = new TServerSocket(7911); 



      TSimpleServer server = new TSimpleServer(new TSimpleServer.Args(serverTransport). 
        processor(processor)); 

      System.out.println("Starting server on port 7911 ..."); 
      server.serve(); 

客户端代码：

TFramedTransport transport; 

    transport = new TFramedTransport(new TSocket("localhost", 7911)); 
    transport.open(); 


    TProtocol protocol = new TBinaryProtocol(transport); 

    System.out.println("1"); 
    TMultiplexedProtocol mp = new TMultiplexedProtocol(protocol, "AddService"); 
    AddService.Client service = new AddService.Client(mp); 

    System.out.println("2"); 
    TMultiplexedProtocol mp2 = new TMultiplexedProtocol(protocol, "MultiplyService"); 
    MultiplyService.Client service2 = new MultiplyService.Client(mp2); 

    System.out.println("3"); 

    System.out.println(service.add(2,2)); 
    System.out.println(service2.multiply(2000,200)); 

但是当我运行服务器（端口7911监听）和客户端，客户端犯规进程最后两次调用add/multiply函数。

我可以调试参数已发送到服务器，但服务器无法处理它们。

任何指针，至于我失踪？

Answer 1

未经测试，但看起来非常像在服务器和客户端上运行两个不同的协议堆栈。试试这个：

TMultiplexedProcessor processor = new TMultiplexedProcessor(); 

processor.registerProcessor(
    "AddService", 
    new AddService.Processor(new AddHandler())); 

processor.registerProcessor(
    "MultiplyService", 
    new MultiplyService.Processor(new MultiplyHandler())); 

TServerTransport serverTransport = new TServerSocket(7911); 

TTransportFactory factory = new TFramedTransport.Factory(); 

TServer.Args args = new TServer.Args(serverTransport); 
args.processor(processor); 
args.transportFactory(factory); 
TSimpleServer server = new TSimpleServer(args); 

System.out.println("Starting server on port 7911 ..."); 
server.serve();