锟斤拷锟斤拷位锟矫ｏ拷锟斤拷页 > 锟斤拷锟斤拷锟教筹拷 > 锟教筹拷 > Dubbo锟斤拷艿锟�1锟斤拷锟斤拷锟斤拷锟斤拷频锟�

Dubbo锟斤拷艿锟�1锟斤拷锟斤拷锟斤拷锟斤拷频锟�

锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷|锟斤拷时锟戒：2024-09-14 09:54:51 |锟斤拷锟侥讹拷锟斤拷154锟斤拷|锟斤拷锟斤拷签锟斤拷锟斤拷锟斤拷锟斤拷锟� 锟斤拷 |锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

锟斤拷锟斤拷锟斤拷戏

Java锟斤拷锟斤拷要说锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟絉PC锟斤拷艿锟斤拷锟紻ubbo锟斤拷原锟斤拷锟斤拷锟斤拷锟洁，锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟揭的伙拷锟斤拷锟斤拷锟斤拷远锟教碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟狡得猴拷锟斤拷锟斤拷锟斤拷锟斤拷

Java锟斤拷锟斤拷要说锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟絉PC锟斤拷艿锟斤拷锟紻ubbo锟斤拷原锟斤拷锟斤拷锟斤拷锟洁，锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟揭的伙拷锟斤拷锟斤拷锟斤拷远锟教碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟狡得猴拷锟斤拷锟斤拷锟斤拷锟斤拷

1锟斤拷Dubbo锟脚碉拷隙啵拷锟街伙拷锟斤拷锟斤拷锟揭�

1.1锟斤拷锟脚碉拷

业锟节讹拷锟斤拷微锟斤拷锟斤拷之锟斤拷锟斤拷玫目锟斤拷选锟斤拷隙啵拷锟斤拷锟斤拷锟絊pring Cloud锟斤拷Rest锟斤拷式锟斤拷 Dubbo锟斤拷式锟斤拷锟斤拷使锟斤拷Dubbo锟斤拷式锟接多。Dubbo锟斤拷业锟斤拷锟斤拷锟矫ｏ拷锟饺讹拷锟街革拷效锟斤拷锟斤拷锟杰革拷锟斤拷司锟叫凤拷同学锟斤拷喜锟斤拷锟斤拷

Dubbo锟斤拷锟脚碉拷隙啵拷锟斤拷纾�

锟斤拷锟斤拷锟斤拷 锟斤拷Dubbo 使锟矫碉拷锟角伙拷锟斤拷 Netty 锟斤拷锟皆讹拷锟斤拷通锟斤拷协锟介，锟结供锟剿革拷效锟侥讹拷锟斤拷锟斤拷锟斤拷锟捷达拷锟戒，使锟斤拷远锟教凤拷锟斤拷锟斤拷锟斤拷锟斤拷艽锟斤拷锟斤拷锟斤拷锟斤拷
模锟介化锟斤拷锟� 锟斤拷Dubbo 锟侥架癸拷锟角筹拷模锟介化锟斤拷锟斤拷要锟斤拷锟斤拷锟斤拷锟斤拷模锟斤拷锟斤拷桑锟皆讹拷痰锟斤拷锟侥ｏ拷椋≧PC锟斤拷锟斤拷锟斤拷群模锟介、锟斤拷锟截撅拷锟斤拷模锟介、锟捷达拷模锟斤拷锟阶拷锟斤拷锟斤拷锟侥ｏ拷椤�
每锟斤拷锟斤拷锟斤拷锟斤拷支锟街讹拷协锟斤拷 锟斤拷每锟斤拷锟斤拷锟斤拷锟斤拷支锟街讹拷锟斤拷协锟介，锟斤拷锟斤拷注锟斤拷锟斤拷锟侥ｏ拷支锟斤拷ZK锟斤拷Redis锟斤拷Nacos锟饺等★拷
锟斤拷锟截撅拷锟斤拷锟斤拷荽锟� 锟斤拷Dubbo 锟结供锟剿讹拷锟斤拷锟捷达拷锟斤拷锟狡ｏ拷锟斤拷锟斤拷失锟斤拷锟斤拷锟皆★拷失锟斤拷转锟狡等★拷锟斤拷支锟街讹拷锟街革拷锟截撅拷锟解，锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟窖拷锟揭伙拷锟斤拷怨锟较ｏ拷取锟�
锟斤拷锟斤拷注锟斤拷头锟斤拷锟� 锟斤拷Dubbo锟斤拷锟斤拷锟斤拷注锟斤拷锟斤拷锟侥的革拷锟筋，实锟斤拷锟剿凤拷锟斤拷锟斤拷远锟阶拷锟酵凤拷锟街★拷
SPI 锟斤拷展锟斤拷锟斤拷 锟斤拷锟斤拷 锟斤拷锟剿癸拷锟斤拷 锟斤拷锟斤拷锟铰ｏ拷Dubbo锟斤拷锟结及锟斤拷锟侥撅拷锟斤拷使锟斤拷锟斤拷锟斤拷锟斤拷Java锟斤拷SPI锟斤拷锟狡ｏ拷锟斤拷锟斤拷锟斤拷锟秸癸拷裕锟斤拷锟揭伙拷锟斤拷锟斤拷呒锟斤拷锟斤拷锟斤拷呒锟斤拷前伞锟�

