zoukankan      html  css  js  c++  java
  • 好用的工具类



    ***********************************************************************************************************************************

    反射相关的可以参考--【spring-core】中的ReflectionUtils.java

    ***********************************************************************************************************************************
    final ScheduledExecutorService executor;
    final ScheduledExecutorService executorService;
    public ClientWorker(final HttpAgent agent, final ConfigFilterChainManager configFilterChainManager, final Properties properties) {
    this.agent = agent;
    this.configFilterChainManager = configFilterChainManager;

    // Initialize the timeout parameter

    init(properties);

    executor = Executors.newScheduledThreadPool(1, new ThreadFactory() {
    @Override
    public Thread newThread(Runnable r) {
    Thread t = new Thread(r);
    t.setName("com.alibaba.nacos.client.Worker." + agent.getName());
    t.setDaemon(true);
    return t;
    }
    });

    executorService = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors(), new ThreadFactory() {
    @Override
    public Thread newThread(Runnable r) {
    Thread t = new Thread(r);
    t.setName("com.alibaba.nacos.client.Worker.longPolling." + agent.getName());
    t.setDaemon(true);
    return t;
    }
    });

    executor.scheduleWithFixedDelay(new Runnable() {
    @Override
    public void run() {
    try {
    checkConfigInfo();
    } catch (Throwable e) {
    LOGGER.error("[" + agent.getName() + "] [sub-check] rotate check error", e);
    }
    }
    }, 1L, 10L, TimeUnit.MILLISECONDS);
    }
    *************************************************************************************************************************************************

    //
    // Source code recreated from a .class file by IntelliJ IDEA
    // (powered by Fernflower decompiler)
    //

    package org.springframework.util;

    import java.lang.reflect.Constructor;
    import java.lang.reflect.Field;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.lang.reflect.Modifier;
    import java.lang.reflect.UndeclaredThrowableException;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.Arrays;
    import java.util.Iterator;
    import java.util.List;
    import java.util.Map;
    import java.util.regex.Pattern;

    public abstract class ReflectionUtils {
    private static final String CGLIB_RENAMED_METHOD_PREFIX = "CGLIB$";
    private static final Pattern CGLIB_RENAMED_METHOD_PATTERN = Pattern.compile("(.+)\$\d+");
    private static final Map<Class<?>, Method[]> declaredMethodsCache = new ConcurrentReferenceHashMap(256);
    public static ReflectionUtils.FieldFilter COPYABLE_FIELDS = new ReflectionUtils.FieldFilter() {
    public boolean matches(Field field) {
    return !Modifier.isStatic(field.getModifiers()) && !Modifier.isFinal(field.getModifiers());
    }
    };
    public static ReflectionUtils.MethodFilter NON_BRIDGED_METHODS = new ReflectionUtils.MethodFilter() {
    public boolean matches(Method method) {
    return !method.isBridge();
    }
    };
    public static ReflectionUtils.MethodFilter USER_DECLARED_METHODS = new ReflectionUtils.MethodFilter() {
    public boolean matches(Method method) {
    return !method.isBridge() && method.getDeclaringClass() != Object.class;
    }
    };

    public ReflectionUtils() {
    }

    public static Field findField(Class<?> clazz, String name) {
    return findField(clazz, name, (Class)null);
    }

    public static Field findField(Class<?> clazz, String name, Class<?> type) {
    Assert.notNull(clazz, "Class must not be null");
    Assert.isTrue(name != null || type != null, "Either name or type of the field must be specified");

    for(Class searchType = clazz; !Object.class.equals(searchType) && searchType != null; searchType = searchType.getSuperclass()) {
    Field[] fields = searchType.getDeclaredFields();
    Field[] arr$ = fields;
    int len$ = fields.length;

    for(int i$ = 0; i$ < len$; ++i$) {
    Field field = arr$[i$];
    if ((name == null || name.equals(field.getName())) && (type == null || type.equals(field.getType()))) {
    return field;
    }
    }
    }

    return null;
    }

    public static void setField(Field field, Object target, Object value) {
    try {
    field.set(target, value);
    } catch (IllegalAccessException var4) {
    handleReflectionException(var4);
    throw new IllegalStateException("Unexpected reflection exception - " + var4.getClass().getName() + ": " + var4.getMessage());
    }
    }

    public static Object getField(Field field, Object target) {
    try {
    return field.get(target);
    } catch (IllegalAccessException var3) {
    handleReflectionException(var3);
    throw new IllegalStateException("Unexpected reflection exception - " + var3.getClass().getName() + ": " + var3.getMessage());
    }
    }

    public static Method findMethod(Class<?> clazz, String name) {
    return findMethod(clazz, name);
    }

    public static Method findMethod(Class<?> clazz, String name, Class... paramTypes) {
    Assert.notNull(clazz, "Class must not be null");
    Assert.notNull(name, "Method name must not be null");

    for(Class searchType = clazz; searchType != null; searchType = searchType.getSuperclass()) {
    Method[] methods = searchType.isInterface() ? searchType.getMethods() : getDeclaredMethods(searchType);
    Method[] arr$ = methods;
    int len$ = methods.length;

    for(int i$ = 0; i$ < len$; ++i$) {
    Method method = arr$[i$];
    if (name.equals(method.getName()) && (paramTypes == null || Arrays.equals(paramTypes, method.getParameterTypes()))) {
    return method;
    }
    }
    }

    return null;
    }

    public static Object invokeMethod(Method method, Object target) {
    return invokeMethod(method, target);
    }

    public static Object invokeMethod(Method method, Object target, Object... args) {
    try {
    return method.invoke(target, args);
    } catch (Exception var4) {
    handleReflectionException(var4);
    throw new IllegalStateException("Should never get here");
    }
    }

    public static Object invokeJdbcMethod(Method method, Object target) throws SQLException {
    return invokeJdbcMethod(method, target);
    }

    public static Object invokeJdbcMethod(Method method, Object target, Object... args) throws SQLException {
    try {
    return method.invoke(target, args);
    } catch (IllegalAccessException var4) {
    handleReflectionException(var4);
    } catch (InvocationTargetException var5) {
    if (var5.getTargetException() instanceof SQLException) {
    throw (SQLException)var5.getTargetException();
    }

    handleInvocationTargetException(var5);
    }

    throw new IllegalStateException("Should never get here");
    }

    public static void handleReflectionException(Exception ex) {
    if (ex instanceof NoSuchMethodException) {
    throw new IllegalStateException("Method not found: " + ex.getMessage());
    } else if (ex instanceof IllegalAccessException) {
    throw new IllegalStateException("Could not access method: " + ex.getMessage());
    } else {
    if (ex instanceof InvocationTargetException) {
    handleInvocationTargetException((InvocationTargetException)ex);
    }

    if (ex instanceof RuntimeException) {
    throw (RuntimeException)ex;
    } else {
    throw new UndeclaredThrowableException(ex);
    }
    }
    }

    public static void handleInvocationTargetException(InvocationTargetException ex) {
    rethrowRuntimeException(ex.getTargetException());
    }

    public static void rethrowRuntimeException(Throwable ex) {
    if (ex instanceof RuntimeException) {
    throw (RuntimeException)ex;
    } else if (ex instanceof Error) {
    throw (Error)ex;
    } else {
    throw new UndeclaredThrowableException(ex);
    }
    }

    public static void rethrowException(Throwable ex) throws Exception {
    if (ex instanceof Exception) {
    throw (Exception)ex;
    } else if (ex instanceof Error) {
    throw (Error)ex;
    } else {
    throw new UndeclaredThrowableException(ex);
    }
    }

    public static boolean declaresException(Method method, Class<?> exceptionType) {
    Assert.notNull(method, "Method must not be null");
    Class<?>[] declaredExceptions = method.getExceptionTypes();
    Class[] arr$ = declaredExceptions;
    int len$ = declaredExceptions.length;

    for(int i$ = 0; i$ < len$; ++i$) {
    Class<?> declaredException = arr$[i$];
    if (declaredException.isAssignableFrom(exceptionType)) {
    return true;
    }
    }

    return false;
    }

    public static boolean isPublicStaticFinal(Field field) {
    int modifiers = field.getModifiers();
    return Modifier.isPublic(modifiers) && Modifier.isStatic(modifiers) && Modifier.isFinal(modifiers);
    }

    public static boolean isEqualsMethod(Method method) {
    if (method != null && method.getName().equals("equals")) {
    Class<?>[] paramTypes = method.getParameterTypes();
    return paramTypes.length == 1 && paramTypes[0] == Object.class;
    } else {
    return false;
    }
    }

    public static boolean isHashCodeMethod(Method method) {
    return method != null && method.getName().equals("hashCode") && method.getParameterTypes().length == 0;
    }

    public static boolean isToStringMethod(Method method) {
    return method != null && method.getName().equals("toString") && method.getParameterTypes().length == 0;
    }

    public static boolean isObjectMethod(Method method) {
    if (method == null) {
    return false;
    } else {
    try {
    Object.class.getDeclaredMethod(method.getName(), method.getParameterTypes());
    return true;
    } catch (Exception var2) {
    return false;
    }
    }
    }

    public static boolean isCglibRenamedMethod(Method renamedMethod) {
    String name = renamedMethod.getName();
    return name.startsWith("CGLIB$") && CGLIB_RENAMED_METHOD_PATTERN.matcher(name.substring("CGLIB$".length())).matches();
    }

    public static void makeAccessible(Field field) {
    if ((!Modifier.isPublic(field.getModifiers()) || !Modifier.isPublic(field.getDeclaringClass().getModifiers()) || Modifier.isFinal(field.getModifiers())) && !field.isAccessible()) {
    field.setAccessible(true);
    }

    }

    public static void makeAccessible(Method method) {
    if ((!Modifier.isPublic(method.getModifiers()) || !Modifier.isPublic(method.getDeclaringClass().getModifiers())) && !method.isAccessible()) {
    method.setAccessible(true);
    }

    }

    public static void makeAccessible(Constructor<?> ctor) {
    if ((!Modifier.isPublic(ctor.getModifiers()) || !Modifier.isPublic(ctor.getDeclaringClass().getModifiers())) && !ctor.isAccessible()) {
    ctor.setAccessible(true);
    }

    }

    public static void doWithMethods(Class<?> clazz, ReflectionUtils.MethodCallback mc) {
    doWithMethods(clazz, mc, (ReflectionUtils.MethodFilter)null);
    }

    public static void doWithMethods(Class<?> clazz, ReflectionUtils.MethodCallback mc, ReflectionUtils.MethodFilter mf) {
    Method[] methods = getDeclaredMethods(clazz);
    Method[] arr$ = methods;
    int len$ = methods.length;

    int i$;
    for(i$ = 0; i$ < len$; ++i$) {
    Method method = arr$[i$];
    if (mf == null || mf.matches(method)) {
    try {
    mc.doWith(method);
    } catch (IllegalAccessException var9) {
    throw new IllegalStateException("Not allowed to access method '" + method.getName() + "': " + var9);
    }
    }
    }

    if (clazz.getSuperclass() != null) {
    doWithMethods(clazz.getSuperclass(), mc, mf);
    } else if (clazz.isInterface()) {
    Class[] arr$ = clazz.getInterfaces();
    len$ = arr$.length;

    for(i$ = 0; i$ < len$; ++i$) {
    Class<?> superIfc = arr$[i$];
    doWithMethods(superIfc, mc, mf);
    }
    }

    }

    public static Method[] getAllDeclaredMethods(Class<?> leafClass) {
    final List<Method> methods = new ArrayList(32);
    doWithMethods(leafClass, new ReflectionUtils.MethodCallback() {
    public void doWith(Method method) {
    methods.add(method);
    }
    });
    return (Method[])methods.toArray(new Method[methods.size()]);
    }

    public static Method[] getUniqueDeclaredMethods(Class<?> leafClass) {
    final List<Method> methods = new ArrayList(32);
    doWithMethods(leafClass, new ReflectionUtils.MethodCallback() {
    public void doWith(Method method) {
    boolean knownSignature = false;
    Method methodBeingOverriddenWithCovariantReturnType = null;
    Iterator i$ = methods.iterator();

    while(i$.hasNext()) {
    Method existingMethod = (Method)i$.next();
    if (method.getName().equals(existingMethod.getName()) && Arrays.equals(method.getParameterTypes(), existingMethod.getParameterTypes())) {
    if (existingMethod.getReturnType() != method.getReturnType() && existingMethod.getReturnType().isAssignableFrom(method.getReturnType())) {
    methodBeingOverriddenWithCovariantReturnType = existingMethod;
    break;
    }

    knownSignature = true;
    break;
    }
    }

    if (methodBeingOverriddenWithCovariantReturnType != null) {
    methods.remove(methodBeingOverriddenWithCovariantReturnType);
    }

    if (!knownSignature && !ReflectionUtils.isCglibRenamedMethod(method)) {
    methods.add(method);
    }

    }
    });
    return (Method[])methods.toArray(new Method[methods.size()]);
    }

    private static Method[] getDeclaredMethods(Class<?> clazz) {
    Method[] result = (Method[])declaredMethodsCache.get(clazz);
    if (result == null) {
    result = clazz.getDeclaredMethods();
    declaredMethodsCache.put(clazz, result);
    }

    return result;
    }

    public static void doWithFields(Class<?> clazz, ReflectionUtils.FieldCallback fc) {
    doWithFields(clazz, fc, (ReflectionUtils.FieldFilter)null);
    }

    public static void doWithFields(Class<?> clazz, ReflectionUtils.FieldCallback fc, ReflectionUtils.FieldFilter ff) {
    Class targetClass = clazz;

    do {
    Field[] fields = targetClass.getDeclaredFields();
    Field[] arr$ = fields;
    int len$ = fields.length;

    for(int i$ = 0; i$ < len$; ++i$) {
    Field field = arr$[i$];
    if (ff == null || ff.matches(field)) {
    try {
    fc.doWith(field);
    } catch (IllegalAccessException var10) {
    throw new IllegalStateException("Not allowed to access field '" + field.getName() + "': " + var10);
    }
    }
    }

    targetClass = targetClass.getSuperclass();
    } while(targetClass != null && targetClass != Object.class);

    }

    public static void shallowCopyFieldState(final Object src, final Object dest) {
    if (src == null) {
    throw new IllegalArgumentException("Source for field copy cannot be null");
    } else if (dest == null) {
    throw new IllegalArgumentException("Destination for field copy cannot be null");
    } else if (!src.getClass().isAssignableFrom(dest.getClass())) {
    throw new IllegalArgumentException("Destination class [" + dest.getClass().getName() + "] must be same or subclass as source class [" + src.getClass().getName() + "]");
    } else {
    doWithFields(src.getClass(), new ReflectionUtils.FieldCallback() {
    public void doWith(Field field) throws IllegalArgumentException, IllegalAccessException {
    ReflectionUtils.makeAccessible(field);
    Object srcValue = field.get(src);
    field.set(dest, srcValue);
    }
    }, COPYABLE_FIELDS);
    }
    }

    public interface FieldFilter {
    boolean matches(Field var1);
    }

    public interface FieldCallback {
    void doWith(Field var1) throws IllegalArgumentException, IllegalAccessException;
    }

    public interface MethodFilter {
    boolean matches(Method var1);
    }

    public interface MethodCallback {
    void doWith(Method var1) throws IllegalArgumentException, IllegalAccessException;
    }
    }
  • 相关阅读:
    Node Sass version 5.0.0 is incompatible with^4.0.0
    解决vue-cli引入sass,报错:this.getResolve is not a function问题
    解决nuxt官方脚手架的一些坑:1、支持es6+语法 2、样式支持sass
    针对【create-nuxt-app新版本v3.2.0】构建项目时没有server配置以及运行后弹出收集匿名数据选项等问题的解决方法
    create-nuxt-app创建出来的目录没有server文件夹
    Redis安装(Windows环境下Redis安装)
    koa2中间件,路由,cookies
    用同步的写法来执行异步操作, async, awiat
    koa2 安装与启动
    练习:自己写一个容器ArrayList集合 一一数组综合练习
  • 原文地址:https://www.cnblogs.com/longxok/p/11138058.html
Copyright © 2011-2022 走看看