客户连接多个服务端_Dubbo源码解析之客户端Consumer
前面我们学习了Dubbo源码解析之服务端Provider。对服务提供方进行思路上的讲解,我们知道以下知识点。本篇文章主要对消费方进行讲解。废话不多说请看下文。
- 如何将对象方法生成Invoker
- 如何将Invoker注册到注册地中心
- 如何处理客户端的请求
- 二进制数据转java数据协议
- 协议中包含的序列化知识
一、启动一个客户端Consumer
1. 定义一个接口
注意这里其实是引用的前文中的接口。生产中是服务提供方打一个jar包给客户端用。
@Testpublic void consumerTest() { // 当前应用配置 ApplicationConfig application = new ApplicationConfig(); application.setName("consumerTest"); // 连接注册中心配置 RegistryConfig registry = new RegistryConfig(); registry.setAddress("zookeeper://127.0.0.1:2181"); // 注意:ReferenceConfig为重对象,内部封装了与注册中心的连接,以及与服务提供方的连接 // 引用远程服务 ReferenceConfig reference = new ReferenceConfig(); // 此实例很重,封装了与注册中心的连接以及与提供者的连接,请自行缓存,否则可能造成内存和连接泄漏 reference.setApplication(application); reference.setRegistry(registry); // 多个注册中心可以用setRegistries() reference.setInterface(UserService.class); reference.setVersion("1.0.0"); UserService userService = reference.get(); userService.say("hello");}
2. 生成本地服务
@Testpublic void consumerTest() { // 当前应用配置 ApplicationConfig application = new ApplicationConfig(); application.setName("consumerTest"); // 连接注册中心配置 RegistryConfig registry = new RegistryConfig(); registry.setAddress("zookeeper://127.0.0.1:2181"); // 注意:ReferenceConfig为重对象,内部封装了与注册中心的连接,以及与服务提供方的连接 // 引用远程服务 ReferenceConfig reference = new ReferenceConfig(); // 此实例很重,封装了与注册中心的连接以及与提供者的连接,请自行缓存,否则可能造成内存和连接泄漏 reference.setApplication(application); reference.setRegistry(registry); // 多个注册中心可以用setRegistries() reference.setInterface(UserService.class); reference.setVersion("1.0.0"); UserService userService = reference.get(); userService.say("hello");}
3. 原理分析
首先客户端只有接口的,那么可以根据这个接口生成一个代理。而代理对象的逻辑就是,从zk中找到服务端地址。
然后通过netty客户端去请求服务端的数据。然后返回
二、源码分析
带着我们猜测的逻辑一起来看下ReferenceConfig的实现原理。
public synchronized T get() { if (destroyed){ throw new IllegalStateException("Already destroyed!"); } if (ref == null) { //逻辑就在init里面 init(); } return ref; }
init先做写检查信息,如这个方法是否存在接口中
createProxy#loadRegistries
1. 集群容错策略
注意只有多个服务提供方才会有这里,只有一个服务提供方,没办法容错处理哈。
可以看到一共有9种策略。
当时服务端是多个的时候,才会生成集群策略。另外既然是集群就要选择到底使用哪个来执行。这就是
负载均衡或者说叫路由策略。
LoadBalance负载均衡
- directory中获取所有的invoker
- 如果有多个invoker就去看配置的负载均衡策略
- 根据负载均衡策略找到一个Inoker
public abstract class AbstractClusterInvoker implements Invoker { public Result invoke(final Invocation invocation) throws RpcException { checkWheatherDestoried(); LoadBalance loadbalance; //获取所有的invoker List> invokers = list(invocation); //如果有多个invoker就去看配置的负载均衡策略 if (invokers != null && invokers.size() > 0) { loadbalance = ExtensionLoader.getExtensionLoader(LoadBalance.class).getExtension(invokers.get(0).getUrl() .getMethodParameter(invocation.getMethodName(),Constants.LOADBALANCE_KEY, Constants.DEFAULT_LOADBALANCE)); } else { loadbalance = ExtensionLoader.getExtensionLoader(LoadBalance.class).getExtension(Constants.DEFAULT_LOADBALANCE); } RpcUtils.attachInvocationIdIfAsync(getUrl(), invocation); //根据策略选一个 return doInvoke(invocation, invokers, loadbalance); } protected List> list(Invocation invocation) throws RpcException { List> invokers = directory.list(invocation); return invokers; }}
2. invoker生成代理对象
代理的知识点不用说了。
3. 客户端的invoker逻辑
Protocol#refer
主要看DubboProtocol的逻辑
public Invoker refer(Class serviceType, URL url) throws RpcException { // create rpc invoker. DubboInvoker invoker = new DubboInvoker(serviceType, url, getClients(url), invokers); invokers.add(invoker); return invoker;}
DubboInvoker
底层调用netty通信api发送数据到客户端。然后读取数据。
客户端doInvoke时候会生成ExchangeClient就是NettyClient。public class DubboInvoker extends AbstractInvoker { @Override protected Result doInvoke(final Invocation invocation) throws Throwable { RpcInvocation inv = (RpcInvocation) invocation; final String methodName = RpcUtils.getMethodName(invocation); inv.setAttachment(Constants.PATH_KEY, getUrl().getPath()); inv.setAttachment(Constants.VERSION_KEY, version); ExchangeClient currentClient; if (clients.length == 1) { currentClient = clients[0]; } else { currentClient = clients[index.getAndIncrement() % clients.length]; } try { boolean isAsync = RpcUtils.isAsync(getUrl(), invocation); boolean isOneway = RpcUtils.isOneway(getUrl(), invocation); int timeout = getUrl().getMethodParameter(methodName, Constants.TIMEOUT_KEY,Constants.DEFAULT_TIMEOUT); if (isOneway) { boolean isSent = getUrl().getMethodParameter(methodName, Constants.SENT_KEY, false); currentClient.send(inv, isSent); RpcContext.getContext().setFuture(null); return new RpcResult(); } else if (isAsync) { ResponseFuture future = currentClient.request(inv, timeout) ; RpcContext.getContext().setFuture(new FutureAdapter(future)); return new RpcResult(); } else { RpcContext.getContext().setFuture(null); return (Result) currentClient.request(inv, timeout).get(); } } catch (TimeoutException e) { throw new RpcException(RpcException.TIMEOUT_EXCEPTION, "Invoke remote method timeout. method: " + invocation.getMethodName() + ", provider: " + getUrl() + ", cause: " + e.getMessage(), e); } catch (RemotingException e) { throw new RpcException(RpcException.NETWORK_EXCEPTION, "Failed to invoke remote method: " + invocation.getMethodName() + ", provider: " + getUrl() + ", cause: " + e.getMessage(), e); } } @Override public boolean isAvailable() { if (!super.isAvailable()) return false; for (ExchangeClient client : clients){ if (client.isConnected() && !client.hasAttribute(Constants.CHANNEL_ATTRIBUTE_READONLY_KEY)){ //cannot write == not Available ? return true ; } } return false; } }
三、总结
在前文的基础上,客户端的代码算是比较简单的。
回顾以下本文学习的知识点:
- 主要是集群容错
- 负载均衡、路由。
- 客户端如何发送数据DubboInvoker
主要是利用代理来实现的。
最后求关注,求订阅,谢谢你的阅读!
客户连接多个服务端_Dubbo源码解析之客户端Consumer相关推荐
- JAVA毕业设计Vue.js网上书城管理系统设计与实现服务端计算机源码+lw文档+系统+调试部署+数据库
JAVA毕业设计Vue.js网上书城管理系统设计与实现服务端计算机源码+lw文档+系统+调试部署+数据库 JAVA毕业设计Vue.js网上书城管理系统设计与实现服务端计算机源码+lw文档+系统+调试部 ...
- java开源即时通讯软件服务端openfire源码构建
java开源即时通讯软件服务端openfire源码构建 本文使用最新的openfire主干代码为例,讲解了如何搭建一个openfire开源开发环境,正在实现自己写java聊天软件: 编译环境搭建 调试 ...
- php手游服务端开发教程,【手游服务端】梦想海贼王 卡牌系列一键端服务端游戏源码+教程...
[手游服务端]梦想海贼王 卡牌系列一键端服务端游戏源码+教程 游戏介绍: <梦想海贼王>是一款卡牌类手游,游戏以全球第一超人气动漫<海贼王>为题材,用Q版风格配合新奇多样的玩法 ...
- C++RTSP服务端(附源码)
VC++开发常用功能一系列文章 (欢迎订阅,持续更新...) 第16章:VC++ RTSP服务端(附源码) 源代码demo已上传到百度网盘:永久生效 ,文章尾部附 百度链接
- (Nacos源码解析五)Nacos服务事件变动源码解析
Nacos源码解析系列目录 Nacos 源码编译运行 (Nacos源码解析一)Nacos 注册实例源码解析 (Nacos源码解析二)Nacos 服务发现源码解析 (Nacos源码解析三)Nacos 心 ...
- 客户连接多个服务端_Linux 服务端最大并发数是多少?
(给Linux爱好者加星标,提升Linux技能) 转自:后端技术指南针 1. 开场白 在开始今天的文章之前,先抛一个面试题出来: 你接触过的单机最大并发数是多少? 你认为当前正常配置的服务器物理机最大 ...
- 暴露的全局方法_Dubbo源码解析实战 - 服务暴露原理
欢迎关注全是干货的技术公众号 dubbo面试中比较喜欢问的两个点:服务发布和服务引用. 人性的拷问 服务发布过程中做了哪些事 dubbo都有哪些协议,他们之间有什么特点,缺省值是什么 什么是本地暴露和 ...
- 从零开始开发IM(即时通讯)服务端附源码
前言 首先讲讲IM(即时通讯)技术可以用来做什么: 聊天:qq.微信 直播:斗鱼直播.抖音 实时位置共享.游戏多人互动等等 可以说几乎所有高实时性的应用场景都需要用到IM技术. 本篇将带大家从零开始搭 ...
- 热血传奇服务端FIR0918源码服务端Actor继承关系以及注解
首先要声明一下,Fir0918服务端方面个人感觉实在是渣 代码各种乱入,写此博客只是记录自己学习的点滴.并不是来告诉大家fir的代码有多好. TBaseObject 只有四个成员 对象所在地图的X,Y ...
最新文章
- php程序员面试题(持续补充,偏中级面试题)
- python匿名函数lambda_python的匿名函数lambda解释及用法
- CF 1529E. Trees of Tranquillity
- Java压缩技术(七) TAR——Commons实现
- 图片不显示问题 图片url监测改变问题
- linux(1):Linux经典面试题
- 平衡二叉树删除_AVL 平衡树
- windows下安装Redis数据库
- iOS警报– UIAlertController
- HttpClient 4使用方法的几个例子
- there is the flag
- gym 101908C Pizza Cutter (逆序对)
- javaweb医院科室管理系统springboot
- 路由器重温——ISIS路由-2
- 如何获得coredump
- 中国到美国寄国际快递怎么收费
- ldpc译码讲解_LDPC码及其译码实现
- cnn风格迁移_机器学习:利用卷积神经网络实现图像风格迁移 (一)
- Android经典的大牛博客推荐
- es统计mysql 报表_用Elasticsearch实现统计排行榜
热门文章
- boost::python::iterator相关的测试程序
- boost::multi_array模块确保 multi_arrays 与 STL 容器一起使用
- boost::hana::drop_front_exactly用法的测试程序
- GDCM:显示有关输入DICOM文件的meta元信息的测试程序
- GDCM:提取JP2文件所有解析度的测试程序
- ITK:追加两个3D体积
- ITK:查找图像的更高导数
- DCMTK:类DcmSequence和DcmPixelSequence的测试程序
- VTK:可视化之ChooseTextColorDemo
- OpenGL延迟着色之一