Renamed feign-reactor-webclient to feign-reactor-webclient-netty

Added HTTP2 support for Netty client

Author: skarpenko

.circleci/config.yml

@@ -6,7 +6,7 @@ version: 2 # use CircleCI 2.0
 jobs: # a collection of steps
   build:
     environment:
-      # Configure the JVMto avoid OOM errors
+      # Configure the JVM to avoid OOM errors
       _JAVA_OPTIONS: "-Xmx3g"
     docker: # run the steps with Docker
       - image: circleci/openjdk:17.0.1-jdk-buster

feign-reactor-benchmarks/pom.xml

@@ -32,7 +32,7 @@
 
         <dependency>
             <groupId>com.playtika.reactivefeign</groupId>
-            <artifactId>feign-reactor-webclient</artifactId>
+            <artifactId>feign-reactor-webclient-netty</artifactId>
         </dependency>
 
         <dependency>

feign-reactor-benchmarks/src/main/java/reactivefeign/benchmarks/RealRequestBenchmarks.java

@@ -24,7 +24,7 @@
 import reactivefeign.java11.Java11ReactiveOptions;
 import reactivefeign.jetty.JettyReactiveFeign;
 import reactivefeign.jetty.JettyReactiveOptions;
-import reactivefeign.webclient.WebReactiveFeign;
+import reactivefeign.webclient.netty.NettyWebReactiveFeign;
 import reactor.core.publisher.Mono;
 
 import java.io.IOException;
