Provider 服务端

服务端我们复用前篇Spring Cloud alibaba 使用Nacos配置中心的代码

修改启动类

在启动类上添加@EnableDiscoveryClient 注解 开启服务注册发现功能

package com.yyoo.cloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication(scanBasePackages = {"com.yyoo"})
@EnableDiscoveryClient // 开启服务注册发现功能
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}}

就此我们的服务端就已经完成了。我们后续的示例会用到前篇示例中的TestController

在application.properties配置中添加如下配置

# 当前应用的访问端口
server.port=8702
# 当前应用的访问上下文
server.servlet.context-path=/myCloud
# 当前服务名称
spring.application.name=myCloudConsumer# 配置Nacos注册中心
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
# 不配置默认是${spring.application.name}的值
spring.cloud.nacos.discovery.service=myCloudConsumer

Consumer消费端

pom.xml配置

4.0.0org.exampleCloudConsumer1.0-SNAPSHOTCloudConsumerUTF-8UTF-81.82021.0.42021.0.4.0org.springframework.bootspring-boot-starter-parent2.6.11org.springframework.cloudspring-cloud-dependencies${spring.cloud.version}pomimportcom.alibaba.cloudspring-cloud-alibaba-dependencies${spring.cloud.alibaba.version}pomimportcom.alibaba.cloudspring-cloud-starter-alibaba-nacos-discoverycom.alibaba.cloudspring-cloud-starter-alibaba-nacos-configorg.springframework.cloudspring-cloud-starter-loadbalancerorg.springframework.cloudspring-cloud-starter-bootstraporg.springframework.bootspring-boot-starter-testtestjunitjunittestorg.springframework.bootspring-boot-starter-weborg.projectlomboklombokdevdevtruetesttestprepreprodprodorg.springframework.bootspring-boot-maven-plugin${build.name}src/main/resourcestruemapper/**/*.xmlapplication.propertiesapplication-${profileActive}.propertiesbootstrap.propertieslogback-spring.xml

跟我们的前篇的引用是差不多的，多了个spring-cloud-starter-loadbalancer的引用而已，因为我们的Consumer会用到，负载均衡我们会在后续详细介绍

老版本的Spring Cloud以及其相关组件如Feign、openFeign等都默认使用ribbon做负载均衡组件，但是ribbon已经停止更新，所以spring官方推出了spring-cloud-starter-loadbalancer来作为替代。

配置RestTemplate

package com.yyoo.cloud.conf;import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;@Configuration
public class ConsumerConf {@LoadBalanced@Beanpublic RestTemplate restTemplate(){return new RestTemplate();}}

@LoadBalanced 自动为RestTemplate设置负载均衡策略。这个我们后续再讲。

测试ConsumerController

package com.yyoo.cloud.controller;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;@RestController
@RequestMapping("consumer")
public class ConsumerController {@Autowiredprivate RestTemplate restTemplate;@GetMapping("/getMyCloudConf")public String getMyCloudConf(){return restTemplate.getForObject("http://myCloud/myCloud/conf/getCommonConf",String.class);}}

注：示例中有两个myCloud，前一个myCloud是我们的Provider的服务名（spring.cloud.nacos.discovery.service），后一个myCloud是我们的Provider的上下文，请注意区分

这里为什么不用127.0.0.1:8701/myCloud/conf/getCommonConf来访问呢？这样不就跟我们没有使用Cloud一样了嘛，直接http调用。这里使用服务名来调用，就会使用我们导入的负载均衡，此时如果有多个Provider，最后其调用的Provider会根据我们的负载均衡策略来执行。

另一种示例写法

配置RestTemplate

@Configuration
public class ConsumerConf {@Beanpublic RestTemplate restTemplate(){return new RestTemplate();}}

注意：没有@LoadBalanced注解

测试ConsumerController

package com.yyoo.cloud.controller;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.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;@RestController
@RequestMapping("consumer")
public class ConsumerController {@Autowiredprivate LoadBalancerClient loadBalancerClient;@Autowiredprivate RestTemplate restTemplate;@GetMapping("/getMyCloudConf")public String getMyCloudConf(){//使用 LoadBalanceClient 和 RestTemplate 结合的方式来访问ServiceInstance serviceInstance = loadBalancerClient.choose("myCloud");String url = String.format("http://%s:%s/myCloud/conf/getCommonConf",serviceInstance.getHost(),serviceInstance.getPort());System.out.println("request url:"+url);return restTemplate.getForObject(url,String.class);}}

此写法我们直接使用了LoadBalancerClient 接口，spring-cloud-starter-loadbalancer中有其实现类，并且已经自动配置了，不用像RestTemplate一样需要自行配置。

执行结果

以上两种写法，访问 http://localhost:8702/myCloud/consumer/getMyCloudConf 链接都能得到最终的结果：
CommonConf(name=没事儿写两篇, age=12, desc=Spring Cloud 学习)