目录
二、在主类上添加@EnableDiscoveryClient注解
六、优化：使用Fegin替换restTemplate实现服务调用
思考一：为什么关掉nacos的终端窗口还是可以对服务进行访问？
一、nacos的作用
Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。
从上面的介绍就可以看出，nacos的作用就是一个注册中心，用来管理注册上来的各个微服务。
1. 服务发现：
- 服务注册：保存服务提供者和服务调用者的信息
- 服务订阅：服务调用者订阅服务提供者的信息，注册中心向订阅者推送提供者的信息
2. 服务配置：
- 配置订阅：服务提供者和服务调用者订阅微服务相关的配置
- 配置下发：主动将配置推送给服务提供者和服务调用者
3. 服务健康检测
- 检测服务提供者的健康情况，如果发现异常，执行服务剔除
二、安装与启动nacos
编辑startup.cmd
双击启动：
访问nacos：http://localhost:8848/nacos，默认密码是nacos/nacos
三、项目集成nacos
一、pom.xml导入依赖：
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
二、在主类上添加@EnableDiscoveryClient注解
该注解能够让注册中心能够发现，扫描到该服务
@SpringBootApplication
@EnableDiscoveryClient
public class ProductApplication三、配置文件
spring:
cloud:
nacos:
discovery:
server-addr: 127.0.0.1:8848
四、搭建服务集群：
设置相同的启动类，然后设置不同的端口。
启动两个服务可以看到两个服务都在运行！
打开nacos（http://localhost:8848/nacos）可以看到实例数增加为2.
手动方式实现负载均衡：
修改controller类的方法
/**
* @author Dragon code!
* @create 2022-05-04 16:46
*/
@RestController
@Slf4j
public class OrderController {
@Resource
private OrderService orderService;
@Resource
//可以发出基于http协议的rest风格的请求
private RestTemplate restTemplate;
@Resource
//发现者，利用发现者对象访问服务时通过服务名来访问
private DiscoveryClient discoveryClient;
@RequestMapping("/order/prod/{pid}")
public Order save(@PathVariable Integer pid){
log.info("准备调用商品服务查询商品信息");
//此时的instances就是我们要访问的所有服务(实现负载均衡)
List<ServiceInstance> instances = discoveryClient.getInstances("service-product");
//随机函数实现负载均衡
ServiceInstance instance = instances.get(new Random().nextInt(instances.size()));
log.info("调用的微服务的地址是:"+instance.getPort());
//动态获取url
String url = "http://" + instance.getHost() + ":" + instance.getPort();
//Product product = restTemplate.getForObject("http://localhost:8081/product/" + pid, Product.class);
Product product = restTemplate.getForObject(url + "/product/" + pid, Product.class);
log.info("商品微服务返回的商品"+ JSON.toJSONString(product));
log.info("创建订单对象");
Order order = new Order();
order.setPname(product.getPname());
order.setPprice(product.getPprice());
order.setNumber(1);
order.setPid(product.getPid());
order.setUsername("测试用户");
orderService.save(order);
return order;
}
}再次进行访问（不断刷新）可以看到我们的端口号是在不断的变化的，负载均衡达到！
五、基于Ribbon实现负载均衡
Ribbon是Spring Cloud的一个组件， 它可以让我们使用一个注解就能轻松的搞定负载均衡
第1步：在RestTemplate 的生成方法上添加@LoadBalanced注解
?启动类：
/**
* @author Dragon code!
* @create 2022-05-04 16:43
*/
@SpringBootApplication
@EnableDiscoveryClient
@EntityScan(basePackages = "com.lay.shop.entity")
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
@Bean
//restTemplate可以利用Ribbon实现负载均衡
@LoadBalanced
public RestTemplate restTemplate() {
RestTemplate restTemplate = new RestTemplate();
return restTemplate;
}
}controller类的方法修改如下：
精髓在于加了LoadBalanced注解的restTemplate对象会根据服务名到nacos治理中心去自己实现负载均衡
@RequestMapping("/order/prod/{pid}")
public Order save(@PathVariable Integer pid){
log.info("准备调用商品服务查询商品信息");
//直接使用微服务名字， 从nacos中获取服务地址
String url = "service-product";
// Product product = restTemplate.getForObject("http://localhost:8081/product/" + pid, Product.class);
Product product = restTemplate.getForObject("http://"+url + "/product/" + pid, Product.class);
log.info("商品微服务返回的商品"+ JSON.toJSONString(product));
log.info("创建订单对象");
Order order = new Order();
order.setPname(product.getPname());
order.setPprice(product.getPprice());
order.setNumber(1);
order.setPid(product.getPid());
order.setUsername("测试用户");
orderService.save(order);
return order;
}
不同的负载均衡策略：
?我们可以通过修改配置来调整Ribbon的负载均衡策略，具体代码如下
属于自定义配置，加载order项目的配置文件中
service-product: # 调用的提供者的名称
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
六、优化：使用Fegin替换restTemplate实现服务调用
Feign是Spring Cloud提供的一个声明式的伪Http客户端， 它使得调用远程服务就像调用本地服务一样简单（有点像rpc的远程调用）， 只需要创建一个接口并添加一个注解即可。
Nacos很好的兼容了Feign， Feign默认集成了 Ribbon， 所以在Nacos下使用Fegin默认就实现了负载均衡的效果。
那么使用Fegin的好处就在于它既能实现远程过程调用，又可以实现负载均衡！
一、加入依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
二、在主类上加上Fegin的注解
/**
* @author Dragon code!
* @create 2022-05-04 16:43
*/
@SpringBootApplication
@EnableDiscoveryClient
//开启Fegin
@EnableFeignClients
@EntityScan(basePackages = "com.lay.shop.entity")
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
@Bean
//restTemplate可以利用Ribbon实现负载均衡
@LoadBalanced
public RestTemplate restTemplate() {
RestTemplate restTemplate = new RestTemplate();
return restTemplate;
}
}三、创建service并使用Fegin实现微服务的调用
注意先到调用的提供者（service-prouct）的service中声明提供者的name
@FeignClient+@GetMapping 就是一个完整的请求路径！
http://service- product/product/{pid}
注意点：此处新建的service是参考在order工程里面controller类的方法（也就是红框部分），然后实现修改。
修改后的接口如下：注意接口的方法要加上PathVariable注解实现url属性的映射
/**
* @author Dragon code!
* @create 2022-05-04 15:42
*/
@FeignClient("service-product")//声明调用的提供者的name
public interface ProductService {
@GetMapping(value = "/product/{pid}")
Product findByPid(@PathVariable("pid") Integer pid);
}四、在此基础上修改controller的代码并启动验证
/**
* @author Dragon code!
* @create 2022-05-04 16:46
*/
@RestController
@Slf4j
public class OrderController {
@Resource
private OrderService orderService;
// @Resource
// //可以发出基于http协议的rest风格的请求
// private RestTemplate restTemplate;
// @Resource
// //发现者，利用发现者对象访问服务时通过服务名来访问
// private DiscoveryClient discoveryClient;
@Resource
private ProductService productService;
@RequestMapping("/order/prod/{pid}")
public Order save(@PathVariable Integer pid){
log.info("准备调用商品服务查询商品信息");
//直接使用微服务名字， 从nacos中获取服务地址
String url = "service-product";
//通过fegin调用商品微服务
Product product = productService.findByPid(pid);
log.info("商品微服务返回的商品"+ JSON.toJSONString(product));
log.info("创建订单对象");
Order order = new Order();
order.setPname(product.getPname());
order.setPprice(product.getPprice());
order.setNumber(1);
order.setPid(product.getPid());
order.setUsername("测试用户");
orderService.save(order);
return order;
}
}
注释启动类的老办法与注解
访问成功：
说明Fegin替代restTemplate实现rpc成功！
思考一：为什么关掉nacos的终端窗口还是可以对服务进行访问？
????????其实每一次的访问并不是都走nacos的，第一次访问后，我们的访问地址会被缓存到本地，即使关了nacos但是只要不关idea里的服务器，还是可以进行访问，但是只要idea项目停了缓存就会被清除，此时再重启会发现访问不了。
