除了Json序列化方式其他的序列化方式的问题

这个异常解决了 **{java.lang.ClassCastException: org.xhystudy.rpc.common.RpcRequest cannot be cast to org.xhystudy.rpc.common.RpcResponse}**

但是我现在重新克隆你的项目进行运行，发现把项目的rpc序列化方式换成hessian时，会报这个错误

**Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.lang.RuntimeException: rpc 调用失败,无服务可用 serviceName: {org.xhystudy.rpc.demo.TestService$1.0}, 异常信息: {java.lang.reflect.InvocationTargetException}] with root cause**

**ThreadPollFactory类的方法** 
```
public static void submitRequest(ChannelHandlerContext ctx, RpcProtocol<RpcRequest> protocol){

final RpcRequest request = protocol.getBody();
        String key = request.getClassName() + request.getMethodName() + request.getServiceVersion();
        ThreadPoolExecutor poll = fastPoll;
        if (slowTaskMap.containsKey(key) && slowTaskMap.get(key).intValue() >= 10){
            poll = slowPoll;
        }
        poll.submit(()->{
            RpcProtocol<RpcResponse> resProtocol = new RpcProtocol<>();
            final MsgHeader header = protocol.getHeader();
            RpcResponse response = new RpcResponse();
            long startTime = System.currentTimeMillis();

try {
                final Object result = submit(ctx, protocol);
                response.setData(result);
                response.setDataClass(result == null ? null : result.getClass());
                header.setStatus((byte) MsgStatus.SUCCESS.ordinal());
            } catch (Exception e) {
                // 执行业务失败则将异常返回
                header.setStatus((byte) MsgStatus.FAILED.ordinal());
                response.setException(e);
                logger.error("process request {} error", header.getRequestId(), e);
            }finally {
                long cost = System.currentTimeMillis() - startTime;
                System.out.println("cost time:" + cost);
                if(cost > 1000){
                    final AtomicInteger timeOutCount = slowTaskMap.putIfAbsent(key, new AtomicInteger(1));
                    if (timeOutCount!=null){
                        timeOutCount.incrementAndGet();
                    }
                }
            }
            resProtocol.setHeader(header);
            resProtocol.setBody(response);
            logger.info("执行成功: {},{},{},{}",Thread.currentThread().getName(),request.getClassName(),request.getMethodName(),request.getServiceVersion());
            ctx.fireChannelRead(resProtocol);
        });
    }

private static Object submit(ChannelHandlerContext ctx, RpcProtocol<RpcRequest> protocol) throws Exception{
        // 这个代码没有作用
        RpcProtocol<RpcResponse> resProtocol = new RpcProtocol<>();
        MsgHeader header = protocol.getHeader();
        header.setMsgType((byte) MsgType.RESPONSE.ordinal());

final RpcRequest request = protocol.getBody();
        // 执行具体业务
        return handle(request);
    }

/**
     * 调用方法，获取返回值
     *
     * @param request
     * @return
     * @throws Exception
     */
    private static Object handle(RpcRequest request) throws Exception {
        // 获取服务名
        String serviceKey = RpcServiceNameBuilder.buildServiceKey(request.getClassName(), request.getServiceVersion());
        // 获取服务的实例类
        Object serviceBean = rpcServiceMap.get(serviceKey);

if (serviceBean == null) {
            throw new RuntimeException(String.format("service not exist: %s:%s", request.getClassName(), request.getMethodName()));
        }

// 获取服务提供方信息并创建
        Class<?> serviceClass = serviceBean.getClass(); // 服务实现类
        String methodName = request.getMethodName();    // 服务实现类的方法
        Class<?>[] parameterTypes = request.getParameterTypes(); // 参数类型
        Object[] parameters = new Object[]{request.getData()}; // 参数

// 提供对类的快速访问和调用
        FastClass fastClass = FastClass.create(serviceClass);
        // 获取到的指定方法在目标类中的索引值，可以用于后续的快速方法调用
        int methodIndex = fastClass.getIndex(methodName, parameterTypes);

// 调用方法并返回结果
        return fastClass.invoke(methodIndex, serviceBean, parameters);
    }
```
修改前或者修改后的代码都是  **methodIndex=0 找到匹配的方法**  ，好像数据也没有问题
![输入图片说明](https://foruda.gitee.com/images/1712924677247607529/53b5577f_12927660.png "屏幕截图")

但是一直执行到这段代码就报错  **fastClass.invoke(methodIndex, serviceBean, parameters)** 直接报错

但是在json序列化方式中却能正常运行并成功返回结果, 显示的数据都一样，我换成普通反射调用也不行。

Xhy/Xhy-Rpc

内容风险标识

评论 (10)