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 11:54:20 +08:00
parent f0e930c03e
commit f1fd55f6f7
3 changed files with 16 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
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/>.
*/
package we.api.match;
package we.api.pairing;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -48,11 +48,11 @@ import java.util.Set;
* @author hongqiaowei
*/
public class FizzApiMatchHttpHandler implements HttpHandler {
public class FizzApiPairingHttpHandler implements HttpHandler {
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);
@@ -64,7 +64,7 @@ public class FizzApiMatchHttpHandler implements HttpHandler {
private ForwardedHeaderTransformer forwardedHeaderTransformer;
private boolean enableLoggingRequestDetails = false;
public FizzApiMatchHttpHandler(WebSessionManager sessionManager, ServerCodecConfigurer codecConfigurer,
public FizzApiPairingHttpHandler(WebSessionManager sessionManager, ServerCodecConfigurer codecConfigurer,
LocaleContextResolver localeContextResolver, ForwardedHeaderTransformer forwardedHeaderTransformer) {
this.sessionManager = sessionManager;
this.serverCodecConfigurer = codecConfigurer;

16
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,12 @@
* 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.LoggerFactory;
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.web.embedded.netty.NettyReactiveWebServerFactory;
import org.springframework.boot.web.server.WebServer;
@@ -36,11 +37,12 @@ import javax.annotation.Resource;
* @author hongqiaowei
*/
//@Configuration
//@AutoConfigureAfter({HttpHandlerAutoConfiguration.class})
public class FizzApiMatchWebServer {
@ConditionalOnProperty(name = "fizz.api.pairing.enable", havingValue = "true")
@Configuration
@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
private HttpHandler httpHandler;
@@ -54,7 +56,7 @@ public class FizzApiMatchWebServer {
HttpWebHandlerAdapter adapter = (HttpWebHandlerAdapter) httpHandler;
NettyReactiveWebServerFactory factory = new NettyReactiveWebServerFactory(port);
server = factory.getWebServer(
new FizzApiMatchHttpHandler(
new FizzApiPairingHttpHandler(
new DefaultWebSessionManager(),
adapter.getCodecConfigurer(),
adapter.getLocaleContextResolver(),
@@ -62,7 +64,7 @@ public class FizzApiMatchWebServer {
)
);
server.start();
log.info("fizz api match web server listen on {}", port);
log.info("fizz api pairing web server listen on {}", port);
}
@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.RpcInstanceServiceImpl,\
we.stats.ratelimit.ResourceRateLimitConfigService,\
we.global_resource.GlobalResourceService
we.global_resource.GlobalResourceService,\
we.api.pairing.FizzApiPairingWebServer