百度360必应搜狗淘宝本站头条
分布式事务框架shiro框架java日志框架框架图cad怎么画框架
当前位置：网站首页 > 技术文章 > 正文

Netty实战篇-手写DubboRpc框架（netty4核心原理与手写）

ccwgpt 2025-04-01 16:20 26 浏览 0 评论

1. RPC 基本介绍

rpc是远程调用的一种行为，在数据传输过程中涉及到传输协议，http就是一种传输协议。

RPC（Remote Procedure Call）— 远程过程调用，是一个计算机通信协议。

  • 该协议允许运行于一台计算机的程序调用另一台计算机的子程序，而程序员无需额外地为这个交互作用编程。
  • 两个或多个应用程序都分布在不同的服务器上，它们之间的调用都像是本地方法调用一样

常见的 RPC 框架有:

  • 阿里的Dubbo
  • google的gRPC
  • Go语言的rpc
  • Apache的thrift
  • Spring旗下的 Spring Cloud。

2. RPC 调用流程

说明：

  1. 服务消费方(client)以本地调用方式调用服务
  2. client stub 接收到调用后负责将方法、参数等封装成能够进行网络传输的消息体
  3. client stub 将消息进行编码并发送到服务端
  4. server stub 收到消息后进行解码
  5. server stub 根据解码结果调用本地的服务
  6. 本地服务执行并将结果返回给 server stub
  7. server stub 将返回导入结果进行编码并发送至消费方
  8. client stub 接收到消息并进行解码】
  9. 服务消费方(client)得到结果

RPC 的目标就是将 2-8 这些步骤都封装起来，用户无需关心这些细节，可以像调用本地方法一样即可完成远程服务调用

3. 实现 dubbo RPC(基于 Netty)

3.1 需求说明

  • dubbo 底层使用了 Netty 作为网络通讯框架，要求用 Netty 实现一个简单的 RPC 框架
  • 模仿 dubbo，消费者和提供者约定接口和协议，消费者远程调用提供者的服务，提供者返回一个字符串，消费者打印提供者返回的数据。底层网络通信使用 Netty 4.1.20

    io.netty
    netty-all
    4.1.20.Final

3.2 设计说明

  • 创建一个接口，定义抽象方法。用于消费者和提供者之间的约定。
  • 创建一个提供者，该类需要监听消费者的请求，并按照约定返回数据。
  • 创建一个消费者，该类需要透明的调用自己不存在的方法，内部需要使用 Netty 请求提供者返回数据

3.3 代码实现

项目结构：

客户端启动器ClientBootstrap

public class ClientBootstrap {
    //定义协议头
    public static final String providerName = "HelloService#hello";
    
    public static void main(String[] args) throws InterruptedException {
        NettyClient client = new NettyClient();
        HelloService serviceProxy = (HelloService) client.getBean(HelloService.class, providerName);//拿到代理对象
        //        for (; ; ) {
        //调用客户端的方法
        //            Thread.sleep(2000);
        String result = serviceProxy.hello("阿昌来也");
        System.out.println("客户端调用服务端，结果为：" + result);
        //        }
    }
}

服务端启动器ServerBootstrap

public class ServerBootstrap {
    public static void main(String[] args) throws InterruptedException {
        NettyServer.startServer("127.0.0.1",7000);
    }
}

客户端初始化类NettyClient

public class NettyClient {
    //创建线程池
    private static ExecutorService executors = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
    private static NettyClientHandler nettyClientHandler;

    /**
     * 编写方式使用代理模式，获取一个代理对象
     * @param serviceClass service类
     * @param providerName 协议头
     * @return 代理对象
     */
    public Object getBean(final Class serviceClass,final String providerName){
        return Proxy.newProxyInstance(Thread.currentThread().getContextClassLoader(),
                                      new Class[]{serviceClass},
                                      ((proxy, method, args) -> {
                                          //客户端每调用一次就会进入该代码块
                                          //第一次调用
                                          if (nettyClientHandler==null){
                                              startClient0("127.0.0.1",7000);
                                          }

                                          //设置要发送给服务器的信息
                                          //providerName协议头，args传入的参数
                                          nettyClientHandler.setParam(providerName+args[0]);
                                          return executors.submit(nettyClientHandler).get();
                                      }
                                      ));
    }

