摘要:中的名稱,一定要是服務中注冊的名稱。添加這個的注解,主要是因為定義的時候報錯,也就是說明沒有被實例化。采用隨機分配的策略。添加訪問層添加電影微服務啟動類電影微服務,使用定制化在客戶端進行負載均衡,使用不同服務不同配置策略。
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交流微信群: 微信溝通群二維碼圖片鏈接
歡迎關注,您的肯定是對我最大的支持!!!
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/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...
閱讀 2679·2023-04-25 20:28
閱讀 1849·2021-11-22 09:34
閱讀 3687·2021-09-26 10:20
閱讀 1834·2021-09-22 16:05
閱讀 3085·2021-09-09 09:32
閱讀 2502·2021-08-31 09:40
閱讀 2099·2019-08-30 13:56
閱讀 3320·2019-08-29 17:01