Reactive Feign

현재 진행중인 프로젝트에서 일부 구간은 ReactiveStreams를 적용하려 하였다.

​

이때 Spring Cloud Open Feign으로 통신하는 구간도 Reactive 형태로 지원을 해줘야하는데, 공식 레퍼런스에서는 현재 지원하지 않는다고 한다.

![]()

하지만 feign-reactive를 추천해준다고 하여 링크로 이동하게 되면 spring framework에서 의존성 라이브러리들을 확인할 수 있고, pom.xml을 열어보면 필요 라이브러리들을 알 수 있다.

​

![]()

Maven 설정

com.playtika.reactivefeign feign-reactor-spring-configuration com.playtika.reactivefeign feign-reactor-cloud com.playtika.reactivefeign feign-reactor-webclient

Gradle 설정

implementation 'com.playtika.reactivefeign:feign-reactor-spring-configuration:2.0.22' implementation 'com.playtika.reactivefeign:feign-reactor-cloud:2.0.22' implementation 'com.playtika.reactivefeign:feign-reactor-webclient:2.0.22'

여기서 좀 특이한점이 ‘org.springframework.boot:spring-boot-starter-webflux’ 를 의존성으로 걸 필요가 없다는 것이다.

​

예제 프로젝트는 아래 링크를 확인하면 된다.

https://github.com/audtjddld/feign-reactive-sample

(추가적인 예제는 나중에 올려보도록한다.)

@SpringBootApplication @EnableEurekaClient @RestController @EnableReactiveFeignClients @EnableFeignClients public class FeignApplication { ... }

구동 설정은 위와 같이 설정한다.

@EnableReactiveFeignClients @EnableFeignClients

Mono, Flux를 사용하기 때문에 자연스럽게 @EnableWebFlux를 같이 걸어주게 되면 오류가 발생된다.

Caused by: java.lang.IllegalStateException: The Java/XML config for Spring MVC and Spring WebFlux cannot both be enabled, e.g. via @EnableWebMvc and @EnableWebFlux, in the same application. at org.springframework.util.Assert.state(Assert.java:76) ~[spring-core-5.2.9.RELEASE.jar:5.2.9.RELEASE] at org.springframework.web.reactive.config.WebFluxConfigurationSupport.setApplicationContext(WebFluxConfigurationSupport.java:101) ~[spring-webflux-5.2.9.RELEASE.jar:5.2.9.RELEASE] at org.springframework.context.support.ApplicationContextAwareProcessor.invokeAwareInterfaces(ApplicationContextAwareProcessor.java:123) ~[spring-context-5.2.9.RELEASE.jar:5.2.9.RELEASE] at org.springframework.context.support.ApplicationContextAwareProcessor.postProcessBeforeInitialization(ApplicationContextAwareProcessor.java:100) ~[spring-context-5.2.9.RELEASE.jar:5.2.9.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:415) ~[spring-beans-5.2.9.RELEASE.jar:5.2.9.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1786) ~[spring-beans-5.2.9.RELEASE.jar:5.2.9.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:594) ~[spring-beans-5.2.9.RELEASE.jar:5.2.9.RELEASE] ... 61 common frames omitted

​

WebFlux 설정은 빼서 설정해주면 된다.

​

그 밖의 Feing Client는 아래와 같이 작성해주면 된다.

@ReactiveFeignClient(name = "web-flux-app") public interface GreetingReactive { @GetMapping("/greeting") Mono greeting(); @GetMapping("/greetingWithParam") Mono greetingWithParam(@RequestParam(value = "id") Long id); }

​