Feign — это клиентская платформа Java HTTP с открытым исходным кодом, в основном используемая для упрощения HTTP-вызовов между службами, особенно для межсервисного взаимодействия в микросервисной архитектуре. Он позволяет разработчикам определять HTTP-запросы декларативным образом, что абстрагирует HTTP-запросы в вызовы методов интерфейса Java, так что вызовы между службами выглядят так же просто и понятно, как вызов локальных методов.
Основные особенности Feign:
1. Декларативный вызов интерфейса. Используя аннотации в интерфейсе Java для указания такой информации, как методы HTTP, URL-адреса, заголовки и параметры запроса, вы можете инициировать соответствующие HTTP-запросы, реализовав этот интерфейс.
2. Легкость: Feign основан на механизме динамического прокси Java и может автоматически генерировать прокси-класс, реализующий интерфейс. Прокси-класс уже инкапсулировал логику отправки HTTP-запросов.
3. Простота интеграции: Feign по умолчанию интегрирует Ribbon для балансировки нагрузки клиентов, а также может легко использоваться с другими компонентами обнаружения сервисов (такими как Eureka) для обнаружения сервисов и балансировки нагрузки.
4. Масштабируемость: Feign поддерживает пользовательские кодеры и декодеры и может гибко настраивать обработку HTTP-запросов и ответов в соответствии с потребностями проекта.
Как работает Фейн:
1. Определение интерфейса. Разработчики описывают спецификации HTTP-запросов, определяя интерфейсы Java с помощью притворных аннотаций, например, используя аннотацию @RequestLine для указания методов HTTP и шаблонов URL-адресов.
2. Генерация прокси-объекта. При запуске приложения Spring Cloud Feign сканирует интерфейс, помеченный `@FeignClient`, и генерирует для него динамический прокси-объект.
3. Вызов запроса. При вызове метода прокси-объекта он фактически запускает логику HTTP-запроса, заданную Feign. Переданные параметры будут заполнены в шаблоне URL-адреса для формирования полного HTTP-запроса.
4. Отправка запроса: Feign использует Ribbon для балансировки нагрузки, чтобы выбрать целевой сервер, а затем отправляет фактический HTTP-запрос через HTTP-клиент (например, Apache HttpClient или OkHttp).
5. Обработка ответа. После получения ответа HTTP Feign преобразует его в соответствующий объект Java в соответствии с настроенным декодером, а затем возвращает его вызывающей стороне.
6. Отказоустойчивость и автоматический выключатель: Feign может сотрудничать с Hystrix и включать функцию автоматического выключателя путем настройки. При сбое службы он может быстро выйти из строя, чтобы избежать цепных реакций, влияющих на стабильность всей системы.
Реализация балансировки нагрузки Feign
Реализация балансировки нагрузки Feign в среде Spring Cloud в основном опирается на компонент Ribbon. Ribbon — это клиентский балансировщик нагрузки, а Feign интегрирует Ribbon, поэтому, когда мы используем Feign для выполнения межсервисных вызовов в приложениях Spring Cloud, у нас, естественно, есть возможность балансировать нагрузку. Ниже приведен общий процесс реализации балансировки нагрузки Feign через Ribbon: 1. Внедрение зависимостей: Когда мы используем аннотацию @FeignClient для определения интерфейса Feign в приложении Spring Cloud, если проект также содержит зависимости Ribbon, Feign будет использовать Ribbon в качестве базового HTTP-клиента для выполнения запросов. 2. Обнаружение службы: Feign объединяет компоненты регистрации и обнаружения служб, такие как Eureka, для получения списка экземпляров служб из центра регистрации служб через Ribbon. 3. Стратегия балансировки нагрузки: Лента предоставляет различные стратегии балансировки нагрузки, по умолчанию используется алгоритм опроса. Перед каждым запросом он выберет подходящий экземпляр для вызова на основе текущего списка экземпляров службы. 4. Переадресация запроса: При вызове метода интерфейса Feign Ribbon выберет экземпляр в списке сервисов, заменит имя сервиса в интерфейсе Feign на адрес выбранного экземпляра, а затем инициирует запрос к экземпляру через HTTP-клиент. 5. Проверка работоспособности и повторная попытка: В процессе балансировки нагрузки Ribbon также может сочетаться с Hystrix для проверки работоспособности и механизмов повторных попыток, чтобы гарантировать, что запросы перенаправляются к исправным экземплярам службы, и пробовать другие экземпляры при возникновении проблем. Хотя сам Feign не реализует балансировку нагрузки напрямую, благодаря бесшовной интеграции с Ribbon и другими компонентами экосистемы Spring Cloud вы можете воспользоваться преимуществами балансировки нагрузки при использовании Feign для совершения сервисных вызовов. Что касается конфигурации и управления сервисами, разработчикам не нужно заботиться о конкретных деталях реализации балансировки нагрузки, а только об определении интерфейса.
Весной Пример Java-кода использования Feign для реализации межсервисных вызовов в облаке: 1. Добавьте зависимости: <!-- Добавьте Feign и связанные зависимости в pom.xml проекта потребителя службы. --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> 2. Включите клиент Feign: // Добавьте аннотацию @EnableFeignClients в класс запуска. import org.springframework.cloud.openfeign.EnableFeignClients; @SpringBootApplication @EnableFeignClients public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } } 3. Определите интерфейс Feign: // Создайте интерфейс Feign, чтобы определить методы интерфейса вызываемой службы. import feign.Headers; import feign.Param; import feign.RequestLine; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.RequestMethod; @FeignClient(name = "service-provider") // Укажите имя службы, которое должно соответствовать идентификатору службы в Eureka. public interface ServiceClient { @RequestLine("GET /api/users/{id}") @Headers("Content-Type: application/json") User getUser(@Param("id") Long id); @RequestLine(value = "POST /api/users", method = RequestMethod.POST) void createUser(User user); } 4. Используйте интерфейс Feign: // Внедрите и используйте приведенный выше интерфейс Feign в классе обслуживания потребителя службы. @Service public class UserService { private final ServiceClient serviceClient; @Autowired public UserService(ServiceClient serviceClient) { this.serviceClient = serviceClient; } public User findUserById(Long id) { return serviceClient.getUser(id); } public void addUser(User user) { serviceClient.createUser(user); } } В этом примере мы определяем интерфейс ServiceClient как клиент Feign, который содержит два метода, соответствующие операциям GET и POST поставщика услуг. В класс сервиса потребителя сервиса мы внедряем клиент Feign и добиваемся прозрачного доступа к удаленному сервису, вызывая его методы. Когда эти методы вызываются, фактически выполняется HTTP-запрос.