springcloud 学习笔记(三)微服务之feign组件的使用

r囧r小猫 2022-11-16 13:57 165阅读 0赞

## 引言 ##

在前一节内容中我们采用了ribbon的负载均衡功能，大大简化了远程调用时的代码。但是下面的拼接代码可能会频繁的出现，如何解决这一问题是我们讨论的重点。

String url = "http://userservice/userController/queryById/"+id;
    UserDomain userDomain = restTemplate.getForObject(url, UserDomain.class);

feigin的诞生就帮大家解决了这一问题，fegin自动根据参数拼接http请求地址。

## fegin的使用 ##

### 导入依赖 ###

在上一节consumer工程的pom文件中加入依赖

<dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>

### 编写fegin接口 ###

编写feginclient接口

@FeignClient("userservice")//声明当前类是一个feign的客户端，指定服务名为userservice
    public interface UserClient { 
    
        @GetMapping("/userController/queryById/{id}")
        public UserDomain queryById(@PathVariable  Long id);
        //本质上此时所要访问的地址就是userservice/userController/queryById
    }

### 启动类 ###

@EnableFeignClients
    @SpringCloudApplication //可代替上述三个注解
    public class ConsumerApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(ConsumerApplication.class, args);
        }
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate(){ 
            return new RestTemplate();
        }
    }

启动类中需要开启fegin

### 编写fegin的测试类 ###

@RestController
    @RequestMapping("/ufc")
    @Slf4j
    @DefaultProperties(defaultFallback = "defaultFallback")
    public class UserFeignController { 
    
        @Autowired
        private RestTemplate restTemplate;
    
        @Autowired
        private DiscoveryClient discoveryClient;
    
    
        @Autowired
        private UserClient userClient;
        
    
        @RequestMapping("/findById/{id}")
        @HystrixCommand(fallbackMethod = "findByIdCallBack")
        public String findById(@PathVariable Long id){ 
            //String url = "http://localhost:9090/userController/findById/"+id;
            if(id ==1){ 
                throw new RuntimeException("太忙了！！！");
            }
            UserDomain userDomain = userClient.queryById(id);
            return  userDomain.toString();
        }
    
     /*@GetMapping ("/findById/{id}") public UserDomain findById(@PathVariable Long id){ String url = ""; List<ServiceInstance> userservice = discoveryClient.getInstances("userservice"); ServiceInstance serviceInstance = userservice.get(0); url="http://"+ serviceInstance.getHost()+":"+serviceInstance.getPort()+"/userController/findById/"+id; UserDomain userDomain = restTemplate.getForObject(url, UserDomain.class); return userDomain; }*/
    
        public String findByIdCallBack(Long id){ 
                log.error("查询用户信息失败。id：{}", id);
            return "对不起，网络不太好！";
        }
    
        public String defaultFallback(Long id){ 
            log.error("查询用户信息失败。id：{}", id);
            return "对不起，网络太忙了！";
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1ZXNoYW5mZWl0aWFu_size_16_color_FFFFFF_t_70]

### fegin的负载均衡 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1ZXNoYW5mZWl0aWFu_size_16_color_FFFFFF_t_70 1]  
feign已经集成了ribbon ,所以可以直接通过feign配置实现负载均衡和熔断，**feign内部的ribbon默认设置了请求超时时长默认是1000。** ribbon内部有重试机制，**一旦超时，会自动重新发起请求。** 如果不希望重试，可以添加配置：

ribbon:
      ConnectTimeout: 1000 # 连接超时时长
      ReadTimeout: 2000 # 数据通信超时时长
      MaxAutoRetries: 0 # 当前服务器的重试次数
      MaxAutoRetriesNextServer: 0 # 重试多少次服务
      OkToRetryOnAllOperations: false # 是否对所有的请求方式都重试

### fegin中的熔断实现 ###

#### 修改配置文件 ####

加入以下hystix的配置内容

feign:
      hystrix:
        enabled: true

##### 定义fallback类 #####

需要实现UserClient 接口

@Component
    public class UserClientFallBack implements UserClient { 
        @Override
        public UserDomain queryById(Long id) { 
            UserDomain userDomain = new UserDomain();
            userDomain.setId(id);
            userDomain.setName("用户异常");
            return userDomain;
        }
    }

##### 修改接口注解 #####

@FeignClient(value = "userservice",fallback = UserClientFallBack.class/*, configuration = FeignConfig.class*/)//声明当前类是一个feign的客户端，指定服务名为userservice
    public interface UserClient { 
    
        @GetMapping("/userController/queryById/{id}")
        public UserDomain queryById(@PathVariable  Long id);
        //本质上此时所要访问的地址就是userservice/userController/queryById
    }

修改userservice模块中的UserService

@Service
    public class UserService { 
        @Autowired
        private UserDao userDao;
        /** * 根据主键查询 * @param id * @return */
        public User queryById(Long id){ 
            try { 
                Thread.sleep(2000);
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
            return userDao.selectByPrimaryKey(id);
        }
    
    
        public User findById(Long id){ 
            try { 
                Thread.sleep(2000);
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
            return userDao.selectByPrimaryKey(id);
        }
    }

使得访问产生异常  
![在这里插入图片描述][20210407175009169.png]

### feign的压缩实现 ###

feign:
      hystrix:
        enabled: true
      compression:
        request:
          enabled: true # 开启请求压缩
          mime-types: text/html,application/xml,application/json # 设置压缩的数据类型
          min-request-size: 2048 #设置触发压缩的大小下限
        response:
          enabled: true #开启响应压缩

### 日志配置 ###

**通过 logging.level.xx=debug 来设置日志级别。然而这个对Fegin客户端而言不会产生效果。** 因为@FeignClient 注解修改的客户端在被代理时，都会创建一个新的Fegin.Logger实例。**我们需要额外指定这个日志的级别才可以。**

#### 日志配置类 ####

需要手动编写日志配置类，来设置Fegin.Logger实例。

##### 日志配置类 #####

@Configuration
    public class FeignConfig { 
    
        @Bean
        Logger.Level feignLoggerLevel(){ 
            //记录所有信息
            return Logger.Level.FULL;
        }
    }

修改@FeignClient 注解，指定配置文件为FeignConfig文件，其本质是Feign依据FeignConfig 配置来创建UserClient动态代理类，从而使得日志配置生效。

##### 在配置文件中需要注明日志作用的范围 #####

logging:
      level:
        com.feitian.controller: debug

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1ZXNoYW5mZWl0aWFu_size_16_color_FFFFFF_t_70]: /images/20221022/aaa5d9b20bcd4dbb8ae7ce4da1de9165.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1ZXNoYW5mZWl0aWFu_size_16_color_FFFFFF_t_70 1]: /images/20221022/02de8c2b9ac446c8beefecad3789d9cb.png
[20210407175009169.png]: /images/20221022/291fbb32386b4a5daef64b6031a4c649.png