lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HttpSimpleRequest优化

Browse Source
This commit is contained in:
redkale
2023-11-07 23:38:12 +08:00
parent 7f8d6f96f1
commit ff4c34fe33
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/redkale/net/client/ClientCodec.java
View File

@@ -37,7 +37,7 @@ public abstract class ClientCodec<R extends ClientRequest, P extends ClientResul
protected ClientMessageListener messageListener; protected ClientMessageListener messageListener;
public ClientCodec(ClientConnection<R, P> connection) { protected ClientCodec(ClientConnection<R, P> connection) {
Objects.requireNonNull(connection); Objects.requireNonNull(connection);
this.connection = connection; this.connection = connection;
} }
@@ -118,9 +118,7 @@ public abstract class ClientCodec<R extends ClientRequest, P extends ClientResul
void responseComplete(boolean halfCompleted, ClientFuture<R, P> respFuture, P message, Throwable exc) { void responseComplete(boolean halfCompleted, ClientFuture<R, P> respFuture, P message, Throwable exc) {
R request = respFuture.request; R request = respFuture.request;
if (request != null) { Traces.currentTraceid(request.getTraceid());
Traces.currentTraceid(request.getTraceid());
}
AsyncIOThread readThread = connection.channel.getReadIOThread(); AsyncIOThread readThread = connection.channel.getReadIOThread();
final WorkThread workThread = request.workThread; final WorkThread workThread = request.workThread;
try { try {

5
src/main/java/org/redkale/net/http/HttpSimpleRequest.java
View File

@@ -139,6 +139,11 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
return sb.toString(); return sb.toString();
} }
public HttpSimpleRequest formUrlencoded() {
this.headers.put("Content-Type", "x-www-form-urlencoded");
return this;
}
public HttpSimpleRequest rpc(boolean rpc) { public HttpSimpleRequest rpc(boolean rpc) {
this.rpc = rpc; this.rpc = rpc;
return this; return this;