Nacos安装
Nacos 的 Github(Tags · alibaba/nacos · GitHub)下载我们所需的 Nacos 版本,可以选择 windows 或者 Linux。 进入官网,选择合适版本,tar.gz为linux版本,zip为windows版本。下载并解压 nacos-server-1.4.3.zip,解压完成后进入 /bin 目录,运行startup.cmd脚本。然后访问管理平台:
nacos注册服务中心管理可以通过管理平台查看和配置。启动后访问如下:
管理平台:http://localhost:8848/nacos
用户名:nacos
密 码:nacos
注册中心
这里对架构CAP进行简单介绍
CAP:C 一致性 A 可用性 P 分区容错性
以下是各个注册中心的CAP原理介绍
(1)Zookeeper 和 Consul 遵循 CP 原则,保证了强一致性和分区容错性,放弃可用性,在分布式环境中,如果涉及数据存储的场景,数据一致性应该是首先被保证的,但对于服务发现来说,可用性才是最核心的,针对同一个服务,即使注册中心的不同节点保存的服务提供者信息不相同,也并不会造成灾难性的后果。因为对于服务消费者来说,能消费才是最重要的,消费者拿到不正确的服务实例信息后尝试消费一下,也胜过因为无法获取实例信息而不去消费而导致系统异常
(2)Eureka 遵循 AP 原则,保证可用性,放弃数据一致性,基本能满足注册中心所需的核心功能,但 Eureka 2.x 版本已停止开发,并且宣布如果继续使用的话,风险自负。
(3)Nacos 同时支持 AP 与 CP,默认是 AP,同时功能更丰富,与 SpringCloud Alibaba 的兼容性更好,使用更简单灵活,可以满足更多的业务场景,且支持 K8S 的集成。
在进行Springcloud项目时版本依赖一定要合适,由于本人在一开始搭建项目的时候由于版本问题折腾了一段时间,在此把版本依赖进行记录。
推荐组件版本
导入依赖
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency>
application.yml文件配置
spring: application: name: user cloud: nacos: server-addr: localhost:8848 discovery: cluster-name: SH//集群名字
负载均衡
导入依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-ribbon</artifactId> </dependency>
负载均衡配置文件
@Configuration public class RestTemplateConfiguration { @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } }
业务使用
@RestController @RefreshScope public class UserController { @Autowired OrdersMapper ordersMapper; String url="http://user:9201/user/"; @Value("${pattern.dateformat}") private String dateformat; @Autowired RestTemplate restTemplate; @Autowired Feign feign; @GetMapping("/order/{id}") public Orders orders(@PathVariable("id") Long id, @RequestHeader(value = "token",required = false) String token){ System.out.println(token); DateFormat df=new SimpleDateFormat(dateformat); System.out.println(df.format(new Date())); Orders orders = ordersMapper.selectById(id); User forObject = restTemplate.getForObject(url + orders.getUserId(), User.class); //User user = feign.findbyId(orders.getUserId()); orders.setUser(user); return orders; } }
配置nacos访问进行负载均衡的时候 优先访问集群内部的服务,在访问集群内部的服务实例的时候采用随机方式,配置代码如下,如果不设计以下代码,在访问的时候负载均衡默认采用轮询的方式。
user://要做配置的微服务名称 ribbon: NFLoadBalancerRuleClassName: com.alibaba.cloud.nacos.ribbon.NacosRule
实际部署中有这样的场景,服务器设备性能有差异,部分实例所在机器性能较好,另一些较差,我们希望性能好的机器承担更多的用户请求Nacos提供了权重配置来控制访问频率,权重越大则访问频率越高。可以在nacos中心配置实例权重值。
Nacos配置管理
导入依赖
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency>
在nacos注册中心配置列表新建provider-dev.yaml文件,微服务名-部署环境.文件类型
在resources中新建bootstrap.yml
spring: application: name: provider profiles: active: dev cloud: nacos: server-addr: localhost:8848 config: file-extension: yaml discovery: cluster-name: BJ
配置完成后就可以正常的使用了。
配置热更新在业务组件上加上@RefreshScope注解就可以了
多环境配置共享,微服务启动时会从nacos中读取多个配置文件,[spring.apllication.name].yaml这个文件一定会加载,因此多环境共享配置可以写入这个文件。
多种配置优先级:服务名-profile.yaml>服务名.yaml>本地配置
Feign
导入依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>
编写Feign客户端
@FeignClient("user") public interface Feign { @GetMapping("/user/{id}") User findbyId(@PathVariable("id") Long id); }
Gateway
新建一个moudle
导入依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway</artifactId> </dependency> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency>
编写路由配置
spring: application: name: gateway cloud: nacos: server-addr: localhost:8848 gateway: routes: - id: pro-vider uri: lb://provider predicates: - Path=/order/** filters: - AddRequestHeader=token,mytoken //部分 default-filters: - AddRequestHeader=token,mytoken //全局
另一种全局过滤器
@Component @Order(-1)//越小优先级越高 public class Filter implements GlobalFilter { public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { ServerHttpRequest request = exchange.getRequest(); MultiValueMap<String, String> queryParams = request.getQueryParams(); String author = queryParams.getFirst("author"); if("admin".equals(author)){ return chain.filter(exchange); } exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED); return exchange.getResponse().setComplete(); } }
请求进入网关会碰到三类过滤器:当前路由的过滤器、DefaultFilter、GlobalFilter,请求路由后,会将当前路由过滤器和DefaultFilter、GlobalFilter,合并到一个过滤器链(集合)中,排序后依次执行每个过滤器。
由于浏览器不能执行其他网站的脚本,Ajax请求发送不出去。Gateway跨域配置代码如下
spring: application: name: gateway cloud: nacos: server-addr: localhost:8848 gateway: routes: - id: pro-vider uri: lb://provider predicates: - Path=/order/** filters: - AddRequestHeader=token,mytoken globalcors: #全局的跨域处理 add-to-simple-url-handler-mapping: true #解决options请求拦截的问题 corsConfigurations: '[/**]': allowedOrigins: #允许哪些网站的跨域请求 - "http://localhost:10010" - "http://www.baidu.com" allowedMethods: #允许的跨域ajax的请求方式 - "GET" - "POST" - "DELETE" - "PUT" - "OPTIONS" allowedHeaders: "*" #允许在请求中携带的头信息 allowCredentials: true #是否允许携带cookie maxAge: 240000 #这次跨域的有效期,单位ms


