Question

dubbo thrift和原生态thrift的怎么实现信息互通

Answer 1

重写exchange，主要涉及到HeaderExchangeChannel，HeaderExchangeClient，HeaderExchangeServer，HeaderExchanger，HeartBeatTask，Request，凡是涉及到发request的地方，都要重写，假设重写后的请求叫Request2，在发请求的时候，发Request2。主要原因是想用requestId代替TMessage里seqId，但是Request的id是long型的，如果强转为int，那么当id增长到大于int的最大值时，到客户端处理时，拿到的Response的id是long型强转后的int值，在DefaultFuture里就找不到自己的future，可以在客户端这边做缓存，当Request的id大于int型的最大值，或小于int型的最小值时，把long型的RequestId和强转后的int值关联，但是觉得这样不太优雅，而且不及时删除这个缓存有可能引起内存泄露。所以自己就重写了Request2，把里面的INVOKER_ID改为AtomicInteger，其他的都没改，这样的话，Request的id就一直是int型，也可以直接替换TMessage里的seqId。涉及到发送Request的地方全都改成Request2。