i1see1you / qiurpc Goto Github PK

    private Object handle(RpcRequest request) throws Throwable {
        String className = request.getClassName();
        Object rpcService = ExtensionLoader.getProxy(className);
        if (null == rpcService)
            throw new NullPointerException("server interface config is null");

        Method method = ReflectionCache.getMethod(request.getInterfaceName(),
                request.getMethodName(), request.getParameterTypes());
        Object[] parameters = request.getParameters();
        // invoke
        Object result = method.invoke(rpcService, parameters);
        return result;
    }

    //如果是异步，则封装context
            RpcContext.getContext().setFuture(new FutureAdapter<Object>(invokeFuture));
            return new RpcResponse();