Java教程：dubbo源码解析-网络通信

       在之前的源码内容中，我们探讨了消费者端服务发现与提供者端服务暴露的打包相关内容，同时了解到消费者端通过内置的源码负载均衡算法获取合适的调用invoker进行远程调用。接下来，打包我们聚焦于远程调用过程，源码即网络通信的打包regnet 源码细节。

       网络通信位于Remoting模块中，源码支持多种通信协议，打包包括但不限于：dubbo协议、源码rmi协议、打包hessian协议、源码pm源并重新安装。打包对于启动时的源码InetSocketAddress错误，可能需要降级到Java 8版本来解决。打包

Dubbo源码：跟着Demo学习基本使用

       Dubbo 是源码一款由阿里开源的高性能轻量级RPC框架，因其在各大企业如阿里、京东、小米、携程等的广泛应用而备受瞩目。本文将通过一个基础Demo，带你了解Dubbo的基本使用步骤。

       首先，你需要设置一个ZooKeeper服务器作为服务注册中心。爱之谷源码ZooKeeper是Dubbo生产环境中的常见选择。下载并解压zookeeper-3.4..tar.gz包，然后修改conf/zoo.cfg配置，启动ZooKeeper服务。

       接下来，定义业务接口，即Dubbo Provider和Consumer之间的约定，如dubbo-demo-interface模块中的DemoService接口。它包含sayHello()和sayHelloAsync()方法。

       在dubbo-demo-xml模块中，提供了基于Spring XML的Provider和Consumer实现。在Provider端的dubbo-provider.xml中，配置DemoServiceImpl为Spring Bean，并暴露到ZooKeeper。在Consumer端的dubbo-consumer.xml中，配置ZooKeeper地址，并使用dubbo:reference引入DemoService，以便远程调用其提供的服务。

       启动Consumer端的Application，通过ClassPathXmlApplicationContext加载配置文件，即可实现服务的调用。如果你有任何问题或需求，微视频源码欢迎留言互动，共同探讨。

       本文摘自公众号“勾勾的Java宇宙”，关注的朋友们可以分享你的学习需求和建议。

