3

我正在我的 Mac 上运行一对使用 Apache Thrift 进行通信的客户端和服务器程序。在我们的生产系统中，我们最终可能会遇到客户端使用TJSONProtocol和服务器TBinaryProtocol用于序列化和反序列化的情况。

我知道这是一件可怕的事情。但我不确定如何事先检测到这一点。我尝试了一个具有不同协议的示例程序。我原以为会收到异常，但客户端卡在 RPC 调用上并且从未返回。

服务器代码使用TBinaryProtocol：

shared_ptr<SomethingHandler> handler(new SomethingHandler());
shared_ptr<TProcessor> processor(new SomethingProcessor(handler));
shared_ptr<TServerTransport> serverTransport(new TServerSocket(port));
shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory());
shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());
TSimpleServer server(processor, serverTransport, transportFactory, protocolFactory);
server.serve();

客户端代码使用TJSONProtocol：

boost::shared_ptr < TSocket > socket(new TSocket(argv[1], 9090));
boost::shared_ptr < TTransport > transport(new TBufferedTransport(socket));
boost::shared_ptr < TProtocol > protocol(new TJSONProtocol(transport));
transport->open();
std::cout<<"Transport open success"<<std::endl;
SomethingClient client(protocol);
std::cout<<"Create client success"<<std::endl;
try{
    std::cout<<"About to ping"<<std::endl;
    client.ping(argv[2]);
    std::cout<<"Ping success"<<std::endl;
    }catch(TException e){
    std::cout<<"Exception occurred:"<<e.what()<<std::endl;
}
transport->close();

在这个例子中，我从来没有Ping success打印出来。有什么方法可以检测到这种不兼容而不会卡住？

4

1 回答 1

4

恐怕你不能。根据定义，您应该在两端设置完全相同的协议/传输堆栈1) ；其他任何事情都是无效的。

如果您需要不同的协议/传输堆栈，则需要设置适当数量的不同端点。

除了堆栈更高级别的常用机制之外，没有任何保护或检测。您卡住的原因很可能是对数据的误解，因此服务器可能只是等待更多的请求字节进来，而您没有发送。

1）该规则有一些例外，但在这里它们无关紧要。

于 2015-08-07T18:25:12.483 回答