1.2锟斤拷锟斤拷锟斤拷锟斤拷一

锟斤拷锟角ｏ拷Dubbo锟斤拷锟斤拷锟斤拷锟剿的ｏ拷 锟斤拷支锟斤拷 锟斤拷锟矫凤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷RPC锟斤拷锟矫★拷Dubbo锟侥讹拷位锟斤拷一锟斤拷RPC锟斤拷埽锟斤拷锟斤拷锟斤拷锟斤拷暮锟斤拷暮锟斤拷锟斤拷锟街拷兀锟斤拷锟斤拷锟紻ubbo锟斤拷RPC锟侥碉拷锟矫癸拷锟斤拷透锟斤拷锟斤拷锟斤拷使锟矫匡拷锟斤拷锟竭匡拷锟斤拷专注锟斤拷业锟斤拷锟竭硷拷锟斤拷锟斤拷锟斤拷锟矫癸拷注锟阶诧拷通锟斤拷锟斤拷锟解。

一锟斤拷RPC锟斤拷锟街伙拷芯劢锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟絉PC锟斤拷锟矫癸拷锟斤拷锟斤拷锟侥ｏ拷椋拷呕锟斤拷锟斤拷斯锟阶拷锟斤拷锟斤拷锟斤拷锟脚点都锟斤拷锟斤拷锟斤拷之锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

锟斤拷锟竭斤拷RPC锟斤拷锟矫碉拷锟斤拷锟斤拷锟斤拷蹋锟斤拷锟斤拷锟斤拷 一锟斤拷协锟斤拷锟斤拷息锟侥达拷锟斤拷锟斤拷锟� 锟斤拷锟斤拷通锟斤拷 锟斤拷锟狡猴拷锟竭程的等达拷锟酵伙拷锟斤拷 锟斤拷锟斤拷实锟斤拷远锟教凤拷锟斤拷锟斤拷锟矫★拷锟斤拷一锟斤拷锟剿悸凤拷锟斤拷锟斤拷锟斤拷睿拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟竭碉拷锟角慧★拷

2锟斤拷RPC锟斤拷锟斤拷示锟斤拷

学Dubbo锟斤拷锟斤拷锟饺撅拷锟斤拷要学习锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷思路锟斤拷锟斤拷锟节此ｏ拷锟斤拷实锟斤拷一锟斤拷锟斤拷锟阶碉拷远锟教凤拷锟斤拷锟斤拷锟矫ｏ拷锟斤拷Dubbo锟斤拷RPC锟斤拷锟教硷拷锟阶伙拷锟斤拷

2.1锟斤拷示锟斤拷锟斤拷锟斤拷

锟斤拷锟阶碉拷RPC锟斤拷锟教诧拷锟斤拷锟斤拷锟铰ｏ拷锟斤拷锟铰凤拷5锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷Netty锟斤拷锟斤拷Socket通讯锟斤拷锟竭★拷

使锟斤拷2锟斤拷Java锟斤拷锟斤拷锟斤拷模锟斤拷2锟斤拷系统之锟斤拷牡锟斤拷茫锟紸锟斤拷锟斤拷锟斤拷 B锟斤拷锟教★拷
A锟斤拷锟教碉拷某锟斤拷锟斤拷锟斤拷锟斤拷使锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟紹锟斤拷锟教碉拷某锟斤拷锟斤拷锟斤拷锟斤拷
然锟斤拷A锟斤拷锟教的凤拷锟斤拷锟酵达拷锟节等达拷状态锟斤拷
锟斤拷B锟斤拷锟教的凤拷锟斤拷执锟斤拷锟斤拷之锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷通知锟斤拷A锟斤拷锟教★拷
然锟斤拷A锟斤拷锟教的凤拷锟斤拷锟斤拷锟斤拷锟窖ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷执锟叫★拷

