Nacos学习(二)——继承Feign与Config中心

目录

一、集成Feign

(一)基础用法

1.添加openfeign依赖

2. 开启openFeign注解扫描

3.创建ProviderService接口 

4.修改ConsumerController

(二)OpenFeign日志配置

(三)参数传递

1.参数传递的问题

2.参数传递的方式

2.1URL路径传参

2.2URL上拼接参数

2.3body传参

二、Config中心

1.bootstrap方式

1.1pom.xml

1.2新增bootstrap.properties

1.3在nacos中，增加一个配置

1.4新建接口

1.5重启consumer-service

2.spring.config.import方式(推荐)

2.1注释掉bootstrap依赖并删除bootstrap.properties文件

2.2application.properteis中，增加配置

2.3重启consumer-service

3.动态刷新

4.加载指定文件

4.1Group

4.1.1克隆配置

4.1.2修改application.properties 

4.1.3重启consumer-service服务，刷新浏览器

4.2Namespace

4.2.1新建两个命名空间

5.使用Mysql

5.1nacos-mysql.sql 

5.2修改conf下的application.properties文件

5.3保存后重启nacos

---

书接上文《Nacos学习(一)——基本介绍、安装与负载均衡策略》

一、集成Feign

(一)基础用法

feign本质是对 Http请求封装，使服务之间的调用更简单。

1.添加openfeign依赖

修改consumer-service服务的pom.xml文件：

<!-- openfeign 也是放在调用方-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

2. 开启openFeign注解扫描

@SpringBootApplication
@EnableFeignClients // 开启openFeign注解扫描
public class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class,args);}
}

3.创建ProviderService接口 

@FeignClient(name = "provider-service")
public interface ProviderService {@GetMapping("/provider")String provider();
}

就是将红框里的方法，复制到ProviderService中，并改为抽象方法 

        这段代码定义了一个名为 ProviderService 的 Feign 客户端接口，用于调用名为 provider-service 的服务。该接口包含一个方法 provider，通过 GET 请求访问 /provider 路径，并返回一个字符串。
        Feign 客户端被称为“代理”的原因在于它使用了代理模式。具体来说：

• 动态代理：Feign 通过动态代理机制生成接口的实现类。在运行时，当你调用 ProviderService 接口的方法时，实际上是由 Feign 生成的代理对象来处理请求。
• 远程调用透明化：代理对象负责将方法调用转换为 HTTP 请求发送到目标服务，并将响应结果转换为方法的返回值。对于开发者而言，这种远程调用是透明的，就像调用本地方法一样简单。

        因此，Feign 客户端被称为“代理”，因为它充当了本地服务与远程服务之间的中介角色，简化了远程服务调用的过程。

4.修改ConsumerController

添加下面的代码：

@Autowired
private ProviderService providerService;@GetMapping("/balancer2")
public String balancer2() {return providerService.provider();
}

重启consumer-service服务，访问该接口，采用的是provider的随机权重

(二)OpenFeign日志配置

注意：凡是带有default的，都表示全局配置。

配置日志，可以让我们看到远程调用时的一些详细情况

日志配置有 2 种：

• 全局配置：feign.client.config.default.属性名
• 局部配置：feign.client.config.服务名.属性名

如果同时存在，以 局部配置 为主，修改配置文件：

# feign日志级别，可选值包括BASIC、HEADERS、FULL或NONE，用于请求和响应的日志输出级别
# NONE：不记录日志
# BASIC：记录方法、URL、HTTP状态、响应时间等，适用于生产环境
# HEADERS：在BASIC的基础上，额外记录请求和响应头信息
# FULL: 记录请求和响应的所有数据，适用于开发环境
feign.client.config.default.loggerLevel=full#如果想让feign的日志生效，还需要设置springboot的日志级别
# 格式：logging.level.<FeignClient所在类包名>=debug
logging.level.com.xiaoai.service=debug
# 如果只想让某一个feign客户端生效,那么：logging.level.<FeignClient类全路径>=debug#springboot的日志级别
logging.level.root=DEBUG

最终的配置文件，consumer-service的application.properties：

server.port=8888
spring.application.name=consumer-service
#nacos的地址
spring.cloud.nacos.discovery.server-addr=192.168.157.102:8848
spring.cloud.nacos.discovery.ip=192.168.0.16
# 指定springboot的日志级别
logging.level.root=debug
# 指定feign的日志级别
feign.client.config.default.logger-level=full
# 指定调用的provider-service服务的日志级别
logging.level.com.javatest.service.ProviderService=debug

注意：debug级别的日志太多，启动有报错不需要理会。

(三)参数传递

1.参数传递的问题

@RestController
public class ProviderController {@Value("${server.port}")private String port;@GetMapping("/provider")public String provider(String username) {return "provider-service:" + port + "------" + username;}
}