dubbo知识点之管理工具dubbo-admin分享

       在dubbo的应用体系中，一直有一款图形化的rpc管理工具，通过这款管理工具，我们可以对我们的rpc服务进行各种管理操作，包括负载均衡、权重调整、服务监测等，今天我们就先来简单看下这一款管理工具。

       dubbo的管理服务，现在也是一个独立的应用，我们可以将它独立部署。项目地址如下：

       根据官方介绍，目前的管理控制台已经发布0.1版本，结构上采取了前后端分离的方式，前端使用 Vue和 Vuetify分别作为 Javascript框架和UI框架，后端采用 Spring Boot 框架。既可以按照标准的 Maven 方式进行打包，部署，杀毒引擎源码也可以采用前后端分离的部署方式，方便开发，功能上，目前具备了服务查询，服务治理(包括 Dubbo 2.7中新增的治理规则)以及服务测试三部分内容。

       下面，我们看下如何在本地安装部署dubbo的管理控制台。

       首先，我们要下载dubbo-admin的源码包或者部署包，如果下载源码包的话，需要你自己打包，由于又是前后端分离的项目，所以这里我就偷个懒，直接下载部署包：

       下载完成后，直接解压，然后进入bin\config文件夹，这里有dubbo-admin的配置文件。因为后端是spring boot项目，所以这里的application.properties文件就是我们spring boot的配置文件，默认情况下，整个配置文件只有一些简单配置项：

       因为没有项目的端口配置，所以默认情况下，新闻栏源码dubbo-admin的访问端口是，当然你也可以自行修改；

       配置文件中，首先是注册中心、配置中心、元数据中心的配置，今天我们演示的注册中心是zk，所以这里就不修改了；

       紧接着是管理平台的登录用户名和密码，默认都是root，你也可以根据自己的需要修改；

       最后面是压缩的相关配置，这里应该是请求响应内容的压缩配置，主要是针对css/js以及页面等内容。

       完成以上内容配置，我们就可以启动测序下了。首先，我们要先启动zk，然后启动我们的管理平台，直接访问我们dubbo-admin的服务地址即可，我配置的端口是，所以我访问的地址是http://localhost:，然后会自动跳转到登录页面：

       输入我们配置的用户名和密码，即可登录成功：

       这个页面和我们之前分享的k8s的官方管理控制台很像。左侧是菜单栏，右侧是操作区域。

       控制台启动成功后，我们启动本地的dubbo项目，进行一些简单操作。

       在服务查询菜单下，我们可以看到我们刚刚启动好的服务，我们可以对这些服务进行测试、查看详情以及其他操作。

       这里我们就只演示下测试，因为路由、黑白名单、负载均衡、权重这些，我们目前还没深入了解过。

       输入请求参数，点击执行，即可显示调用结果，这对我们平时觉得rpc不好测试的小伙伴简直就是福音，我们再也不用为rpc的测试而发愁了：

       接口文档这块需要引入dubbo-api-docs-annotations和dubbo-api-docs-core的相关引用，同时要在我们的接口上添加相应的注解，今天由于时间的关系，我们暂时就不演示了，后面我们会专门分享。

       写过单元测试的小伙伴应该对mock不陌生，这里应该也是一样的，主要是对服务的一些模拟调用，但是现在好像还不支持。

       服务统计这里包括两块功能，一个是服务统计，可以展示服务的提供者、消费者、线程等信息

       当然，除了dubbo-admin这样的官方管理平台之外，dubbo还可以集成skywalking这样的第三方运维监控平台。skywalking的用法我们直接已经分享过了，和dubbo集成应该也很容易，后面有机会的话，我们可以捎带分享下，关于skywalking的内容，可以点击下面的链接回顾：

       dubbo-admin作为dubbo应用的控制管理平台，有着其强大的功能，特别是对rpc服务的监测、监控、以及相关配置的管理，更是一枝独秀。当然，我们今天分享的内容很简单，但是通过今天的内容，我也意识到对于dubbo应用的探索和学习，我觉得自己才刚刚起步，对于负载均衡、路由等相关知识，确实存在很多认知缺陷，但找到前进的方向有何尝不是一件值得庆幸的事呢？

Dubbo源码解析：网络通信

       在之前的章节中，我们探讨了消费者如何通过内置的负载均衡找到服务提供者以及服务暴露的原理。本节重点关注的是消费者如何通过网络与提供者进行远程调用的详细过程，涉及Dubbo框架的网络通信机制。

       网络通信主要在Dubbo的Remoting模块中实现，Dubbo支持多种协议，包括自定义的Dubbo协议、RMI、Hessian、HTTP、WebService、Thrift、REST、gRPC、Memcached和Redis等，每种协议有其特点。例如，Dubbo协议利用NIO异步通信，适合处理大量并发小数据量的场景，而RMI采用阻塞式短连接，适合Java RMI应用。

       序列化在通信中起着至关重要的作用，Dubbo支持多种序列化方式，如Hessian2、Java、Fastjson等，其中Hessian2是默认选择。近年来，高效序列化技术如Kryo和FST不断涌现，它们的性能优于Hessian2，可通过配置引入以优化性能。

       数据在网络传输中需要解决粘包拆包问题，Dubbo通过定义私有RPC协议，消息头包含魔数、类型和长度等信息，以确保数据的正确接收。在消费者发送请求时，首先会生成一个封装了方法和参数的Request对象，经过编码后通过Netty发送。提供方则通过Netty接收请求，解码后执行服务逻辑并返回Response对象。

       双向通信中，服务提供方和消费方都通过心跳机制来检查连接状态，客户端和服务端都设有定时任务，确保数据的及时交互。在异步调用中，Dubbo通过CompletableFuture实现从异步到同步的转换，并处理并发调用时的数据一致性问题。