Dubbo框架的1个核心设计点

2.2锟斤拷示锟斤拷锟斤拷锟斤拷

B锟斤拷锟斤拷锟斤拷为锟斤拷锟斤拷耍锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

public class BProcessServer {
    private final int port;
    public BProcessServer(int port) {
        this.port = port;
    }

    public void start() throws InterruptedException {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer() {
                        @Override
                        protected void initChannel(SocketChannel ch) {
                            ch.pipeline().addLast(new BProcessServerHandler());
                        }
                    });

            ChannelFuture future = bootstrap.bind(port).sync();
            System.out.println("B锟斤拷锟斤拷锟剿凤拷锟今，端口猴拷: " + port);
            future.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }

    public static void main(String[] args) throws InterruptedException {
        new BProcessServer(8088).start();
    }
}

B锟斤拷锟教斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷谢锟街拷锟街达拷卸锟接︼拷姆锟斤拷锟斤拷锟斤拷俳锟街达拷薪锟斤拷锟斤拷锟截ｏ拷

public class BProcessServerHandler extends SimpleChannelInboundHandler {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
        String reqData = msg.toString(CharsetUtil.UTF_8);
        System.out.println("B锟斤拷锟教斤拷锟杰碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷: " + reqData);

        executeMethod(ctx);
    }

    /**
     * 执锟叫凤拷锟斤拷
     *
     * @param ctx
     * @throws InterruptedException
     */
    private void executeMethod(ChannelHandlerContext ctx) throws InterruptedException {
        // TODO 锟斤拷锟斤拷锟斤拷锟斤拷息锟斤拷锟斤拷某锟街癸拷锟斤拷锟斤拷锟斤拷煞锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷龋锟斤拷锟绞碉拷锟斤拷欠锟斤拷锟斤拷谢锟斤拷墓锟斤拷獭锟�
        System.out.println("锟皆斤拷锟杰碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟叫伙拷锟斤拷然锟斤拷始执锟斤拷 锟斤拷息锟斤拷锟斤拷指锟斤拷锟侥凤拷锟斤拷...");

        // 模锟解方锟斤拷执锟斤拷
        Thread.sleep(2000);
        System.out.println("执锟斤拷锟斤拷希锟斤拷锟斤拷亟锟斤拷...");

        // 锟斤拷锟斤拷锟� 通知锟斤拷 A 锟斤拷锟斤拷
        ByteBuf dataByteBuf = ctx.alloc().buffer().writeBytes("Task completed".getBytes(CharsetUtil.UTF_8));
        ctx.writeAndFlush(dataByteBuf);
    }

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

A锟斤拷锟斤拷锟斤拷锟斤拷Netty锟酵伙拷锟剿ｏ拷锟斤拷锟斤拷锟斤拷B锟斤拷锟教碉拷通锟脚ｏ拷然锟斤拷锟斤拷远锟教碉拷锟矫ｏ拷锟斤拷锟节等达拷状态锟斤拷

public class AProcessClient {

    private final String host;
    private final int port;
    private final Object lock = new Object();  // 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