openFeign默认支持spring mvc 注解，调用接口时，如果传递参数，也要加上对应的注解，比如：

@FeignClient(name = "provider-service")
public interface ProviderService {@GetMapping("/provider")String provider(@RequestParam String username);
}

修改ConsumerController中的接口： 

@Autowired
private ProviderService providerService;@GetMapping("/balancer2")
public String balancer2(String username) {return providerService.provider(username);
}

重启consumer-service和provider-service集群，浏览器url输入参数： 

如果没有 RequestParam 注解，结果：

这是因为，底层把参数加到 body 中，比如：

同时，因为openfeign底层用的是jdk的原生http工具，在HttpURLConnection中如果body不是空，会把get请求转换为post请求，所以提示 405 状态码。

而使用 RequestParam 注解后，会把参数拼到 url 上，比如：

2.参数传递的方式

2.1URL路径传参

调用方服务代码：

@RestController
public class ConsumerController {@Autowiredprivate ProviderService providerService;/*** 使用URL路径传参* @param username* @return*/@GetMapping("/balancer3")public String balancer3(String username) {return providerService.getport(username);}}

@FeignClient(name = "provider-service")
public interface ProviderService {/*** URL路径传参* @param username* @return*/@GetMapping("/getport/{username}")String getport(@PathVariable String username);
}

被调用方接收参数：

@RestController
public class ProviderController {@Value("${server.port}")private String port;/*** 接收URL路径传参* @param username* @return*/@GetMapping("/getport/{username}")public String getport(@PathVariable String username) {return "getport:" + port + "------" + username;}
}

2.2URL上拼接参数

ConsumerController：

@RestController
public class ConsumerController {@Autowiredprivate ProviderService providerService;/*** URL上拼接参数方式一：零散参数* http://localhost:8888/balancer2?username=rose&age=19* @param username* @return*/@GetMapping("/balancer2")public String balancer2(String username, Integer age) {return providerService.provider(username, age); // 传递的零散参数是指这里}/*** URL上拼接参数方式二：传递对象* http://localhost:8888/getUser?username=jack&age=22* http://localhost:8888/getUser?username=%E5%BC%A0%E4%B8%89&age=29*  %E5%BC%A0%E4%B8%89 是URL编码* @param user* @return*/@GetMapping("/getUser")public String getUser(User user) {return providerService.provider(user); // 传递的对象是指这里}/*** URL上拼接参数方式三：传递Map* http://localhost:8888/getMap?username=john&age=22* http://localhost:8888/getMap?username=%E5%BC%A0%E4%B8%89&age=22* @param user* @return*/@GetMapping("/getMap")public String getMap(User user) {Map<String, Object> map = new HashMap<>();map.put("username", user.getUsername());return providerService.provider(map); // 传递的Map是指这里}
}

ProviderService： 

@FeignClient(name = "provider-service")
public interface ProviderService {/*** URL上拼接参数方式一：零散参数** @param username* @return*/@GetMapping("/provider")String provider(@RequestParam String username, @RequestParam Integer age);/*** URL上拼接参数方式二：传递对象* @param user* @return @SpringQueryMap注解只能修饰一个参数* @SpringQueryMap注解会将对象打散，以?的形式拼接，以&分割*/@GetMapping("/provider")String provider(@SpringQueryMap User user);/*** URL上拼接参数方式三：传递Map** @param map* @return*/@GetMapping("/provider")String provider(@RequestParam Map<String, Object> map);
}

被调用的服务的ProviderController： 

@RestController
public class ProviderController {@Value("${server.port}")private String port;/*** 接收URL上拼接参数三种方式** @param username* @return*/@GetMapping("/provider")public String provider(String username) {return "provider:" + port + "------" + username;}
}

注意：

        ProviderService和ProviderController中的接口是意义对应的，一般是将ProviderController中的请求方式和方法复制到ProviderService中，去掉方法体和public，变成抽象方法。

