diff --git a/src/main/java/org/redkale/util/Creator.java b/src/main/java/org/redkale/util/Creator.java
index 847e3f8ae..8e6b55c2e 100644
--- a/src/main/java/org/redkale/util/Creator.java
+++ b/src/main/java/org/redkale/util/Creator.java
@@ -1,825 +1,812 @@
-/*
- * To change this template, choose Tools | Templates
- * and open the template in the editor.
- */
-package org.redkale.util;
-
-import java.io.*;
-import java.lang.reflect.*;
-import java.net.*;
-import java.util.AbstractMap.SimpleEntry;
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.function.*;
-import java.util.logging.*;
-import java.util.stream.Stream;
-import org.redkale.annotation.ConstructorParameters;
-import org.redkale.asm.*;
-import static org.redkale.asm.Opcodes.*;
-import org.redkale.asm.Type;
-
-/**
- *
- * 实现一个类的构造方法。 代替低效的反射实现方式。 不支持数组类。
- * 常见的无参数的构造函数类都可以自动生成Creator， 对应自定义的类可以提供一个静态构建Creator方法。
- * 例如:
- *
- * public class Record {
- *
- * private final int id;
- *
- * private String name;
- *
- * Record(int id, String name) {
- * this.id = id;
- * this.name = name;
- * }
- *
- * private static Creator createCreator() {
- * return new Creator<Record>() {
- * @Override
- * @ConstructorParameters({"id", "name"})
- * public Record create(Object... params) {
- * if(params[0] == null) params[0] = 0;
- * return new Record((Integer) params[0], (String) params[1]);
- * }
- * };
- * }
- * }
- *
- *
- * 或者:
- *
- * public class Record {
- *
- * private final int id;
- *
- * private String name;
- *
- * @ConstructorParameters({"id", "name"})
- * public Record(int id, String name) {
- * this.id = id;
- * this.name = name;
- * }
- * }
- *
- *
- *
- * 详情见: https://redkale.org
- *
- * @author zhangjx
- * @param 构建对象的数据类型
- */
-public interface Creator {
-
- @SuppressWarnings("unchecked")
- static class CreatorInner {
-
- static final Logger logger = Logger.getLogger(Creator.class.getSimpleName());
-
- static final Map creatorCacheMap = new HashMap<>();
-
- static final Map arrayCacheMap = new ConcurrentHashMap<>();
-
- static {
- creatorCacheMap.put(Object.class, p -> new Object());
- creatorCacheMap.put(ArrayList.class, p -> new ArrayList<>());
- creatorCacheMap.put(HashMap.class, p -> new HashMap<>());
- creatorCacheMap.put(HashSet.class, p -> new HashSet<>());
- creatorCacheMap.put(Stream.class, p -> new ArrayList<>().stream());
- creatorCacheMap.put(ConcurrentHashMap.class, p -> new ConcurrentHashMap<>());
- creatorCacheMap.put(CompletableFuture.class, p -> new CompletableFuture<>());
- creatorCacheMap.put(CompletionStage.class, p -> new CompletableFuture<>());
- creatorCacheMap.put(Map.Entry.class, new Creator() {
- @Override
- @ConstructorParameters({"key", "value"})
- public Map.Entry create(Object... params) {
- return new AbstractMap.SimpleEntry(params[0], params[1]);
- }
-
- @Override
- public Class[] paramTypes() {
- return new Class[]{Object.class, Object.class};
- }
- });
- creatorCacheMap.put(AbstractMap.SimpleEntry.class, new Creator() {
- @Override
- @ConstructorParameters({"key", "value"})
- public AbstractMap.SimpleEntry create(Object... params) {
- return new AbstractMap.SimpleEntry(params[0], params[1]);
- }
-
- @Override
- public Class[] paramTypes() {
- return new Class[]{Object.class, Object.class};
- }
- });
- creatorCacheMap.put(AnyValue.DefaultAnyValue.class, p -> new AnyValue.DefaultAnyValue());
- creatorCacheMap.put(AnyValue.class, p -> new AnyValue.DefaultAnyValue());
-
- arrayCacheMap.put(int.class, t -> new int[t]);
- arrayCacheMap.put(byte.class, t -> new byte[t]);
- arrayCacheMap.put(long.class, t -> new long[t]);
- arrayCacheMap.put(String.class, t -> new String[t]);
- arrayCacheMap.put(Object.class, t -> new Object[t]);
- arrayCacheMap.put(boolean.class, t -> new boolean[t]);
- arrayCacheMap.put(short.class, t -> new short[t]);
- arrayCacheMap.put(char.class, t -> new char[t]);
- arrayCacheMap.put(float.class, t -> new float[t]);
- arrayCacheMap.put(double.class, t -> new double[t]);
- }
-
- static class SimpleClassVisitor extends ClassVisitor {
-
- private final String constructorDesc;
-
- private final List fieldnames;
-
- private boolean started;
-
- public SimpleClassVisitor(int api, List fieldnames, String constructorDesc) {
- super(api);
- this.fieldnames = fieldnames;
- this.constructorDesc = constructorDesc;
- }
-
- @Override
- public MethodVisitor visitMethod(int access, String name, String desc, String signature, String[] exceptions) {
- if (java.lang.reflect.Modifier.isStatic(access) || !"".equals(name)) {
- return null;
- }
- if (constructorDesc != null && !constructorDesc.equals(desc)) {
- return null;
- }
- if (this.started) {
- return null;
- }
- this.started = true;
- //返回的List中参数列表可能会比方法参数量多，因为方法内的临时变量也会存入list中， 所以需要list的元素集合比方法的参数多
- return new MethodVisitor(Opcodes.ASM6) {
- @Override
- public void visitLocalVariable(String name, String description, String signature, Label start, Label end, int index) {
- if (index < 1) {
- return;
- }
- int size = fieldnames.size();
- //index不会按顺序执行的
- if (index > size) {
- for (int i = size; i < index; i++) {
- fieldnames.add(" ");
- }
- fieldnames.set(index - 1, name);
- }
- fieldnames.set(index - 1, name);
- }
- };
- }
- }
-
- public static SimpleEntry[] getConstructorField(Class clazz, int paramcount, String constructorDesc) {
- String n = clazz.getName();
- InputStream in = clazz.getResourceAsStream(n.substring(n.lastIndexOf('.') + 1) + ".class");
- if (in == null) {
- return null;
- }
- ByteArrayOutputStream out = new ByteArrayOutputStream(1024);
- byte[] bytes = new byte[1024];
- int pos;
- try {
- while ((pos = in.read(bytes)) != -1) {
- out.write(bytes, 0, pos);
- }
- in.close();
- } catch (IOException io) {
- return null;
- }
- final List fieldnames = new ArrayList<>();
- new ClassReader(out.toByteArray()).accept(new SimpleClassVisitor(Opcodes.ASM6, fieldnames, constructorDesc), 0);
- while (fieldnames.remove(" ")); //删掉空元素
- if (fieldnames.isEmpty()) {
- return null;
- }
- if (paramcount == fieldnames.size()) {
- return getConstructorField(clazz, paramcount, fieldnames.toArray(new String[fieldnames.size()]));
- } else {
- String[] fs = new String[paramcount];
- for (int i = 0; i < fs.length; i++) {
- fs[i] = fieldnames.get(i);
- }
- return getConstructorField(clazz, paramcount, fs);
- }
- }
-
- public static SimpleEntry[] getConstructorField(Class clazz, int paramcount, String[] names) {
- SimpleEntry[] se = new SimpleEntry[names.length];
- for (int i = 0; i < names.length; i++) { //查询参数名对应的Field
- try {
- Field field = clazz.getDeclaredField(names[i]);
- se[i] = new SimpleEntry<>(field.getName(), field.getType());
- } catch (NoSuchFieldException fe) {
- Class cz = clazz;
- Field field = null;
- while ((cz = cz.getSuperclass()) != Object.class) {
- try {
- field = cz.getDeclaredField(names[i]);
- break;
- } catch (NoSuchFieldException nsfe) {
- }
- }
- if (field == null) {
- return null;
- }
- se[i] = new SimpleEntry<>(field.getName(), field.getType());
- } catch (Exception e) {
- if (logger.isLoggable(Level.FINE)) {
- logger.log(Level.FINE, clazz + " getConstructorField error", e);
- }
- return null;
- }
- }
- return se;
- }
-
- public static SimpleEntry[] getConstructorField(Class clazz, int paramcount, Parameter[] params) {
- SimpleEntry[] se = new SimpleEntry[params.length];
- for (int i = 0; i < params.length; i++) { //查询参数名对应的Field
- try {
- Field field = clazz.getDeclaredField(params[i].getName());
- se[i] = new SimpleEntry<>(field.getName(), field.getType());
- } catch (Exception e) {
- return null;
- }
- }
- return se;
- }
-
- static class TypeArrayIntFunction implements IntFunction {
-
- private final Class type;
-
- public TypeArrayIntFunction(Class type) {
- this.type = type;
- }
-
- @Override
- public T[] apply(int value) {
- return (T[]) Array.newInstance(type, value);
- }
-
- }
-
- public static IntFunction createArrayFunction(final Class clazz) {
- final String interName = clazz.getName().replace('.', '/');
- final String interDesc = Type.getDescriptor(clazz);
- final ClassLoader loader = clazz.getClassLoader();
- final String newDynName = "org/redkaledyn/creator/_DynArrayFunction__" + clazz.getName().replace('.', '_').replace('$', '_');
- try {
- Class clz = RedkaleClassLoader.findDynClass(newDynName.replace('/', '.'));
- return (IntFunction) (clz == null ? loader.loadClass(newDynName.replace('/', '.')) : clz).getDeclaredConstructor().newInstance();
- } catch (Throwable ex) {
- }
-
- //-------------------------------------------------------------
- ClassWriter cw = new ClassWriter(ClassWriter.COMPUTE_FRAMES);
- MethodVisitor mv;
- cw.visit(V11, ACC_PUBLIC + ACC_FINAL + ACC_SUPER, newDynName, "Ljava/lang/Object;Ljava/util/function/IntFunction<[" + interDesc + ">;", "java/lang/Object", new String[]{"java/util/function/IntFunction"});
-
- {//IntFunction自身的构造方法
- mv = cw.visitMethod(ACC_PUBLIC, "", "()V", null, null);
- mv.visitVarInsn(ALOAD, 0);
- mv.visitMethodInsn(INVOKESPECIAL, "java/lang/Object", "", "()V", false);
- mv.visitInsn(RETURN);
- mv.visitMaxs(1, 1);
- mv.visitEnd();
- }
- {//apply 方法
- mv = cw.visitMethod(ACC_PUBLIC, "apply", "(I)[" + interDesc, null, null);
- mv.visitVarInsn(ILOAD, 1);
- mv.visitTypeInsn(ANEWARRAY, interName);
- mv.visitInsn(ARETURN);
- mv.visitMaxs(1, 2);
- mv.visitEnd();
- }
- { //虚拟 apply 方法
- mv = cw.visitMethod(ACC_PUBLIC + ACC_BRIDGE + ACC_SYNTHETIC, "apply", "(I)Ljava/lang/Object;", null, null);
- mv.visitVarInsn(ALOAD, 0);
- mv.visitVarInsn(ILOAD, 1);
- mv.visitMethodInsn(INVOKEVIRTUAL, newDynName, "apply", "(I)[" + interDesc, false);
- mv.visitInsn(ARETURN);
- mv.visitMaxs(2, 2);
- mv.visitEnd();
- }
- cw.visitEnd();
- final byte[] bytes = cw.toByteArray();
- try {
- Class resultClazz = new ClassLoader(loader) {
- public final Class loadClass(String name, byte[] b) {
- return defineClass(name, b, 0, b.length);
- }
- }.loadClass(newDynName.replace('/', '.'), bytes);
- RedkaleClassLoader.putDynClass(newDynName.replace('/', '.'), bytes, resultClazz);
- RedkaleClassLoader.putReflectionDeclaredConstructors(resultClazz, newDynName.replace('/', '.'));
- return (IntFunction) resultClazz.getDeclaredConstructor().newInstance();
- } catch (Exception ex) {
- //ex.printStackTrace(); //一般不会发生
- //return t -> (T[]) Array.newInstance(clazz, t);
- throw new RuntimeException(ex);
- }
- }
- }
-
- /**
- * 创建对象
- *
- * @param params 构造函数的参数
- *
- * @return 构建的对象
- */
- public T create(Object... params);
-
- /**
- * 参数类型数组
- *
- * @return 参数类型数组
- */
- default Class[] paramTypes() {
- return new Class[0];
- }
-
- /**
- * 创建指定类型对象数组的IntFunction
- *
- * @param 泛型
- * @param type 类型
- *
- * @return IntFunction
- */
- public static IntFunction arrayFunction(final Class type) {
- return CreatorInner.arrayCacheMap.computeIfAbsent(type, t -> CreatorInner.createArrayFunction(t));
- }
-
- /**
- * 创建指定大小的对象数组
- *
- * @param 泛型
- * @param type 类型
- * @param size 数组大小
- *
- * @return 数组
- */
- public static T[] newArray(final Class type, final int size) {
- if (type == int.class) {
- return (T[]) (Object) new int[size];
- }
- if (type == byte.class) {
- return (T[]) (Object) new byte[size];
- }
- if (type == long.class) {
- return (T[]) (Object) new long[size];
- }
- if (type == String.class) {
- return (T[]) new String[size];
- }
- if (type == Object.class) {
- return (T[]) new Object[size];
- }
- if (type == boolean.class) {
- return (T[]) (Object) new boolean[size];
- }
- if (type == short.class) {
- return (T[]) (Object) new short[size];
- }
- if (type == char.class) {
- return (T[]) (Object) new char[size];
- }
- if (type == float.class) {
- return (T[]) (Object) new float[size];
- }
- if (type == double.class) {
- return (T[]) (Object) new double[size];
- }
- //return (T[]) Array.newInstance(type, size);
- return arrayFunction(type).apply(size);
- }
-
- /**
- * 根据Supplier生产Creator
- *
- * @param 构建类的数据类型
- * @param supplier Supplier
- *
- * @return Creator对象
- */
- public static Creator create(final Supplier supplier) {
- Objects.requireNonNull(supplier);
- return (Object... params) -> supplier.get();
- }
-
- /**
- * 根据Function生产Creator
- *
- * @param 构建类的数据类型
- * @param func Function
- *
- * @return Creator对象
- */
- public static Creator create(final Function func) {
- Objects.requireNonNull(func);
- return (Object... params) -> func.apply(params);
- }
-
- /**
- * 根据指定的class采用ASM技术生产Creator。
- *
- * @param 构建类的数据类型
- * @param clazz 构建类
- *
- * @return Creator对象
- */
- @SuppressWarnings("unchecked")
- public static Creator create(Class clazz) {
- if (List.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(ArrayList.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections") || clazz.getName().startsWith("java.util.Arrays"))) {
- clazz = (Class) ArrayList.class;
- } else if (Map.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(HashMap.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections"))) {
- clazz = (Class) HashMap.class;
- } else if (Set.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(HashSet.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections"))) {
- clazz = (Class) HashSet.class;
- } else if (Map.class.isAssignableFrom(clazz) && clazz.isAssignableFrom(ConcurrentHashMap.class)) {
- clazz = (Class) ConcurrentHashMap.class;
- } else if (Deque.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(ArrayDeque.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections"))) {
- clazz = (Class) ArrayDeque.class;
- } else if (Collection.class.isAssignableFrom(clazz) && clazz.isAssignableFrom(ArrayList.class)) {
- clazz = (Class) ArrayList.class;
- } else if (Map.Entry.class.isAssignableFrom(clazz) && (Modifier.isInterface(clazz.getModifiers()) || Modifier.isAbstract(clazz.getModifiers()) || !Modifier.isPublic(clazz.getModifiers()))) {
- clazz = (Class) AbstractMap.SimpleEntry.class;
- } else if (Iterable.class == clazz) {
- clazz = (Class) ArrayList.class;
- }
- Creator creator = CreatorInner.creatorCacheMap.get(clazz);
- if (creator != null) {
- return creator;
- }
- if (clazz.isInterface() || Modifier.isAbstract(clazz.getModifiers())) {
- throw new RuntimeException("[" + clazz + "] is a interface or abstract class, cannot create it's Creator.");
- }
- for (final Method method : clazz.getDeclaredMethods()) { //查找类中是否存在提供创建Creator实例的静态方法
- if (!Modifier.isStatic(method.getModifiers())) {
- continue;
- }
- if (method.getParameterTypes().length != 0) {
- continue;
- }
- if (method.getReturnType() != Creator.class) {
- continue;
- }
- try {
- method.setAccessible(true);
- Creator c = (Creator) method.invoke(null);
- if (c != null) {
- RedkaleClassLoader.putReflectionDeclaredMethods(clazz.getName());
- RedkaleClassLoader.putReflectionMethod(clazz.getName(), method);
- return c;
- }
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
- final String supDynName = Creator.class.getName().replace('.', '/');
- final String interName = clazz.getName().replace('.', '/');
- final String interDesc = Type.getDescriptor(clazz);
- ClassLoader loader = Thread.currentThread().getContextClassLoader();
- if (String.class.getClassLoader() != clazz.getClassLoader()) {
- loader = clazz.getClassLoader();
- }
- final String newDynName = "org/redkaledyn/creator/_Dyn" + Creator.class.getSimpleName() + "__" + clazz.getName().replace('.', '_').replace('$', '_');
- try {
- Class clz = RedkaleClassLoader.findDynClass(newDynName.replace('/', '.'));
- return (Creator) (clz == null ? loader.loadClass(newDynName.replace('/', '.')) : clz).getDeclaredConstructor().newInstance();
- } catch (Throwable ex) {
- }
-
- Constructor constructor0 = null;
- SimpleEntry[] constructorParameters0 = null; //构造函数的参数
-
- if (constructor0 == null) { // 1、查找public的空参数构造函数
- for (Constructor c : clazz.getConstructors()) {
- if (c.getParameterCount() == 0) {
- constructor0 = c;
- constructorParameters0 = new SimpleEntry[0];
- break;
- }
- }
- }
- if (constructor0 == null) { // 2、查找public带ConstructorParameters注解的构造函数
- for (Constructor c : clazz.getConstructors()) {
- ConstructorParameters cp = (ConstructorParameters) c.getAnnotation(ConstructorParameters.class);
- if (cp == null) {
- continue;
- }
- SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), cp.value());
- if (fields != null) {
- constructor0 = c;
- constructorParameters0 = fields;
- break;
- }
- }
- }
- if (constructor0 == null) { // 3、查找public且不带ConstructorParameters注解的构造函数
- List cs = new ArrayList<>();
- for (Constructor c : clazz.getConstructors()) {
- if (c.getAnnotation(ConstructorParameters.class) != null) {
- continue;
- }
- if (c.getParameterCount() < 1) {
- continue;
- }
- cs.add(c);
- }
- //优先参数最多的构造函数
- cs.sort((o1, o2) -> o2.getParameterCount() - o1.getParameterCount());
- for (Constructor c : cs) {
- SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), Type.getConstructorDescriptor(c));
- if (fields != null) {
- constructor0 = c;
- constructorParameters0 = fields;
- break;
- }
- }
- }
- if (constructor0 == null) { // 4、查找非private带ConstructorParameters的构造函数
- for (Constructor c : clazz.getDeclaredConstructors()) {
- if (Modifier.isPublic(c.getModifiers()) || Modifier.isPrivate(c.getModifiers())) {
- continue;
- }
- ConstructorParameters cp = (ConstructorParameters) c.getAnnotation(ConstructorParameters.class);
- if (cp == null) {
- continue;
- }
- SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), cp.value());
- if (fields != null) {
- constructor0 = c;
- constructorParameters0 = fields;
- break;
- }
- }
- }
- if (constructor0 == null) { // 5、查找非private且不带ConstructorParameters的构造函数
- List cs = new ArrayList<>();
- for (Constructor c : clazz.getDeclaredConstructors()) {
- if (Modifier.isPublic(c.getModifiers()) || Modifier.isPrivate(c.getModifiers())) {
- continue;
- }
- if (c.getAnnotation(ConstructorParameters.class) != null) {
- continue;
- }
- if (c.getParameterCount() < 1) {
- continue;
- }
- cs.add(c);
- }
- //优先参数最多的构造函数
- cs.sort((o1, o2) -> o2.getParameterCount() - o1.getParameterCount());
- for (Constructor c : cs) {
- SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), Type.getConstructorDescriptor(c));
- if (fields != null) {
- constructor0 = c;
- constructorParameters0 = fields;
- break;
- }
- }
- }
- final Constructor constructor = constructor0;
- final SimpleEntry[] constructorParameters = constructorParameters0;
- if (constructor == null || constructorParameters == null) {
- throw new RuntimeException("[" + clazz + "] have no public or ConstructorParameters-Annotation constructor.");
- }
- final int[] iconsts = {ICONST_0, ICONST_1, ICONST_2, ICONST_3, ICONST_4, ICONST_5};
- //-------------------------------------------------------------
- ClassWriter cw = new ClassWriter(ClassWriter.COMPUTE_FRAMES);
- FieldVisitor fv;
- MethodVisitor mv;
- AnnotationVisitor av0;
- cw.visit(V11, ACC_PUBLIC + ACC_FINAL + ACC_SUPER, newDynName, "Ljava/lang/Object;L" + supDynName + "<" + interDesc + ">;", "java/lang/Object", new String[]{supDynName});
-
- {//Creator自身的构造方法
- mv = cw.visitMethod(ACC_PUBLIC, "", "()V", null, null);
- mv.visitVarInsn(ALOAD, 0);
- mv.visitMethodInsn(INVOKESPECIAL, "java/lang/Object", "", "()V", false);
- mv.visitInsn(RETURN);
- mv.visitMaxs(1, 1);
- mv.visitEnd();
- }
- {//paramTypes 方法
- mv = cw.visitMethod(ACC_PUBLIC, "paramTypes", "()[Ljava/lang/Class;", null, null);
- int paramLen = constructorParameters.length;
- if (paramLen < 6) {
- mv.visitInsn(ICONST_0 + paramLen);
- } else if (paramLen <= Byte.MAX_VALUE) {
- mv.visitIntInsn(BIPUSH, paramLen);
- } else if (paramLen <= Short.MAX_VALUE) {
- mv.visitIntInsn(SIPUSH, paramLen);
- } else {
- mv.visitLdcInsn(paramLen);
- }
- mv.visitTypeInsn(ANEWARRAY, "java/lang/Class");
-
- for (int i = 0; i < constructorParameters.length; i++) {
- final Class pt = constructorParameters[i].getValue();
- mv.visitInsn(DUP);
- if (i < 6) {
- mv.visitInsn(iconsts[i]);
- } else if (i <= Byte.MAX_VALUE) {
- mv.visitIntInsn(BIPUSH, i);
- } else if (i <= Short.MAX_VALUE) {
- mv.visitIntInsn(SIPUSH, i);
- } else {
- mv.visitLdcInsn(i);
- }
- if (pt == boolean.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Boolean", "TYPE", "Ljava/lang/Class;");
- } else if (pt == byte.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Byte", "TYPE", "Ljava/lang/Class;");
- } else if (pt == char.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Character", "TYPE", "Ljava/lang/Class;");
- } else if (pt == short.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Short", "TYPE", "Ljava/lang/Class;");
- } else if (pt == int.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Integer", "TYPE", "Ljava/lang/Class;");
- } else if (pt == float.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Float", "TYPE", "Ljava/lang/Class;");
- } else if (pt == long.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Long", "TYPE", "Ljava/lang/Class;");
- } else if (pt == double.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Double", "TYPE", "Ljava/lang/Class;");
- } else {
- mv.visitLdcInsn(Type.getType(Type.getDescriptor(pt)));
- }
- mv.visitInsn(AASTORE);
- }
- mv.visitInsn(ARETURN);
- mv.visitMaxs(4, 1);
- mv.visitEnd();
- }
- {//create 方法
- mv = cw.visitMethod(ACC_PUBLIC + ACC_VARARGS, "create", "([Ljava/lang/Object;)L" + interName + ";", null, null);
- if (constructorParameters.length > 0) {
- av0 = mv.visitAnnotation(Type.getDescriptor(ConstructorParameters.class), true);
- AnnotationVisitor av1 = av0.visitArray("value");
- for (SimpleEntry n : constructorParameters) {
- av1.visit(null, n.getKey());
- }
- av1.visitEnd();
- av0.visitEnd();
- }
- { //有Primitive数据类型且值为null的参数需要赋默认值
- for (int i = 0; i < constructorParameters.length; i++) {
- final Class pt = constructorParameters[i].getValue();
- if (!pt.isPrimitive()) {
- continue;
- }
- mv.visitVarInsn(ALOAD, 1);
- if (i < 6) {
- mv.visitInsn(iconsts[i]);
- } else if (i <= Byte.MAX_VALUE) {
- mv.visitIntInsn(BIPUSH, i);
- } else if (i <= Short.MAX_VALUE) {
- mv.visitIntInsn(SIPUSH, i);
- } else {
- mv.visitLdcInsn(i);
- }
- mv.visitInsn(AALOAD);
- Label lab = new Label();
- mv.visitJumpInsn(IFNONNULL, lab);
- mv.visitVarInsn(ALOAD, 1);
- if (i < 6) {
- mv.visitInsn(iconsts[i]);
- } else if (i <= Byte.MAX_VALUE) {
- mv.visitIntInsn(BIPUSH, i);
- } else if (i <= Short.MAX_VALUE) {
- mv.visitIntInsn(SIPUSH, i);
- } else {
- mv.visitLdcInsn(i);
- }
- if (pt == int.class) {
- mv.visitInsn(ICONST_0);
- mv.visitMethodInsn(INVOKESTATIC, "java/lang/Integer", "valueOf", "(I)Ljava/lang/Integer;", false);
- } else if (pt == long.class) {
- mv.visitInsn(LCONST_0);
- mv.visitMethodInsn(INVOKESTATIC, "java/lang/Long", "valueOf", "(J)Ljava/lang/Long;", false);
- } else if (pt == boolean.class) {
- mv.visitFieldInsn(GETSTATIC, "java/lang/Boolean", "FALSE", "Ljava/lang/Boolean;");
- } else if (pt == short.class) {
- mv.visitInsn(ICONST_0);
- mv.visitMethodInsn(INVOKESTATIC, "java/lang/Short", "valueOf", "(S)Ljava/lang/Short;", false);
- } else if (pt == float.class) {
- mv.visitInsn(FCONST_0);
- mv.visitMethodInsn(INVOKESTATIC, "java/lang/Float", "valueOf", "(F)Ljava/lang/Float;", false);
- } else if (pt == byte.class) {
- mv.visitInsn(ICONST_0);
- mv.visitMethodInsn(INVOKESTATIC, "java/lang/Byte", "valueOf", "(B)Ljava/lang/Byte;", false);
- } else if (pt == double.class) {
- mv.visitInsn(DCONST_0);
- mv.visitMethodInsn(INVOKESTATIC, "java/lang/Double", "valueOf", "(D)Ljava/lang/Double;", false);
- } else if (pt == char.class) {
- mv.visitInsn(ICONST_0);
- mv.visitMethodInsn(INVOKESTATIC, "java/lang/Character", "valueOf", "(C)Ljava/lang/Character;", false);
- }
- mv.visitInsn(AASTORE);
- mv.visitLabel(lab);
- }
- }
- mv.visitTypeInsn(NEW, interName);
- mv.visitInsn(DUP);
- //---------------------------------------
- {
- for (int i = 0; i < constructorParameters.length; i++) {
- mv.visitVarInsn(ALOAD, 1);
- if (i < 6) {
- mv.visitInsn(iconsts[i]);
- } else if (i <= Byte.MAX_VALUE) {
- mv.visitIntInsn(BIPUSH, i);
- } else if (i <= Short.MAX_VALUE) {
- mv.visitIntInsn(SIPUSH, i);
- } else {
- mv.visitLdcInsn(i);
- }
- mv.visitInsn(AALOAD);
- final Class ct = constructorParameters[i].getValue();
- if (ct.isPrimitive()) {
- final Class bigct = Array.get(Array.newInstance(ct, 1), 0).getClass();
- mv.visitTypeInsn(CHECKCAST, bigct.getName().replace('.', '/'));
- try {
- Method pm = bigct.getMethod(ct.getSimpleName() + "Value");
- mv.visitMethodInsn(INVOKEVIRTUAL, bigct.getName().replace('.', '/'), pm.getName(), Type.getMethodDescriptor(pm), false);
- } catch (Exception ex) {
- throw new RuntimeException(ex); //不可能会发生
- }
- } else {
- mv.visitTypeInsn(CHECKCAST, ct.getName().replace('.', '/'));
- }
- }
- }
- //---------------------------------------
- mv.visitMethodInsn(INVOKESPECIAL, interName, "", Type.getConstructorDescriptor(constructor), false);
- mv.visitInsn(ARETURN);
- mv.visitMaxs((constructorParameters.length > 0 ? (constructorParameters.length + 3) : 2), 2);
- mv.visitEnd();
- }
- { //虚拟 create 方法
- mv = cw.visitMethod(ACC_PUBLIC + ACC_BRIDGE + ACC_VARARGS + ACC_SYNTHETIC, "create", "([Ljava/lang/Object;)Ljava/lang/Object;", null, null);
- mv.visitVarInsn(ALOAD, 0);
- mv.visitVarInsn(ALOAD, 1);
- mv.visitMethodInsn(INVOKEVIRTUAL, newDynName, "create", "([Ljava/lang/Object;)" + interDesc, false);
- mv.visitInsn(ARETURN);
- mv.visitMaxs(2, 2);
- mv.visitEnd();
- }
- cw.visitEnd();
- final byte[] bytes = cw.toByteArray();
- final boolean ispub = Modifier.isPublic(constructor.getModifiers());
- Class resultClazz = null;
- if (loader instanceof URLClassLoader && !ispub) {
- try {
- final URLClassLoader urlLoader = (URLClassLoader) loader;
- final URL url = new URL("memclass", "localhost", -1, "/" + newDynName.replace('/', '.') + "/", new URLStreamHandler() {
- @Override
- protected URLConnection openConnection(URL u) throws IOException {
- return new URLConnection(u) {
- @Override
- public void connect() throws IOException {
- }
-
- @Override
- public InputStream getInputStream() throws IOException {
- return new ByteArrayInputStream(bytes);
- }
- };
- }
- });
- Method addURLMethod = URLClassLoader.class.getDeclaredMethod("addURL", URL.class);
- addURLMethod.setAccessible(true);
- addURLMethod.invoke(urlLoader, url);
- resultClazz = urlLoader.loadClass(newDynName.replace('/', '.'));
- } catch (Throwable t) { //异常无需理会， 使用下一种loader方式
- t.printStackTrace();
- }
- }
- if (!ispub && resultClazz == null) {
- throw new RuntimeException("[" + clazz + "] have no public or ConstructorParameters-Annotation constructor.");
- }
- try {
- if (resultClazz == null) {
- resultClazz = new ClassLoader(loader) {
- public final Class loadClass(String name, byte[] b) {
- return defineClass(name, b, 0, b.length);
- }
- }.loadClass(newDynName.replace('/', '.'), bytes);
- }
- RedkaleClassLoader.putDynClass(newDynName.replace('/', '.'), bytes, resultClazz);
- RedkaleClassLoader.putReflectionDeclaredConstructors(resultClazz, newDynName.replace('/', '.'));
- return (Creator) resultClazz.getDeclaredConstructor().newInstance();
- } catch (Exception ex) {
- throw new RuntimeException(ex);
- }
- }
-}
+/*
+ * To change this template, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package org.redkale.util;
+
+import java.io.*;
+import java.lang.reflect.*;
+import java.net.*;
+import java.util.AbstractMap.SimpleEntry;
+import java.util.*;
+import java.util.concurrent.*;
+import java.util.function.*;
+import java.util.logging.*;
+import java.util.stream.Stream;
+import org.redkale.annotation.ConstructorParameters;
+import org.redkale.asm.*;
+import static org.redkale.asm.Opcodes.*;
+import org.redkale.asm.Type;
+
+/**
+ *
+ * 实现一个类的构造方法。 代替低效的反射实现方式。 不支持数组类。
+ * 常见的无参数的构造函数类都可以自动生成Creator， 对应自定义的类可以提供一个静态构建Creator方法。
+ * 例如:
+ *
+ * public class Record {
+ *
+ * private final int id;
+ *
+ * private String name;
+ *
+ * Record(int id, String name) {
+ * this.id = id;
+ * this.name = name;
+ * }
+ *
+ * private static Creator createCreator() {
+ * return new Creator<Record>() {
+ * @Override
+ * @ConstructorParameters({"id", "name"})
+ * public Record create(Object... params) {
+ * if(params[0] == null) params[0] = 0;
+ * return new Record((Integer) params[0], (String) params[1]);
+ * }
+ * };
+ * }
+ * }
+ *
+ *
+ * 或者:
+ *
+ * public class Record {
+ *
+ * private final int id;
+ *
+ * private String name;
+ *
+ * @ConstructorParameters({"id", "name"})
+ * public Record(int id, String name) {
+ * this.id = id;
+ * this.name = name;
+ * }
+ * }
+ *
+ *
+ *
+ * 详情见: https://redkale.org
+ *
+ * @author zhangjx
+ * @param 构建对象的数据类型
+ */
+public interface Creator {
+
+ /**
+ * 创建对象
+ *
+ * @param params 构造函数的参数
+ *
+ * @return 构建的对象
+ */
+ public T create(Object... params);
+
+ /**
+ * 参数类型数组
+ *
+ * @since 2.8.0
+ * @return 参数类型数组
+ */
+ default Class[] paramTypes() {
+ return new Class[0];
+ }
+
+ /**
+ * 创建指定类型对象数组的IntFunction
+ *
+ * @param 泛型
+ * @param type 类型
+ *
+ * @return IntFunction
+ */
+ public static IntFunction arrayFunction(final Class type) {
+ return CreatorInner.arrayCacheMap.computeIfAbsent(type, CreatorInner::createArrayFunction);
+ }
+
+ /**
+ * 创建指定大小的对象数组
+ *
+ * @param 泛型
+ * @param type 类型
+ * @param size 数组大小
+ *
+ * @return 数组
+ */
+ public static T[] newArray(final Class type, final int size) {
+ if (type == int.class) {
+ return (T[]) (Object) new int[size];
+ }
+ if (type == byte.class) {
+ return (T[]) (Object) new byte[size];
+ }
+ if (type == long.class) {
+ return (T[]) (Object) new long[size];
+ }
+ if (type == String.class) {
+ return (T[]) new String[size];
+ }
+ if (type == Object.class) {
+ return (T[]) new Object[size];
+ }
+ if (type == boolean.class) {
+ return (T[]) (Object) new boolean[size];
+ }
+ if (type == short.class) {
+ return (T[]) (Object) new short[size];
+ }
+ if (type == char.class) {
+ return (T[]) (Object) new char[size];
+ }
+ if (type == float.class) {
+ return (T[]) (Object) new float[size];
+ }
+ if (type == double.class) {
+ return (T[]) (Object) new double[size];
+ }
+ //return (T[]) Array.newInstance(type, size);
+ return arrayFunction(type).apply(size);
+ }
+
+ /**
+ * 根据Supplier生产Creator
+ *
+ * @param 构建类的数据类型
+ * @param supplier Supplier
+ *
+ * @return Creator对象
+ */
+ public static Creator create(final Supplier supplier) {
+ Objects.requireNonNull(supplier);
+ return (Object... params) -> supplier.get();
+ }
+
+ /**
+ * 根据Function生产Creator
+ *
+ * @param 构建类的数据类型
+ * @param func Function
+ *
+ * @return Creator对象
+ */
+ public static Creator create(final Function func) {
+ Objects.requireNonNull(func);
+ return (Object... params) -> func.apply(params);
+ }
+
+ /**
+ * 根据指定的class采用ASM技术生产Creator。
+ *
+ * @param 构建类的数据类型
+ * @param clazz 构建类
+ *
+ * @return Creator对象
+ */
+ @SuppressWarnings("unchecked")
+ public static Creator create(Class clazz) {
+ if (List.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(ArrayList.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections") || clazz.getName().startsWith("java.util.Arrays"))) {
+ clazz = (Class) ArrayList.class;
+ } else if (Map.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(HashMap.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections"))) {
+ clazz = (Class) HashMap.class;
+ } else if (Set.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(HashSet.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections"))) {
+ clazz = (Class) HashSet.class;
+ } else if (Map.class.isAssignableFrom(clazz) && clazz.isAssignableFrom(ConcurrentHashMap.class)) {
+ clazz = (Class) ConcurrentHashMap.class;
+ } else if (Deque.class.isAssignableFrom(clazz) && (clazz.isAssignableFrom(ArrayDeque.class) || clazz.getName().startsWith("java.util.Collections") || clazz.getName().startsWith("java.util.ImmutableCollections"))) {
+ clazz = (Class) ArrayDeque.class;
+ } else if (Collection.class.isAssignableFrom(clazz) && clazz.isAssignableFrom(ArrayList.class)) {
+ clazz = (Class) ArrayList.class;
+ } else if (Map.Entry.class.isAssignableFrom(clazz) && (Modifier.isInterface(clazz.getModifiers()) || Modifier.isAbstract(clazz.getModifiers()) || !Modifier.isPublic(clazz.getModifiers()))) {
+ clazz = (Class) AbstractMap.SimpleEntry.class;
+ } else if (Iterable.class == clazz) {
+ clazz = (Class) ArrayList.class;
+ }
+ Creator creator = CreatorInner.creatorCacheMap.get(clazz);
+ if (creator != null) {
+ return creator;
+ }
+ if (clazz.isInterface() || Modifier.isAbstract(clazz.getModifiers())) {
+ throw new RuntimeException("[" + clazz + "] is a interface or abstract class, cannot create it's Creator.");
+ }
+ for (final Method method : clazz.getDeclaredMethods()) { //查找类中是否存在提供创建Creator实例的静态方法
+ if (!Modifier.isStatic(method.getModifiers())) {
+ continue;
+ }
+ if (method.getParameterTypes().length != 0) {
+ continue;
+ }
+ if (method.getReturnType() != Creator.class) {
+ continue;
+ }
+ try {
+ method.setAccessible(true);
+ Creator c = (Creator) method.invoke(null);
+ if (c != null) {
+ RedkaleClassLoader.putReflectionDeclaredMethods(clazz.getName());
+ RedkaleClassLoader.putReflectionMethod(clazz.getName(), method);
+ return c;
+ }
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+ final String supDynName = Creator.class.getName().replace('.', '/');
+ final String interName = clazz.getName().replace('.', '/');
+ final String interDesc = Type.getDescriptor(clazz);
+ ClassLoader loader = Thread.currentThread().getContextClassLoader();
+ if (String.class.getClassLoader() != clazz.getClassLoader()) {
+ loader = clazz.getClassLoader();
+ }
+ final String newDynName = "org/redkaledyn/creator/_Dyn" + Creator.class.getSimpleName() + "__" + clazz.getName().replace('.', '_').replace('$', '_');
+ try {
+ Class clz = RedkaleClassLoader.findDynClass(newDynName.replace('/', '.'));
+ return (Creator) (clz == null ? loader.loadClass(newDynName.replace('/', '.')) : clz).getDeclaredConstructor().newInstance();
+ } catch (Throwable ex) {
+ }
+
+ Constructor constructor0 = null;
+ SimpleEntry[] constructorParameters0 = null; //构造函数的参数
+
+ if (constructor0 == null) { // 1、查找public的空参数构造函数
+ for (Constructor c : clazz.getConstructors()) {
+ if (c.getParameterCount() == 0) {
+ constructor0 = c;
+ constructorParameters0 = new SimpleEntry[0];
+ break;
+ }
+ }
+ }
+ if (constructor0 == null) { // 2、查找public带ConstructorParameters注解的构造函数
+ for (Constructor c : clazz.getConstructors()) {
+ ConstructorParameters cp = (ConstructorParameters) c.getAnnotation(ConstructorParameters.class);
+ if (cp == null) {
+ continue;
+ }
+ SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), cp.value());
+ if (fields != null) {
+ constructor0 = c;
+ constructorParameters0 = fields;
+ break;
+ }
+ }
+ }
+ if (constructor0 == null) { // 3、查找public且不带ConstructorParameters注解的构造函数
+ List cs = new ArrayList<>();
+ for (Constructor c : clazz.getConstructors()) {
+ if (c.getAnnotation(ConstructorParameters.class) != null) {
+ continue;
+ }
+ if (c.getParameterCount() < 1) {
+ continue;
+ }
+ cs.add(c);
+ }
+ //优先参数最多的构造函数
+ cs.sort((o1, o2) -> o2.getParameterCount() - o1.getParameterCount());
+ for (Constructor c : cs) {
+ SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), Type.getConstructorDescriptor(c));
+ if (fields != null) {
+ constructor0 = c;
+ constructorParameters0 = fields;
+ break;
+ }
+ }
+ }
+ if (constructor0 == null) { // 4、查找非private带ConstructorParameters的构造函数
+ for (Constructor c : clazz.getDeclaredConstructors()) {
+ if (Modifier.isPublic(c.getModifiers()) || Modifier.isPrivate(c.getModifiers())) {
+ continue;
+ }
+ ConstructorParameters cp = (ConstructorParameters) c.getAnnotation(ConstructorParameters.class);
+ if (cp == null) {
+ continue;
+ }
+ SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), cp.value());
+ if (fields != null) {
+ constructor0 = c;
+ constructorParameters0 = fields;
+ break;
+ }
+ }
+ }
+ if (constructor0 == null) { // 5、查找非private且不带ConstructorParameters的构造函数
+ List cs = new ArrayList<>();
+ for (Constructor c : clazz.getDeclaredConstructors()) {
+ if (Modifier.isPublic(c.getModifiers()) || Modifier.isPrivate(c.getModifiers())) {
+ continue;
+ }
+ if (c.getAnnotation(ConstructorParameters.class) != null) {
+ continue;
+ }
+ if (c.getParameterCount() < 1) {
+ continue;
+ }
+ cs.add(c);
+ }
+ //优先参数最多的构造函数
+ cs.sort((o1, o2) -> o2.getParameterCount() - o1.getParameterCount());
+ for (Constructor c : cs) {
+ SimpleEntry[] fields = CreatorInner.getConstructorField(clazz, c.getParameterCount(), Type.getConstructorDescriptor(c));
+ if (fields != null) {
+ constructor0 = c;
+ constructorParameters0 = fields;
+ break;
+ }
+ }
+ }
+ final Constructor constructor = constructor0;
+ final SimpleEntry[] constructorParameters = constructorParameters0;
+ if (constructor == null || constructorParameters == null) {
+ throw new RuntimeException("[" + clazz + "] have no public or ConstructorParameters-Annotation constructor.");
+ }
+ final int[] iconsts = {ICONST_0, ICONST_1, ICONST_2, ICONST_3, ICONST_4, ICONST_5};
+ //-------------------------------------------------------------
+ ClassWriter cw = new ClassWriter(ClassWriter.COMPUTE_FRAMES);
+ FieldVisitor fv;
+ MethodVisitor mv;
+ AnnotationVisitor av0;
+ cw.visit(V11, ACC_PUBLIC + ACC_FINAL + ACC_SUPER, newDynName, "Ljava/lang/Object;L" + supDynName + "<" + interDesc + ">;", "java/lang/Object", new String[]{supDynName});
+
+ {//Creator自身的构造方法
+ mv = cw.visitMethod(ACC_PUBLIC, "", "()V", null, null);
+ mv.visitVarInsn(ALOAD, 0);
+ mv.visitMethodInsn(INVOKESPECIAL, "java/lang/Object", "", "()V", false);
+ mv.visitInsn(RETURN);
+ mv.visitMaxs(1, 1);
+ mv.visitEnd();
+ }
+ {//paramTypes 方法
+ mv = cw.visitMethod(ACC_PUBLIC, "paramTypes", "()[Ljava/lang/Class;", null, null);
+ int paramLen = constructorParameters.length;
+ if (paramLen < 6) {
+ mv.visitInsn(ICONST_0 + paramLen);
+ } else if (paramLen <= Byte.MAX_VALUE) {
+ mv.visitIntInsn(BIPUSH, paramLen);
+ } else if (paramLen <= Short.MAX_VALUE) {
+ mv.visitIntInsn(SIPUSH, paramLen);
+ } else {
+ mv.visitLdcInsn(paramLen);
+ }
+ mv.visitTypeInsn(ANEWARRAY, "java/lang/Class");
+
+ for (int i = 0; i < constructorParameters.length; i++) {
+ final Class pt = constructorParameters[i].getValue();
+ mv.visitInsn(DUP);
+ if (i < 6) {
+ mv.visitInsn(iconsts[i]);
+ } else if (i <= Byte.MAX_VALUE) {
+ mv.visitIntInsn(BIPUSH, i);
+ } else if (i <= Short.MAX_VALUE) {
+ mv.visitIntInsn(SIPUSH, i);
+ } else {
+ mv.visitLdcInsn(i);
+ }
+ if (pt == boolean.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Boolean", "TYPE", "Ljava/lang/Class;");
+ } else if (pt == byte.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Byte", "TYPE", "Ljava/lang/Class;");
+ } else if (pt == char.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Character", "TYPE", "Ljava/lang/Class;");
+ } else if (pt == short.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Short", "TYPE", "Ljava/lang/Class;");
+ } else if (pt == int.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Integer", "TYPE", "Ljava/lang/Class;");
+ } else if (pt == float.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Float", "TYPE", "Ljava/lang/Class;");
+ } else if (pt == long.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Long", "TYPE", "Ljava/lang/Class;");
+ } else if (pt == double.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Double", "TYPE", "Ljava/lang/Class;");
+ } else {
+ mv.visitLdcInsn(Type.getType(Type.getDescriptor(pt)));
+ }
+ mv.visitInsn(AASTORE);
+ }
+ mv.visitInsn(ARETURN);
+ mv.visitMaxs(4, 1);
+ mv.visitEnd();
+ }
+ {//create 方法
+ mv = cw.visitMethod(ACC_PUBLIC + ACC_VARARGS, "create", "([Ljava/lang/Object;)L" + interName + ";", null, null);
+ if (constructorParameters.length > 0) {
+ av0 = mv.visitAnnotation(Type.getDescriptor(ConstructorParameters.class), true);
+ AnnotationVisitor av1 = av0.visitArray("value");
+ for (SimpleEntry n : constructorParameters) {
+ av1.visit(null, n.getKey());
+ }
+ av1.visitEnd();
+ av0.visitEnd();
+ }
+ { //有Primitive数据类型且值为null的参数需要赋默认值
+ for (int i = 0; i < constructorParameters.length; i++) {
+ final Class pt = constructorParameters[i].getValue();
+ if (!pt.isPrimitive()) {
+ continue;
+ }
+ mv.visitVarInsn(ALOAD, 1);
+ if (i < 6) {
+ mv.visitInsn(iconsts[i]);
+ } else if (i <= Byte.MAX_VALUE) {
+ mv.visitIntInsn(BIPUSH, i);
+ } else if (i <= Short.MAX_VALUE) {
+ mv.visitIntInsn(SIPUSH, i);
+ } else {
+ mv.visitLdcInsn(i);
+ }
+ mv.visitInsn(AALOAD);
+ Label lab = new Label();
+ mv.visitJumpInsn(IFNONNULL, lab);
+ mv.visitVarInsn(ALOAD, 1);
+ if (i < 6) {
+ mv.visitInsn(iconsts[i]);
+ } else if (i <= Byte.MAX_VALUE) {
+ mv.visitIntInsn(BIPUSH, i);
+ } else if (i <= Short.MAX_VALUE) {
+ mv.visitIntInsn(SIPUSH, i);
+ } else {
+ mv.visitLdcInsn(i);
+ }
+ if (pt == int.class) {
+ mv.visitInsn(ICONST_0);
+ mv.visitMethodInsn(INVOKESTATIC, "java/lang/Integer", "valueOf", "(I)Ljava/lang/Integer;", false);
+ } else if (pt == long.class) {
+ mv.visitInsn(LCONST_0);
+ mv.visitMethodInsn(INVOKESTATIC, "java/lang/Long", "valueOf", "(J)Ljava/lang/Long;", false);
+ } else if (pt == boolean.class) {
+ mv.visitFieldInsn(GETSTATIC, "java/lang/Boolean", "FALSE", "Ljava/lang/Boolean;");
+ } else if (pt == short.class) {
+ mv.visitInsn(ICONST_0);
+ mv.visitMethodInsn(INVOKESTATIC, "java/lang/Short", "valueOf", "(S)Ljava/lang/Short;", false);
+ } else if (pt == float.class) {
+ mv.visitInsn(FCONST_0);
+ mv.visitMethodInsn(INVOKESTATIC, "java/lang/Float", "valueOf", "(F)Ljava/lang/Float;", false);
+ } else if (pt == byte.class) {
+ mv.visitInsn(ICONST_0);
+ mv.visitMethodInsn(INVOKESTATIC, "java/lang/Byte", "valueOf", "(B)Ljava/lang/Byte;", false);
+ } else if (pt == double.class) {
+ mv.visitInsn(DCONST_0);
+ mv.visitMethodInsn(INVOKESTATIC, "java/lang/Double", "valueOf", "(D)Ljava/lang/Double;", false);
+ } else if (pt == char.class) {
+ mv.visitInsn(ICONST_0);
+ mv.visitMethodInsn(INVOKESTATIC, "java/lang/Character", "valueOf", "(C)Ljava/lang/Character;", false);
+ }
+ mv.visitInsn(AASTORE);
+ mv.visitLabel(lab);
+ }
+ }
+ mv.visitTypeInsn(NEW, interName);
+ mv.visitInsn(DUP);
+ //---------------------------------------
+ {
+ for (int i = 0; i < constructorParameters.length; i++) {
+ mv.visitVarInsn(ALOAD, 1);
+ if (i < 6) {
+ mv.visitInsn(iconsts[i]);
+ } else if (i <= Byte.MAX_VALUE) {
+ mv.visitIntInsn(BIPUSH, i);
+ } else if (i <= Short.MAX_VALUE) {
+ mv.visitIntInsn(SIPUSH, i);
+ } else {
+ mv.visitLdcInsn(i);
+ }
+ mv.visitInsn(AALOAD);
+ final Class ct = constructorParameters[i].getValue();
+ if (ct.isPrimitive()) {
+ final Class bigct = Array.get(Array.newInstance(ct, 1), 0).getClass();
+ mv.visitTypeInsn(CHECKCAST, bigct.getName().replace('.', '/'));
+ try {
+ Method pm = bigct.getMethod(ct.getSimpleName() + "Value");
+ mv.visitMethodInsn(INVOKEVIRTUAL, bigct.getName().replace('.', '/'), pm.getName(), Type.getMethodDescriptor(pm), false);
+ } catch (Exception ex) {
+ throw new RuntimeException(ex); //不可能会发生
+ }
+ } else {
+ mv.visitTypeInsn(CHECKCAST, ct.getName().replace('.', '/'));
+ }
+ }
+ }
+ //---------------------------------------
+ mv.visitMethodInsn(INVOKESPECIAL, interName, "", Type.getConstructorDescriptor(constructor), false);
+ mv.visitInsn(ARETURN);
+ mv.visitMaxs((constructorParameters.length > 0 ? (constructorParameters.length + 3) : 2), 2);
+ mv.visitEnd();
+ }
+ { //虚拟 create 方法
+ mv = cw.visitMethod(ACC_PUBLIC + ACC_BRIDGE + ACC_VARARGS + ACC_SYNTHETIC, "create", "([Ljava/lang/Object;)Ljava/lang/Object;", null, null);
+ mv.visitVarInsn(ALOAD, 0);
+ mv.visitVarInsn(ALOAD, 1);
+ mv.visitMethodInsn(INVOKEVIRTUAL, newDynName, "create", "([Ljava/lang/Object;)" + interDesc, false);
+ mv.visitInsn(ARETURN);
+ mv.visitMaxs(2, 2);
+ mv.visitEnd();
+ }
+ cw.visitEnd();
+ final byte[] bytes = cw.toByteArray();
+ final boolean ispub = Modifier.isPublic(constructor.getModifiers());
+ Class resultClazz = null;
+ if (loader instanceof URLClassLoader && !ispub) {
+ try {
+ final URLClassLoader urlLoader = (URLClassLoader) loader;
+ final URL url = new URL("memclass", "localhost", -1, "/" + newDynName.replace('/', '.') + "/", new URLStreamHandler() {
+ @Override
+ protected URLConnection openConnection(URL u) throws IOException {
+ return new URLConnection(u) {
+ @Override
+ public void connect() throws IOException {
+ }
+
+ @Override
+ public InputStream getInputStream() throws IOException {
+ return new ByteArrayInputStream(bytes);
+ }
+ };
+ }
+ });
+ Method addURLMethod = URLClassLoader.class.getDeclaredMethod("addURL", URL.class);
+ addURLMethod.setAccessible(true);
+ addURLMethod.invoke(urlLoader, url);
+ resultClazz = urlLoader.loadClass(newDynName.replace('/', '.'));
+ } catch (Throwable t) { //异常无需理会， 使用下一种loader方式
+ t.printStackTrace();
+ }
+ }
+ if (!ispub && resultClazz == null) {
+ throw new RuntimeException("[" + clazz + "] have no public or ConstructorParameters-Annotation constructor.");
+ }
+ try {
+ if (resultClazz == null) {
+ resultClazz = new ClassLoader(loader) {
+ public final Class loadClass(String name, byte[] b) {
+ return defineClass(name, b, 0, b.length);
+ }
+ }.loadClass(newDynName.replace('/', '.'), bytes);
+ }
+ RedkaleClassLoader.putDynClass(newDynName.replace('/', '.'), bytes, resultClazz);
+ RedkaleClassLoader.putReflectionDeclaredConstructors(resultClazz, newDynName.replace('/', '.'));
+ return (Creator) resultClazz.getDeclaredConstructor().newInstance();
+ } catch (Exception ex) {
+ throw new RuntimeException(ex);
+ }
+ }
+
+ @SuppressWarnings("unchecked")
+ static class CreatorInner {
+
+ static final Logger logger = Logger.getLogger(Creator.class.getSimpleName());
+
+ static final Map creatorCacheMap = new HashMap<>();
+
+ static final Map arrayCacheMap = new ConcurrentHashMap<>();
+
+ static {
+ creatorCacheMap.put(Object.class, p -> new Object());
+ creatorCacheMap.put(ArrayList.class, p -> new ArrayList<>());
+ creatorCacheMap.put(HashMap.class, p -> new HashMap<>());
+ creatorCacheMap.put(HashSet.class, p -> new HashSet<>());
+ creatorCacheMap.put(Stream.class, p -> new ArrayList<>().stream());
+ creatorCacheMap.put(ConcurrentHashMap.class, p -> new ConcurrentHashMap<>());
+ creatorCacheMap.put(CompletableFuture.class, p -> new CompletableFuture<>());
+ creatorCacheMap.put(CompletionStage.class, p -> new CompletableFuture<>());
+ creatorCacheMap.put(Map.Entry.class, new Creator() {
+ @Override
+ @ConstructorParameters({"key", "value"})
+ public Map.Entry create(Object... params) {
+ return new AbstractMap.SimpleEntry(params[0], params[1]);
+ }
+
+ @Override
+ public Class[] paramTypes() {
+ return new Class[]{Object.class, Object.class};
+ }
+ });
+ creatorCacheMap.put(AbstractMap.SimpleEntry.class, new Creator() {
+ @Override
+ @ConstructorParameters({"key", "value"})
+ public AbstractMap.SimpleEntry create(Object... params) {
+ return new AbstractMap.SimpleEntry(params[0], params[1]);
+ }
+
+ @Override
+ public Class[] paramTypes() {
+ return new Class[]{Object.class, Object.class};
+ }
+ });
+ creatorCacheMap.put(AnyValue.DefaultAnyValue.class, p -> new AnyValue.DefaultAnyValue());
+ creatorCacheMap.put(AnyValue.class, p -> new AnyValue.DefaultAnyValue());
+
+ arrayCacheMap.put(int.class, t -> new int[t]);
+ arrayCacheMap.put(byte.class, t -> new byte[t]);
+ arrayCacheMap.put(long.class, t -> new long[t]);
+ arrayCacheMap.put(String.class, t -> new String[t]);
+ arrayCacheMap.put(Object.class, t -> new Object[t]);
+ arrayCacheMap.put(boolean.class, t -> new boolean[t]);
+ arrayCacheMap.put(short.class, t -> new short[t]);
+ arrayCacheMap.put(char.class, t -> new char[t]);
+ arrayCacheMap.put(float.class, t -> new float[t]);
+ arrayCacheMap.put(double.class, t -> new double[t]);
+ }
+
+ static class SimpleClassVisitor extends ClassVisitor {
+
+ private final String constructorDesc;
+
+ private final List fieldNames;
+
+ private boolean started;
+
+ public SimpleClassVisitor(int api, List fieldNames, String constructorDesc) {
+ super(api);
+ this.fieldNames = fieldNames;
+ this.constructorDesc = constructorDesc;
+ }
+
+ @Override
+ public MethodVisitor visitMethod(int access, String name, String desc, String signature, String[] exceptions) {
+ if (java.lang.reflect.Modifier.isStatic(access) || !"".equals(name)) {
+ return null;
+ }
+ if (constructorDesc != null && !constructorDesc.equals(desc)) {
+ return null;
+ }
+ if (this.started) {
+ return null;
+ }
+ this.started = true;
+ //返回的List中参数列表可能会比方法参数量多，因为方法内的临时变量也会存入list中， 所以需要list的元素集合比方法的参数多
+ return new MethodVisitor(Opcodes.ASM6) {
+ @Override
+ public void visitLocalVariable(String name, String description, String signature, Label start, Label end, int index) {
+ if (index < 1) {
+ return;
+ }
+ int size = fieldNames.size();
+ //index不会按顺序执行的
+ if (index > size) {
+ for (int i = size; i < index; i++) {
+ fieldNames.add(" ");
+ }
+ fieldNames.set(index - 1, name);
+ }
+ fieldNames.set(index - 1, name);
+ }
+ };
+ }
+ }
+
+ public static SimpleEntry[] getConstructorField(Class clazz, int paramCount, String constructorDesc) {
+ String n = clazz.getName();
+ InputStream in = clazz.getResourceAsStream(n.substring(n.lastIndexOf('.') + 1) + ".class");
+ if (in == null) {
+ return null;
+ }
+ ByteArrayOutputStream out = new ByteArrayOutputStream(1024);
+ byte[] bytes = new byte[1024];
+ int pos;
+ try {
+ while ((pos = in.read(bytes)) != -1) {
+ out.write(bytes, 0, pos);
+ }
+ in.close();
+ } catch (IOException io) {
+ return null;
+ }
+ final List fieldNames = new ArrayList<>();
+ new ClassReader(out.toByteArray()).accept(new SimpleClassVisitor(Opcodes.ASM6, fieldNames, constructorDesc), 0);
+ while (fieldNames.remove(" ")); //删掉空元素
+ if (fieldNames.isEmpty()) {
+ return null;
+ }
+ if (paramCount == fieldNames.size()) {
+ return getConstructorField(clazz, paramCount, fieldNames.toArray(new String[fieldNames.size()]));
+ } else {
+ String[] fs = new String[paramCount];
+ for (int i = 0; i < fs.length; i++) {
+ fs[i] = fieldNames.get(i);
+ }
+ return getConstructorField(clazz, paramCount, fs);
+ }
+ }
+
+ public static SimpleEntry[] getConstructorField(Class clazz, int paramCount, String[] names) {
+ SimpleEntry[] se = new SimpleEntry[names.length];
+ for (int i = 0; i < names.length; i++) { //查询参数名对应的Field
+ try {
+ Field field = clazz.getDeclaredField(names[i]);
+ se[i] = new SimpleEntry<>(field.getName(), field.getType());
+ } catch (NoSuchFieldException fe) {
+ Class cz = clazz;
+ Field field = null;
+ while ((cz = cz.getSuperclass()) != Object.class) {
+ try {
+ field = cz.getDeclaredField(names[i]);
+ break;
+ } catch (NoSuchFieldException nsfe) {
+ }
+ }
+ if (field == null) {
+ return null;
+ }
+ se[i] = new SimpleEntry<>(field.getName(), field.getType());
+ } catch (Exception e) {
+ if (logger.isLoggable(Level.FINE)) {
+ logger.log(Level.FINE, clazz + " getConstructorField error", e);
+ }
+ return null;
+ }
+ }
+ return se;
+ }
+
+ public static SimpleEntry[] getConstructorField(Class clazz, int paramCount, Parameter[] params) {
+ SimpleEntry[] se = new SimpleEntry[params.length];
+ for (int i = 0; i < params.length; i++) { //查询参数名对应的Field
+ try {
+ Field field = clazz.getDeclaredField(params[i].getName());
+ se[i] = new SimpleEntry<>(field.getName(), field.getType());
+ } catch (Exception e) {
+ return null;
+ }
+ }
+ return se;
+ }
+
+ public static IntFunction createArrayFunction(final Class clazz) {
+ final String interName = clazz.getName().replace('.', '/');
+ final String interDesc = Type.getDescriptor(clazz);
+ final ClassLoader loader = clazz.getClassLoader();
+ final String newDynName = "org/redkaledyn/creator/_DynArrayFunction__" + clazz.getName().replace('.', '_').replace('$', '_');
+ try {
+ Class clz = RedkaleClassLoader.findDynClass(newDynName.replace('/', '.'));
+ return (IntFunction) (clz == null ? loader.loadClass(newDynName.replace('/', '.')) : clz).getDeclaredConstructor().newInstance();
+ } catch (Throwable ex) {
+ }
+
+ //-------------------------------------------------------------
+ ClassWriter cw = new ClassWriter(ClassWriter.COMPUTE_FRAMES);
+ MethodVisitor mv;
+ cw.visit(V11, ACC_PUBLIC + ACC_FINAL + ACC_SUPER, newDynName, "Ljava/lang/Object;Ljava/util/function/IntFunction<[" + interDesc + ">;", "java/lang/Object", new String[]{"java/util/function/IntFunction"});
+
+ {//IntFunction自身的构造方法
+ mv = cw.visitMethod(ACC_PUBLIC, "", "()V", null, null);
+ mv.visitVarInsn(ALOAD, 0);
+ mv.visitMethodInsn(INVOKESPECIAL, "java/lang/Object", "", "()V", false);
+ mv.visitInsn(RETURN);
+ mv.visitMaxs(1, 1);
+ mv.visitEnd();
+ }
+ {//apply 方法
+ mv = cw.visitMethod(ACC_PUBLIC, "apply", "(I)[" + interDesc, null, null);
+ mv.visitVarInsn(ILOAD, 1);
+ mv.visitTypeInsn(ANEWARRAY, interName);
+ mv.visitInsn(ARETURN);
+ mv.visitMaxs(1, 2);
+ mv.visitEnd();
+ }
+ { //虚拟 apply 方法
+ mv = cw.visitMethod(ACC_PUBLIC + ACC_BRIDGE + ACC_SYNTHETIC, "apply", "(I)Ljava/lang/Object;", null, null);
+ mv.visitVarInsn(ALOAD, 0);
+ mv.visitVarInsn(ILOAD, 1);
+ mv.visitMethodInsn(INVOKEVIRTUAL, newDynName, "apply", "(I)[" + interDesc, false);
+ mv.visitInsn(ARETURN);
+ mv.visitMaxs(2, 2);
+ mv.visitEnd();
+ }
+ cw.visitEnd();
+ final byte[] bytes = cw.toByteArray();
+ try {
+ Class resultClazz = new ClassLoader(loader) {
+ public final Class loadClass(String name, byte[] b) {
+ return defineClass(name, b, 0, b.length);
+ }
+ }.loadClass(newDynName.replace('/', '.'), bytes);
+ RedkaleClassLoader.putDynClass(newDynName.replace('/', '.'), bytes, resultClazz);
+ RedkaleClassLoader.putReflectionDeclaredConstructors(resultClazz, newDynName.replace('/', '.'));
+ return (IntFunction) resultClazz.getDeclaredConstructor().newInstance();
+ } catch (Exception ex) {
+ //ex.printStackTrace(); //一般不会发生
+ //return t -> (T[]) Array.newInstance(clazz, t);
+ throw new RuntimeException(ex);
+ }
+ }
+ }
+
+}