文章目录
前言
Ribbon是Spring Cloud的一个组件， 它可以让我们使用一个注解就能轻松的搞定负载均衡。
前边我们调用是从服务中获取实例获取调用的地址和端口，从而调用服务，这样特别麻烦，Feign是Spring Cloud提供的一个声明式的伪Http客户端， 它使得调用远程服务就像调用本地服务一样简单， 只需要创建一个接口并添加一个注解即可。Nacos很好的兼容了Feign， Feign默认集成了 Ribbon， 所以在Nacos下使用Fegin默认就实现了负载均衡的效果。
项目实战
随机获取服务调用
从上篇中，我们复制两个module改下端口，也可以IDEA中直接进行改端口运行两个服务。查看nacos查询服务。
启动成功之后，登录nacos进行查询服务。
此时我们在订单中进行调用product服务。
订单中代码,获取商品服务实例的列表，随机获取一个实例进行调用
//从nacos服务注册中心获取product服务
List<ServiceInstance> productServiceInstanceList = discoveryClient.getInstances("springcloud-product");
int index = new Random().nextInt(productServiceInstanceList.size());
ServiceInstance productServiceInstance =
discoveryClient.getInstances("springcloud-product").get(index);
String productUrl = productServiceInstance.getHost()+":"+productServiceInstance.getPort();
log.info("获取到的商品实例的url:"+productUrl);
Product product = restTemplate.getForObject("http://"+productUrl+"/springcloud/product/getProductById/"+order.getProductId(), Product.class);
res.put("product",product);
ribbon实现负载均衡
ribbon非常简单，直接在在RestTemplate 的生成方法上添加@LoadBalanced注解即可。
/**
* 获取RestTemplate
*/
@Configuration
public class RestemplateConfig {
@LoadBalanced
@Bean
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
}
访问日志可以看到ribbon相关的
负载均衡策略接口类
public interface IRule {
Server choose(Object var1);
void setLoadBalancer(ILoadBalancer var1);
ILoadBalancer getLoadBalancer();
}
也可以自己定义负载均衡策略，配置一下ribbon负载均衡对应的类即可，这里就不多说
feign实现服务调用
引入feign组件依赖
<!--fegin组件-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
启动类
@EnableDiscoveryClient
@SpringBootApplication
@EnableFeignClients//开启Fegin
public class SpringcloudOrderApplication {
public static void main(String[] args) {
SpringApplication.run(SpringcloudOrderApplication.class,args);
}
}
product服务接口
@FeignClient("springcloud-product")
public interface ProductService {
//指定调用提供者的哪个方法
//@FeignClient+@GetMapping 就是一个完整的请求路径
@GetMapping(value = "/springcloud/product/getProductById/{product_id}")
Product getProductById(@PathVariable("product_id") Integer product_id);
}
@FeignClient("springcloud-user")
public interface UserService {
@GetMapping(value = "/springcloud/user/getUserByUseId/{user_id}")
User getUserByUseId(@PathVariable("user_id") Integer user_id);
}
controller测试类
@RestController
@RequestMapping("/springcloud/feign/order")
@Slf4j
public class OrderFeignController {
@Autowired
IOrderService orderService;
@Autowired
ProductService productService;
@Autowired
private UserService userService;
/**
* 获取订单列表
* @return
*/
@GetMapping("/getOrderById/{order_id}")
public HashMap<String,Object> getOrderById(@PathVariable("order_id")Integer order_id){
HashMap<String,Object> res = new HashMap<>();
//获取订单
Order order = orderService.getById(order_id);
res.put("order",order);
//直接使用服务名字作为URL进行调用
//获取用户
User user = userService.getUserByUseId(order.getUserId());
res.put("user",user);
//获取商品信息
Product product = productService.getProductById(order.getProductId());
res.put("product",product);
return res;
}
}
测试
