SpringCloud如何根據(jù)服務名獲取服務運行實例并進行負載均衡
Nacos注冊中心
每個服務啟動之后都要向注冊中心發(fā)送服務注冊請求,注冊中心可以和各個注冊客戶端自定義協(xié)議實現(xiàn)服務注冊和發(fā)現(xiàn)。
pom.xml
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>啟動服務


獲取服務實例測試
@EnableDiscoveryClient
@SpringBootApplication
public class Main83
{
public static void main(String[] args)
{
ConfigurableApplicationContext applicationContext = SpringApplication.run(Main83.class, args);
DiscoveryClient discoveryClient = applicationContext.getBean(DiscoveryClient.class);
List<ServiceInstance> instances = discoveryClient.getInstances("nacos-payment-provider");
for (ServiceInstance instance : instances) {
System.out.println("instance.getHost() = " + instance.getHost());
System.out.println("instance.getPort() = " + instance.getPort());
}
NacosDiscoveryClient nacosDiscoveryClient = applicationContext.getBean(NacosDiscoveryClient.class);
List<ServiceInstance> serviceInstances = nacosDiscoveryClient.getInstances("nacos-payment-provider");
for (ServiceInstance instance : serviceInstances) {
System.out.println("Nacos instance.getHost() = " + instance.getHost());
System.out.println("instance.getPort() = " + instance.getPort());
}
LoadBalancerClient balancerClient = applicationContext.getBean(LoadBalancerClient.class);
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
}
}在引入注冊中心相關的依賴后,注冊中心的相關API會實現(xiàn)SpringCloud規(guī)范,自動給容器中存入DiscoveryClient對象,引入了Nacos,就是NacosDiscoveryClient。通過DiscoveryClient接口提供的能力可以從注冊中心實時拉取服務列表。
- 負載均衡實現(xiàn)
微服務在自動進行服務發(fā)現(xiàn)后,進行的是客戶端負載均衡,也就是客戶端自己維護了一套負載均衡算法,每次請求選擇某一臺服務器進行請求。
pom.xml
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>LoadBalancerClient balancerClient = applicationContext.getBean(LoadBalancerClient.class);
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());
System.out.println("balancerClient.choose(\"nacos-payment-provider\").getPort() = " + balancerClient.choose("nacos-payment-provider").getPort());LoadBalancerClient類會自動使用容器中的DiscoveryClient進行服務的負載均衡。
到此這篇關于SpringCloud根據(jù)服務名獲取服務運行實例并進行負載均衡的文章就介紹到這了,更多相關SpringCloud服務名獲取服務運行實例內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Redis6搭建集群并在SpringBoot中使用RedisTemplate的實現(xiàn)
本文主要介紹了Redis6搭建集群并在SpringBoot中使用RedisTemplate,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2022-04-04

