在日常的第三方应用开发过程中，经常会遇到某个类的某个成员变量、方法或是属性是私有的或是只对系统应用开放，这时候就可以利用Java的反射机制通过反射来获取所需的私有成员或是方法。当然，也不是所有的都适合反射，之前就遇到一个案例，通过反射得到的结果与预期不符。阅读源码发现，经过层层调用后在最终返回结果的地方对应用的权限进行了校验，对于没有权限的应用返回值是没有意义的缺省值，否则返回实际值起到保护用户的隐私目的。

反射机制的相关类#

与Java反射相关的类如下：

类名	用途
Class类	代表类的实体，在运行的Java应用程序中表示类和接口
Field类	代表类的成员变量（成员变量也称为类的属性）
Method类	代表类的方法
Constructor类	代表类的构造方法

Class类#

Class代表类的实体，在运行的Java应用程序中表示类和接口。在这个类中提供了很多有用的方法，这里对他们简单的分类介绍。

获得类相关的方法

方法	用途
asSubclass(Class clazz)	把传递的类的对象转换成代表其子类的对象
Cast	把对象转换成代表类或是接口的对象
getClassLoader()	获得类的加载器
getClasses()	返回一个数组，数组中包含该类中所有公共类和接口类的对象
getDeclaredClasses()	返回一个数组，数组中包含该类中所有类和接口类的对象
forName(String className)	根据类名返回类的对象
getName()	获得类的完整路径名字
newInstance()	创建类的实例
getPackage()	获得类的包
getSimpleName()	获得类的名字
getSuperclass()	获得当前类继承的父类的名字
getInterfaces()	获得当前类实现的类或是接口

获得类中属性相关的方法

方法	用途
getField(String name)	获得某个公有的属性对象
getFields()	获得所有公有的属性对象
getDeclaredField(String name)	获得某个属性对象
getDeclaredFields()	获得所有属性对象

获得类中注解相关的方法

方法	用途
getAnnotation(Class annotationClass)	返回该类中与参数类型匹配的公有注解对象
getAnnotations()	返回该类所有的公有注解对象
getDeclaredAnnotation(Class annotationClass)	返回该类中与参数类型匹配的所有注解对象
getDeclaredAnnotations()	返回该类所有的注解对象

获得类中构造器相关的方法

方法	用途
getConstructor(Class…<?> parameterTypes)	获得该类中与参数类型匹配的公有构造方法
getConstructors()	获得该类的所有公有构造方法
getDeclaredConstructor(Class…<?> parameterTypes)	获得该类中与参数类型匹配的构造方法
getDeclaredConstructors()	获得该类所有构造方法

获得类中方法相关的方法

方法	用途
getMethod(String name, Class…<?> parameterTypes)	获得该类某个公有的方法
getMethods()	获得该类所有公有的方法
getDeclaredMethod(String name, Class…<?> parameterTypes)	获得该类某个方法
getDeclaredMethods()	获得该类所有方法

类中其他重要的方法

方法	用途
isAnnotation()	如果是注解类型则返回true
isAnnotationPresent(Class<? extends Annotation> annotationClass)	如果是指定类型注解类型则返回true
isAnonymousClass()	如果是匿名类则返回true
isArray()	如果是一个数组类则返回true
isEnum()	如果是枚举类则返回true
isInstance(Object obj)	如果obj是该类的实例则返回true
isInterface()	如果是接口类则返回true
isLocalClass()	如果是局部类则返回true
isMemberClass()	如果是内部类则返回true

Field类#

Field代表类的成员变量（成员变量也称为类的属性）。

方法	用途
equals(Object obj)	属性与obj相等则返回true
get(Object obj)	获得obj中对应的属性值
set(Object obj, Object value)	设置obj中对应属性值

Method类#

Method代表类的方法。

方法	用途
invoke(Object obj, Object… args)	传递object对象及参数调用该对象对应的方法

Constructor类#

Constructor代表类的构造方法。

方法	用途
newInstance(Object… initargs)	根据传递的参数创建类的对象

示例#

