江苏龙网

  1. 首页 > 人文 > >

基于Netty高性能RPC框架Nifty协议、传输层、编解码( 二 )

继续往下看： TProtocolReader:
public Map readMap(ThriftCodec keyCodec, ThriftCodec valueCodec) throws Exception {TMap tMap = protocol.readMapBegin();Map map = new HashMap<>();for (int i = 0; i < tMap.size; i++) {K key = keyCodec.read(protocol);V value = http://kandian.youth.cn/index/valueCodec.read(protocol);map.put(key, value);}protocol.readMapEnd();return map;}复制代码是不是很容易理解 ， 拿到key和value的编解码器后 ， 不停的往下读即可 。
比较疑问的地方就是这里没有涉及到循环遍历i ， 实际上这是关于map的协议来决定的 ， protocal.readMapBegin在TBinaryProtocal中的实现是 ， 依次读取一个字节 ， 一个字节 ， 4个字节分别表示key的类型 ， value的类型和 元素数量 。 得到了map中元素数量tMap.size后 ， 由于每次读取key和value的时候buffer中的指针都会移动 ， 读完了value后 ， 能保证下次读到的就是下一个元素的key 。 最后将结果放到构建的hashMap中即可 。
1.2. 读取结构体方法的形参里面除了基本类型 ， 集合类型外 ， 经常还能遇到结构体类型 ， 对于java来说就是对象 ， 这个时候对应的处理如下 。
case STRUCT: {return factory.generateThriftTypeCodec(ThriftCodecManager.this, type.getStructMetadata());}复制代码做点小改动 ， 在这里使用一个新的ThriftCodecManager构造方法 ， 传入编解码器工厂类ReflectionThriftCodecFactory
ThriftCodecManager manager = new ThriftCodecManager(new ReflectionThriftCodecFactory());复制代码其实还有个工厂类CompilerThriftCodecFactory ， 看名字是个自建编译器的工厂类 ， 看过内部实现代码多而且不大好理解 ， 所以这里使用反射方式的编解码器工厂类 。
ReflectionThriftCodecFactory继承自ThriftCodecFactory ， 提供了获取编解码器的方法 。
public interface ThriftCodecFactory{ThriftCodec generateThriftTypeCodec(ThriftCodecManager codecManager, ThriftStructMetadata metadata);}复制代码ReflectionThriftCodecFactory的实现如下：
public class ReflectionThriftCodecFactory implements ThriftCodecFactory {@Overridepublic ThriftCodec generateThriftTypeCodec(ThriftCodecManager codecManager, ThriftStructMetadata metadata) {switch (metadata.getMetadataType()) {case STRUCT:return new ReflectionThriftStructCodec<>(codecManager, metadata);case UNION:return new ReflectionThriftUnionCodec<>(codecManager, metadata);default:throw new IllegalStateException(format("encountered type %s", metadata.getMetadataType()));}}}复制代码那么问题就是, ThriftStructMetadata如何得到以及干嘛用的, 看名字就知道这是保存结构体元数据的. 由type.getStructMetadata()得到, 那么问题就是如何构造的ThriftType . 其实在最开始构造ThriftServiceProcessor的时候就构造好了,
创建过程比较复杂 ， 简单来说就是：构建ThriftServiceProcessor的时候 ， 会将构建ThriftServiceMetadata；而构建ThriftServiceMetadata的时候会构建ThriftMethodMetadata；构建 的时候会构建List； 每个ThriftFieldMetadata都代表一个方法形参 ， 内部持有一个ThriftType, 到这里就知道了ThriftType是属于ThriftFieldMetadata ， 在构建ThriftMethodMetadata的时候会得到ThriftType ， 如何得到？其实就是根据方法形参得到ThriftType的 ， 从目录类ThriftCatalog获取到 ， 其内部存有一个Type和ThriftType的映射 ， 来简单看下 。


推荐阅读


上一篇：阿里投资、阅文、丰巢被罚

下一篇：南财对话丨专访闵万里：人工智能，离无所不能还有多远？