皮皮网

【云集溯源码】【经典网站源码大全】【akka框架源码解析】ribbon客户端源码_ribbon源码深度解析

时间:2024-12-29 10:35:03 来源:zeek源码分析 作者:bootstrap 源码分析

1.一个注解@LoadBalanced就能让RestTemplate拥有负载均衡的客户能力?「扩展点实战系列」- 第443篇
2.SpringCloud原理OpenFeign原来是这么基于Ribbon来实现负载均衡的
3.SpringCloud(3):使用Ribbon进行负载均衡配置,以及遇坑指南
4.ribbon负载均衡详解
5.SharePoint文档管理之文档推送
6.如何用Qt实现Ribbon风格?附源码

ribbon客户端源码_ribbon源码深度解析

一个注解@LoadBalanced就能让RestTemplate拥有负载均衡的端源度解能力?「扩展点实战系列」- 第443篇

       在系列文章《国内最全的Spring Boot系列》中,我们探讨了多个主题,码r码深如扩展点的客户应用实践:《扩展点实战系列》的第篇到第篇,其中包括CommandLineRunner和ApplicationRunner的端源度解缓存预热,初始化与销毁的码r码深云集溯源码三种方法,观察者模式的客户应用,服务状态监控,端源度解以及配置类静态变量的码r码深使用。第篇中,客户我们提到一个简单的端源度解注解@LoadBalanced,似乎就能让RestTemplate具备负载均衡功能,码r码深但这个背后的客户技术细节是什么呢?

       在前文的讲解中,我们提到了Ribbon的端源度解负载均衡实现思路,并且师傅悟纤提到Ribbon的码r码深实现方式与我们自定义的类似。为了验证这一点,悟纤将深入Ribbon的源码世界,探寻真相。

       首先,让我们回顾一下在使用Ribbon开启负载均衡时的代码示例,通过服务名称而非IP地址进行请求。这种方法与我们之前讨论的扩展方法非常相似。

       接着,我们看到Ribbon的核心自动配置类RibbonAutoConfiguration,它包含一个内部类RibbonClientHttpRequestFactoryConfiguration,经典网站源码大全这个类负责扩展RestTemplate的功能。虽然没有直接看到拦截器的注入,但后续的LoadBalancerAutoConfiguration类中,@LoadBalanced注解的使用和Spring扩展点的使用,都预示着拦截器的存在。

       LoadBalancerAutoConfiguration类利用SmartInitializingSingleton扩展点,将自定义的拦截器LoadBalancerInterceptor添加到RestTemplate中。这个拦截器在请求处理过程中,根据负载均衡算法从多个服务器中选择合适的服务器进行请求。

       至于@LoadBalanced注解,其关键作用是通过Qualifier限定,确保只有标注了该注解的RestTemplate被注入。简单来说,使用@Autowired和@LoadBalanced组合,Spring会自动识别并注入配置好的负载均衡的RestTemplate实例。

       总结来说,Ribbon的负载均衡实现是通过自定义注解、拦截器和Spring扩展点的巧妙结合。当我们使用@LoadBalanced时,实际上是告诉Spring我们需要一个已经配置好负载均衡功能的RestTemplate。这就是Spring Cloud Ribbon的负载均衡原理,它将配置和逻辑分离,使得代码更加简洁且易于维护。

       最后,akka框架源码解析问题留给你:@Autowired和@LoadBalanced如何协同工作,使得配置的RestTemplate自动注入?这背后的原理,需要你进一步研究Spring的依赖注入和扩展点机制来解答。」