为了演示反射的使用，首先构造一个与书籍相关的model——Book.java，然后通过反射方法示例创建对象、反射私有构造方法、反射私有属性、反射私有方法，最后给出两个比较复杂的反射示例——获得当前ZenMode和关机Shutdown。

被反射类Book.java

1
public class Book{
2
    private final static String TAG = "BookTag";
3

4
    private String name;
5
    private String author;
6

7
    @Override
8
    public String toString() {
9
        return "Book{" +
10
                "name='" + name + '\'' +
11
                ", author='" + author + '\'' +
12
                '}';
13
    }
14

15
    public Book() {
16
    }
17

18
    private Book(String name, String author) {
19
        this.name = name;
20
        this.author = author;
21
    }
22

23
    public String getName() {
24
        return name;
25
    }
26

27
    public void setName(String name) {
28
        this.name = name;
29
    }
30

31
    public String getAuthor() {
32
        return author;
33
    }
34

35
    public void setAuthor(String author) {
36
        this.author = author;
37
    }
38

39
    private String declaredMethod(int index) {
40
        String string = null;
41
        switch (index) {
42
            case 0:
43
                string = "I am declaredMethod 1 !";
44
                break;
45
            case 1:
46
                string = "I am declaredMethod 2 !";
47
                break;
48
            default:
49
                string = "I am declaredMethod 1 !";
50
        }
51

52
        return string;
53
    }
54
}

反射逻辑封装在ReflectClass.java