@@ -86,7 +86,7 @@ protected void setup() throws Exception {
 
         webClient = WebClient.create();
 
-        webClientFeign = WebReactiveFeign.<FeignReactorTestInterface>builder()
+        webClientFeign = NettyWebReactiveFeign.<FeignReactorTestInterface>builder()
                 .target(FeignReactorTestInterface.class, SERVER_URL);
 
         jettyHttpClient = new HttpClient();

feign-reactor-bom/pom.xml

@@ -58,7 +58,7 @@
             </dependency>
             <dependency>
                 <groupId>com.playtika.reactivefeign</groupId>
-                <artifactId>feign-reactor-webclient</artifactId>
+                <artifactId>feign-reactor-webclient-netty</artifactId>
                 <version>${project.version}</version>
             </dependency>
             <dependency>

feign-reactor-cloud/pom.xml

@@ -37,7 +37,7 @@
         <!-- Tests -->
         <dependency>
             <groupId>com.playtika.reactivefeign</groupId>
-            <artifactId>feign-reactor-webclient</artifactId>
+            <artifactId>feign-reactor-webclient-netty</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>

feign-reactor-cloud/src/test/java/reactivefeign/cloud2/BuilderUtils.java

@@ -4,7 +4,7 @@
 import org.springframework.cloud.circuitbreaker.resilience4j.Resilience4JConfigBuilder;
 import org.springframework.cloud.client.circuitbreaker.ConfigBuilder;
 import org.springframework.cloud.client.circuitbreaker.ReactiveCircuitBreakerFactory;
-import reactivefeign.webclient.WebReactiveFeign;
+import reactivefeign.webclient.netty.NettyWebReactiveFeign;
 
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -16,7 +16,7 @@ public class BuilderUtils {
     private static final AtomicInteger uniqueCircuitBreakerCounter = new AtomicInteger();
 
     static <T> CloudReactiveFeign.Builder<T> cloudBuilder(){
-        return CloudReactiveFeign.<T>builder(WebReactiveFeign.builder());
+        return CloudReactiveFeign.<T>builder(NettyWebReactiveFeign.builder());
     }
 
     static <T> CloudReactiveFeign.Builder<T> cloudBuilder(ReactiveCircuitBreakerFactory circuitBreakerFactory){
@@ -38,7 +38,7 @@ static <T> CloudReactiveFeign.Builder<T> cloudBuilderWithUniqueCircuitBreaker(
             Consumer<ConfigBuilder> customizer,
             AtomicReference<String> lastCircuitBreakerId) {
         int uniqueId = uniqueCircuitBreakerCounter.incrementAndGet();
-        return CloudReactiveFeign.<T>builder(WebReactiveFeign.builder())
+        return CloudReactiveFeign.<T>builder(NettyWebReactiveFeign.builder())
                 .enableCircuitBreaker(circuitBreakerId -> {
                     String uniqueCircuitBreakerId = circuitBreakerId + "."+uniqueId;
                     if(lastCircuitBreakerId != null) {

feign-reactor-cloud/src/test/java/reactivefeign/cloud2/MetricsTest.java

@@ -19,21 +19,21 @@
 import org.springframework.cloud.client.loadbalancer.reactive.ReactiveLoadBalancer;
 import reactivefeign.ReactiveFeignBuilder;
 import reactivefeign.testcase.IcecreamServiceApi;
-import reactivefeign.webclient.WebReactiveOptions;
+import reactivefeign.webclient.netty.NettyReactiveOptions;
 
 /**
  * @author Sergii Karpenko
  */
 public class MetricsTest extends reactivefeign.MetricsTest {
 
-  private static String serviceName = "MetricsTest-loadBalancingDefaultPolicyRoundRobin";
+  private static final String serviceName = "MetricsTest-loadBalancingDefaultPolicyRoundRobin";
 
-    private static ReactiveLoadBalancer.Factory<ServiceInstance> loadBalancerFactory;
+  private static ReactiveLoadBalancer.Factory<ServiceInstance> loadBalancerFactory;
 
-    @BeforeClass
-    public static void setupServersList() {
-        loadBalancerFactory = LoadBalancingReactiveHttpClientTest.loadBalancerFactory(serviceName, wireMockRule.port());
-    }
+  @BeforeClass
+  public static void setupServersList() {
+    loadBalancerFactory = LoadBalancingReactiveHttpClientTest.loadBalancerFactory(serviceName, wireMockRule.port());
+  }
 
   @Override
   protected String getHost() {
@@ -55,7 +55,7 @@ protected Target<IcecreamServiceApi> target(){
   protected ReactiveFeignBuilder<IcecreamServiceApi> builder(long readTimeoutInMillis) {
     return BuilderUtils.<IcecreamServiceApi>cloudBuilder()
             .enableLoadBalancer(loadBalancerFactory)
-            .options(new WebReactiveOptions.Builder().setReadTimeoutMillis(readTimeoutInMillis).build()
+            .options(new NettyReactiveOptions.Builder().setReadTimeoutMillis(readTimeoutInMillis).build()
     );
   }
 

feign-reactor-core/src/test/java/reactivefeign/ReactivityTest.java

@@ -15,12 +15,13 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import org.junit.AfterClass;
-import org.junit.BeforeClass;
+import org.junit.Before;
 import org.junit.Test;
 import reactivefeign.testcase.IcecreamServiceApi;
 import reactivefeign.testcase.domain.OrderGenerator;
 import reactor.core.publisher.Mono;
 import reactor.netty.DisposableServer;
+import reactor.netty.http.HttpProtocol;
 import reactor.netty.http.server.HttpServer;
 
 import java.time.Duration;
@@ -29,7 +30,6 @@
 
 import static org.awaitility.Awaitility.waitAtMost;
 import static org.hamcrest.CoreMatchers.is;
-import static reactor.netty.http.HttpProtocol.H2C;
 import static reactor.netty.http.HttpProtocol.HTTP11;
 
 /**
@@ -45,24 +45,32 @@ abstract public class ReactivityTest extends BaseReactorTest {
 
   private static DisposableServer server;
 
-  @BeforeClass
-  public static void startServer() throws JsonProcessingException {
-    byte[] data = TestUtils.MAPPER.writeValueAsString(new OrderGenerator().generate(1)).getBytes();
-
-    server = HttpServer.create()
-            .protocol(HTTP11, H2C)
-            .route(r -> r.get("/icecream/orders/1",
-                    (req, res) -> {
-                      res.header("Content-Type", "application/json");
-                      return Mono.delay(Duration.ofMillis(DELAY_IN_MILLIS))
-                              .thenEmpty(res.sendByteArray(Mono.just(data)));
-                    }))
-            .bindNow();
+  @Before
+  public void startServer() throws JsonProcessingException {
+    if(server == null) {
+      byte[] data = TestUtils.MAPPER.writeValueAsString(new OrderGenerator().generate(1)).getBytes();
+
+      server = HttpServer.create()
+              .protocol(serverProtocols())
+              .http2Settings(builder -> builder.maxConcurrentStreams(1000))
+              .route(r -> r.get("/icecream/orders/1",
+                      (req, res) -> {
+                        res.header("Content-Type", "application/json");
+                        return Mono.delay(Duration.ofMillis(DELAY_IN_MILLIS))
+                                .thenEmpty(res.sendByteArray(Mono.just(data)));
+                      }))
+              .bindNow();
+    }
+  }
+
+  protected HttpProtocol[] serverProtocols(){
+    return new HttpProtocol[]{HTTP11};
   }
 
   @AfterClass
   public static void stopServer(){
     server.disposeNow();
+    server = null;
   }
 
   @Test

feign-reactor-java11/src/test/java/reactivefeign/java11/h2c/ReactivityTest.java

@@ -15,11 +15,19 @@
 
 import reactivefeign.ReactiveFeign;
 import reactivefeign.testcase.IcecreamServiceApi;
+import reactor.netty.http.HttpProtocol;
 
 import static reactivefeign.java11.h2c.TestUtils.builderHttp2;
+import static reactor.netty.http.HttpProtocol.H2C;
+import static reactor.netty.http.HttpProtocol.HTTP11;
 
 public class ReactivityTest extends reactivefeign.ReactivityTest {
 
+  @Override
+  protected HttpProtocol[] serverProtocols(){
+    return new HttpProtocol[]{H2C, HTTP11};
+  }
+
   @Override
   protected ReactiveFeign.Builder<IcecreamServiceApi> builder() {
     return builderHttp2();

feign-reactor-jetty/src/test/java/reactivefeign/jetty/h2c/ReactivityTest.java

@@ -17,9 +17,17 @@
 import reactivefeign.jetty.JettyReactiveFeign;
 import reactivefeign.jetty.JettyReactiveOptions;
 import reactivefeign.testcase.IcecreamServiceApi;
+import reactor.netty.http.HttpProtocol;
+
+import static reactor.netty.http.HttpProtocol.H2C;
 
 public class ReactivityTest extends reactivefeign.ReactivityTest {
 
+  @Override
+  protected HttpProtocol[] serverProtocols(){
+    return new HttpProtocol[]{H2C};
+  }
+
   @Override
   protected ReactiveFeign.Builder<IcecreamServiceApi> builder() {
     return JettyReactiveFeign.<IcecreamServiceApi>builder().options(