При использовании Feign для связи между микросервисами тайм-ауты запросов могут возникать из-за задержек в сети и по другим причинам. Чтобы решить эту проблему, мы можем настроить Feign и установить таймаут.

Настройте период ожидания Feign

При использовании Feign мы можем установить тайм-аут запроса посредством конфигурации. В частности, мы можем добавить следующие свойства в файл конфигурации приложения:

feign.client.config.default.connectTimeout=5000
feign.client.config.default.readTimeout=5000

В приведенной выше конфигурации мы установили таймаут соединения и таймаут чтения на 5 секунд. Вы также можете использовать аннотацию @FeignClient в классе конфигурации Java приложения, чтобы настроить тайм-аут клиента Feign:

@FeignClient(name = "user-service", configuration = UserClientConfiguration.class)
public interface UserClient {

    @GetMapping("/users/{id}")
    User getUser(@PathVariable int id);

    @PostMapping("/users")
    User createUser(@RequestBody User user);

    @PutMapping("/users/{id}")
    User updateUser(@PathVariable int id, @RequestBody User user);

    @DeleteMapping("/users/{id}")
    void deleteUser(@PathVariable int id);
}

В приведенном выше примере мы используем атрибут конфигурации в аннотации @FeignClient, чтобы указать класс UserClientConfiguration, который содержит конфигурацию тайм-аута клиента Feign:

@Configuration
public class UserClientConfiguration {

    @Bean
    public Request.Options requestOptions() {
        return new Request.Options(5000, 5000);
    }
}

В приведенном выше примере мы используем аннотацию @Configuration для обозначения класса UserClientConfiguration, указывая, что это класс конфигурации Spring. Затем мы используем аннотацию @Bean, чтобы отметить метод requestOptions, который возвращает объект Request.Options, содержащий тайм-аут соединения и тайм-аут чтения, оба из которых установлены на 5 секунд.

Обработка исключений тайм-аута

Когда время запроса истечет, Feign выдаст FeignException. Мы можем использовать блок try-catch, чтобы перехватить это исключение и предпринять соответствующие действия. Например, мы можем использовать механизм повтора для повторного выполнения запроса или возврата значения по умолчанию или сообщения об ошибке.

Вот пример:

@RestController
public class UserController {

    private final UserClient userClient;

    public UserController(UserClient userClient) {
        this.userClient = userClient;
    }

    @GetMapping("/users/{id}")
    public User getUser(@PathVariable int id) {
        try {
            return userClient.getUser(id);
        } catch (FeignException e) {
            throw new ResponseStatusException(HttpStatus.INTERNAL_SERVER_ERROR, "Failed to get user", e);
        }
    }
}

В приведенном выше примере мы используем блок try-catch в методе getUser, чтобы перехватить исключение FeignException. Если время запроса истечет, будет выдано это исключение. В блоке catch мы используем класс ResponseStatusException для выдачи ошибки HTTP 500, указывающей на невозможность получения информации о пользователе. В то же время мы передаем исходное исключение FeignException в качестве параметра классу ResponseStatusException, чтобы его можно было записать в журнал.

Обработка отката тайм-аута Feign

Помимо использования механизма повтора и возврата значения по умолчанию или сообщения об ошибке в Обработку исключений тайм-аутаснаружи,Feign также предоставляет механизм для решения проблем с тайм-аутом.,То есть откат таймаута. Откат по тайм-ауту относится к моменту истечения времени ожидания запроса.,Feign будет использовать указанный резервный метод или резервный класс для обработки запроса. Это гарантирует, что даже если время запроса истечет,Приложение все еще может продолжать работать,без сбоев.

Вот пример использования механизма возврата по тайм-ауту:

@FeignClient(name = "user-service", fallback = UserClientFallback.class)
public interface UserClient {

    @GetMapping("/users/{id}")
    User getUser(@PathVariable int id);

    @PostMapping("/users")
    User createUser(@RequestBody User user);

    @PutMapping("/users/{id}")
    User updateUser(@PathVariable int id, @RequestBody User user);

    @DeleteMapping("/users/{id}")
    void deleteUser(@PathVariable int id);
}

@Component
public class UserClientFallback implements UserClient {

    @Override
    public User getUser(int id) {
        return new User(id, "Fallback User");
    }

    @Override
    public User createUser(User user) {
        return new User(-1, "Fallback User");
    }

    @Override
    public User updateUser(int id, User user) {
        return new User(id, "Fallback User");
    }

    @Override
    public void deleteUser(int id) {
        // Do nothing
    }
}

В приведенном выше примере мы определили класс UserClientFallback, который реализует интерфейс UserClient и обеспечивает механизм возврата по истечении времени ожидания. В аннотации @FeignClient мы используем запасной атрибут, чтобы указать класс UserClientFallback в качестве резервного класса по тайм-ауту.

По истечении времени ожидания запроса Feign автоматически использует соответствующий метод класса UserClientFallback для обработки запроса. В методе getUser мы возвращаем объект Fallback User, указывающий на невозможность получить информацию о пользователе, но при этом возвращаем объект, чтобы приложение могло продолжить работу. В других методах мы возвращаем аналогичный объект Fallback User или ничего не делаем, в зависимости от реальной ситуации.

Следует отметить, что при использовании механизма возврата по тайм-ауту мы должны, насколько это возможно, предоставить значимый метод обработки возврата, чтобы гарантировать, что приложение все еще может продолжать работать и предоставлять необходимый ответ.