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