1
public class ReflectClass {
2
    private final static String TAG = "peter.log.ReflectClass";
3

4
    // 创建对象
5
    public static void reflectNewInstance() {
6
        try {
7
            Class<?> classBook = Class.forName("com.android.peter.reflectdemo.Book");
8
            Object objectBook = classBook.newInstance();
9
            Book book = (Book) objectBook;
10
            book.setName("Android进阶之光");
11
            book.setAuthor("刘望舒");
12
            Log.d(TAG,"reflectNewInstance book = " + book.toString());
13
        } catch (Exception ex) {
14
            ex.printStackTrace();
15
        }
16
    }
17

18
    // 反射私有的构造方法
19
    public static void reflectPrivateConstructor() {
20
        try {
21
            Class<?> classBook = Class.forName("com.android.peter.reflectdemo.Book");
22
            Constructor<?> declaredConstructorBook = classBook.getDeclaredConstructor(String.class,String.class);
23
            //将构造方法设置成可以访问的
24
            declaredConstructorBook.setAccessible(true);
25
            Object objectBook = declaredConstructorBook.newInstance("Android开发艺术探索","任玉刚");
26
            Book book = (Book) objectBook;
27
            Log.d(TAG,"reflectPrivateConstructor book = " + book.toString());
28
        } catch (Exception ex) {
29
            ex.printStackTrace();
30
        }
31
    }
32

33
    // 反射私有属性
34
    public static void reflectPrivateField() {
35
        try {
36
            Class<?> classBook = Class.forName("com.android.peter.reflectdemo.Book");
37
            Object objectBook = classBook.newInstance();
38
            Field fieldTag = classBook.getDeclaredField("TAG");
39
            //将私有属性设置成可以访问的
40
            fieldTag.setAccessible(true);
41
            String tag = (String) fieldTag.get(objectBook);
42
            Log.d(TAG,"reflectPrivateField tag = " + tag);
43
        } catch (Exception ex) {
44
            ex.printStackTrace();
45
        }
46
    }
47

48
    // 反射私有方法
49
    public static void reflectPrivateMethod() {
50
        try {
51
            Class<?> classBook = Class.forName("com.android.peter.reflectdemo.Book");
52
            Method methodBook = classBook.getDeclaredMethod("declaredMethod",int.class);
53
            //将私有方法设置成可以访问的
54
            methodBook.setAccessible(true);
55
            Object objectBook = classBook.newInstance();
56
            String string = (String) methodBook.invoke(objectBook,0);
57

58
            Log.d(TAG,"reflectPrivateMethod string = " + string);
59
        } catch (Exception ex) {
60
            ex.printStackTrace();
61
        }
62
    }
63

64
    // 获得系统Zenmode值
65
    public static int getZenMode() {
66
        int zenMode = -1;
67
        try {
68
            Class<?> cServiceManager = Class.forName("android.os.ServiceManager");
69
            Method mGetService = cServiceManager.getMethod("getService", String.class);
70
            Object oNotificationManagerService = mGetService.invoke(null, Context.NOTIFICATION_SERVICE);
71
            Class<?> cINotificationManagerStub = Class.forName("android.app.INotificationManager$Stub");
72
            Method mAsInterface = cINotificationManagerStub.getMethod("asInterface",IBinder.class);
73
            Object oINotificationManager = mAsInterface.invoke(null,oNotificationManagerService);
74
            Method mGetZenMode = cINotificationManagerStub.getMethod("getZenMode");
75
            zenMode = (int) mGetZenMode.invoke(oINotificationManager);
76
        } catch (Exception ex) {
77
            ex.printStackTrace();
78
        }
79

80
        return zenMode;
81
    }
82

83
    // 关闭手机
84
    public static void shutDown() {
85
        try {
86
            Class<?> cServiceManager = Class.forName("android.os.ServiceManager");
87
            Method mGetService = cServiceManager.getMethod("getService",String.class);
88
            Object oPowerManagerService = mGetService.invoke(null,Context.POWER_SERVICE);
89
            Class<?> cIPowerManagerStub = Class.forName("android.os.IPowerManager$Stub");
90
            Method mShutdown = cIPowerManagerStub.getMethod("shutdown",boolean.class,String.class,boolean.class);
91
            Method mAsInterface = cIPowerManagerStub.getMethod("asInterface",IBinder.class);
92
            Object oIPowerManager = mAsInterface.invoke(null,oPowerManagerService);
93
            mShutdown.invoke(oIPowerManager,true,null,true);
94

95
        } catch (Exception ex) {
96
            ex.printStackTrace();
97
        }
98
    }
99

100
    public static void shutdownOrReboot(final boolean shutdown, final boolean confirm) {
101
        try {
102
            Class<?> ServiceManager = Class.forName("android.os.ServiceManager");
103
            // 获得ServiceManager的getService方法
104
            Method getService = ServiceManager.getMethod("getService", java.lang.String.class);
105
            // 调用getService获取RemoteService
106
            Object oRemoteService = getService.invoke(null, Context.POWER_SERVICE);
107
            // 获得IPowerManager.Stub类
108
            Class<?> cStub = Class.forName("android.os.IPowerManager$Stub");
109
            // 获得asInterface方法
110
            Method asInterface = cStub.getMethod("asInterface", android.os.IBinder.class);
111
            // 调用asInterface方法获取IPowerManager对象
112
            Object oIPowerManager = asInterface.invoke(null, oRemoteService);
113
            if (shutdown) {
114
                // 获得shutdown()方法
115
                Method shutdownMethod = oIPowerManager.getClass().getMethod(
116
                        "shutdown", boolean.class, String.class, boolean.class);
117
                // 调用shutdown()方法
118
                shutdownMethod.invoke(oIPowerManager, confirm, null, false);
119
            } else {
120
                // 获得reboot()方法
121
                Method rebootMethod = oIPowerManager.getClass().getMethod("reboot",
122
                        boolean.class, String.class, boolean.class);
123
                // 调用reboot()方法
124
                rebootMethod.invoke(oIPowerManager, confirm, null, false);
125
            }
126
        } catch (Exception e) {
127
            e.printStackTrace();
128
        }
129
    }
130
}

调用相应反射逻辑方法

1
        try {
2
            // 创建对象
3
            ReflectClass.reflectNewInstance();
4

5
            // 反射私有的构造方法
6
            ReflectClass.reflectPrivateConstructor();
7

8
            // 反射私有属性
9
            ReflectClass.reflectPrivateField();
10

11
            // 反射私有方法
12
            ReflectClass.reflectPrivateMethod();
13
        } catch (Exception ex) {
14
            ex.printStackTrace();
15
        }
