当前位置：首页 > news >正文

Rpc了解

news 来源：原创 2024/11/15 21:36:01

1、为什么要有rpc?

因为微服务之间需要进行服务间的通信，不同服务之间的接口要互相调用。而常见的通信协议主要有 RPC 和 REST 协议

使用rpc的好处是：

引入RPC框架对我们现有的代码影响最小，同时又可以帮我们实现架构上的扩展

两者对比

2、什么是Rpc

Remote Procdeure Call ，即远程过程调用，是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络实现的技术。

RPC 是一种进程间通信方式，允许像调用本地服务一样调用远程服务

例如微服务中有订单服务需要调用用户服务获取用户信息，之前的方法可能是通过http请求来访问接口，获取信息，现在调用时，只需要知道获取用户信息的接口的类名、方法名，传入相应参数，就可以获取到对应的用户信息。

3、Rpc流程

客户端以本地调用方式发起请求，请求内容包括：远程方法在本地的模拟对象，方法名，方法参数，将请求内容包装后的信息通过网络发送到服务端。
服务端收到消息后，进行解码为实际的方法名和参数
服务端本地服务执行并将结果返回
服务端将返回结果打包成消息并发送至客户端
客户端收到消息后，解码，获取响应内容

4、Rpc使用到的核心技术

代理，为什么要有代理，因为客户端只管发送请求，获取响应，至于过程如何不关心，所以需要一个代理来进行中间过程的封装。
反射，服务端收到请求后，需要通过反射机制来获取要调用的方法的对象，执行对应的方法
序列化，网络传输过程中需要先将数据进行序列化才能进行传输，接收到数据后需要将数据进行反序列化才能进行下一步操作。

5、一个简单的RpcDemo

发起服务端

package com.ljx.splearn.RpcDemo;

public class Main{

    public static void main(String[] args) throws Exception{
        //RPC调用，客户端获取要调用的服务并发起调用
        UserService service=(UserService)Client.getStub(UserService.class);
        User user = service.findUserByID(222);
        System.out.println(user.getName());

    }
}

client实现，重要类

package com.ljx.splearn.RpcDemo;

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.net.Socket;

public class Client{
    //远程调用类
    public static Object getStub(final Class clazz) throws Exception{
        InvocationHandler handler = new InvocationHandler() {
            @Override
            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
                //通过socket将请求发送到服务方
                Socket socket = new Socket("127.0.0.1", 8888);
                ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
                String className = clazz.getName();
                String methodName = method.getName();
                Class[] parametersTypes = method.getParameterTypes();
                oos.writeUTF(className);
                oos.writeUTF(methodName);
                oos.writeObject(parametersTypes);
                oos.writeObject(args);
                oos.flush();
                ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
                Object o = ois.readObject();
                oos.close();
                socket.close();
                return o ;
            }
        };
        //通过代理实现方法调用
        Object o = Proxy.newProxyInstance(clazz.getClassLoader(),
                new Class[]{clazz},handler);
        return o;
    }
}

服务端启动一个socket，接收传递过来的请求数据，通过反射获取方法名和参数，并调用方法返回结果

package com.ljx.splearn.RpcDemo;

import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.lang.reflect.Method;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服务端
 */
public class Server {
    private static boolean running = true;
    public static void main(String[] args) throws  Exception{
        //启动一个socket方法
        ServerSocket serverSocket = new ServerSocket(8888);
        while (running){
            Socket socket = serverSocket.accept();
            process(socket);
            socket.close();
        }
        serverSocket.close();
    }
    private static void  process(Socket socket) throws Exception{
        InputStream in = socket.getInputStream();
        OutputStream out = socket.getOutputStream();
        ObjectInputStream ois = new ObjectInputStream(in);
        
        // 拿到客户端传递过来的class
        String clazzName =ois.readUTF();
        String methodName =ois.readUTF();
        Class[] parameterTypes = (Class[])ois.readObject();
        Object[] args =(Object[])ois.readObject();
        //反射拿到class
        //通过反射可以获取所有的接口类
        Class clazz =Class.forName(clazzName);
        if(clazz.isInterface()){
            if(clazzName.equals("com.ljx.splearn.RpcDemo.UserService")){
                clazz = UserServiceImpl.class;
            }
        }
        //使用反射获取结果
        Method method = clazz.getMethod(methodName,parameterTypes);
        Object object = method.invoke(clazz.newInstance(),args);
        //通过socket将结果返回
        ObjectOutputStream oos = new ObjectOutputStream(out);
        oos.writeObject(object);
        oos.flush();
    }
}

服务调用的接口和实体类

package com.ljx.splearn.RpcDemo;

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

/**
 * @author lijianxi
 * @date 2023年01月16日 10:40 上午
 */
@Data
@AllArgsConstructor
public class User implements Serializable {
    Integer id;
    String name;

}

package com.ljx.splearn.RpcDemo;

public interface UserService {
    public User findUserByID(Integer id);
}

package com.ljx.splearn.RpcDemo;

public class UserServiceImpl implements UserService {
    @Override
    public User findUserByID(Integer id) {
        return new User(id, "ljx");
    }

 
}

启动server,调用main

结果如下

6、RPC和HTTP

    1、RPC是远程过程调用，只是对不同应用间相互调用的一种描述，它是一种思想。具体怎么调用？实现方式可以是最直接的TCP通信，也可以是HTTP方式。
    2、HTTP是应用层的一种协议，负责服务之间的通信操作。
    3、dubbo是基于tcp通信的，gRPC是Google公布的开源软件，基于最新的HTTP2.0协议，底层使用到了Netty框架的支持。