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

HttpSimpleClient优化

Browse Source
This commit is contained in:
redkale
2023-11-30 15:40:09 +08:00
parent f0e53d4a8e
commit c25001c5e4
10 changed files with 174 additions and 102 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
src/main/java/org/redkale/cluster/HttpClusterRpcClient.java
View File

@@ -123,6 +123,14 @@ public class HttpClusterRpcClient extends HttpRpcClient {
clientHeaders.set(Rest.REST_HEADER_RESP_CONVERT, req.getRespConvertType().toString());
}
if (httpSimpleClient != null) {
HttpSimpleRequest newReq = req.copy().headers(clientHeaders);
InetSocketAddress addr = randomAddress(newReq, addrs);
if (logger.isLoggable(Level.FINEST)) {
logger.log(Level.FINEST, "httpAsync: module=" + localModule + ", resname=" + resname + ", addr=" + addr);
}
return (CompletableFuture) httpSimpleClient.sendAsync(addr, newReq);
}
byte[] clientBody = null;
if (isNotEmpty(req.getBody())) {
String paramstr = req.getParametersToString();
@@ -147,7 +155,12 @@ public class HttpClusterRpcClient extends HttpRpcClient {
});
}
private CompletableFuture<HttpResult<byte[]>> sendEachAddressAsync(HttpSimpleRequest req,
protected InetSocketAddress randomAddress(HttpSimpleRequest req, Set<InetSocketAddress> addrs) {
InetSocketAddress[] array = addrs.toArray(new InetSocketAddress[addrs.size()]);
return array[ThreadLocalRandom.current().nextInt(array.length)];
}
protected CompletableFuture<HttpResult<byte[]>> sendEachAddressAsync(HttpSimpleRequest req,
String requestPath, final HttpHeaders clientHeaders, byte[] clientBody, Iterator<InetSocketAddress> it) {
if (!it.hasNext()) {
return new HttpResult<byte[]>().status(404).toFuture();
@@ -159,26 +172,21 @@ public class HttpClusterRpcClient extends HttpRpcClient {
logger.log(Level.FINER, "sendEachAddressAsync: url: " + url
+ ", body: " + (clientBody != null ? new String(clientBody, StandardCharsets.UTF_8) : "") + ", headers: " + clientHeaders);
}
if (httpSimpleClient != null) {
clientHeaders.set("Host", host);
return httpSimpleClient.postAsync(url, clientHeaders, clientBody);
} else {
java.net.http.HttpRequest.Builder builder = java.net.http.HttpRequest.newBuilder()
.uri(URI.create(url))
.timeout(Duration.ofMillis(10_000))
//存在sendHeader后不发送body数据的问题， java.net.http.HttpRequest的bug?
.method("POST", createBodyPublisher(clientBody));
clientHeaders.forEach(builder::header);
return httpClient.sendAsync(builder.build(), java.net.http.HttpResponse.BodyHandlers.ofByteArray())
.thenApply((java.net.http.HttpResponse<byte[]> resp) -> {
Traces.currentTraceid(req.getTraceid());
final int rs = resp.statusCode();
if (rs != 200) {
return new HttpResult<byte[]>().status(rs);
}
return new HttpResult<>(resp.body());
});
}
java.net.http.HttpRequest.Builder builder = java.net.http.HttpRequest.newBuilder()
.uri(URI.create(url))
.timeout(Duration.ofMillis(10_000))
//存在sendHeader后不发送body数据的问题， java.net.http.HttpRequest的bug?
.method("POST", createBodyPublisher(clientBody));
clientHeaders.forEach(builder::header);
return httpClient.sendAsync(builder.build(), java.net.http.HttpResponse.BodyHandlers.ofByteArray())
.thenApply((java.net.http.HttpResponse<byte[]> resp) -> {
Traces.currentTraceid(req.getTraceid());
final int rs = resp.statusCode();
if (rs != 200) {
return new HttpResult<byte[]>().status(rs);
}
return new HttpResult<>(resp.body());
});
}
private static java.net.http.HttpRequest.BodyPublisher createBodyPublisher(byte[] clientBody) {

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

@@ -146,42 +146,25 @@ public abstract class ClientCodec<R extends ClientRequest, P extends ClientResul
if (exc == null) {
final Object rs = request.respTransfer == null ? message : request.respTransfer.apply(message);
if (workThread.inIO() && workThread.getState() == Thread.State.RUNNABLE) { //fullCache时state不是RUNNABLE
//workThread不区分IO线程，respFuture.complete中使用CompletableFuture.join会一直阻塞
workThread.runWork(() -> {
Traces.currentTraceid(request.traceid);
respFuture.complete(rs);
Traces.removeTraceid();
} else {
workThread.runWork(() -> {
Traces.currentTraceid(request.traceid);
respFuture.complete(rs);
Traces.removeTraceid();
});
}
});
} else { //异常
if (workThread.inIO() && workThread.getState() == Thread.State.RUNNABLE) { //fullCache时state不是RUNNABLE
workThread.runWork(() -> {
Traces.currentTraceid(request.traceid);
respFuture.completeExceptionally(exc);
Traces.removeTraceid();
} else {
workThread.runWork(() -> {
Traces.currentTraceid(request.traceid);
respFuture.completeExceptionally(exc);
Traces.removeTraceid();
});
}
});
}
} catch (Throwable t) {
if (workThread.inIO() && workThread.getState() == Thread.State.RUNNABLE) { //fullCache时state不是RUNNABLE
workThread.runWork(() -> {
Traces.currentTraceid(request.traceid);
respFuture.completeExceptionally(t);
Traces.removeTraceid();
} else {
workThread.runWork(() -> {
Traces.currentTraceid(request.traceid);
respFuture.completeExceptionally(t);
Traces.removeTraceid();
});
}
});
connection.client.logger.log(Level.INFO, "Complete result error, request: " + respFuture.request, t);
}
}

1
src/main/java/org/redkale/net/client/ClientConnection.java
View File

@@ -312,6 +312,7 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
public void accept(AsyncConnection t) {
respWaitingCounter.reset();
if (connEntry != null) { //index=-1
connEntry.connection = null;
connEntry.connOpenState.set(false);
}
ClientMessageListener listener = getCodec().getMessageListener();

7
src/main/java/org/redkale/net/client/ClientRequest.java
View File

@@ -8,6 +8,7 @@ package org.redkale.net.client;
import java.io.Serializable;
import java.nio.charset.StandardCharsets;
import java.util.function.Function;
import org.redkale.convert.ConvertColumn;
import org.redkale.net.WorkThread;
import org.redkale.util.*;
@@ -24,12 +25,14 @@ public abstract class ClientRequest {
public static final byte[] EMPTY_TRACEID = new byte[0];
@ConvertColumn(index = 1)
protected String traceid;
@ConvertColumn(index = 2)
protected long createTime = System.currentTimeMillis();
protected WorkThread workThread;
protected String traceid;
//只会在ClientCodec的读线程里调用, 将ClientResult转成最终结果对象
Function respTransfer;

4
src/main/java/org/redkale/net/http/HttpRequest.java
View File

@@ -295,7 +295,6 @@ public class HttpRequest extends Request<HttpContext> {
this.readState = READ_STATE_HEADER;
}
if (this.readState == READ_STATE_HEADER) {
this.completed = true;
if (last != null && ((HttpRequest) last).headerLength > 0) {
final HttpRequest httplast = (HttpRequest) last;
int bufremain = buffer.remaining();
@@ -351,9 +350,10 @@ public class HttpRequest extends Request<HttpContext> {
this.boundary = true;
}
if (this.boundary) {
this.completed = false; //completed=true时ProtocolCodec会继续读下一个request
this.keepAlive = false; //文件上传必须设置keepAlive为false，因为文件过大时用户不一定会skip掉多余的数据
}
//completed=true时ProtocolCodec会继续读下一个request
this.completed = !this.boundary && !maybews && this.headerParsed;
this.readState = READ_STATE_BODY;
}
if (this.readState == READ_STATE_BODY) {

24
src/main/java/org/redkale/net/http/HttpSimpleClient.java
View File

@@ -240,10 +240,25 @@ public class HttpSimpleClient extends Client<HttpSimpleConnection, HttpSimpleReq
}
final URI uri = URI.create(url);
final String host = uri.getHost();
final ByteArray array = new ByteArray();
final int port = uri.getPort() > 0 ? uri.getPort() : (url.startsWith("https:") ? 443 : 80);
int urlpos = url.indexOf("/", url.indexOf("//") + 3);
array.put((method.toUpperCase() + " " + (urlpos > 0 ? url.substring(urlpos) : "/") + " HTTP/1.1\r\n").getBytes(StandardCharsets.UTF_8));
final String path = (urlpos > 0 ? url.substring(urlpos) : "/");
if (!url.startsWith("https:")) {
HttpSimpleRequest req = HttpSimpleRequest.createPath(path, headers).method(method).body(body);
return (CompletableFuture) sendAsync(new InetSocketAddress(host, port), req)
.thenApply((HttpSimpleResult rs) -> {
if (valueType == null) {
return rs;
} else {
Convert c = convert == null ? JsonConvert.root() : convert;
return rs.result(c.convertToBytes(valueType, (byte[]) rs.result));
}
});
}
//以下代码暂废弃
final ByteArray array = new ByteArray();
array.put((method.toUpperCase() + " " + path + " HTTP/1.1\r\n").getBytes(StandardCharsets.UTF_8));
array.put(("Host: " + uri.getHost() + "\r\n").getBytes(StandardCharsets.UTF_8));
array.put(HttpSimpleRequest.contentLengthBytes(body));
@@ -263,7 +278,6 @@ public class HttpSimpleClient extends Client<HttpSimpleConnection, HttpSimpleReq
array.put(body);
}
final int port = uri.getPort() > 0 ? uri.getPort() : (url.startsWith("https:") ? 443 : 80);
return createConnection(host, port).thenCompose(conn -> {
Traces.currentTraceid(traceid);
final CompletableFuture<HttpResult<T>> future = new CompletableFuture();
@@ -304,7 +318,7 @@ public class HttpSimpleClient extends Client<HttpSimpleConnection, HttpSimpleReq
// final AsyncIOGroup asyncGroup = new AsyncIOGroup(8192, 16);
// asyncGroup.start();
// String url = "http://redkale.org";
// HttpSimpleClient client = HttpSimpleClient.createPath(asyncGroup);
// HttpSimpleClient client = HttpSimpleClient.createPostPath(asyncGroup);
// (System.out).println(client.getAsync(url).join());
// }
//

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

@@ -9,6 +9,7 @@ import java.io.Serializable;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.function.Function;
import org.redkale.annotation.Comment;
import org.redkale.annotation.Nullable;
import org.redkale.convert.*;
@@ -17,8 +18,10 @@ import org.redkale.net.client.ClientConnection;
import org.redkale.net.client.ClientRequest;
import static org.redkale.net.http.HttpSimpleClient.*;
import org.redkale.util.ByteArray;
import org.redkale.util.Copier;
import org.redkale.util.RedkaleException;
import org.redkale.util.Traces;
import org.redkale.util.Utility;
import static org.redkale.util.Utility.isNotEmpty;
/**
@@ -33,87 +36,134 @@ import static org.redkale.util.Utility.isNotEmpty;
*/
public class HttpSimpleRequest extends ClientRequest implements java.io.Serializable {
@ConvertColumn(index = 2)
private static final Function<HttpSimpleRequest, HttpSimpleRequest> copyFunc = Copier.func(HttpSimpleRequest.class, HttpSimpleRequest.class);
@ConvertColumn(index = 12)
@Comment("是否RPC请求, 该类通常是为RPC创建的，故默认是true")
protected boolean rpc = true;
@ConvertColumn(index = 3)
@ConvertColumn(index = 13)
@Comment("链路ID")
protected String traceid;
@ConvertColumn(index = 4)
@ConvertColumn(index = 14)
@Comment("请求参数的ConvertType")
protected ConvertType reqConvertType;
@ConvertColumn(index = 5)
@ConvertColumn(index = 15)
@Comment("输出结果的ConvertType")
protected ConvertType respConvertType;
@Comment("Method GET/POST/...")
@ConvertColumn(index = 6)
@ConvertColumn(index = 16)
protected String method;
@ConvertColumn(index = 7)
@ConvertColumn(index = 17)
@Comment("请求的Path")
protected String path;
@ConvertColumn(index = 8)
@ConvertColumn(index = 18)
@Comment("请求的前缀")
protected String contextPath;
@ConvertColumn(index = 9)
@ConvertColumn(index = 19)
@Comment("客户端IP")
protected String remoteAddr;
@ConvertColumn(index = 10)
@ConvertColumn(index = 20)
@Comment("Locale国际化")
protected String locale;
@ConvertColumn(index = 11)
@ConvertColumn(index = 21)
@Comment("会话ID")
protected String sessionid;
@ConvertColumn(index = 12)
@ConvertColumn(index = 22)
@Comment("Content-Type")
protected String contentType;
@ConvertColumn(index = 13) //@since 2.5.0 由int改成Serializable, 具体数据类型只能是int、long、BigInteger、String
@ConvertColumn(index = 23) //@since 2.5.0 由int改成Serializable, 具体数据类型只能是int、long、BigInteger、String
protected Serializable currentUserid;
@ConvertColumn(index = 14)
@ConvertColumn(index = 24)
@Comment("http header信息")
protected HttpHeaders headers;
@ConvertColumn(index = 15)
@ConvertColumn(index = 25)
@Comment("参数信息")
protected HttpParameters params;
@ConvertColumn(index = 16)
@ConvertColumn(index = 26)
@Comment("http body信息")
protected byte[] body; //对应HttpRequest.array
public static HttpSimpleRequest createPath(String path) {
return new HttpSimpleRequest().path(path).method("POST").traceid(Traces.currentTraceid());
return new HttpSimpleRequest().path(path).traceid(Traces.currentTraceid());
}
public static HttpSimpleRequest createPath(String path, HttpHeaders header) {
return createPath(path).headers(header);
}
public static HttpSimpleRequest createPath(String path, Object... params) {
HttpSimpleRequest req = new HttpSimpleRequest().path(path).method("POST").traceid(Traces.currentTraceid());
int len = params.length / 2;
for (int i = 0; i < len; i++) {
req.param(params[i * 2].toString(), params[i * 2 + 1]);
return createPath(path, (HttpHeaders) null, params);
}
public static HttpSimpleRequest createPath(String path, HttpHeaders header, Object... params) {
HttpSimpleRequest req = createPath(path).headers(header);
if (params.length > 0) {
int len = params.length / 2;
for (int i = 0; i < len; i++) {
req.param(params[i * 2].toString(), params[i * 2 + 1]);
}
}
return req;
}
public static HttpSimpleRequest createPath(String path, HttpHeaders header) {
return new HttpSimpleRequest().path(path).method("POST").headers(header).traceid(Traces.currentTraceid());
public static HttpSimpleRequest createGetPath(String path) {
return createPath(path).method("GET");
}
public static HttpSimpleRequest createGetPath(String path, HttpHeaders header) {
return createPath(path, header).method("GET");
}
public static HttpSimpleRequest createGetPath(String path, Object... params) {
return createPath(path, params).method("GET");
}
public static HttpSimpleRequest createGetPath(String path, HttpHeaders header, Object... params) {
return createPath(path, header, params).method("GET");
}
public static HttpSimpleRequest createPostPath(String path) {
return createPath(path).method("POST");
}
public static HttpSimpleRequest createPostPath(String path, HttpHeaders header) {
return createPath(path, header).method("POST");
}
public static HttpSimpleRequest createPostPath(String path, Object... params) {
return createPath(path, params).method("POST");
}
public static HttpSimpleRequest createPostPath(String path, HttpHeaders header, Object... params) {
return createPath(path, header, params).method("POST");
}
public HttpSimpleRequest copy() {
HttpSimpleRequest rs = copyFunc.apply(this);
rs.workThread = this.workThread;
rs.createTime = this.createTime;
return rs;
}
@Override
public void writeTo(ClientConnection conn, ByteArray array) {
//组装path和body
String requestPath = requestPath();
String contentType0 = this.contentType;
String contentType0 = Utility.orElse(this.contentType, "x-www-form-urlencoded");
byte[] clientBody = null;
if (isNotEmpty(body)) {
String paramstr = getParametersToString();
@@ -133,11 +183,14 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
contentType0 = "x-www-form-urlencoded";
}
//写status
array.put((method.toUpperCase() + " " + requestPath + " HTTP/1.1\r\n").getBytes(StandardCharsets.UTF_8));
array.put(((method == null ? "GET" : method.toUpperCase()) + " " + requestPath + " HTTP/1.1\r\n").getBytes(StandardCharsets.UTF_8));
//写header
if (traceid != null && !containsHeaderIgnoreCase(Rest.REST_HEADER_TRACEID)) {
array.put((Rest.REST_HEADER_TRACEID + ": " + traceid + "\r\n").getBytes(StandardCharsets.UTF_8));
}
if (currentUserid != null && !containsHeaderIgnoreCase(Rest.REST_HEADER_CURRUSERID)) {
array.put((Rest.REST_HEADER_CURRUSERID + ": " + currentUserid + "\r\n").getBytes(StandardCharsets.UTF_8));
}
if (!containsHeaderIgnoreCase("User-Agent")) {
array.put(header_bytes_useragent);
}
@@ -215,16 +268,20 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public HttpSimpleRequest path(String path) {
if (path.indexOf(' ') >= 0 || path.indexOf('\r') >= 0 || path.indexOf('\n') >= 0) {
throw new RedkaleException("http-path(" + path + ") is illegal");
if (path != null) {
if (path.indexOf(' ') >= 0 || path.indexOf('\r') >= 0 || path.indexOf('\n') >= 0) {
throw new RedkaleException("http-path(" + path + ") is illegal");
}
}
this.path = path;
return this;
}
public HttpSimpleRequest contextPath(String contextPath) {
if (contextPath.indexOf(' ') >= 0 || contextPath.indexOf('\r') >= 0 || contextPath.indexOf('\n') >= 0) {
throw new RedkaleException("http-context-path(" + contextPath + ") is illegal");
if (contextPath != null) {
if (contextPath.indexOf(' ') >= 0 || contextPath.indexOf('\r') >= 0 || contextPath.indexOf('\n') >= 0) {
throw new RedkaleException("http-context-path(" + contextPath + ") is illegal");
}
}
this.contextPath = contextPath;
return this;
@@ -296,6 +353,11 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public HttpSimpleRequest method(String method) {
if (method != null) {
if (method.indexOf(' ') >= 0 || method.indexOf('\r') >= 0 || method.indexOf('\n') >= 0) {
throw new RedkaleException("http-method(" + method + ") is illegal");
}
}
this.method = method;
return this;
}
@@ -419,7 +481,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setRpc(boolean rpc) {
this.rpc = rpc;
rpc(rpc);
}
public String getTraceid() {
@@ -427,7 +489,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setTraceid(String traceid) {
this.traceid = traceid;
traceid(traceid);
}
public String getMethod() {
@@ -435,7 +497,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setMethod(String method) {
this.method = method;
method(method);
}
public String getPath() {
@@ -443,7 +505,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setPath(String path) {
this.path = path;
path(path);
}
public String getContextPath() {
@@ -451,7 +513,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setContextPath(String contextPath) {
this.contextPath = contextPath;
contextPath(contextPath);
}
public String getSessionid() {
@@ -459,7 +521,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setSessionid(String sessionid) {
this.sessionid = sessionid;
sessionid(sessionid);
}
public String getRemoteAddr() {
@@ -467,7 +529,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setRemoteAddr(String remoteAddr) {
this.remoteAddr = remoteAddr;
remoteAddr(remoteAddr);
}
public String getLocale() {
@@ -475,7 +537,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setLocale(String locale) {
this.locale = locale;
locale(locale);
}
public Serializable getCurrentUserid() {
@@ -483,7 +545,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setCurrentUserid(Serializable currentUserid) {
this.currentUserid = currentUserid;
currentUserid(currentUserid);
}
public String getContentType() {
@@ -491,7 +553,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setContentType(String contentType) {
this.contentType = contentType;
contentType(contentType);
}
public HttpHeaders getHeaders() {
@@ -515,7 +577,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setBody(byte[] body) {
this.body = body;
body(body);
}
public ConvertType getReqConvertType() {
@@ -523,7 +585,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setReqConvertType(ConvertType reqConvertType) {
this.reqConvertType = reqConvertType;
reqConvertType(reqConvertType);
}
public ConvertType getRespConvertType() {
@@ -531,7 +593,7 @@ public class HttpSimpleRequest extends ClientRequest implements java.io.Serializ
}
public void setRespConvertType(ConvertType respConvertType) {
this.respConvertType = respConvertType;
respConvertType(respConvertType);
}
@Override

3
src/main/java/org/redkale/net/sncp/SncpRequest.java
View File

@@ -83,7 +83,6 @@ public class SncpRequest extends Request<SncpContext> {
}
//---------------------head----------------------------------
if (this.readState == READ_STATE_HEADER) {
this.completed = true;
int remain = buffer.remaining();
int expect = halfArray == null ? this.headerSize - 2 : this.headerSize - 2 - halfArray.length();
if (remain < expect) {
@@ -110,6 +109,8 @@ public class SncpRequest extends Request<SncpContext> {
return -1;
}
this.traceid = this.header.getTraceid();
//completed=true时ProtocolCodec会继续读下一个request
this.completed = true;
this.readState = READ_STATE_BODY;
}
//---------------------body----------------------------------

6
src/test/java/org/redkale/test/http/HttpSimpleClientTest.java
View File

@@ -46,7 +46,7 @@ public class HttpSimpleClientTest {
HttpSimpleClient client = HttpSimpleClient.create(asyncGroup);
InetSocketAddress addr = new InetSocketAddress("127.0.0.1", port);
{
HttpSimpleRequest req = HttpSimpleRequest.createPath("/test").param("id", 100);
HttpSimpleRequest req = HttpSimpleRequest.createPostPath("/test").param("id", 100);
System.out.println(client.getAsync("http://127.0.0.1:" + port + req.getPath() + "?id=100").join());
System.out.println(client.sendAsync(addr, req).join());
}
@@ -55,7 +55,7 @@ public class HttpSimpleClientTest {
final CountDownLatch cdl = new CountDownLatch(count);
for (int i = 100; i < 100 + count; i++) {
final int index = i;
HttpSimpleRequest req = HttpSimpleRequest.createPath("/test").param("id", index);
HttpSimpleRequest req = HttpSimpleRequest.createPostPath("/test").param("id", index);
client.getAsync("http://127.0.0.1:" + port + req.getPath() + "?id=" + index).whenComplete((v, t) -> {
cdl.countDown();
Assertions.assertEquals("ok-" + index, new String((byte[]) v.getResult()));
@@ -68,7 +68,7 @@ public class HttpSimpleClientTest {
final CountDownLatch cdl = new CountDownLatch(count);
for (int i = 100; i < 100 + count; i++) {
final int index = i;
HttpSimpleRequest req = HttpSimpleRequest.createPath("/test").param("id", index);
HttpSimpleRequest req = HttpSimpleRequest.createPostPath("/test").param("id", index);
client.sendAsync(addr, req).whenComplete((v, t) -> {
cdl.countDown();
System.out.println("输出: " + new String((byte[]) v.getResult()));

6
src/test/java/org/redkale/test/http/RequestCoderTest.java
View File

@@ -28,7 +28,7 @@ public class RequestCoderTest {
@Test
public void run1() throws Exception {
HttpSimpleRequest req1 = HttpSimpleRequest.createPath("/aaa");
HttpSimpleRequest req1 = HttpSimpleRequest.createPostPath("/aaa");
System.out.println("simpleRequest1: " + req1);
byte[] bytes = HttpSimpleRequestCoder.getInstance().encode(req1);
HttpSimpleRequest req2 = HttpSimpleRequestCoder.getInstance().decode(bytes);
@@ -41,7 +41,7 @@ public class RequestCoderTest {
@Test
public void run2() throws Exception {
HttpSimpleRequest req1 = HttpSimpleRequest.createPath("/aaa");
HttpSimpleRequest req1 = HttpSimpleRequest.createPostPath("/aaa");
req1.addHeader("X-aaa", "aaa");
req1.param("bean", "{}");
System.out.println("simpleRequest1: " + req1);
@@ -56,7 +56,7 @@ public class RequestCoderTest {
@Test
public void run3() throws Exception {
HttpSimpleRequest req1 = HttpSimpleRequest.createPath("/aaa");
HttpSimpleRequest req1 = HttpSimpleRequest.createPostPath("/aaa");
req1.addHeader("X-aaa", "aaa");
req1.addHeader("X-bbb", "bbb1");
req1.addHeader("X-bbb", "bbb2");