16

17
        Log.d(TAG," zenmode = " + ReflectClass.getZenMode());

Log输出结果如下：

1
08-27 15:11:37.999 11987-11987/com.android.peter.reflectdemo D/peter.log.ReflectClass: reflectNewInstance book = Book{name='Android进阶之光', author='刘望舒'}
2
08-27 15:11:38.000 11987-11987/com.android.peter.reflectdemo D/peter.log.ReflectClass: reflectPrivateConstructor book = Book{name='Android开发艺术探索', author='任玉刚'}
3
08-27 15:11:38.000 11987-11987/com.android.peter.reflectdemo D/peter.log.ReflectClass: reflectPrivateField tag = BookTag
4
08-27 15:11:38.000 11987-11987/com.android.peter.reflectdemo D/peter.log.ReflectClass: reflectPrivateMethod string = I am declaredMethod 1 !
5
08-27 15:11:38.004 11987-11987/com.android.peter.reflectdemo D/peter.log.ReflectDemo:  zenmode = 0

总结#

总结反射案例用到的方法：#

1.实例化Class类对象

1
 Class<?> classu = Class.forName("reflect.User");

2.获得某个类的全部属性

1
Field[] userFields = classu.getDeclaredFields();

3.取消权限的访问控制(可以通过获取私有的属性值)

1
userFields[i].setAccessible(true);

4.得到属性的字段名

1
userFields[i].getName()

5.将指定对象变量上(user) 此Field对象表示的字段设置为指定的新值。

1
userFields[i].set(user,map.get(s));

6.通过反射实例化类的对象

1
User user = (User) classu.newInstance();

7.通过反射机制调用某个类的方法

1
 Method method = classu.getMethod();//参数：方法名  若方法有参数，加上参数类型的class对象
2
 method.invoke();//参数：实例化出来的类对象，若方法有参数，加上值value

本文列举了反射机制使用过程中常用的、重要的一些类及其方法，更多信息和用法需要近一步的阅读Google提供的相关文档和示例。

在阅读Class类文档时发现一个特点，以通过反射获得Method对象为例，一般会提供四种方法，getMethod(parameterTypes)、getMethods()、getDeclaredMethod(parameterTypes)和getDeclaredMethods()。getMethod(parameterTypes)用来获取某个公有的方法的对象，getMethods()获得该类所有公有的方法，getDeclaredMethod(parameterTypes)获得该类某个方法，getDeclaredMethods()获得该类所有方法。**带有Declared修饰的方法可以反射到私有的方法，没有Declared修饰的只能用来反射公有的方法。**其他的Annotation、Field、Constructor也是如此。

在ReflectClass类中还提供了两种反射PowerManager.shutdown()的方法，在调用的时候会输出如下log，提示没有相关权限。之前在项目中尝试反射其他方法的时候还遇到过有权限和没权限返回的值不一样的情况。如果源码中明确进行了权限验证，而你的应用又无法获得这个权限的话，建议就不要浪费时间反射了。

1
 W/System.err: java.lang.reflect.InvocationTargetException
2
 W/System.err:     at java.lang.reflect.Method.invoke(Native Method)
3
 W/System.err:     at .ReflectClass.shutDown(ReflectClass.java:104)
4
 W/System.err:     at .MainActivity$1.onClick(MainActivity.java:25)
5
 W/System.err:     at android.view.View.performClick(View.java:6259)
6
 W/System.err:     at android.view.View$PerformClick.run(View.java:24732)
7
 W/System.err:     at android.os.Handler.handleCallback(Handler.java:789)
8
 W/System.err:     at android.os.Handler.dispatchMessage(Handler.java:98)
9
 W/System.err:     at android.os.Looper.loop(Looper.java:164)
10
 W/System.err:     at android.app.ActivityThread.main(ActivityThread.java:6592)
11
 W/System.err:     at java.lang.reflect.Method.invoke(Native Method)
12
 W/System.err:     at com.android.internal.os.Zygote$MethodAndArgsCaller.run(Zygote.java:240)
