From 31c6ffdd17bb8cd714631af62f30899a0d887cfd Mon Sep 17 00:00:00 2001 From: redkale Date: Sat, 2 Dec 2023 09:00:19 +0800 Subject: [PATCH] =?UTF-8?q?client=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/redkale/net/client/Client.java | 3 +++ src/main/java/org/redkale/net/http/Rest.java | 22 +++++++++---------- 2 files changed, 14 insertions(+), 11 deletions(-) diff --git a/src/main/java/org/redkale/net/client/Client.java b/src/main/java/org/redkale/net/client/Client.java index 8b8044e78..9997d525d 100644 --- a/src/main/java/org/redkale/net/client/Client.java +++ b/src/main/java/org/redkale/net/client/Client.java @@ -398,6 +398,9 @@ public abstract class Client, R extends ClientR } return array; }); + if (workThread != null && workThread.threads() == entrys.length && workThread.index() > -1) { + return entrys[workThread.index()]; + } ThreadLocalRandom random = ThreadLocalRandom.current(); int index = workThread == null || workThread.index() < 0 ? random.nextInt(entrys.length) : workThread.index() % entrys.length; return entrys[index]; diff --git a/src/main/java/org/redkale/net/http/Rest.java b/src/main/java/org/redkale/net/http/Rest.java index 8576982ff..14ffa05c1 100644 --- a/src/main/java/org/redkale/net/http/Rest.java +++ b/src/main/java/org/redkale/net/http/Rest.java @@ -58,17 +58,17 @@ public final class Rest { public static final String REST_HEADER_RESP_CONVERT = "Rest-Resp-Convert"; //--------------------------------------------------------------------------------------------------- - static final String REST_TOSTRINGOBJ_FIELD_NAME = "_redkale_tostringsupplier"; + static final String REST_TOSTRINGOBJ_FIELD_NAME = "_redkale_toStringSupplier"; - static final String REST_CONVERT_FIELD_PREFIX = "_redkale_restconvert_"; + static final String REST_CONVERT_FIELD_PREFIX = "_redkale_restConvert_"; static final String REST_SERVICE_FIELD_NAME = "_redkale_service"; - static final String REST_SERVICEMAP_FIELD_NAME = "_redkale_servicemap"; //如果只有name=""的Service资源,则实例中_servicemap必须为null + static final String REST_SERVICEMAP_FIELD_NAME = "_redkale_serviceMap"; //如果只有name=""的Service资源,则实例中_servicemap必须为null - private static final String REST_PARAMTYPES_FIELD_NAME = "_redkale_paramtypes"; //存在泛型的参数数组 Type[][] 第1维度是方法的下标, 第二维度是参数的下标 + private static final String REST_PARAMTYPES_FIELD_NAME = "_redkale_paramTypes"; //存在泛型的参数数组 Type[][] 第1维度是方法的下标, 第二维度是参数的下标 - private static final String REST_RETURNTYPES_FIELD_NAME = "_redkale_returntypes"; //存在泛型的结果数组 + private static final String REST_RETURNTYPES_FIELD_NAME = "_redkale_returnTypes"; //存在泛型的结果数组 private static final java.lang.reflect.Type TYPE_RETRESULT_STRING = new TypeToken>() { }.getType(); @@ -114,11 +114,11 @@ public final class Rest { static class MethodParamClassVisitor extends ClassVisitor { - private final Map> fieldmap; + private final Map> fieldMap; public MethodParamClassVisitor(int api, final Map> fieldmap) { super(api); - this.fieldmap = fieldmap; + this.fieldMap = fieldmap; } @Override @@ -128,10 +128,10 @@ public final class Rest { } List fieldnames = new ArrayList<>(); String key = name + ":" + desc; - if (fieldmap.containsKey(key)) { + if (fieldMap.containsKey(key)) { return null; } - fieldmap.put(key, fieldnames); + fieldMap.put(key, fieldnames); return new MethodVisitor(Opcodes.ASM6) { @Override public void visitLocalVariable(String name, String description, String signature, Label start, Label end, int index) { @@ -1859,11 +1859,11 @@ public final class Rest { av0.visitEnd(); fv.visitEnd(); } - { //_servicemap字段 Map + { //_serviceMap字段 Map fv = cw.visitField(ACC_PRIVATE, REST_SERVICEMAP_FIELD_NAME, "Ljava/util/Map;", "Ljava/util/Map;", null); fv.visitEnd(); } - { //_redkale_tostringsupplier字段 Supplier + { //_redkale_toStringSupplier字段 Supplier fv = cw.visitField(ACC_PRIVATE, REST_TOSTRINGOBJ_FIELD_NAME, "Ljava/util/function/Supplier;", "Ljava/util/function/Supplier;", null); fv.visitEnd(); }