SpringCloud OpenFeign组件实现服务间的调用

String restTemplateForObject = restTemplate.getForObject("http://服务名/url?参数" + name, String.class);

#存在问题:
- 1.每次调用服务都需要写这些代码,存在大量的代码冗余
- 2.服务地址如果修改,维护成本增高
- 3.使用时不够灵活

<!--Open Feign依赖-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

@SpringBootApplication
@EnableFeignClients  //入口类加入注解开启OpenFeign支持
@EnableDiscoveryClient  //都是能够让注册中心能够发现，扫描到该服务。
public class UserApplication {
    public static void main(String[] args) {
        SpringApplication.run(UserApplication.class, args);
    }
}

@FeignClient("products")
public interface ProductClient {
    @GetMapping("/product/findAll") //书写服务调用路径
    String findAll();
}

   @Autowired
    private ProductClient productClient;
    @GetMapping("/user/findAllFeignClient")
    public String findAllFeignClient(){
        log.info("通过使用openFeign组件调用商品服务");
        String msg = productClient.findAll();
        return msg;
    }

@RestController
@Slf4j
public class ProductAction {
    @Value("${server.port}")
    private int port;
    @GetMapping("/product/findOne")
    public Map<String,Object> findAll(String productId) {
        log.info("商品服务调度成功，当前服务端口[{}]", port);
        log.info("当前商品接收信息的ID：[{}]", productId);
        HashMap<String, Object> map = new HashMap<>();
        map.put("msg","服务调度成功，服务端口为:" + port);
        map.put("status",true);
        map.put("productId",productId);
        return map;
    }
}

@FeignClient("products")
public interface ProductClient {
    /**
     * 根据Id查询商品
     * @RequestParam 路径传参
     * @param productId
     * @return
     */
    @GetMapping("/product/findOne")
    String findOne(@RequestParam("productId")String productId);
}

   @Autowired
    private ProductClient productClient;
    @GetMapping("/user/findOneFeignClient")
    public String findOneFeignClient(String productId){
        log.info("通过openFeign组件调用商品服务。。。。。");
        String msg=productClient.findOne(productId);
        return  msg;
    }

    @PutMapping("/product/saveName")
    public Map<String, Object> save(String name) {
        log.info("商品服务现在调用的端口号[{}]"+port);
        log.info("商品接收到的姓名[{}]"+name);
        HashMap<String, Object> map = new HashMap<>();
        map.put("msg","商品服务查询商品信息调用成功,当前服务端口: "+port);
        map.put("status",true);
        map.put("name",name);
        return  map;
    }

   /**
     * 存储商品名
     * @RequestParam ？传参
     * @param name
     * @return
     */
    @PutMapping("/product/saveName")
    String saveName(@RequestParam("name") String name);

    @GetMapping("/user/saveName")
    public String saveName(String name) {
        log.info("调用商品组件的保存姓名功能");
        String s = productClient.saveName(name);
        return s;
    }

@Data  //等价于@Setter、@Getter、@RequiredArgsConstructor、@ToString、@EqualsAndHashCode
public class Product {
    private String productId;
    private String name;
    private Double Price;
}

  @PostMapping("/product/saveProduct")
    public Map<String, Object> saveProduct(@RequestBody Product product) {
        log.info("商品服务保存商品信息调用成功,当前服务端口:[{}]", port);
        log.info("当前接收商品名称:[{}]", product);
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("msg", "商品服务查询商品信息调用成功,当前服务端口: " + port);
        map.put("status", true);
        map.put("product", product);
        return map;
    }

    @PostMapping("/product/saveProduct")
    String saveProduct(@RequestBody Product product);

    @GetMapping("/user/saveProduct")
    public String saveProduct(Product product){
        log.info("接收到的商品信息:[{}]",product);
        String save = productClient.saveProduct(product);
        log.info("调用成功返回结果: "+save);
        return save;
    }

    @PostMapping("/product/saveProduct")
    public Map<String, Object> saveProduct(@RequestBody Product product) throws InterruptedException {
        Thread.sleep(2000);
        log.info("商品服务保存商品信息调用成功,当前服务端口:[{}]", port);
        log.info("当前接收商品名称:[{}]", product);
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("msg", "商品服务查询商品信息调用成功,当前服务端口: " + port);
        map.put("status", true);
        map.put("product", product);
        return map;
    }

#配置指定服务连接超时
feign.client.config.product.connectTimeout=5000
#配置指定服务等待超时
feign.client.config.product.readTimeout=5000

  `NONE  不记录任何日志
  `BASIC 仅仅记录请求方法，url，响应状态代码及执行时间 
  `HEADERS 记录Basic级别的基础上，记录请求和响应的header
  `FULL 记录请求和响应的header，body和元数据

feign.client.config.products.loggerLevel=full  #开启指定服务日志展示
#feign.client.config.default.loggerLevel=full  #全局开启服务日志展示
logging.level.com.tjcu.feignclients=debug    #指定feign调用客户端对象所在包,必须是debug级别