    //初始化客户端
    private static void startClient0(String ipaddr,Integer port){
        nettyClientHandler = new NettyClientHandler();
        NioEventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            Bootstrap bootstrap = new Bootstrap();
            Bootstrap clientBootstrap = bootstrap.group(workerGroup)
                .channel(NioSocketChannel.class)
                .option(ChannelOption.TCP_NODELAY,true)
                .handler(new ChannelInitializer() {
                    @Override
                    protected void initChannel(SocketChannel socketChannel) throws Exception {
                        ChannelPipeline pipeline = socketChannel.pipeline();
                        pipeline.addLast(new StringEncoder());
                        pipeline.addLast(new StringDecoder());
                        pipeline.addLast(nettyClientHandler);
                    }
                });
            clientBootstrap.connect(ipaddr,port).sync();
        }catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

客户端处理器NettyClientHandler

public class NettyClientHandler extends ChannelInboundHandlerAdapter implements Callable {
    private ChannelHandlerContext channelHandlerContext;//上下文
    private String result;//调用的返回结果
    private String param;//客户端调用方法时的参数

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
    }

    //收到服务器的数据后就会被调用
    @Override
    public synchronized void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("channelRead");
        result = msg.toString();
        notify();//唤醒等待的线程
    }

    //与服务器连接成功后就会被调用
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("channelActive");
        channelHandlerContext = ctx;
    }

    //被代理对象调用，异步发送数据给服务器，然后阻塞，会等待被唤醒
    @Override
    public synchronized Object call() throws Exception {
        System.out.println("call1");
        channelHandlerContext.writeAndFlush(param);
        //进行wait阻塞
        wait();
        System.out.println("call2");

        return result;
    }


    //设置发送的数据
    void setParam(String msg){
        System.out.println("setParam");
        this.param = msg;
    }
    
}
复制代码

服务端初始化类NettyServer

public class NettyServer {

    public static  void startServer(String hostname,Integer port) throws InterruptedException {
        startServer0(hostname,port);
    }


    private static void startServer0(String hostname,Integer port) throws InterruptedException {
        NioEventLoopGroup boosGroup = new NioEventLoopGroup(1);
        NioEventLoopGroup workerGroup = new NioEventLoopGroup(8);
        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            ServerBootstrap serverBootstrap = bootstrap.group(boosGroup, workerGroup)
                //                    .handler(new LoggingHandler())
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer() {
                    @Override
                    protected void initChannel(SocketChannel socketChannel) throws Exception {
                        ChannelPipeline pipeline = socketChannel.pipeline();
                        pipeline.addLast(new StringDecoder());
                        pipeline.addLast(new StringEncoder());
                        pipeline.addLast(new NettyServerHandler());
                    }
                });
            System.out.println("服务端启动成功....端口："+port);
            ChannelFuture cf = serverBootstrap.bind(hostname, port).sync();
            cf.channel().closeFuture().sync();
        }finally {
            boosGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
    
}
复制代码

服务端处理器NettyServerHandler

public class NettyServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        //获取客户端发送来的消息，并调用服务
        System.out.println("msg="+msg);

        //客户端想要调用服务器的api时，想要满足一定协议的要求才能调用
        //比如，我们这里要求，每次发送消息时，都必须要求以"HelloService#hello开头"
        if (msg.toString().startsWith("HelloService#hello")){
            String result = new HelloServiceImpl().hello(msg.toString().split("HelloService#hello")[1]);
            ctx.writeAndFlush(result);
        }
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
    }
}

客户端接口的真正实现Impl:HelloServiceImpl

public class HelloServiceImpl implements HelloService {
    private static int count = 0;
    @Override
    public String hello(String message) {
        System.out.println("客户端发来的消息为：【"+message+"】");
        if (message!=null){
            return "你好客户端，服务端已经收到了消息"+"调用次数为：【"+(++count)+"】";
        }else {
            return "消息不能为空";
        }
    }
}

服务提供方 和 服务消费放 公共部分，约定的接口规范 HelloService

public interface HelloService {
    String hello(String message);
}




作者：hsfxuebao
链接：
https://juejin.cn/post/7102020346861060109

相关推荐

2025南通中考作文解读之四:结构框架

文题《继续走，迈向远方》结构框架：清晰叙事，层层递进示例结构：1.开头（点题）：用环境描写或比喻引出“走”与“远方”，如“人生如一条长路，每一次驻足后，都需要继续走，才能看见更美的风景”。2.中间...

高中数学的知识框架（高中数学知识框架图第三章）

高中数学的知识框架可以划分为多个核心板块，每个板块包含具体的知识点与内容，以下为详细的知识框架结构：基础知识1.集合与逻辑用语：涵盖集合的概念、表示方式、性质、运算，以及命题、四种命题关系、充分条件...