13
 W/System.err:     at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:769)
14
 W/System.err: Caused by: java.lang.SecurityException: Neither user 10224 nor current process has android.permission.REBOOT.
15
 W/System.err:     at android.os.Parcel.readException(Parcel.java:1942)
16
 W/System.err:     at android.os.Parcel.readException(Parcel.java:1888)
17
 W/System.err:     at android.os.IPowerManager$Stub$Proxy.shutdown(IPowerManager.java:787)
18
 W/System.err:  ... 12 more

项目中反射的使用案例1#

1、主要用到类介绍#

1.1、方法参数#

1
@Data
2
@Builder
3
public class Command {
4
    private String method;
5
    private JSONObject params;
6
}

1.2、方法集合接口#

1
@Validated
2
public interface Service {
3

4
    /**
5
     * 用户注册
6
     *
7
     * @param bizUserId 用户ID
8
     * @return 返回信息
9
     * @throws IOException 异常
10
     */
11
    String createMember(@NotNull String bizUserId) throws IOException;
12
}

1.3、方法接口实现类#

调用的发送请求的方法，RequestFactory去构建出一个统一参数对象RequestDTO

1
public class ServiceImpl implements Service {
2

3
    @Override
4
    public String createMember(String bizUserId) throws IOException {
5
        return new YunHttpClient().post(RequestFactory.registerMember(bizUserId, RegisterMemberRq.Source.Mobile));
6
    }
7
}

1.4、发送请求方法#

1
/**
2
 * YunHttpClient
3
 *
4
 * @author zhengyong
5
 * @date 2019/5/16
6
 */
7
@Slf4j
8
public class YunHttpClient extends BaseClient {
9

10
    /**
11
     * 封装的post请求方法
12
     * @param entity  请求体
13
     * @param <T>     请求参数
14
     * @return        返回信息
15
     * @throws IOException  io异常
16
     */
17
    public <T> String post(RequestDTO<T> entity) throws IOException {
18
        StringBuilder result = new StringBuilder();
19
        BufferedWriter writer = null;
20
        BufferedReader reader = null;
21
        log.info("发送通联请求参数，{}", JSON.toJSONString(entity));
22
        String data;
23
        try {
24
          //自定义编码签名
25
            data = urlEncode(entity);
26
        } catch (Exception e) {
27
            throw new IOException(e);
28
        }
29
        try {
30
            URL httpUrl = new URL(TonglianContext.getServerUrl());
31
            HttpURLConnection connection = (HttpURLConnection)httpUrl.openConnection();
32
            connection.setRequestProperty("Connection", "keep-alive");
33
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
34
            connection.setRequestMethod("POST");
35
            connection.setDoOutput(true);
36
            connection.setDoInput(true);
37
            writer = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream(), StandardCharsets.UTF_8));
38
            writer.write(data);
39
            writer.flush();
40
            reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8));
41
            String line;
42
            while ((line = reader.readLine()) != null) {
43
                result.append(line);
44
            }
45
        } finally {
46
            IOUtils.close(writer);
47
            IOUtils.close(reader);
48
        }
49
        log.info("【通联同步返回参数】：{}",result.toString());
50
        ResponseDTO resp = JSON.parseObject(result.toString(), ResponseDTO.class);
51
        resp.verify();
52
        if (resp.isSuccees()) {
53
            return resp.getSignedValue();
54
        } else {
55
            throw new ApiException(resp.getErrorCode(), resp.getMessage());
56
        }
57
    }
58

59
      /**
60
     * 封装的get请求方法
61
     * @param entity  请求体
62
     * @param <T>     请求参数
63
     * @return        返回信息
64
     * @throws IOException  io异常
65
     */
66
    public <T> String get(RequestDTO<T> entity) throws IOException {
67
        StringBuilder result = new StringBuilder();
68
        BufferedReader reader = null;
69
        String data;
70
        try {
71
            data = urlEncode(entity);
72
        } catch (Exception e) {
73
            throw new IOException(e);
74
        }
75
        try {
76
            URL httpUrl = new URL(TonglianContext.getServerUrl() + "?" + data);
77
            HttpURLConnection connection = (HttpURLConnection)httpUrl.openConnection();
78
            connection.setRequestProperty("Connection", "keep-alive");
79
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
80
            connection.setRequestMethod("GET");
81
            connection.setDoOutput(true);
82
            reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8));
