1.Ribbon默认使用RoundRobinRule策略轮询选择server

切换策略

1. @Configuration
2. public class ConfigBean {
3. // @Bean
4. // public RestTemplate getRestTemplate() {
5. // return new RestTemplate();
6. // }
7. @Bean
8. @LoadBalanced//Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端 负载均衡的工具。
9. public RestTemplate getRestTemplate() {
10. return new RestTemplate();
11. }
12. @Bean
13. public IRule myRule()
14. {
15. //return new RoundRobinRule();
16. // return new RandomRule();//达到的目的，用我们重新选择的随机算法替代默认的轮询。
17. return new RetryRule();
18. }
19. }

自定义算法：

配置类（必须不能在启动类和启动类下所包含的子包下面）

1. public class RandomRule_ZY extends AbstractLoadBalancerRule
2. {
3. // total = 0 // 当total==5以后，我们指针才能往下走，
4. // index = 0 // 当前对外提供服务的服务器地址，
5. // total需要重新置为零，但是已经达到过一个5次，我们的index = 1
6. // 分析：我们5次，但是微服务只有8001 8002 8003 三台，OK？
7. //
8. private int total = 0; // 总共被调用的次数，目前要求每台被调用5次
9. private int currentIndex = 0; // 当前提供服务的机器号
10. public Server choose(ILoadBalancer lb, Object key)
11. {
12. if (lb == null) {
13. return null;
14. }
15. Server server = null;
16. while (server == null) {
17. if (Thread.interrupted()) {
18. return null;
19. }
20. List<Server> upList = lb.getReachableServers();
21. List<Server> allList = lb.getAllServers();
22. int serverCount = allList.size();
23. if (serverCount == 0) {
24. /*
25. * No servers. End regardless of pass, because subsequent passes only get more
26. * restrictive.
27. */
28. return null;
29. }
30. // int index = rand.nextInt(serverCount);// java.util.Random().nextInt(3);
31. // server = upList.get(index);
32. // private int total = 0; // 总共被调用的次数，目前要求每台被调用5次
33. // private int currentIndex = 0; // 当前提供服务的机器号
34. if(total < 5)
35. {
36. server = upList.get(currentIndex);
37. total++;
38. }else {
39. total = 0;
40. currentIndex++;
41. if(currentIndex >= upList.size())
42. {
43. currentIndex = 0;
44. }
45. }
46. if (server == null) {
47. /*
48. * The only time this should happen is if the server list were somehow trimmed.
49. * This is a transient condition. Retry after yielding.
50. */
51. Thread.yield();
52. continue;
53. }
54. if (server.isAlive()) {
55. return (server);
56. }
57. // Shouldn't actually happen.. but must be transient or a bug.
58. server = null;
59. Thread.yield();
60. }
61. return server;
62. }
63. @Override
64. public Server choose(Object key)
65. {
66. return choose(getLoadBalancer(), key);
67. }
68. @Override
69. public void initWithNiwsConfig(IClientConfig clientConfig)
70. {
71. // TODO Auto-generated method stub
72. }
73. }

1. @Configuration
2. public class MySelfRule {
3. @Bean
4. public IRule myRule() {
5. // return new RandomRule();// Ribbon默认是轮询，我自定义为随机
6. return new RandomRule_ZY();// 我自定义为每台机器5次
7. }
8. }

另一配置类（在启动类包里面）

1. @Configuration
2. public class ConfigBean {
3. // @Bean
4. // public RestTemplate getRestTemplate() {
5. // return new RestTemplate();
6. // }
7. @Bean
8. @LoadBalanced//Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端 负载均衡的工具。
9. public RestTemplate getRestTemplate() {
10. return new RestTemplate();
11. }
12. // @Bean
13. // public IRule myRule()
14. // {
15. // //return new RoundRobinRule();
16. // return new RandomRule();//达到的目的，用我们重新选择的随机算法替代默认的轮询。
17. // return new RetryRule();
18. // }
19. }

启动类

1. @SpringBootApplication
2. @EnableEurekaClient
3. //在启动该微服务的时候就能去加载我们的自定义Ribbon配置类，从而使配置生效
4. //@RibbonClient(name="MICROSERVICECLOUD-DEPT",configuration=MySelfRule.class)
5. @RibbonClient(name="MICROSERVICECLOUD-DEPT",configuration=MySelfRule.class)
6. public class DeptConsumer80_App {
7. public static void main(String[] args) {
8. SpringApplication.run(DeptConsumer80_App.class, args);
9. }
10. }

测试效果为每个server执行5次再轮询

转自：https://blog.csdn.net/flynn_chen/article/details/80631717