决定人生的六大框架（决定人生的要素）

45岁的自己混到今天，其实是失败的，要是早点意识到影响人生的六大框架，也不至于今天的模样啊！排第一的是环境，不是有句话叫人是环境的产物，身边的环境包括身边的人和事，这些都会对一个人产生深远的影响。其次...

2023年想考过一级造价师土建计量，看这30个知识点(三)

第二章工程构造考点一:工业建筑分类[考频分析]★★★1.按厂房层数分:(1)单层厂房;(2)多层厂房;(3)混合层数厂房。2.按工业建筑用途分:(1)生产厂房;(2)生产辅助厂房;(3)动力用厂房;(...

一级建造师习题集-建筑工程实务(第一章-第二节-2)

建筑工程管理与实务题库（章节练习）第一章建筑工程技术第二节结构设计与构造二、结构设计1.常见建筑结构体系中，适用建筑高度最小的是()。A.框架结构体系B.剪力墙结构体系C.框架-剪力墙结构体系D...

冷眼读书丨多塔斜拉桥，这么美又这么牛

”重大交通基础设施的建设是国民经济和社会发展的先导，是交通运输行业新技术集中应用与创新的综合体现。多塔斜拉桥因跨越能力强、地形适应性强、造型优美等特点，备受桥梁设计者的青睐，在未来跨越海峡工程中将得...

2021一级造价师土建计量知识点:民用建筑分类

2021造价考试备考开始了，学霸君为大家整理了一级造价师备考所用的知识点，希望对大家的备考道路上有所帮助。　　民用建筑分类　　一、按层数和高度分　　1.住宅建筑按层数分类：1～3层为低层住宅，4～6层...

6个建筑结构常见类型，你都知道吗?

建筑结构是建筑物中支承荷载（作用）起骨架作用的体系。结构是由构件组成的。构件有拉（压）杆、梁、板、柱、拱、壳、薄膜、索、基础等。常见的建筑结构类型有6种：砖混结构、砖木结构、框架结构、钢筋混凝土结构、...

框架结构设计经验总结（框架结构设计应注意哪些问题）

1.结构设计说明主要是设计依据，抗震等级，人防等级，地基情况及承载力，防潮抗渗做法，活荷载值，材料等级，施工中的注意事项，选用详图，通用详图或节点，以及在施工图中未画出而通过说明来表达的信息。2.各...

浅谈混凝土框架结构设计（混凝土框架结构设计主要内容）

浅谈混凝土框架结构设计　摘要：结构设计是个系统的全面的工作，需要扎实的理论知识功底，灵活创新的思维和严肃认真负责的工作态度。钢筋混凝土框架结构虽然相对简单，但设计中仍有很多需要注意的问题。本文针...

2022一级建造师《建筑实务》1A412020 结构设计 精细考点整理

历年真题分布统计1A412021常用建筑结构体系和应用一、混合结构体系【2012-3】指楼盖和屋盖采用钢筋混凝土或钢木结构，而墙和柱采用砌体结构建造的房屋，大多用在住宅、办公楼、教学楼建筑中。优点：...

破土动工!这个故宫“分院”科技含量有点儿高

故宫“分院”设计图。受访者供图近日，位于北京海淀区西北旺镇的故宫北院区项目已开始破土动工，该项目也被称作故宫“分院”，筹备近十年之久。据悉，故宫本院每年展览文物的数量不到1万件，但是“分院”建成后，预...

装配式结构体系介绍(上)（装配式结构如何设计）

PC构件深化、构件之间连接节点做法等与相应装配式结构体系密切相关。本节列举目前常见的几种装配式结构体系：装配整体式混凝土剪力墙结构体系、装配整体式混凝土框架结构体系、装配整体式混凝土空腔结构体系（S...

这些不是双向抗侧结构体系（这些不是双向抗侧结构体系的特点）

双向抗侧土木吧规范对双向抗恻力结构有何规定？为何不应采用单向有墙的结构？双向抗侧土木吧1.规范对双向抗侧力结构体系的要求抗侧力体系是指抵抗水平地震作用及风荷载的结构体系。对于结构体系的布置，规范针对...

2022一级建造师《建筑实务》1A412020 结构设计 精细化考点整理

1A412021常用建筑结构体系和应用一、混合结构体系【2012-3】指楼盖和屋盖采用钢筋混凝土或钢木结构，而墙和柱采用砌体结构建造的房屋，大多用在住宅、办公楼、教学楼建筑中。优点：抗压强度高，造价...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表