fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add switch for api pairing web server

Browse Source
This commit is contained in:
hongqiaowei
2021-10-19 13:38:43 +08:00
committed by GitHub
parent f0e930c03e
commit 120e7453ed
3 changed files with 18 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
fizz-core/src/main/java/we/api/match/FizzApiMatchHttpHandler.java → fizz-core/src/main/java/we/api/pairing/FizzApiPairingHttpHandler.java
View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>. * along with this program. If not, see <https://www.gnu.org/licenses/>.
*/ */
package we.api.match; package we.api.pairing;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -48,11 +48,11 @@ import java.util.Set;
* @author hongqiaowei * @author hongqiaowei
*/ */
public class FizzApiMatchHttpHandler implements HttpHandler { public class FizzApiPairingHttpHandler implements HttpHandler {
private static final String disconnected_client_log_category = "DisconnectedClient"; private static final String disconnected_client_log_category = "DisconnectedClient";
private static final Logger log = LoggerFactory.getLogger(FizzApiMatchHttpHandler.class); private static final Logger log = LoggerFactory.getLogger(FizzApiPairingHttpHandler.class);
private static final Logger lostClientLog = LoggerFactory.getLogger(disconnected_client_log_category); private static final Logger lostClientLog = LoggerFactory.getLogger(disconnected_client_log_category);
@@ -64,8 +64,8 @@ public class FizzApiMatchHttpHandler implements HttpHandler {
private ForwardedHeaderTransformer forwardedHeaderTransformer; private ForwardedHeaderTransformer forwardedHeaderTransformer;
private boolean enableLoggingRequestDetails = false; private boolean enableLoggingRequestDetails = false;
public FizzApiMatchHttpHandler(WebSessionManager sessionManager, ServerCodecConfigurer codecConfigurer, public FizzApiPairingHttpHandler(WebSessionManager sessionManager, ServerCodecConfigurer codecConfigurer,
LocaleContextResolver localeContextResolver, ForwardedHeaderTransformer forwardedHeaderTransformer) { LocaleContextResolver localeContextResolver, ForwardedHeaderTransformer forwardedHeaderTransformer) {
this.sessionManager = sessionManager; this.sessionManager = sessionManager;
this.serverCodecConfigurer = codecConfigurer; this.serverCodecConfigurer = codecConfigurer;
this.localeContextResolver = localeContextResolver; this.localeContextResolver = localeContextResolver;

18
fizz-core/src/main/java/we/api/match/FizzApiMatchWebServer.java → fizz-core/src/main/java/we/api/pairing/FizzApiPairingWebServer.java
View File

@@ -15,11 +15,13 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>. * along with this program. If not, see <https://www.gnu.org/licenses/>.
*/ */
package we.api.match; package we.api.pairing;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.AutoConfigureAfter; import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.autoconfigure.web.reactive.HttpHandlerAutoConfiguration; import org.springframework.boot.autoconfigure.web.reactive.HttpHandlerAutoConfiguration;
import org.springframework.boot.web.embedded.netty.NettyReactiveWebServerFactory; import org.springframework.boot.web.embedded.netty.NettyReactiveWebServerFactory;
import org.springframework.boot.web.server.WebServer; import org.springframework.boot.web.server.WebServer;
@@ -36,17 +38,19 @@ import javax.annotation.Resource;
* @author hongqiaowei * @author hongqiaowei
*/ */
//@Configuration @ConditionalOnProperty(name = "fizz.api.pairing.enable", havingValue = "true")
//@AutoConfigureAfter({HttpHandlerAutoConfiguration.class}) @Configuration
public class FizzApiMatchWebServer { @AutoConfigureAfter({HttpHandlerAutoConfiguration.class})
public class FizzApiPairingWebServer {
private static final Logger log = LoggerFactory.getLogger(FizzApiMatchWebServer.class); private static final Logger log = LoggerFactory.getLogger(FizzApiPairingWebServer.class);
@Resource @Resource
private HttpHandler httpHandler; private HttpHandler httpHandler;
private WebServer server; private WebServer server;
@Value("${fizz.api.pairing.web-server.port:8601}")
private int port = 8601; private int port = 8601;
@PostConstruct @PostConstruct
@@ -54,7 +58,7 @@ public class FizzApiMatchWebServer {
HttpWebHandlerAdapter adapter = (HttpWebHandlerAdapter) httpHandler; HttpWebHandlerAdapter adapter = (HttpWebHandlerAdapter) httpHandler;
NettyReactiveWebServerFactory factory = new NettyReactiveWebServerFactory(port); NettyReactiveWebServerFactory factory = new NettyReactiveWebServerFactory(port);
server = factory.getWebServer( server = factory.getWebServer(
new FizzApiMatchHttpHandler( new FizzApiPairingHttpHandler(
new DefaultWebSessionManager(), new DefaultWebSessionManager(),
adapter.getCodecConfigurer(), adapter.getCodecConfigurer(),
adapter.getLocaleContextResolver(), adapter.getLocaleContextResolver(),
@@ -62,7 +66,7 @@ public class FizzApiMatchWebServer {
) )
); );
server.start(); server.start();
log.info("fizz api match web server listen on {}", port); log.info("fizz api pairing web server listen on {}", port);
} }
@PreDestroy @PreDestroy

3
fizz-spring-boot-starter/src/main/resources/META-INF/spring.factories
View File

@@ -45,4 +45,5 @@ we.proxy.FizzWebClient,\
we.proxy.NacosUriSelector,\ we.proxy.NacosUriSelector,\
we.proxy.RpcInstanceServiceImpl,\ we.proxy.RpcInstanceServiceImpl,\
we.stats.ratelimit.ResourceRateLimitConfigService,\ we.stats.ratelimit.ResourceRateLimitConfigService,\
we.global_resource.GlobalResourceService we.global_resource.GlobalResourceService,\
we.api.pairing.FizzApiPairingWebServer