        我这里没有对应是因为ProviderService中使用了方法重载。

2.3body传参

使用 RequestBody 注解 或 无任何注解时，会把参数放到 body 中，比如：

ConsumerController： 

@GetMapping("/testBody")
public String testBody(User user) {return providerService.providerBody(user);
}

ProviderService： 

@GetMapping("/providerBody")  // 改为@PostMapping也可以
String providerBody(User user);

被调用方ProviderController：

@PostMapping("/providerBody")
String providerBody(@RequestBody User user) {return "providerBody:" + port + "------" + user.getUsername() + "--------" + user.getAge();
}

浏览器请求： 

二、Config中心

nacos 除了用于服务注册，还可以作为配置中心。

1.bootstrap方式

1.1pom.xml

修改 consumer-service 中的 pom.xml，增加下面的依赖：

<!-- nacos 配置中心 -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency><!-- bootstrap 依赖，2.4之前的springboot，并不需要单独依赖 这里使用的springboot版本是2.6.11，所以要手动添加-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>

1.2新增bootstrap.properties

consumer-service中：

#从Nacos上获取配置文件
# 配置中心地址  这里的ip是nacos部署的机器ip
spring.cloud.nacos.config.server-addr=192.168.157.102:8848

注意：bootstrap.properties文件的优先级比application.properties文件的优先级高很多。因此，SpringBoot启动时，会先加载bootstrap.properties，后加载application.properties。

为了让日志少打印，将springboot的日志级别改为info，下面的两个日志级别配置就不会生效了。 

1.3在nacos中，增加一个配置

1.4新建接口

@RestController
public class ConfigController {@Value("${hero.name}")private String hero;@GetMapping("/hero")public String hero() {return "hello, " + hero;}
}

1.5重启consumer-service

重启 consumer 后浏览器访问：

2.spring.config.import方式(推荐)

2.1注释掉bootstrap依赖并删除bootstrap.properties文件

2.2application.properteis中，增加配置

spring.cloud.nacos.config.server-addr=192.168.157.102:8848
#格式：nacos:dataId
spring.config.import=nacos:${spring.application.name}

application.properteis中的完整配置如下：

server.port=8888
spring.application.name=consumer-service
#指定了 Nacos 服务器的地址和端口
spring.cloud.nacos.discovery.server-addr=192.168.157.102:8848
# 指定当前应用在注册到 Nacos 时使用的 IP 地址
spring.cloud.nacos.discovery.ip=192.168.0.16spring.cloud.nacos.config.server-addr=192.168.157.102:8848
#格式：nacos:dataId
spring.config.import=nacos:${spring.application.name}# 指定springboot的日志级别
logging.level.root=info
# 指定feign的日志级别
feign.client.config.default.logger-level=full
# 指定调用的provider-service服务的日志级别
logging.level.com.javatest.service.ProviderService=debug

2.3重启consumer-service

重启 consumer 后浏览器访问：

3.动态刷新

如果想要实时刷新配置，必须添加@RefreshScope 

@RestController
@RefreshScope // 实时刷新配置，在哪里使用nacos的配置，就在里使用@RefreshScope
public class ConfigController {@Value("${hero.name}")private String hero;@GetMapping("/hero")public String hero() {return "hello, " + hero;}
}

重启consumer-service，nacos修改配置： 

刷新浏览器：新的配置能够自动加载

4.加载指定文件

4.1Group

4.1.1克隆配置

4.1.2修改application.properties 

添加下面的配置：

spring.cloud.nacos.config.server-addr=192.168.157.102:8848
#格式：nacos:dataId
spring.config.import=nacos:${spring.application.name}# 当data ID相同时，指定配置的分组
spring.cloud.nacos.config.group=DEV_GROUP

4.1.3重启consumer-service服务，刷新浏览器

---

如果想要访问PROD_GROUP：

application.properties：

# 当data ID相同时，指定配置的分组
spring.cloud.nacos.config.group=PROD_GROUP

重启consumer-service服务，刷新浏览器 

4.2Namespace

4.2.1新建两个命名空间

                               

命名空间创建完成后，配置管理页面就会出现：

继续克隆，并且选择对应的命名空间：

修改两个命名空间中的配置：

修改application.properties文件：

添加想要获取的命名空间：

spring.cloud.nacos.config.server-addr=192.168.157.102:8848#格式：nacos:dataId
spring.config.import=nacos:${spring.application.name}# 当data ID相同时，指定配置的分组
spring.cloud.nacos.config.group=DEV_GROUP
spring.cloud.nacos.config.namespace=5479b5a2-5124-4b28-ba5e-88d10cdc6da0

重启consumer-service，刷新浏览器：

注意：如果Nacos上的配置不使用properties，而是使用yaml，需要修改application.properties文件。

# 当data ID相同时，指定配置的分组
spring.cloud.nacos.config.group=DEV_GROUP
spring.cloud.nacos.config.namespace=5479b5a2-5124-4b28-ba5e-88d10cdc6da0
spring.cloud.nacos.config.file-extension=yaml

5.使用Mysql

nacos默认使用嵌入式数据库(derby)实现数据的存储，不方便观察数据存储的情况
但它同时支持mysql，官方文档：Nacos支持三种部署模式

5.1nacos-mysql.sql 

在mysql中新建一个数据库

执行这个sql脚本：

5.2修改conf下的application.properties文件

在文件的最后一行添加数据库配置：

spring.datasource.platform=mysqldb.num=1
db.url.0=jdbc:mysql://mysql所在的机器ip:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&serverTimezone=UTC
db.user=用户名
db.password=密码

5.3保存后重启nacos

重启nacos，会发现之前的配置都没有了，就证明切换成的mysql，比如：

 

在mysql中可以查看到：

tenant_id表示命名空间：