{"id":638,"date":"2023-09-06T16:30:38","date_gmt":"2023-09-06T08:30:38","guid":{"rendered":"http:\/\/www.huerpu.cc:7000\/?p=638"},"modified":"2023-09-06T16:30:38","modified_gmt":"2023-09-06T08:30:38","slug":"spring-cloudkilburn-2022-0-2%e7%89%88%e6%9c%ac%e7%b3%bb%e5%88%97%e6%95%99%e7%a8%8b%e4%ba%8c-%e6%9c%8d%e5%8a%a1%e6%b6%88%e8%b4%b9%e8%80%85resttemplateloadbalancer","status":"publish","type":"post","link":"http:\/\/www.huerpu.cc:7000\/?p=638","title":{"rendered":"Spring Cloud(Kilburn 2022.0.2\u7248\u672c)\u7cfb\u5217\u6559\u7a0b(\u4e8c) \u670d\u52a1\u6d88\u8d39\u8005(RestTemplate+Loadbalancer)"},"content":{"rendered":"

Spring Cloud(Kilburn 2022.0.2\u7248\u672c)\u7cfb\u5217\u6559\u7a0b(\u4e8c) \u670d\u52a1\u6d88\u8d39\u8005(RestTemplate+Loadbalancer)<\/h3>\n

\u4e00\u3001\u670d\u52a1\u6d88\u8d39<\/h3>\n

\u53ef\u4ee5\u53c2\u8003\u4e0a\u8282eurekaClientConsumer<\/code>\u3002<\/p>\n

\"image-20230421163829719\"<\/p>\n

\u5728\u542f\u52a8\u7c7b\u4e2d\uff0c\u6211\u4eec\u5df2\u7ecf\u6ce8\u5165\u4e86\u4e00\u4e2arestTemplate<\/code>\u4e86\uff0c\u5e76\u4e14\u5728\u4e0a\u9762\u589e\u52a0\u4e86@LoadBalanced<\/code>\u6ce8\u89e3\uff0c\u8fd9\u4e2a\u662f\u5bfc\u5165\u7684org.springframework.cloud.client.loadbalancer.LoadBalanced<\/code>\u5305\u4e0b\u7684\uff0c\u4e0d\u662fnetflix<\/code>\u5305\u4e0b\u7684\uff0c\u56e0\u4e3a\u65b0\u7248\u672c\u7684SpringCloud<\/code>\u5df2\u7ecf\u5f03\u7528\u4e86Ribbon<\/code>\uff0c\u4f7f\u7528\u7684\u4e8bSpring<\/code>\u81ea\u5bb6\u7684\u8d1f\u8f7d\u5747\u8861Loadbalancer<\/code>\u3002<\/p>\n

@Bean\n@LoadBalanced\npublic RestTemplate restTemplate() {\n      return new RestTemplate();\n}<\/code><\/pre>\n
\u5728ConsumerController<\/code>\u4e2d\u65b0\u589e\u65b9\u6cd5eurekaClientConsumerChooseInstance<\/code>\uff0c\u6765\u770b\u4e00\u4e0b\u6d88\u8d39\u670d\u52a1\u7684\u65f6\u5019\u5230\u5e95\u8c03\u7528\u7684\u54ea\u4e2aURL<\/code>\u3002<\/p>\n
@RequestMapping("\/eurekaClientConsumerChooseInstance")\npublic String eurekaClientConsumerChooseInstance() {\n    ServiceInstance serviceInstance = loadBalancerClient.choose("eurekaClient");\n    String server = serviceInstance.getInstanceId()+":"\n      +serviceInstance.getHost()+":"\n      +serviceInstance.getPort();\n    System.out.println(server);\n    return server;\n}<\/code><\/pre>\n
\u4e8c\u3001Loadbalancer\u8d1f\u8f7d\u5747\u8861<\/h3>\n
\u6211\u4eec\u5df2\u7ecf\u6709\u4e00\u4e2aeurekaClient<\/code>\u7684\u670d\u52a1\u63d0\u4f9b\u8005\uff0c\u63d0\u4f9b\u6839\u636eID\u53bb\u67e5\u8be2\u7528\u6237\u7684\u63a5\u53e3\u670d\u52a1\uff0c\u4e3a\u4e86\u4f53\u73b0\u8d1f\u8f7d\u5747\u8861\u6211\u4eec\u590d\u5236\u4e00\u4e0b\u8fd9\u4e2a\u9879\u76ee\u5e76\u4fee\u6539\u540d\u79f0\u4e3aeurekaClientProvider<\/code>\uff0c\u53ea\u9700\u628a\u7aef\u53e3\u53f7\u6539\u62108002<\/code>\uff0c\u5176\u4f59\u90fd\u4e0d\u53d8\u3002<\/p>\n
\u628a\u6240\u6709\u9879\u76ee\u90fd\u542f\u52a8\uff0c\u7a0d\u7b49\u7247\u523b\uff0ceureka<\/code>\u4e0a\u4f1a\u6709eurekaClient<\/code>\u548ceurekaClientProvider<\/code>\u6ce8\u518c\u4e0a\u6765\u3002<\/p>\n
\"image-20230421113420815\"<\/p>\n
\u591a\u6b21\u8c03\u7528http:\/\/localhost:8001\/eurekaClientConsumerChooseInstance<\/code>\uff0c\u53ef\u4ee5\u770b\u5230\u670d\u52a1\u57288000<\/code>\u548c8002<\/code>\u4e24\u4e2a\u7aef\u53e3\u7684\u670d\u52a1\u5668\u4e0a\u8f6e\u8be2\u8c03\u7528\u3002<\/p>\n
\"image-20230421161317480\"<\/p>\n
\u4e09\u3001\u5207\u6362Loadbalancer\u8d1f\u8f7d\u5747\u8861\u7b56\u7565<\/h3>\n
Loadbalancer<\/code>\u4e00\u5171\u6709\u4e24\u79cd\u8d1f\u8f7d\u5747\u8861\u7b56\u7565\uff0c\u8f6e\u8be2\u548c\u968f\u673a\uff0c\u5206\u522b\u5bf9\u5e94\u4e8eRoundRobinLoadBalancer<\/code>\u548cRandomLoadBalancer<\/code>\u3002<\/p>\n
\u5728loadbalancer<\/code>\u5305\u4e0b\uff0c\u65b0\u589e\u4e00\u4e2a\u914d\u7f6e\u7c7bCustomLoadBalancerConfiguration<\/code>\u3002\u5e76\u8bbe\u7f6e\u9ed8\u8ba4\u7b56\u7565\u4e3aRandomLoadBalancer<\/code>\u3002\u6ce8\u610f\u7c7b\u4e0a\u9762$\\textcolor{red}{\u4e0d\u52a0}$@Configuration<\/code>\u6ce8\u89e3\u3002<\/p>\n
package cc.huerpu.eurekaclient.loadbalancer;\n\nimport org.springframework.cloud.client.ServiceInstance;\nimport org.springframework.cloud.loadbalancer.core.RandomLoadBalancer;\nimport org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;\nimport org.springframework.cloud.loadbalancer.core.RoundRobinLoadBalancer;\nimport org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;\nimport org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.core.env.Environment;\n\npublic class CustomLoadBalancerConfiguration {\n    @Bean\n    public ReactorLoadBalancer<ServiceInstance> reactorServiceInstanceLoadBalancer(Environment environment,LoadBalancerClientFactory loadBalancerClientFactory) {\n        String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);\n        \/\/RoundRobinLoadBalancer RandomLoadBalancer\n        return new RandomLoadBalancer(loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class), name);\n    }\n}<\/code><\/pre>\n
\u5728\u542f\u52a8\u7c7bEurekaClientConsumerApplication<\/code>\u4e0a\u589e\u52a0@LoadBalancerClients<\/code>\u914d\u7f6e\uff0c\u8fd9\u4e2a\u662f\u5168\u5c40\u7684\u3002<\/p>\n
@LoadBalancerClients(defaultConfiguration = {CustomLoadBalancerConfiguration.class})<\/code><\/pre>\n
\u5982\u679c\u53ea\u662f\u5728\u7279\u5b9a\u7684\u670d\u52a1\u4e0a\u4f7f\u7528\u8fd9\u4e2a\u7b56\u7565\uff0c\u53ef\u4ee5\u589e\u52a0name<\/code>\u5c5e\u6027\uff0c\u6807\u8bc6\u670d\u52a1\u5e94\u7528\u540d\u3002<\/p>\n
@LoadBalancerClient(value = "eurekaClient", configuration = CustomLoadBalancerConfiguration.class)<\/code><\/pre>\n
\u91cd\u542f\u5e94\u7528\uff0c\u591a\u6b21\u8c03\u7528http:\/\/localhost:8001\/eurekaClientConsumerChooseInstance<\/code>\uff0c\u53ef\u4ee5\u770b\u5230\u670d\u52a1\u57288000<\/code>\u548c8002<\/code>\u4e24\u4e2a\u7aef\u53e3\u7684\u670d\u52a1\u5668\u4e0a\u968f\u673a\u8c03\u7528\u3002<\/p>\n
\"image-20230421162502940\"<\/p>\n
\n
\u672c\u6587\u53c2\u8003loadbalancer\u5b98\u65b9\u6587\u6863\uff1ahttps:\/\/docs.spring.io\/spring-cloud-commons\/docs\/4.0.2\/reference\/html\/#spring-cloud-loadbalancer<\/code><\/p>\n<\/blockquote>\n","protected":false},"excerpt":{"rendered":"
Spring Cloud(Kilburn 2022.0.2\u7248\u672c)\u7cfb\u5217\u6559\u7a0b(\u4e8c) \u670d\u52a1\u6d88\u8d39\u8005(RestTempl […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[22],"tags":[],"class_list":["post-638","post","type-post","status-publish","format-standard","hentry","category-spring-cloudkilburn-2022-0-2"],"_links":{"self":[{"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=\/wp\/v2\/posts\/638","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=638"}],"version-history":[{"count":1,"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=\/wp\/v2\/posts\/638\/revisions"}],"predecessor-version":[{"id":639,"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=\/wp\/v2\/posts\/638\/revisions\/639"}],"wp:attachment":[{"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=638"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=638"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.huerpu.cc:7000\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=638"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}