83

84
            String line;
85
            while ((line = reader.readLine()) != null) {
86
                result.append(line);
87
            }
88
        } finally {
89
            IOUtils.close(reader);
90
        }
91
        ResponseDTO resp = JSON.parseObject(result.toString(), ResponseDTO.class).verify();
92
        if (resp.isSuccees()) {
93
            return resp.getSignedValue();
94
        } else {
95
            throw new ApiException(resp.getErrorCode(), resp.getMessage());
96
        }
97
    }
98
}

1.5、根据实际情况封装的请求对象#

1
/**
2
 * RequestDTO  请求DTO
3
 *
4
 * @author zhengyong
5
 * @date 2019/5/16
6
 */
7
@Data
8
@Builder
9
public class RequestDTO<T> {
10
    /**
11
     * 通联分配id
12
     */
13
    private String sysid;
14
    /**
15
     * 时间戳
16
     */
17
    private Date timestamp;
18
    /**
19
     * 版本号
20
     */
21
    private String v;
22
    /**
23
     * 请求参数
24
     */
25
    private RqWrapper<T> req;
26

27
}
28

29
/**
30
 * RqWrapper
31
 * 请求包装器
32
 * @author  zhengyong
33
 * @date 2019/5/20
34
 */
35
@Data
36
@Builder
37
public class RqWrapper<T> {
38
    /**
39
     * 服务对象
40
     */
41
    private String service;
42
    /**
43
     * 调用方法
44
     */
45
    private String method;
46
    /**
47
     * 参数
48
     */
49
    private T param;
50
}

1.6、RequestFactory