    public AProcessClient(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void start() throws InterruptedException {
        EventLoopGroup group = new NioEventLoopGroup();

        try {
            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(group)
                    .channel(NioSocketChannel.class)
                    .handler(new ChannelInitializer() {
                        @Override
                        protected void initChannel(SocketChannel ch) {
                            ch.pipeline().addLast(new AProcessClientHandler(lock));
                        }
                    });

            ChannelFuture future = bootstrap.connect(host, port).sync();
            System.out.println("A锟斤拷锟斤拷锟斤拷B锟斤拷锟教斤拷锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷");

            Channel channel = future.channel();

            // 锟斤拷锟斤拷远锟教碉拷锟斤拷
            callRemoteMethod(channel);

            channel.closeFuture().sync();
        } finally {
            group.shutdownGracefully();
        }
    }

    /**
     * 执锟叫凤拷锟斤拷
     *
     * @param channel
     * @throws InterruptedException
     */
    private void callRemoteMethod(Channel channel) throws InterruptedException {
        //TODO 锟剿达拷锟斤拷要锟斤拷锟斤拷锟矫的凤拷锟斤拷锟酵诧拷锟斤拷锟斤拷锟斤拷锟斤拷协锟斤拷锟斤拷锟斤拷锟斤拷谢锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷省去锟剿癸拷锟教★拷
        System.out.println("A锟斤拷锟教斤拷 锟斤拷锟斤拷姆锟斤拷锟斤拷筒锟斤拷锟� 锟斤拷锟斤拷锟斤拷锟叫伙拷锟斤拷然锟斤拷锟斤拷B锟斤拷锟教凤拷锟斤拷锟斤拷锟斤拷锟斤拷锟�...");

        ByteBuf dataByteBuf = channel.alloc().buffer().writeBytes("Start call method".getBytes(CharsetUtil.UTF_8));

        channel.writeAndFlush(dataByteBuf);

        // 使锟斤拷wait锟饺达拷B锟斤拷锟斤拷通知
        synchronized (lock) {
            System.out.println("A锟斤拷锟教等达拷B锟斤拷锟教碉拷锟斤拷应...");
            lock.wait();  // 锟饺达拷通知
        }

        System.out.println("A锟斤拷锟斤拷锟秸碉拷锟斤拷B锟斤拷锟教碉拷锟斤拷应通知锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷...");
    }

    public static void main(String[] args) throws InterruptedException {
        new AProcessClient("localhost", 8088).start();
    }
}

A锟斤拷锟教斤拷锟斤拷B锟斤拷锟教碉拷锟斤拷应锟斤拷同时锟斤拷锟斤拷锟窖ｏ拷然锟斤拷锟斤拷锟斤拷 lock.wait() 锟皆猴拷拇锟斤拷锟斤拷锟皆硷拷锟斤拷执锟叫★拷

public class AProcessClientHandler extends SimpleChannelInboundHandler {

    private final Object lock;

    public AProcessClientHandler(Object lock) {
        this.lock = lock;
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
        String resData = msg.toString(CharsetUtil.UTF_8);
        System.out.println("A锟斤拷锟教斤拷锟杰碉拷锟斤拷锟斤拷应锟斤拷锟斤拷: " + resData);

        // B 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷桑锟绞癸拷锟� notify 锟斤拷锟窖等达拷锟斤拷锟竭筹拷
        synchronized (lock) {
            lock.notify();  // 锟斤拷锟斤拷 A 锟斤拷锟斤拷
        }
    }

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

3锟斤拷锟杰斤拷

Dubbo锟斤拷锟斤拷锟斤拷锟斤拷锟剿悸凤拷锟斤拷锟斤拷啵拷锟街伙拷锟斤拷锟斤拷锟揭伙拷锟斤拷蔷锟斤拷锟絉PC锟侥碉拷锟矫癸拷锟教★拷锟斤拷锟斤拷锟斤拷一锟斤拷锟斤拷锟阶碉拷RPC远锟教碉拷锟矫碉拷示锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷Dubbo锟斤拷原锟斤拷锟斤拷源锟诫，希锟斤拷锟斤拷锟斤拷锟叫帮拷锟斤拷锟斤拷

锟斤拷篇锟斤拷幔★拷锟接� 锟斤拷注锟斤拷锟斤拷V(yclxiao)锟斤拷锟斤拷锟斤拷全锟斤拷锟斤拷锟斤拷(锟斤拷锟斤拷员锟斤拷支锟斤拷)

原锟斤拷锟斤拷锟接ｏ拷 https://mp.weixin.qq.com/s/J0fzDH-iqGnnnjqaXMLs-A

Dubbo框架的1个核心设计点

小锟斤拷锟狡硷拷锟侥讹拷

锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟侥斤拷为锟斤拷锟斤拷锟斤拷息锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷同锟斤拷锟睫观碉拷锟街な碉拷锟斤拷锟斤拷锟斤拷锟�

锟斤拷锟斤拷: 锟斤拷锟酵ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷营状态锟斤拷锟斤拷式锟斤拷营锟斤拷锟斤拷锟斤拷锟皆ｏ拷英锟斤拷锟斤拷锟斤拷; 锟斤拷戏锟斤拷锟斤拷

锟斤拷戏锟斤拷锟�

锟斤拷戏锟斤拷频

锟斤拷戏锟斤拷锟斤拷

锟斤拷戏锟筋动; 锟斤拷锟斤拷锟侥★拷锟斤拷CORE锟斤拷锟斤拷锟斤拷戏锟斤拷FURYJAM锟斤拷锟铰碉拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟轿ｏ拷锟斤拷戏锟叫ｏ拷锟斤拷医锟斤拷锟斤拷品锟斤拷锟侥帮拷色小锟斤拷锟侥ｏ拷锟斤拷锟斤拷锟斤拷