bug

Author: harry.ding

androidipc/src/main/java/cn/ding/hu/androidipc/AndroidRpc.java

@@ -54,61 +54,74 @@ public static void register(Class serviceInterface, Class serviceInterfaceImpl)
     public static Class getService(String serviceName) {
         return rpcMap.get(serviceName);
     }
-
-    public static class AndroidRpcInvocationHandler implements InvocationHandler {
-        private AndroidRpcActivty androidRpcActivty;
-        private Class<?> cls;
-
-        public AndroidRpcInvocationHandler(Class<?> cls, AndroidRpcActivty androidRpcActivty) {
-            this.androidRpcActivty = androidRpcActivty;
-            this.cls = cls;
-        }
-
-        @Override
-        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
-            System.out.println("开始事务111");
-
-            Messenger messenger = androidRpcActivty.getmServerMessenger();
-            Message message = Message.obtain();
-            message.what = MSG_INVOKE_MSG;
-            message.replyTo = androidRpcActivty.getmClientMessenger();
-            Bundle bundle = new Bundle();
-            bundle.putString("serviceName", cls.getName());
-            bundle.putString("methodName", method.getName());
-            bundle.putSerializable("parameterTypes", method.getParameterTypes());
-            bundle.putSerializable("arguments", args);
-            message.setData(bundle);
-            messenger.send(message);
-            //阻塞线程等待返回
-
-            //发送消息
-            System.out.println("提交事务111");
-            return null;
-        }
-    }
-
-
-    public static <T> void invoke(final AndroidRpcActivty activity,Object rpcService, String method, IRpcInvokeListener<T> invokeListener, Object... args) {
+//
+//    public static class AndroidRpcInvocationHandler implements InvocationHandler {
+//        private AndroidRpcActivty androidRpcActivty;
+//        private Class<?> cls;
+//
+//        public AndroidRpcInvocationHandler(Class<?> cls, AndroidRpcActivty androidRpcActivty) {
+//            this.androidRpcActivty = androidRpcActivty;
+//            this.cls = cls;
+//        }
+//
+//        @Override
+//        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
+//            System.out.println("开始事务111");
+//
+//            Messenger messenger = androidRpcActivty.getmServerMessenger();
+//            Message message = Message.obtain();
+//            message.what = MSG_INVOKE_MSG;
+//            message.replyTo = androidRpcActivty.getmClientMessenger();
+//            Bundle bundle = new Bundle();
+//            bundle.putString("serviceName", cls.getName());
+//            bundle.putString("methodName", method.getName());
+//            bundle.putSerializable("parameterTypes", method.getParameterTypes());
+//            bundle.putSerializable("arguments", args);
+//            message.setData(bundle);
+//            messenger.send(message);
+//            //阻塞线程等待返回
+//
+//            //发送消息
+//            System.out.println("提交事务111");
+//            return null;
+//        }
+//    }
+
+
+    public static <T> void invoke(final AndroidRpcActivty activity,Object rpcService, String methodName, IRpcInvokeListener<T> invokeListener, Object... args) {
 
         try {
             Method[] methods = rpcService.getClass().getMethods();
             for (int i = 0; i < methods.length; i++) {
-                if (methods[i].getName().equals(method)) {
-                    activity.addRpcInvokeListener(methods[i].getName(),invokeListener);
-                    methods[i].invoke(rpcService, args);
+                if (methods[i].getName().equals(methodName)) {
+                    Method method = methods[i];
+                    activity.addRpcInvokeListener(method.getName(),invokeListener);
+//                    methods[i].invoke(rpcService, args);
+
+                    Messenger messenger = activity.getmServerMessenger();
+                    Message message = Message.obtain();
+                    message.what = MSG_INVOKE_MSG;
+                    message.replyTo = activity.getmClientMessenger();
+                    Bundle bundle = new Bundle();
+                    bundle.putString("serviceName", rpcService.getClass().getName());
+                    bundle.putString("methodName", method.getName());
+                    bundle.putSerializable("parameterTypes", method.getParameterTypes());
+                    bundle.putSerializable("arguments", args);
+                    message.setData(bundle);
+                    messenger.send(message);
                 }
             }
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
 
-    public static Object getRpcService(final Class<?> cls, final AndroidRpcActivty activity) {
-        return Proxy.newProxyInstance(
-                cls.getClassLoader(),
-                new Class[]{cls},
-                new AndroidRpcInvocationHandler(cls, activity)
-        );
-    }
+//    public static Object getRpcService(final Class<?> cls, final AndroidRpcActivty activity) {
+//        return Proxy.newProxyInstance(
+//                cls.getClassLoader(),
+//                new Class[]{cls},
+//                new AndroidRpcInvocationHandler(cls, activity)
+//        );
+//    }
 }
 

androidipc/src/main/java/cn/ding/hu/androidipc/AndroidRpcActivty.java

@@ -48,7 +48,6 @@ public Messenger getmClientMessenger() {
     protected Object result;
 
     private IRpcListener iRpcListener;
-    private AndroidRpc.AndroidRpcInvocationHandler androidRpcInvocationHandler;
 
     private HashMap<String, IRpcInvokeListener> rpcInvokeListenerHashMap = new HashMap<>();
 

app/src/main/java/cn/ding/hu/androidipclib/IRpcServiceImpl.java

@@ -10,6 +10,6 @@ public class IRpcServiceImpl implements IRpcService {
     @Override
     public String getName() {
         Log.i("rpc","rpc call getName");
-        return "dinghu-rpc";
+        return "dinghu-rpc-lixi";
     }
 }