1
public class RequestFactory {
2

3
    private RequestFactory() {
4

5
    }
6

7
    /**
8
     * 用户注册
9
     *
10
     * @param bizUserId 业务系统用户ID
11
     * @param type    类型
12
     * @return        注册信息
13
     */
14
    public static RequestDTO<RegisterMemberRq> registerMember(String bizUserId, RegisterMemberRq.Source type) {
15
        //构建指定类型的请求参数
16
        RegisterMemberRq member = RegisterMemberRq.builder().bizUserId(bizUserId)
17
                .memberType(RegisterMemberRq.MenberType.Personal.getType()).source(type.getSource()).build();
18
        return build(member, "createMember", "MemberService");
19
    }
20

21
    private static <T> RequestDTO<T> build(T t, String method, String service) {
22
        //组装 RqWrapper，并设置到 RequestDTO中
23
        RqWrapper<T> re = RqWrapper.<T>builder().method(method).service(service).param(t).build();
24
        return RequestDTO.<T>builder().sysid(TonglianContext.getSysId()).timestamp(new Date()).v("2.0").req(re).build();
25
    }

1.7、TonglianAdapter 适配器#

1
@Validated
2
public interface TonglianAdapter {
3

4
    /**
5
     * 执行方法
6
     * @param cmd 命令
7
     * @return 结果
8
     */
9
    String excute(Command cmd);
10
}

1.8、TonglianAdapterImpl#

1、创建时，在构造器中注入了 service

2、使用反射，执行command参数中指定的方法

3、类型转换器中去取出不同类型的参数

jo.getJSONArray(name)

jo.getJSONObject(name)

jo.getString(name)

jo.getLong(name)

jo.get(name)

4、调用反射，执行，返回string

1
<R> R collect(Supplier<R> supplier,
2
                  BiConsumer<R, ? super T> accumulator,
3
                  BiConsumer<R, R> combiner);
4

5
来说，
6
参数supplier 是一个生成目标类型实例的方法，代表着目标容器是什么；
7

8
accumulator是将操作的目标数据填充到supplier 生成的目标类型实例中去的方法，代表着如何将元素添加到容器中；
9

10
而combiner是将多个supplier 生成的实例整合到一起的方法，代表着规约操作，将多个结果合并。

1
@Slf4j
2
public class TonglianAdapterImpl implements TonglianAdapter {
3

4
    private Service service;
5

6
    private OrderService orderService;
7

8
    public TonglianAdapterImpl(AdapterProperties adapterProperties) {
9
        TonglianContext.init(adapterProperties);
10
        service = new ServiceImpl();
11
        orderService = new OrderServiceImpl();
12
    }
13

14
    @Override
15
    public String excute(Command cmd) {
16
        //去取所有方法
17
        Method[] methods = Service.class.getDeclaredMethods();
18
        for (Method me : methods) {
19
            //匹配传进来的方法名字
20
            if (me.getName().equals(cmd.getMethod())) {
21
                //获取方法的所有参数
22
                Parameter[] params = me.getParameters();
23
                //来说，参数supplier 是一个生成目标类型实例的方法，代表着目标容器是什么；
24
                // accumulator是将操作的目标数据填充到supplier 生成的目标类型实例中去的方法，代表着如何将元素添加到容器中；
25
                // 而combiner是将多个supplier 生成的实例整合到一起的方法，代表着规约操作，将多个结果合并。
26
                //将参数转为数组，并获取参数类型，参数名字，typeTransformer去转换出统一的Object参数
27
                ArrayList<Object> objList = Arrays.stream(params).collect
28
                        //声明创建ArrayList
29
                        (ArrayList::new,
30
                        //BiConsumer 接口接收两个泛型参数 a:list,b:Parameter
31
                        (a, b) -> { a.add(typeTransformer(cmd.getParams(), b.getType(), b.getName())); },
32
                        //合并
33
                        (a, b) -> a.addAll(b));
34
                try {
35
                    //反射调用，service在类实例化的时候已经被传入进来
36
                    return (String) me.invoke(service, objList.toArray(new Object[objList.size()]));
37
                } catch (InvocationTargetException e1){
38
                    Throwable targetException = e1.getTargetException();
39
                    if(targetException instanceof ApiException) {
40
                        throw (ApiException) targetException;
41
                    }
42
                    throw new RuntimeException(e1);
43
                } catch(IllegalAccessException e) {
44
                    throw new RuntimeException(e);
45
                }
46
            }
47
        }
48
        throw new RuntimeException("excute:CMD Method Error。。。。");
49
    }
50

51

52
      /**
53
     * 类型转换器
54
     * @param jo  JSONObject
55
     * @param type  类型
56
     * @param name 名字
57
     * @param <T>  对应类型
58
     * @return     对应类型
59
     */
60
    private <T> Object typeTransformer(JSONObject jo, Class<T> type, String name) {
61
        if (type.equals(Long.class)) {
62
            return jo.getLong(name);
63
        } else if (type.equals(PayType.class)) {
64
            return PayType.valueOf(jo.getString(name));
65
        } else if (type.equals(ValidateType.class)) {
66
            return ValidateType.valueOf(jo.getString(name));
67
        } else if (type.equals(AuthType.class)) {
68
            return AuthType.valueOf(jo.getString(name));
69
        } else if (type.equals(WechatConfig.AppType.class)) {
70
            return WechatConfig.AppType.valueOf(jo.getString(name));
71
        } else if (type.equals(JSONObject.class)) {
72
            return jo.getJSONObject(name);
73
        } else if (type.equals(JSONArray.class)) {
74
            return jo.getJSONArray(name);
75
        } else {
76
            return jo.get(name);
77
        }
78
    }
79
}

2、整体架构图#

如果这篇文章对你有帮助，欢迎分享给更多人！

Java反射机制详解：Class、Field、Method与Constructor

https://onecodemaker.cn/posts/java核心-03-反射/

作者

糖糖IT

发布于

2026-01-12

许可协议

CC BY-NC-SA 4.0

部分信息可能已经过时

Java多线程与并发编程深度解析

Java集合核心问题：哈希冲突与并发修改异常