thrift/swift:ThriftMethodProcessor代码分析

private Object[] readArguments(TProtocol in)
            throws Exception
    {
        try {
            int numArgs = method.getParameterTypes().length;
            // 初始化参数数组，初始值都为null
            Object[] args = new Object[numArgs];
            TProtocolReader reader = new TProtocolReader(in);

            // 先从收到的数据库根据fieldId 将不为null的服务方法参数解析出来，
            // 为null的参数不在收到的数据中出现
            // 所以这个循环结束时，不为null的参数已经被正确解析并保存到args的对应位置了
            // client填null(原本就是null)的参数对应的位置就是null,
            reader.readStructBegin();
            while (reader.nextField()) {
                short fieldId = reader.getFieldId();

                ThriftCodec<?> codec = parameterCodecs.get(fieldId);
                if (codec == null) {
                    // unknown field
                    reader.skipFieldData();
                }
                else {
                    // 将参数调用对应用的解码器ThriftCodec解析成正确的数据类型，
                    // 存入arg数组对应的位置
                    args[thriftParameterIdToJavaArgumentListPositionMap.get(fieldId)] = reader.readField(codec);
                }
            }
            reader.readStructEnd();

            // 在下面这个循环中，对args数组中为null的参数进行检查，
            // 如果是primitive类型则调用 Defaults.defaultValue方法返回缺省值
            // 比如对于Integer类型缺省值就是0
            // 如果删除掉这一整段循环代码，service端收到的Integer参数就可以是null
            int argumentPosition = 0;
            for (ThriftFieldMetadata argument : parameters) {
                if (args[argumentPosition] == null) {
                    Type argumentType = argument.getThriftType().getJavaType();

                    if (argumentType instanceof Class) {
                        Class<?> argumentClass = (Class<?>) argumentType;
                        argumentClass = Primitives.unwrap(argumentClass);
                        args[argumentPosition] = Defaults.defaultValue(argumentClass);
                    }
                }
                argumentPosition++;
            }

            return args;
        }
        catch (TProtocolException e) {
            // TProtocolException is the only recoverable exception
            // Other exceptions may have left the input stream in corrupted state so we must
            // tear down the socket.
            throw new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
        }
    }