third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore: powerjob-remote-impl-http use shade vertx

Browse Source
This commit is contained in:
tjq 2023-12-01 19:37:22 +08:00
parent c47515232c
commit 703a36e6e3
4 changed files with 24 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
powerjob-remote/powerjob-remote-impl-http/pom.xml
View File

@ -29,21 +29,6 @@
<version>${powerjob-remote-framework.version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/io.vertx/vertx-core -->
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-core</artifactId>
<version>${vertx.version}</version>
</dependency>
<dependency>
<groupId>io.vertx</groupId>
<artifactId>vertx-web</artifactId>
<version>${vertx.version}</version>
</dependency>
</dependencies>
</project>

20
powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/HttpVertxCSInitializer.java
View File

@ -1,16 +1,16 @@
package tech.powerjob.remote.http;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.vertx.core.Handler;
import io.vertx.core.Vertx;
import io.vertx.core.http.HttpClient;
import io.vertx.core.http.HttpServer;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.web.RequestBody;
import io.vertx.ext.web.Route;
import io.vertx.ext.web.Router;
import io.vertx.ext.web.RoutingContext;
import io.vertx.ext.web.handler.BodyHandler;
import tech.powerjob.shade.io.vertx.core.Handler;
import tech.powerjob.shade.io.vertx.core.Vertx;
import tech.powerjob.shade.io.vertx.core.http.HttpClient;
import tech.powerjob.shade.io.vertx.core.http.HttpServer;
import tech.powerjob.shade.io.vertx.core.json.JsonObject;
import tech.powerjob.shade.io.vertx.ext.web.RequestBody;
import tech.powerjob.shade.io.vertx.ext.web.Route;
import tech.powerjob.shade.io.vertx.ext.web.Router;
import tech.powerjob.shade.io.vertx.ext.web.RoutingContext;
import tech.powerjob.shade.io.vertx.ext.web.handler.BodyHandler;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import tech.powerjob.common.exception.PowerJobException;

14
powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxInitializer.java
View File

@ -1,11 +1,11 @@
package tech.powerjob.remote.http.vertx;
import io.vertx.core.Vertx;
import io.vertx.core.VertxOptions;
import io.vertx.core.http.HttpClient;
import io.vertx.core.http.HttpClientOptions;
import io.vertx.core.http.HttpServer;
import io.vertx.core.http.HttpServerOptions;
import tech.powerjob.shade.io.vertx.core.Vertx;
import tech.powerjob.shade.io.vertx.core.VertxOptions;
import tech.powerjob.shade.io.vertx.core.http.HttpClient;
import tech.powerjob.shade.io.vertx.core.http.HttpClientOptions;
import tech.powerjob.shade.io.vertx.core.http.HttpServer;
import tech.powerjob.shade.io.vertx.core.http.HttpServerOptions;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import tech.powerjob.common.OmsConstant;
@ -50,7 +50,7 @@ public class VertxInitializer {
// 非核心组件，不直接依赖类（无 import），加载报错可忽略
try {
httpServerOptions
.addCompressor(io.netty.handler.codec.compression.StandardCompressionOptions.gzip())
.addCompressor(tech.powerjob.shade.io.netty.handler.codec.compression.StandardCompressionOptions.gzip())
.setCompressionSupported(true);
log.warn("[PowerJob-Vertx] enable server side compression successfully!");
} catch (Throwable t) {

14
powerjob-remote/powerjob-remote-impl-http/src/main/java/tech/powerjob/remote/http/vertx/VertxTransporter.java
View File

@ -3,13 +3,13 @@ package tech.powerjob.remote.http.vertx;
import io.netty.handler.codec.http.HttpHeaderNames;
import io.netty.handler.codec.http.HttpHeaderValues;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.vertx.core.Future;
import io.vertx.core.http.HttpClient;
import io.vertx.core.http.HttpClientRequest;
import io.vertx.core.http.HttpClientResponse;
import io.vertx.core.http.HttpMethod;
import io.vertx.core.http.RequestOptions;
import io.vertx.core.json.JsonObject;
import tech.powerjob.shade.io.vertx.core.Future;
import tech.powerjob.shade.io.vertx.core.http.HttpClient;
import tech.powerjob.shade.io.vertx.core.http.HttpClientRequest;
import tech.powerjob.shade.io.vertx.core.http.HttpClientResponse;
import tech.powerjob.shade.io.vertx.core.http.HttpMethod;
import tech.powerjob.shade.io.vertx.core.http.RequestOptions;
import tech.powerjob.shade.io.vertx.core.json.JsonObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.exception.ExceptionUtils;
import tech.powerjob.common.PowerSerializable;