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

Delete MyApiConfig

Browse Source
This commit is contained in:
hongqiaowei
2021-10-19 10:39:23 +08:00
committed by GitHub
parent 013eab9582
commit f0e930c03e
4 changed files with 17 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
fizz-bootstrap/src/main/java/we/MyApiConfig.java
View File

@@ -1,43 +0,0 @@
package we;
import org.springframework.context.annotation.Configuration;
import we.config.ManualApiConfig;
import we.plugin.PluginConfig;
import we.plugin.auth.ApiConfig;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
/**
* 定义 MyApiConfig 继承 ManualApiConfig， 并注解为 Configuration，
* 然后实现 setApiConfigs 方法，在方法中添加路由配置
*/
@Configuration
public class MyApiConfig extends ManualApiConfig {
@Override
public List<ApiConfig> setApiConfigs() {
List<ApiConfig> apiConfigs = new ArrayList<>();
ApiConfig ac = new ApiConfig(); // 一个路由配置
ac.id = 1000; // 路由 id，建议从 1000 开始
ac.service = "xservice"; // 前端服务名
ac.path = "/ypath"; // 前端路径
ac.type = ApiConfig.Type.REVERSE_PROXY; // 路由类型，此处为反向代理
ac.httpHostPorts = Collections.singletonList("http://127.0.0.1:9094"); // 被代理接口的地址
// ac.httpHostPorts = Collections.singletonList("https://self-signed.badssl.com");
ac.backendPath = "/@ypath"; // 被代理接口的路径
// ac.backendPath = "/";
ac.pluginConfigs = new ArrayList<>();
PluginConfig pc = new PluginConfig();
pc.plugin = "myPlugin"; // 应用 id 为 myPlugin 的插件
ac.pluginConfigs.add(pc);
apiConfigs.add(ac);
log.info("set api configs end");
return apiConfigs; // 返回路由配置
}
}

16
fizz-core/src/main/java/we/incubator/FizzApiDispatchHttpHandler.java → fizz-core/src/main/java/we/api/match/FizzApiMatchHttpHandler.java
View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.incubator;
package we.api.match;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -48,15 +48,15 @@ import java.util.Set;
* @author hongqiaowei
*/
public class FizzApiDispatchHttpHandler implements HttpHandler {
public class FizzApiMatchHttpHandler 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(FizzApiDispatchHttpHandler.class);
private static final Logger log = LoggerFactory.getLogger(FizzApiMatchHttpHandler.class);
private static final Logger lostClientLog = LoggerFactory.getLogger(disconnected_client_log_category);
private static final Logger lostClientLog = LoggerFactory.getLogger(disconnected_client_log_category);
private static final Set<String> disconnected_client_exceptions = new HashSet<>(Arrays.asList("AbortedException", "ClientAbortException", "EOFException", "EofException"));
private static final Set<String> disconnected_client_exceptions = new HashSet<>(Arrays.asList("AbortedException", "ClientAbortException", "EOFException", "EofException"));
private WebSessionManager sessionManager;
private ServerCodecConfigurer serverCodecConfigurer;
@@ -64,8 +64,8 @@ public class FizzApiDispatchHttpHandler implements HttpHandler {
private ForwardedHeaderTransformer forwardedHeaderTransformer;
private boolean enableLoggingRequestDetails = false;
public FizzApiDispatchHttpHandler(WebSessionManager sessionManager, ServerCodecConfigurer codecConfigurer,
LocaleContextResolver localeContextResolver, ForwardedHeaderTransformer forwardedHeaderTransformer) {
public FizzApiMatchHttpHandler(WebSessionManager sessionManager, ServerCodecConfigurer codecConfigurer,
LocaleContextResolver localeContextResolver, ForwardedHeaderTransformer forwardedHeaderTransformer) {
this.sessionManager = sessionManager;
this.serverCodecConfigurer = codecConfigurer;
this.localeContextResolver = localeContextResolver;

13
fizz-core/src/main/java/we/incubator/FizzApiDispatchWebServer.java → fizz-core/src/main/java/we/api/match/FizzApiMatchWebServer.java
View File

@@ -15,12 +15,15 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.incubator;
package we.api.match;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.web.reactive.HttpHandlerAutoConfiguration;
import org.springframework.boot.web.embedded.netty.NettyReactiveWebServerFactory;
import org.springframework.boot.web.server.WebServer;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.server.reactive.HttpHandler;
import org.springframework.web.server.adapter.HttpWebHandlerAdapter;
import org.springframework.web.server.session.DefaultWebSessionManager;
@@ -35,9 +38,9 @@ import javax.annotation.Resource;
//@Configuration
//@AutoConfigureAfter({HttpHandlerAutoConfiguration.class})
public class FizzApiDispatchWebServer {
public class FizzApiMatchWebServer {
private static final Logger log = LoggerFactory.getLogger(FizzApiDispatchWebServer.class);
private static final Logger log = LoggerFactory.getLogger(FizzApiMatchWebServer.class);
@Resource
private HttpHandler httpHandler;
@@ -51,7 +54,7 @@ public class FizzApiDispatchWebServer {
HttpWebHandlerAdapter adapter = (HttpWebHandlerAdapter) httpHandler;
NettyReactiveWebServerFactory factory = new NettyReactiveWebServerFactory(port);
server = factory.getWebServer(
new FizzApiDispatchHttpHandler(
new FizzApiMatchHttpHandler(
new DefaultWebSessionManager(),
adapter.getCodecConfigurer(),
adapter.getLocaleContextResolver(),
@@ -59,7 +62,7 @@ public class FizzApiDispatchWebServer {
)
);
server.start();
log.info("fizz api dispatch web server listen on {}", port);
log.info("fizz api match web server listen on {}", port);
}
@PreDestroy

2
fizz-core/src/main/java/we/global_resource/GlobalResource.java
View File

@@ -49,7 +49,7 @@ public class GlobalResource {
public String val;
public Object originalVal; /** for aggregate use mainly */
public Object originalVal; /** for aggregate use mostly */
public boolean booleanVal;