feat($Gateway): add reactive openfeign support

johnnymillergh · Dec 16, 2020 · f0b7567 · f0b7567
1 parent 7211915
commit f0b7567
Show file tree

Hide file tree

Showing 8 changed files with 84 additions and 16 deletions.
diff --git a/gateway/pom.xml b/gateway/pom.xml
@@ -7,10 +7,6 @@
     <artifactId>gateway</artifactId>
     <name>Muscle and Fitness Server :: Gateway</name>
     <description>Gateway for Muscle and Fitness microservices.</description>
-    <properties>
-        <java.version>11</java.version>
-        <port>8080</port>
-    </properties>
     <parent>
         <groupId>com.jmsoftware.maf</groupId>
         <artifactId>muscle-and-fitness-server</artifactId>
@@ -90,16 +86,27 @@
             <artifactId>spring-cloud-starter-zipkin</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.playtika.reactivefeign</groupId>
+            <artifactId>feign-reactor-webclient</artifactId>
+            <version>${feign-reactor.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.playtika.reactivefeign</groupId>
+            <artifactId>feign-reactor-cloud</artifactId>
+            <version>${feign-reactor.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.playtika.reactivefeign</groupId>
+            <artifactId>feign-reactor-spring-configuration</artifactId>
+            <version>${feign-reactor.version}</version>
+        </dependency>
+
         <dependency>
             <groupId>com.jmsoftware.maf</groupId>
             <artifactId>common</artifactId>
-            <version>0.0.2-SNAPSHOT</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>org.springframework.boot</groupId>
-                    <artifactId>spring-boot-starter-web</artifactId>
-                </exclusion>
-            </exclusions>
         </dependency>
 
         <dependency>

diff --git a/gateway/src/main/java/com/jmsoftware/maf/gateway/GatewayApplication.java b/gateway/src/main/java/com/jmsoftware/maf/gateway/GatewayApplication.java
@@ -7,6 +7,8 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import reactivefeign.spring.config.EnableReactiveFeignClients;
 
 import java.time.Duration;
 import java.time.Instant;
@@ -21,8 +23,10 @@
  * @date 2/15/20 3:56 PM
  **/
 @Slf4j
+@EnableFeignClients
 @EnableDiscoveryClient
 @SpringBootApplication
+@EnableReactiveFeignClients
 public class GatewayApplication {
     private static final String LINE_SEPARATOR = System.lineSeparator();
     private static ProjectProperty projectProperty;
@@ -43,7 +47,7 @@ public static void main(String[] args) {
         log.info("⚙️ Environment: {}", projectProperty.getEnvironment());
         log.info("⏳ Deployment duration: {} seconds ({} ms)", duration.getSeconds(), duration.toMillis());
         log.info("⏰ App started at {} (timezone - {})", endInstant, TimeZone.getDefault().getDisplayName());
-        log.info("{}  App running at{}  - Local:   http://localhost:{}{}/{}  - Network: http://{}/{}",
+        log.info("{}  App running at{}  - Local:   http://localhost:{}{}/{}  - Network: {}/{}",
                  LINE_SEPARATOR, LINE_SEPARATOR, serverConfiguration.getServerPort(), projectProperty.getContextPath(),
                  LINE_SEPARATOR, serverConfiguration.getBaseUrl(), projectProperty.getContextPath());
     }

diff --git a/gateway/src/main/java/com/jmsoftware/maf/gateway/remoteapi/AuthCenterRemoteApi.java b/gateway/src/main/java/com/jmsoftware/maf/gateway/remoteapi/AuthCenterRemoteApi.java
@@ -0,0 +1,30 @@
+package com.jmsoftware.maf.gateway.remoteapi;
+
+import com.jmsoftware.maf.common.bean.ResponseBodyBean;
+import com.jmsoftware.maf.common.domain.authcenter.role.GetRoleListByUserIdResponse;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import reactivefeign.spring.config.ReactiveFeignClient;
+import reactor.core.publisher.Mono;
+
+/**
+ * <h1>AuthCenterRemoteApi</h1>
+ * <p>
+ * Change description here.
+ *
+ * @author Johnny Miller (鍾俊), email: johnnysviva@outlook.com
+ * @date 5/10/20 4:50 PM
+ */
+@Validated
+@ReactiveFeignClient(name = "auth-center")
+public interface AuthCenterRemoteApi {
+    /**
+     * Gets role list by user id.
+     *
+     * @param userId the user id
+     * @return the role list by user id
+     */
+    @GetMapping("/role-remote-api/roles/{userId}")
+    Mono<ResponseBodyBean<GetRoleListByUserIdResponse>> getRoleListByUserId(@PathVariable Long userId);
+}
diff --git a/...c/main/java/com/jmsoftware/maf/gateway/universal/configuration/RedirectConfiguration.java b/...c/main/java/com/jmsoftware/maf/gateway/universal/configuration/RedirectConfiguration.java
@@ -30,7 +30,7 @@ private void postConstruct() {
 
     @Bean
     public RouterFunction<ServerResponse> home() {
-        return route(GET("/home"), request -> {
+        return route(GET("/"), request -> {
             log.info("Redirect to Home page.");
             return ServerResponse.temporaryRedirect(URI.create("/static/home.html")).build();
         });
@@ -47,7 +47,7 @@ public RouterFunction<ServerResponse> doc() {
     @Bean
     public RouterFunction<ServerResponse> favicon() {
         return route(GET("/favicon.ico"), request -> {
-            log.info("Redirect to Bootstrap Swagger API documentation.");
+            log.info("Redirect to favicon.");
             return ServerResponse.temporaryRedirect(URI.create("/static/icon/favicon.ico")).build();
         });
     }

diff --git a/gateway/src/main/java/com/jmsoftware/maf/gateway/universal/controller/CommonController.java b/gateway/src/main/java/com/jmsoftware/maf/gateway/universal/controller/CommonController.java
@@ -1,11 +1,13 @@
 package com.jmsoftware.maf.gateway.universal.controller;
 
 import com.jmsoftware.maf.common.bean.ResponseBodyBean;
+import com.jmsoftware.maf.gateway.remoteapi.AuthCenterRemoteApi;
 import com.jmsoftware.maf.gateway.universal.domain.ValidationTestPayload;
 import com.jmsoftware.maf.gateway.universal.service.CommonService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import lombok.val;
 import org.springframework.web.bind.annotation.*;
 
@@ -19,17 +21,27 @@
  * @author Johnny Miller (鍾俊), email: johnnysviva@outlook.com
  * @date 2/4/20 10:29 AM
  **/
+@Slf4j
 @RestController
 @RequiredArgsConstructor
 @RequestMapping("/common")
 @Api(tags = {"Common Controller"})
 public class CommonController {
     private final CommonService commonService;
+    private final AuthCenterRemoteApi authCenterRemoteApi;
 
     @GetMapping("/app-info")
     @ApiOperation(value = "/app-info", notes = "Retrieve application information")
     public ResponseBodyBean<Map<String, Object>> applicationInformation() {
         val data = commonService.getApplicationInfo();
+        final var roleListByUserId = authCenterRemoteApi.getRoleListByUserId(1L);
+        roleListByUserId
+                .map(getRoleListByUserIdResponseResponseBodyBean -> {
+                    log.info("Response1: {}", getRoleListByUserIdResponseResponseBodyBean);
+                    return getRoleListByUserIdResponseResponseBodyBean.getData();
+                })
+                .doOnNext(getRoleListByUserIdResponse -> log.info("Response2: {}", getRoleListByUserIdResponse.getRoleList()))
+                .subscribe();
         return ResponseBodyBean.ofSuccess(data, "Succeed to retrieve app info.");
     }
 

diff --git a/gateway/src/main/java/com/jmsoftware/maf/gateway/universal/filter/RequestFilter.java b/gateway/src/main/java/com/jmsoftware/maf/gateway/universal/filter/RequestFilter.java
@@ -26,7 +26,7 @@ public class RequestFilter implements GlobalFilter {
 
     @Override
     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
-        log.info("{} intercepted requester's access. Requester: {}, resource: [{}] {}",
+        log.info("{} intercepted requesters access. Requester: {}, resource: [{}] {}",
                  projectProperty.getProjectArtifactId().toUpperCase(),
                  RequestUtil.getRequestIpAndPort(exchange.getRequest()), exchange.getRequest().getMethod(),
                  exchange.getRequest().getURI());

diff --git a/gateway/src/main/resources/application.yml b/gateway/src/main/resources/application.yml
@@ -1,5 +1,5 @@
 server:
-  port: @port@
+  port: @gateway.port@
   tomcat:
     uri-encoding: @project.build.sourceEncoding@
 
@@ -36,6 +36,20 @@ eureka:
   client:
     registryFetchIntervalSeconds: 5
 
+feign:
+  client:
+    config:
+      default:
+        connectTimeout: 5000
+        readTimeout: 10000
+        loggerLevel: full
+  compression:
+    request:
+      enabled: true
+    response:
+      enabled: true
+      useGzipDecoder: true
+
 management:
   endpoints:
     web:

diff --git a/pom.xml b/pom.xml
@@ -46,6 +46,7 @@
         <guava.version>30.0-jre</guava.version>
         <knife4j.version>3.0.2</knife4j.version>
         <jjwt.version>0.11.1</jjwt.version>
+        <feign-reactor.version>2.0.25</feign-reactor.version>
     </properties>
 
     <!-- The modules (sometimes called subprojects) to build as a part of this project. -->