摘要:中的名称,一定要是服务中注册的名称。添加这个的注解,主要是因为定义的时候报错,也就是说明没有被实例化。采用随机分配的策略。添加访问层添加电影微服务启动类电影微服务,使用定制化在客户端进行负载均衡,使用不同服务不同配置策略。
SpringCloud(第 007 篇)电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略
-
一、大致介绍1、通过 RibbonClient 注解来设置随机调度算法方式; 2、通过 restTemplate.getForObject、loadBalancerClient.choose 两种代码调用方式来测试客户端负载均衡算法;二、实现步骤 2.1 添加 maven 引用包
2.2 添加应用配置文件(springms-consumer-movie-ribbon-customsrcmainresourcesapplication.yml)4.0.0 springms-consumer-movie-ribbon-custom 1.0-SNAPSHOT jar com.springms.cloud springms-spring-cloud 1.0-SNAPSHOT org.springframework.boot spring-boot-starter-web org.springframework.cloud spring-cloud-starter-eureka org.springframework.boot spring-boot-starter-actuator
spring: application: name: springms-consumer-movie-ribbon-custom server: port: 8020 #做负载均衡的时候,不需要这个动态配置的地址 #user: # userServicePath: http://localhost:7900/simple/ eureka: client: # healthcheck: # enabled: true serviceUrl: defaultZone: http://admin:admin@localhost:8761/eureka instance: prefer-ip-address: true instance-id: ${spring.application.name}:${spring.cloud.client.ipAddress}:${spring.application.instance_id:${server.port}}2.3 添加实体用户类User(springms-consumer-movie-ribbon-customsrcmainjavacomspringmscloudentityUser.java)
package com.springms.cloud.entity; import java.math.BigDecimal; public class User { private Long id; private String username; private String name; private Short age; private BigDecimal balance; public Long getId() { return this.id; } public void setId(Long id) { this.id = id; } public String getUsername() { return this.username; } public void setUsername(String username) { this.username = username; } public String getName() { return this.name; } public void setName(String name) { this.name = name; } public Short getAge() { return this.age; } public void setAge(Short age) { this.age = age; } public BigDecimal getBalance() { return this.balance; } public void setBalance(BigDecimal balance) { this.balance = balance; } }2.4 添加 RibbonClient 配置类01(springms-consumer-movie-ribbon-customsrcmainjavacomspringmscloudconfigTestConfigurationInside2ScanPackage.java)
package com.springms.cloud.config; import com.netflix.loadbalancer.RoundRobinRule; import com.springms.cloud.ExcludeFromComponentScan; import com.netflix.loadbalancer.IRule; import com.netflix.loadbalancer.RandomRule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * 测试定制 Ribbon ,而且该定制的配置文件是在应用扫描的目录里面,也就是说应用启动后该文件会被扫描到。 * * RibbonClient 中的 name 名称,一定要是 eureka 服务中注册的名称。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017/9/17 * */ @Configuration @ExcludeFromComponentScan public class TestConfigurationInside2ScanPackage { /** * 采用随机分配的策略。 * * @return */ @Bean public IRule ribbonRule(){ return new RandomRule(); //return new RoundRobinRule(); } }2.5 添加 RibbonClient 配置类02(springms-consumer-movie-ribbon-customsrcmainjavacomspringmsconfigTestConfigurationOutsideScanPackage.java)
package com.springms.config; import com.netflix.loadbalancer.IRule; import com.netflix.loadbalancer.RandomRule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * 测试定制 Ribbon ,而且该定制的配置文件是不在应用扫描的目录里面,也就是说应用启动后该文件不会被扫描到。 * * RibbonClient 中的 name 名称,一定要是 eureka 服务中注册的名称。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017/9/17 * */ @Configuration public class TestConfigurationOutsideScanPackage { // @Autowired // IClientConfig config; // // /** // * // * 添加这个 Bean 的注解,主要是因为定义 config 的时候报错,也就是说明 config 没有被实例化。 // * // */ // @Bean // public IClientConfig config(){ // return new DefaultClientConfigImpl(); // } /** * 采用随机分配的策略。 * * @return */ @Bean public IRule ribbonRule(){ return new RandomRule(); } }2.6 添加 RibbonClient 配置类03(springms-consumer-movie-ribbon-customsrcmainjavacomspringmscloudTestConfigurationInsideScanPackage.java)
package com.springms.cloud; import com.netflix.loadbalancer.IRule; import com.netflix.loadbalancer.RandomRule; import com.netflix.loadbalancer.RoundRobinRule; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * 测试定制 Ribbon ,而且该定制的配置文件是在应用扫描的目录里面,也就是说应用启动后该文件会被扫描到。 * * RibbonClient 中的 name 名称,一定要是 eureka 服务中注册的名称。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017/9/17 * */ @Configuration @ExcludeFromComponentScan public class TestConfigurationInsideScanPackage { /** * 采用随机分配的策略。 * * @return */ @Bean public IRule ribbonRule(){ // return new RoundRobinRule(); return new RandomRule(); } }2.7 添加注解,目的就是让应用启动后,含有该注解的文件不会被应用扫描到(springms-consumer-movie-ribbon-customsrcmainjavacomspringmscloudExcludeFromComponentScan.java)
package com.springms.cloud; /** * 添加该注解,目的就是让应用启动后,含有该注解的文件不会被应用扫描到。 * * @author hmilyylimh * * @version 0.0.1 * * @date 2017/9/17 * */ public @interface ExcludeFromComponentScan { }2.8 添加Web访问层Controller(springms-consumer-movie-ribbon-customsrcmainjavacomspringmscloudcontrollerMovieCustomRibbonController.java)
package com.springms.cloud.controller; import com.springms.cloud.entity.User; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.loadbalancer.LoadBalancerClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; @RestController public class MovieCustomRibbonController { @Autowired private RestTemplate restTemplate; @Autowired private LoadBalancerClient loadBalancerClient; @GetMapping("/movie/{id}") public User findById(@PathVariable Long id) { // http://localhost:7900/simple/ // VIP:virtual IP // HAProxy Heartbeat return this.restTemplate.getForObject("http://springms-provider-user/simple/" + id, User.class); } @GetMapping("/choose") public String test() { ServiceInstance serviceInstance = this.loadBalancerClient.choose("springms-provider-user"); System.out.println("00000" + ":" + serviceInstance.getServiceId() + ":" + serviceInstance.getHost() + ":" + serviceInstance.getPort()); ServiceInstance serviceInstance2 = this.loadBalancerClient.choose("springms-provider-user2"); System.out.println("222222222222222222" + ":" + serviceInstance2.getServiceId() + ":" + serviceInstance2.getHost() + ":" + serviceInstance2.getPort()); return "choose successful"; } }2.9 添加电影微服务启动类(springms-consumer-movie-ribbon-customsrcmainjavacomspringmscloudMsConsumerMovieCustomRibbonApplication.java)
package com.springms.cloud; import com.springms.cloud.config.TestConfigurationInside2ScanPackage; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.cloud.netflix.ribbon.RibbonClient; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.FilterType; import org.springframework.web.client.RestTemplate; /** * 电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略。 * * LoadBalanced:该负载均衡注解,已经整合了 Ribbon; * * Ribbon 的默认负载均衡的算法为:轮询; * * @author hmilyylimh * * @version 0.0.1 * * @date 2017/9/17 * */ @SpringBootApplication @EnableEurekaClient @RibbonClient(name = "springms-provider-user", configuration = TestConfigurationInsideScanPackage.class) @ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExcludeFromComponentScan.class) }) public class MsConsumerMovieCustomRibbonApplication { @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } public static void main(String[] args) { SpringApplication.run(MsConsumerMovieCustomRibbonApplication.class, args); System.out.println("【【【【【【 电影微服务-定制Ribbon 】】】】】】已启动."); } }三、测试
/**************************************************************************************** 一、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试轮询分配服务器地址 TestConfigurationOutsideScanPackage)): 1、使用注解:@SpringBootApplication、@EnableEurekaClient; 2、使用注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationOutsideScanPackage.class) 3、TestConfigurationInsideScanPackage 类中采用 RoundRobinRule 轮询调度算法; 4、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 5、启动 springms-consumer-movie-ribbon-custom 模块服务,启动1个端口; 6、在浏览器输入地址http://localhost:8020/movie/2,然后看看 springms-provider-user 的三个端口的服务打印的信息是否均匀,正常情况下应该是轮询打印; 总结:客户端之所以会轮询调用各个微服务,是因为在 TestConfigurationOutsideScanPackage 类中配置了负载均衡调度算法:轮询 RoundRobinRule 策略算法; ****************************************************************************************/ /**************************************************************************************** 二、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试轮询分配服务器地址 TestConfigurationInsideScanPackage): 1、使用注解:@SpringBootApplication、@EnableEurekaClient; 2、使用注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationInsideScanPackage.class) 3、使用注解:@ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExcludeFromComponentScan.class) }) 4、TestConfigurationInsideScanPackage 类中采用 RoundRobinRule 轮询调度算法; 5、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 6、启动 springms-consumer-movie-ribbon-custom 模块服务,启动1个端口; 7、在浏览器输入地址http://localhost:8020/movie/2,然后看看 springms-provider-user 的三个端口的服务打印的信息是否均匀,正常情况下应该是轮询打印; 总结一:客户端之所以会轮询分配调用各个微服务,是因为在注解方面采用了注解 ComponentScan 使配置文件 TestConfigurationOutsideScanPackage 不被扫描到,然后再结合 TestConfigurationOutsideScanPackage 类中配置了负载均衡调度算法:轮询 RoundRobinRule 策略算法; 总结二:可以发现规律,当使用 “restTemplate.getForObject("http://springms-provider-user/simple/" + id, User.class)” 这种方式负载均衡调用各个微服务跟配置文件 TestConfigurationOutsideScanPackage 在哪里没有关系; ****************************************************************************************/ /**************************************************************************************** 三、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试随机分配服务器地址 TestConfigurationOutsideScanPackage)): 1、使用注解:@SpringBootApplication、@EnableEurekaClient; 2、使用注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationOutsideScanPackage.class) 3、TestConfigurationInsideScanPackage 类中采用 RandomRule 随机调度算法; 4、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 5、启动 springms-consumer-movie-ribbon-custom 模块服务,启动1个端口; 6、在浏览器输入地址http://localhost:8020/movie/2,然后看看 springms-provider-user 的三个端口的服务打印的信息是否均匀,正常情况下应该是随机打印; 总结:客户端之所以会随机调用各个微服务,是因为在 TestConfigurationOutsideScanPackage 类中配置了负载均衡调度算法:随机 RandomRule 策略算法; ****************************************************************************************/ /**************************************************************************************** 四、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试随机分配服务器地址 TestConfigurationInsideScanPackage): 1、使用注解:@SpringBootApplication、@EnableEurekaClient; 2、使用注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationInsideScanPackage.class) 3、使用注解:@ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExcludeFromComponentScan.class) }) 4、TestConfigurationInsideScanPackage 类中采用 RandomRule 随机调度算法; 5、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 6、启动 springms-consumer-movie-ribbon-custom 模块服务,启动1个端口; 7、在浏览器输入地址http://localhost:8020/movie/2,然后看看 springms-provider-user 的三个端口的服务打印的信息是否均匀,正常情况下应该是随机打印; 总结一:客户端之所以会轮询分配调用各个微服务,是因为在注解方面采用了注解 ComponentScan 使配置文件 TestConfigurationOutsideScanPackage 不被扫描到,然后再结合 TestConfigurationOutsideScanPackage 类中配置了负载均衡调度算法:随机 RandomRule 策略算法; 总结二:可以发现规律,当使用 “restTemplate.getForObject("http://springms-provider-user/simple/" + id, User.class)” 这种方式负载均衡调用各个微服务跟配置文件 TestConfigurationOutsideScanPackage 在哪里没有关系; 总结三:由(测试一、测试二)和(测试三、测试四)对比可知,当使用 “restTemplate.getForObject("http://springms-provider-user/simple/" + id, User.class)” 这种方式负载均衡调用各个微服务不需要考虑配置文件的放在哪个包下面。 ****************************************************************************************/ /**************************************************************************************** 五、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试自定义分配服务器地址 TestConfigurationInside2ScanPackage 调度方式): 1、使用注解:@SpringBootApplication、@EnableEurekaClient; 2、使用注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationInside2ScanPackage.class) 3、使用注解:@ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExcludeFromComponentScan.class) }) 3、TestConfigurationInside2ScanPackage 类中采用 RoundRobinRule 轮询调度算法; 4、在 MovieCustomRibbonController 里面添加 test 方法来做测试; 5、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 6、启动 springms-provider-user2 模块服务,启动2个端口(7997、7996)(直接将用户微服务 spring.application.name 改了个名字为 springms-provider-user2 再启动而已); 7、启动 springms-consumer-movie-ribbon-custom 模块服务; 8、在浏览器输入地址http://localhost:8020/choose,然后看看 springms-provider-user、springms-provider-user2 的各个对应的端口的服务打印的信息是否均匀,正常情况下应该是轮询分配打印的; 总结:springms-provider-user(之所以轮询是因为使用了 RibbonClient 配置采用 RoundRobinRule 轮询调度算法)、springms-provider-user2(之所以轮询是因为没有任何配置,默认调度算法就是轮询算法); ****************************************************************************************/ /**************************************************************************************** 六、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试自定义分配服务器地址 TestConfigurationInside2ScanPackage 调度方式): 1、使用注解:@SpringBootApplication、@EnableEurekaClient; 2、使用注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationInside2ScanPackage.class) 3、使用注解:@ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExcludeFromComponentScan.class) }) 3、TestConfigurationInside2ScanPackage 类中采用 RandomRule 随机调度算法; 4、在 MovieCustomRibbonController 里面添加 test 方法来做测试; 5、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 6、启动 springms-provider-user2 模块服务,启动2个端口(7997、7996)(直接将用户微服务 spring.application.name 改了个名字为 springms-provider-user2 再启动而已); 7、启动 springms-consumer-movie-ribbon-custom 模块服务; 8、在浏览器输入地址http://localhost:8020/choose,然后看看 springms-provider-user、springms-provider-user2 的各个对应的服务打印的信息是否均匀,正常情况下应该是 springms-provider-user 随机分配,springms-provider-user2 轮询分配; 总结:springms-provider-user(之所以随机是因为使用了 RibbonClient 配置采用 RandomRule 随机调度算法)、springms-provider-user2(之所以轮询是因为没有任何配置,默认调度算法就是轮询算法); ****************************************************************************************/ /**************************************************************************************** 七、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试自定义分配服务器地址 TestConfigurationInsideScanPackage 调度方式): 1、注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationInsideScanPackage.class) 2、注解:@ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExcludeFromComponentScan.class) }) 3、TestConfigurationInsideScanPackage 类中采用 RoundRobinRule 轮询调度算法; 4、在 MovieCustomRibbonController 里面添加 test 方法来做测试; 5、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 6、启动 springms-provider-user2 模块服务,启动2个端口(7997、7996)(直接将用户微服务 spring.application.name 改了个名字为 springms-provider-user2 再启动而已); 7、启动 springms-consumer-movie-ribbon-custom 模块服务; 8、在浏览器输入地址http://localhost:8020/choose,然后看看 springms-provider-user、springms-provider-user2 的两个端口的服务打印的信息是否均匀,正常情况下都是轮询打印; 总结:springms-provider-user(之所以随机是因为使用了 RibbonClient 配置采用 RoundRobinRule 轮询调度算法)、springms-provider-user2(之所以轮询是因为没有任何配置,默认调度算法就是轮询算法); ****************************************************************************************/ /**************************************************************************************** 八、电影微服务,使用定制化 Ribbon 在客户端进行负载均衡,使用 RibbonClient 不同服务不同配置策略(测试自定义分配服务器地址 TestConfigurationInsideScanPackage 调度方式): 1、注解:@RibbonClient(name = "springms-provider-user", configuration = TestConfigurationInsideScanPackage.class) 2、注解:@ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ANNOTATION, value = ExcludeFromComponentScan.class) }) 3、TestConfigurationInsideScanPackage 类中采用 RandomRule 随机调度算法; 4、在 MovieCustomRibbonController 里面添加 test 方法来做测试; 5、启动 springms-provider-user 模块服务,启动3个端口(7900、7899、7898); 6、启动 springms-provider-user2 模块服务,启动2个端口(7997、7996)(直接将用户微服务 spring.application.name 改了个名字为 springms-provider-user2 再启动而已); 7、启动 springms-consumer-movie-ribbon-custom 模块服务; 8、在浏览器输入地址http://localhost:8020/choose,然后看看 springms-provider-user、springms-provider-user2 的两个端口的服务打印的信息是否均匀,正常情况下应该是 springms-provider-user 随机分配,springms-provider-user2 轮询分配; 总结:springms-provider-user(之所以随机是因为使用了 RibbonClient 配置采用 RandomRule 随机调度算法)、springms-provider-user2(之所以轮询是因为没有任何配置,默认调度算法就是轮询算法); ****************************************************************************************/四、下载地址
https://gitee.com/ylimhhmily/SpringCloudTutorial.git
SpringCloudTutorial交流QQ群: 235322432
SpringCloudTutorial交流微信群: 微信沟通群二维码图片链接
欢迎关注,您的肯定是对我最大的支持!!!
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/70442.html
摘要:第篇电影微服务,使用配置文件配置在客户端进行负载均衡调度算法一大致介绍通过配置来设置客户端进行负载均衡的调度算法通过两种代码调用方式来测试客户端负载均衡算法二实现步骤添加引用包模块客户端发现模块 SpringCloud(第 008 篇)电影微服务,使用 application.yml 配置文件配置 Ribbon 在客户端进行负载均衡调度算法 - 一、大致介绍 1、通过 applicat...
摘要:第篇电影微服务,脱离使用配置进行客户端负载均衡调度一大致介绍通过尝试脱离服务治理框架,脱离生态圈,单独操作客户端负载均衡调度本章节仅仅只是使用了来测试客户端负载均衡算法二实现步骤添加引用包模块客 SpringCloud(第 011 篇)电影Ribbon微服务,脱离Eureka使用配置listOfServers进行客户端负载均衡调度 - 一、大致介绍 1、通过尝试脱离服务治理框架,脱离 ...
摘要:第篇电影微服务,使用在客户端进行负载均衡一大致介绍是发布的云中间层服务开源项目,主要功能是提供客户端负载均衡算法。而被注解后,能过用负载均衡,主要是维护了一个被注解的列表,并给列表中的添加拦截器,进而交给负载均衡器去处理。 SpringCloud(第 006 篇)电影微服务,使用 Ribbon 在客户端进行负载均衡 - 一、大致介绍 1、Ribbon 是 Netflix 发布的云中间层...
摘要:在该配置中,加入这个方法的话,表明使用了该配置的地方,就会禁用该模块使用容灾降级的功能添加访问层添加电影微服务启动类电影微服务,定制,一个功能禁用,另一个功能启用。 SpringCloud(第 016 篇)电影微服务,定制Feign,一个Feign功能禁用Hystrix,另一个Feign功能启用Hystrix - 一、大致介绍 1、在一些场景中,部分功能需要使用断路器功能,部分功能不需...
摘要:添加电影微服务启动类电影微服务接入进行客户端负载均衡,通过调用远程微服务。注解表示该电影微服务已经接入模块。 SpringCloud(第 012 篇)电影微服务接入 Feign 进行客户端负载均衡,通过 FeignClient 调用远程 Http 微服务 - 一、大致介绍 1、本章节主要介绍在 SpringCloud 生态圈中,使用一个类似于 Java HTTP 客户端的工具 Feig...
阅读 2683·2023-04-25 20:28
阅读 1852·2021-11-22 09:34
阅读 3688·2021-09-26 10:20
阅读 1836·2021-09-22 16:05
阅读 3086·2021-09-09 09:32
阅读 2504·2021-08-31 09:40
阅读 2102·2019-08-30 13:56
阅读 3322·2019-08-29 17:01