SpringCloud原理OpenFeign原来是这么基于Ribbon来实现负载均衡的

       欢迎来到本篇文章,之前我们已经深入探讨了OpenFeign的动态代理生成原理和Ribbon的运行机制。若要对OpenFeign的动态代理生成原理和Ribbon的运行原理有更深入的了解,可关注微信公众号“三友的java日记”,通过菜单栏查看整理的相关内容。接下来,我们将继续深入SpringCloud组件原理,探讨OpenFeign是如何利用Ribbon实现负载均衡的,以及两组件如何协同工作的。

       一、Feign动态代理调用实现rpc流程解析

       我们从Feign客户端接口的动态代理生成原理出发,了解到动态代理基于JDK实现,所有方法调用最终都会调用到InvocationHandler接口的实现,即ReflectiveFeign.FeignInvocationHandler。接下来,我们将深入探讨FeignInvocationHandler如何实现rpc调用。

       FeignInvocationHandler通过invoke方法实现动态代理功能,其主要逻辑如下:

       1. 对于调用的方法是否为equals、hashCode、toString等特殊方法进行判断,若为则无需走rpc调用。spring怎么阅读源码

       2. 从dispatch获取调用方法对应的MethodHandler,然后调用MethodHandler的invoke方法。

       3. MethodHandler在构建动态代理时生成,作用是最终实现rpc调用,每个方法有对应的MethodHandler。

       4. SynchronousMethodHandler是实现rpc调用的关键类,通过构造RequestTemplate、Options和重试组件,发起.netflix.client.conf.CommonClientConfigKey。

        <clientName>.<nameSpace>.NFLoadBalancerClassName=xx

        <clientName>.<nameSpace>.NFLoadBalancerRuleClassName=xx

        <clientName>.<nameSpace>.NFLoadBalancerPingClassName=xx

        <clientName>.<nameSpace>.NIWSServerListClassName=xx

        <clientName>.<nameSpace>.NIWSServerListFilterClassName=xx

        com.netflix.client.config.IClientConfig:Ribbon的客户端配置,默认采用com.netflix.client.config.DefaultClientConfigImpl实现。

        com.netflix.loadbalancer.IRule:Ribbon的负载均衡策略,默认采用com.netflix.loadbalancer.ZoneAvoidanceRule实现,该策略能够在多区域环境下选出最佳区域的实例进行访问。

        com.netflix.loadbalancer.IPing:Ribbon的实例检查策略,默认采用com.netflix.loadbalancer.NoOpPing实现,该检查策略是一个特殊的实现,实际上它并不会检查实例是否可用,而是始终返回true,默认认为所有服务实例都是可用的。

        com.netflix.loadbalancer.ServerList:服务实例清单的维护机制,默认采用com.netflix.loadbalancer.ConfigurationBasedServerList实现。

        com.netflix.loadbalancer.ServerListFilter:服务实例清单过滤机制,默认采org.springframework.cloud.netflix.ribbon.ZonePreferenceServerListFilter,该策略能够优先过滤出与请求方处于同区域的服务实例。

        com.netflix.loadbalancer.ILoadBalancer:负载均衡器,默认采用com.netflix.loadbalancer.ZoneAwareLoadBalancer实现,它具备了区域感知的能力。

        上面的配置是在项目中没有引入spring Cloud Eureka,如果引入了Eureka和Ribbon依赖时,自动化配置会有一些不同。

        通过自动化配置的实现,可以轻松的实现客户端的负载均衡。同时,针对一些个性化需求,我们可以方便的替换上面的这些默认实现,只需要在springboot应用中创建对应的实现实例就能覆盖这些默认的配置实现。

        @Configuration

        public class MyRibbonConfiguration {

            @Bean

            public IRule ribbonRule(){

                return new RandomRule();

            }

        }

        这样就会使用P使用了RandomRule实例替代了默认的com.netflix.loadbalancer.ZoneAvoidanceRule。

        也可以使用@RibbonClient注解实现更细粒度的客户端配置

       å¯¹äºŽRibbon的参数通常有二种方式:全局配置以及指定客户端配置

        全局配置的方式很简单

        只需要使用ribbon.<key>=<value>格式进行配置即可。其中,<key>代表了Ribbon客户端配置的参数名,<value>则代表了对应参数的值。比如,我们可以想下面这样配置Ribbon的超时时间

        ribbon.ConnectTimeout=

        ribbon.ServerListRefreshInterval=   ribbon获取服务定时时间

        全局配置可以作为默认值进行设置,当指定客户端配置了相应的key的值时,将覆盖全局配置的内容

        指定客户端的配置方式

        <client>.ribbon.<key>=<value>的格式进行配置.<client>表示服务名,比如没有服务治理框架的时候(如Eureka),我们需要指定实例清单,可以指定服务名来做详细的配置,

        user-service.ribbon.listOfServers=localhost:,localhost:,localhost:

        对于Ribbon参数的key以及value类型的定义,可以通过查看com.netflix.client.config.CommonClientConfigKey类。

        当在spring Cloud的应用同时引入Spring cloud Ribbon和Spring Cloud Eureka依赖时,会触发Eureka中实现的对Ribbon的自动化配置。这时的serverList的维护机制实现将被com.netflix.niws.loadbalancer.DiscoveryEnabledNIWSServerList的实例所覆盖,该实现会讲服务清单列表交给Eureka的服务治理机制来进行维护。IPing的实现将被com.netflix.niws.loadbalancer.NIWSDiscoveryPing的实例所覆盖,该实例也将实例接口的任务交给了服务治理框架来进行维护。默认情况下,用于获取实例请求的ServerList接口实现将采用Spring Cloud Eureka中封装的org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList,其目的是为了让实例维护策略更加通用,所以将使用物理元数据来进行负载均衡,而不是使用原生的AWS AMI元数据。在与Spring cloud Eureka结合使用的时候,不需要再去指定类似的user-service.ribbon.listOfServers的参数来指定具体的服务实例清单,因为Eureka将会为我们维护所有服务的实例清单,而对于Ribbon的参数配置,我们依然可以采用之前的两种配置方式来实现。

        此外,由于spring Cloud Ribbon默认实现了区域亲和策略,所以,可以通过Eureka实例的元数据配置来实现区域化的实例配置方案。比如可以将不同机房的实例配置成不同的区域值,作为跨区域的容器机制实现。而实现也非常简单,只需要服务实例的元数据中增加zone参数来指定自己所在的区域,比如:

        eureka.instance.metadataMap.zone=shanghai

        在Spring Cloud Ribbon与Spring Cloud Eureka结合的工程中,我们可以通过参数禁用Eureka对Ribbon服务实例的维护实现。这时又需要自己去维护服务实例列表了。

        ribbon.eureka.enabled=false.

        由于Spring Cloud Eureka实现的服务治理机制强调了cap原理的ap机制(即可用性和可靠性),与zookeeper这类强调cp(一致性,可靠性)服务质量框架最大的区别就是,Eureka为了实现更高的服务可用性,牺牲了一定的一致性,在极端情况下宁愿接受故障实例也不要丢弃"健康"实例。

        比如说,当服务注册中心的网络发生故障断开时候,由于所有的服务实例无法维护续约心跳,在强调ap的服务治理中将会把所有服务实例剔除掉,而Eureka则会因为超过%的实例丢失心跳而触发保护机制,注册中心将会保留此时的所有节点,以实现服务间依然可以进行互相调用的场景,即使其中有部分故障节点,但这样做可以继续保障大多数服务的正常消费。

        在Camden版本,整合了spring retry来增强RestTemplate的重试能力,对于我们开发者来说,只需要简单配置,即可完成重试策略。

        spring.cloud.loadbalancer.retry.enabled=true

        hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=

        user-service.ribbon.ConnectTimeout=

        user-service.ribbon.ReadTimeout=

        user-service.ribbon.OkToRetryOnAllOperations=true

        user-service.ribbon.MaxAutoRetriesNextServer=2

        user-service.ribbon.maxAutoRetries=1

        spring.cloud.loadbalancer.retry.enabled:该参数用来开启重试机制,它默认是关闭的。

        hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds:断路器的超时时间需要大于Ribbon的超时时间,不然不会触发重试。

        user-service.ribbon.ConnectTimeout:请求连接超时时间。

        user-service.ribbon.ReadTimeout:请求处理的超时时间

        user-service.ribbon.OkToRetryOnAllOperations:对所有操作请求都进行重试。

        user-service.ribbon.MaxAutoRetriesNextServer:切换实例的重试次数。

        user-service.ribbon.maxAutoRetries:对当前实例的重试次数。

        根据以上配置,当访问到故障请求的时候,它会再尝试访问一次当前实例(次数由maxAutoRetries配置),如果不行,就换一个实例进行访问,如果还是不行,再换一个实例访问(更换次数由MaxAutoRetriesNextServer配置),如果依然不行,返回失败

       é¡¹ç›®å¯åŠ¨çš„时候会自动的为我们加载LoadBalancerAutoConfiguration自动配置类,该自动配置类初始化条件是要求classpath必须要有RestTemplate这个类,必须要有LoadBalancerClient实现类。

        LoadBalancerAutoConfiguration为我们干了二件事,第一件是创建了LoadBalancerInterceptor拦截器bean,用于实现对客户端发起请求时进行拦截,以实现客户端负载均衡。创建了一个

        RestTemplateCustomizer的bean,用于给RestTemplate增加LoadBalancerInterceptor拦截器。

        每次请求的时候都会执行org.springframework.cloud.client.loadbalancer.LoadBalancerInterceptor的intercept方法,而LoadBalancerInterceptor具有LoadBalancerClient(客户端负载客户端)实例的一个引用,

        在拦截器中通过方法获取服务名的请求url(比如/p/1bddb5dc

        Spring cloud系列六 Ribbon的功能概述、主要组件和属性文件配置  

       /p/faffa

        本人有道云笔记中记录的参考文章

        文档:_ribbon 负载均衡.note

        链接:/noteshare?id=efc3efbbefd8ed0b9&sub=B0E6DFEEBDAF

SharePoint文档管理之文档推送

       文档推送功能,不是一个复杂的功能,我们这里简单的应用了Ribbon定制、Js使用、对象模型推送(Server端),下面,我们来简单介绍下文档推送功能吧。

一、 功能设计:

       文档推送功能,主要就是一个文档库中,选择几个文档,点击Ribbon菜单上的推送菜单,跳入推送页面;推送页面选择目标列表,点击推送按钮,把选中的几个文档,推送到目标文档库。rxjava源码分析总结

       我这里就是复制过去,并没有选择移动,当然如果你需要这样的功能,可以稍作修改以达到目的。推送过程可能存在重命的情况,这样我会在出现异常的时候,把文件名前加上当前时间推送过去。

二、 源代码结构

       如上图所示,包括一个Feature(用来激活功能),一个可视化WebPart(推送功能),一个Ribbon(菜单)。

三、 添加Ribbon

       添加Ribbon菜单应该算是一个比较简单的功能,新建一个Ribbon的空元素,添加我们Ribbon的xml,编写这个Xml就可以了。而这个Ribbon的作用,就是调用一个JS的函数,函数通过内容编辑器添加在页面上。

       当然,如果你对添加Ribbon不是很熟悉,可以参考后面的参考文档,是关于SharePoint如何添加Ribbon,其过程和SharePoint版本是一样的,文档描述的很清楚,相信大家可以很容易完成这一步。

       

       <CustomAction Id="Ribbon.CustomGroup" RegistrationId="" RegistrationType="List" Title="推送文档"

       Location="CommandUI.Ribbon">

       <CommandUIDefinition

       Location="Ribbon.Documents.New.Controls._children">

       <Button Id="Ribbon.Documents.New.PushDocsButton"

       Command="PushDocsButtonCommand"

       Imageby="/_layouts//images/formatmapx.png"

       LabelText="推送文档"

       TemplateAlias="o2" />

       <CommandUIHandler

       Command="PushDocsButtonCommand"

       CommandAction="javascript:PushDoc()" />

四、 准备JS脚本:

       Js脚本的作用,就是去页面上找,我们选中哪些项文档,然后把文档的ID组成一个字符串,用来传送给推送页面使用。

       当然,js脚本还会传送源列表的Guid,为了知道我们要推送的文档来自哪里,这些都是比较容易理解的,由于写JS脚本的时候,没有dw、spd之类的编辑器,是记事本里面写的,样式比较难看,大家凑合看吧。JS脚本附后:

       

五、 写推送部件:

       如下面表格所示,可视化webpart里面就只有一个Label用来显示文字,一个DropDownList用来显示目标文档库合集,一个Button来点击推送。

       下面两个方法是核心方法,包括初始化DropDownLink控件,把所有可选的文档库绑定好;推送方法,获取包含所有ID的字符串数组和源列表的GUID。

       我觉得方法的代码都在这里,没必要给大家具体解释了,代码的逻辑非常简单,推送过程很简单,所有代码附后:

核心代码:

       public void InitDropDownList()//初始化DropDownLink

       public void PushDocs(string ListID, string[] IDC)//推送方法

       

       public void PushDocs(string ListID, string[] IDC)

       {

       try

       {

       string strIDC = Request.QueryString["IDC"].ToString();

       ListID = Request.QueryString["ListID"].ToString();

       if (strIDC.IndexOf("-") > 0)

       {

       IDC = strIDC.Split('-');

       }

       else

       {

       IDC = new string[1];

       IDC[0] = strIDC;

       }

       Guid ListGuid = new Guid(ListID);

       using (SPSite site = new SPSite(SPContext.Current.Site.ID))

       {

       using (SPWeb web = site.OpenWeb(SPContext.Current.Web.ID))

       {

       SPList list = web.Lists[ListGuid];

       SPList Targetlist = web.Lists[dwlist.SelectedValue];

       for (int i = 0; i < IDC.Length; i++)

       {

       SPListItem item = list.GetItemById(Convert.ToInt(IDC[i]));

       try

       {

       string CopyToUrl = site.Url + Targetlist.RootFolder.ServerRelativeUrl.ToString() + "/" + item.Name;

       item.CopyTo(CopyToUrl);

       }

       catch

       {

       string CopyToUrl = site.Url + Targetlist.RootFolder.ServerRelativeUrl.ToString() + "/" + DateTime.Now.ToString("yyyy-MM-dd hhmmss") + item.Name;

       item.CopyTo(CopyToUrl);

       }

       }

       }

       }

       }

       catch

       {

       Response.Write("请?选?择?推ª?送¨ª列¢D表À¨ª...");

       }

       }

       public void InitDropDownList()

       {

       try

       {

       ListItemCollection LIColl = new ListItemCollection();

       using (SPSite site = new SPSite(SPContext.Current.Site.ID))

       {

       using (SPWeb web = site.OpenWeb(SPContext.Current.Web.ID))

       {

       foreach (SPList list in web.Lists)

       {

       if (list.BaseType == SPBaseType.DocumentLibrary)

       {

       ListItem listitem = new ListItem(list.Title,list.ID.ToString());

       LIColl.Add(listitem);

       }

       }

       }

       }

       dwlist.DataSource = LIColl;

       dwlist.DataBind();

       }

       catch

       {

       }

       }

       protected void btn_Push_Click(object sender, EventArgs e)

       {

       PushDocs(ListID, IDC);

       }

        

六、 效果展示:

       1. 如下图,选择我们要推送的文档,然后点击Ribbon上的推送文档;

       2. 点击推送后,弹出推送页面,如下图;可以看到页面的URL上,IDC参数包含了选择的ID,ListID参数是源列表的Guid,点击推送即可。特别地说,这个下拉框的列表类型,都是文档库,在绑定的时候已经过滤,当然,我们还可以通过其他方式,过滤掉系统文档库。

       3. 选择文档库“软件一部”,点击推送,推送后结果:如下图所示,我们选中的两个文档,推送到了软件一部下面,目标完成!

如何用Qt实现Ribbon风格?附源码

       为在Qt中实现Ribbon风格进行探索,操作环境为win bit搭配VS更新至5版本和Qt5.6.0 bit。首选组件是Qt的widget和scrollArea。新创建的Qt程序中,将默认菜单栏和工具栏去除,以便为Ribbon风格定制空间。通过添加一个widget和一个scrollArea至UI界面,这两个控件布局采用垂直排列,进一步在widget内部放置了一个pushButton和TabWidget,其排列形式为水平方向。在scrollArea内部,同样采用水平排列方式放置widget。设计布局完成后,整体展现的界面结构符合Ribbon风格预期。

       在实现过程中,首先确定界面的布局边界设为0,同时间距设置为0,以优化视觉效果。对所有元素进行样式调整,按钮和TabWidget的文字进行了个性化修改。对scrollArea内部的widget背景颜色设定为白色,并指定一个适合宽度,随后调整scrollArea背景颜色,达到与整体风格一致的效果。

       要将左侧的文件菜单置于主界面之上,并确保其他标签向右顺序排列,通过按钮的绝对定位方法能够解决文件菜单的定位问题。然而,对于TabWidget的标签移动问题,借助QSS(CSS扩展)实现更高效的调整。具体代码编写用于执行这一操作。实现后,界面布局的各个元素位置得到精确调整。

       为了增强Ribbon风格的直观性,对按钮和Tabbar的样式进行细致设计,使界面更加美观和实用。在文件菜单实现阶段,直接应用QMenu进行菜单创建可能受限,而利用Qt提供的QWidgetAction来创建自定义菜单widget,并结合QSS进行个性化设计,提供了灵活的实现方法。通过编写适用于QWidgetAction的类并重写paintEvent函数,可以顺利应用QSS样式。对文件按钮菜单进行具体配置,以达到理想的功能效果。

       接下来,对Tabwidget内的groupBox通过QSS进行定制,以塑造更专业的外观与风格。随着对各个组件的逐步优化,界面呈现的美观与功能并重特点逐步显现。最终的界面设计融入了微软雅黑字体风格,对TabWidget背景色进行设定,并隐藏文件按钮菜单的小按钮,使界面在美观与功能性上达到和谐统一。

       通过以上步骤,已实现并展示了基于Qt实现Ribbon风格的完整过程与细节。包括界面布局、组件样式调整、功能性实现及最终美化等环节,旨在提供一种兼具美观与实用性,符合Ribbon风格要求的界面设计方法。

关键词:集合竞价涨跌幅源码

copyright © 2016 powered by 皮皮网   sitemap