前面已经讲了在使用nacos做服务治理时，使用RestTemplate+ Ribbon实现微服务之间的调用和负载均衡。
出现的问题：
- 代码可读性不好（整个地址是拼接出来的）
- 编程风格不统一（调用本地服务和调用远程服务）
现在介绍一下SpringCloud服务间的调用的另一种方式：Feign。
Feign是Spring Cloud提供的一个声明式的伪Http客户端， 它使得调用远程服务就像调用本地服务一样简单， 只需要创建一个接口并添加一个注解@FeignClient即可。
Nacos很好的兼容了Feign， Feign默认集成了 Ribbon， 所以在Nacos下使用Fegin默认就实现了负载均衡的效果。
1. 加入Feign的依赖
<!--feign组件-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2. 在主类上添加Feign的注解
@SpringBootApplication
@MapperScan("com.test.shop.order.dao")
@EnableDiscoveryClient
@EnableFeignClients
public class ShopOrderApplication {
3. 创建一个service接口，并添加@FeignClient("***")注解，并用RequestMapping(GetMapping或者PostMapping指定请求的URI部分)
/**
* @FeignClient+@GetMapping 就是一个完整的请求路径 http://service-product/shop-product/product/{pid}
* 相当于使用 RestTemplate 的 请求地址部分
*/
@FeignClient(value = "service-product") // value用于指定调用nacos下的微服务的名字
public interface ProductService {
@GetMapping("/shop-product/product/{pid}") // 指定请求的URI部分
Product findByPid(@PathVariable("pid") Integer pid);
}
4. 在业务中进行接口的调用
package com.test.shop.order.service.impl;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import com.test.shop.common.constant.Constant;
import com.test.shop.common.entity.Order;
import com.test.shop.common.entity.Product;
import com.test.shop.common.entity.Result;
import com.test.shop.order.dao.OrderDao;
import com.test.shop.order.service.OrderService;
import com.test.shop.order.service.ProductService;
import cn.hutool.json.JSONUtil;
import lombok.extern.slf4j.Slf4j;
@Service
@Slf4j
public class OrderServiceImpl implements OrderService {
@Resource
private OrderDao orderDao;
// @Autowired
// private RestTemplate restTemplate;
// @Autowired
// private DiscoveryClient discoveryClient;
@Resource
private ProductService productService;
@Override
public Result<String> createOrder(Integer pid) {
log.info("商品{}下单", pid);
/*************未使用ribbon时，自定义的负载均衡********************/
// // 从nacos中获取服务地址
// List<ServiceInstance> serviceInstanceList = discoveryClient.getInstances("service-product");
// // 自定义负载均衡
// int index = new Random().nextInt(serviceInstanceList.size());
// ServiceInstance serviceInstance = serviceInstanceList.get(index);
// String url = serviceInstance.getHost() + ":" + serviceInstance.getPort();
// log.info("\n=====>>从nacos中获取到的微服务地址为:" + url);
// Product p = restTemplate.getForObject("http://" + url + "/shop-product/product/" + pid, Product.class);
/*****************************************************/
/************使用Ribbon*******************/
//直接使用微服务名字， 从nacos中获取服务地址
// String url = "service-product";
// //通过restTemplate调用商品微服务
// Product p = restTemplate.getForObject("http://" + url + "/shop-product/product/" + pid, Product.class);
/*************使用Ribbon结束****************/
/************使用Feign调用*******************/
//通过Feign调用商品微服务
Product p = productService.findByPid(pid);
/*************使用Feign结束****************/
log.info("\n查询商品{}成功，内容：{}", pid, JSONUtil.parse(p).toJSONString(1));
Order o = new Order();
o.setNumber(2);
o.setPid(pid);
o.setPname(p.getPname());
o.setPprice(p.getPprice());
o.setUid(123);
o.setUsername("张三");
int n = orderDao.insert(o);
if (n == 1) {
return new Result<String>().success(o);
}
return new Result<String>().error(Constant.ERROR_MSG);
}
}
网友评论