2. [netty-RPC]--消息的请求、响应与接口和实现的映射容器

淡淡的烟草味﹌ 2022-07-12 04:24 108阅读 0赞

首先来说说服务端和客户端交互的中介，也就是消息的请求和响应的定义 以及 服务端对接口和实现的映射容器。

## RPC请求消息结构 ##

先给出源码：

package com.netty.rpc.model;
    
    
    import org.apache.commons.lang3.builder.ReflectionToStringBuilder;
    
    import java.io.Serializable;
    
    /** * 消息的请求体 */
    public class MessageRequest implements Serializable { 
    
        private String messageId;//消息ID
        private String className;//类名称
        private String methodName;//方法名称
        private Class<?>[] typeParameters;//参数结构
        private Object[] parametersVal;//参数值
    
        public String getMessageId() {
            return messageId;
        }
    
        public void setMessageId(String messageId) {
            this.messageId = messageId;
        }
    
        public String getClassName() {
            return className;
        }
    
        public void setClassName(String className) {
            this.className = className;
        }
    
        public String getMethodName() {
            return methodName;
        }
    
        public void setMethodName(String methodName) {
            this.methodName = methodName;
        }
    
        public Class<?>[] getTypeParameters() {
            return typeParameters;
        }
    
        public void setTypeParameters(Class<?>[] typeParameters) {
            this.typeParameters = typeParameters;
        }
    
        public Object[] getParameters() {
            return parametersVal;
        }
    
        public void setParameters(Object[] parametersVal) {
            this.parametersVal = parametersVal;
        }
    
        public String toString() {
            return ReflectionToStringBuilder.toStringExclude(this, new String[]{
       "typeParameters", "parametersVal"});
        }
    }

请求消息给出了消息的id，类名称，方法名称，参数类型结构，以及参数值等信息传递到服务器。

## RPC响应消息体 ##

给出源码：

package com.netty.rpc.model;
    
    import org.apache.commons.lang3.builder.ReflectionToStringBuilder;
    
    import java.io.Serializable;
    
    /** * 响应的请求体 */
    public class MessageResponse implements Serializable { 
    
        private String messageId;//消息ID
        private String error;//错误码
        private Object resultDesc;//返回的结果序列化对象
    
        public String getMessageId() {
            return messageId;
        }
    
        public void setMessageId(String messageId) {
            this.messageId = messageId;
        }
    
        public String getError() {
            return error;
        }
    
        public void setError(String error) {
            this.error = error;
        }
    
        public Object getResult() {
            return resultDesc;
        }
    
        public void setResult(Object resultDesc) {
            this.resultDesc = resultDesc;
        }
    
        public String toString() {
            return ReflectionToStringBuilder.toString(this);
        }
    }

响应消息体里面也给出了 消息的id， 错误码做标志位，以及返回的实例对象的序列化之后的对象。

切记这里的MessageRequest和MessageResponse 都一定要实现序列化接口，这样消息在网络上传输时才能被编码成字节序列传输。

## RPC服务端接口定义和实现映射关系容器 ##

package com.netty.rpc.model;
    
    import java.util.Map;
    
    /** * 服务器端RPC接口定义和RPC接口实现类对象的映射关系 */
    public class MessageKeyVal { 
    
        private Map<String, Object> messageKeyVal;
    
        public void setMessageKeyVal(Map<String, Object> messageKeyVal) {
            this.messageKeyVal = messageKeyVal;
        }
    
        public Map<String, Object> getMessageKeyVal() {
            return messageKeyVal;
        }
    }

这里其实就是一个Map集合，根据请求消息的信息找到具体的实现类。