xposed结合socket服务端给个源码

Xposed结合Socket服务端的源码如下：

1. 在Xposed模块中创建一个Socket服务端

public class XposedModule implements IXposedHookLoadPackage {

    private SocketServerThread mSocketServerThread;

    @Override
    public void handleLoadPackage(final XC_LoadPackage.LoadPackageParam lpparam) throws Throwable {
        if (!lpparam.packageName.equals("com.example.app")) {
            return;
        }

        // 在主线程中创建Socket服务端
        mSocketServerThread = new SocketServerThread();
        mSocketServerThread.start();

        // Hook相关方法
        XposedHelpers.findAndHookMethod("com.example.app.MainActivity", lpparam.classLoader,
                "onCreate", Bundle.class, new XC_MethodHook() {
                    @Override
                    protected void afterHookedMethod(MethodHookParam param) throws Throwable {
                        // 在MainActivity中打印Socket服务端的IP和端口
                        String ip = Utils.getIPAddress(true);
                        int port = mSocketServerThread.getPort();
                        Log.d("XposedModule", "Socket server started at " + ip + ":" + port);
                    }
                });
    }

    // Socket服务端线程
    private static class SocketServerThread extends Thread {
        private ServerSocket mServerSocket;
        private int mPort;

        public int getPort() {
            return mPort;
        }

        @Override
        public void run() {
            try {
                // 创建ServerSocket
                mServerSocket = new ServerSocket(0);
                mPort = mServerSocket.getLocalPort();

                while (true) {
                    // 接受客户端连接
                    Socket socket = mServerSocket.accept();
                    // 处理客户端请求
                    handleClientRequest(socket);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        private void handleClientRequest(Socket socket) throws IOException {
            // 处理客户端请求
        }
    }
}

2. 在客户端中连接Socket服务端

public class MainActivity extends AppCompatActivity {

    private static final String SERVER_IP = "192.168.1.100";
    private static final int SERVER_PORT = 8080;

    private Socket mSocket;
    private PrintWriter mPrintWriter;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // 连接Socket服务端
        connectToServer();
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();

        // 关闭Socket连接
        closeConnection();
    }

    private void connectToServer() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    // 创建Socket连接
                    mSocket = new Socket(SERVER_IP, SERVER_PORT);
                    // 获取输出流
                    mPrintWriter = new PrintWriter(new OutputStreamWriter(mSocket.getOutputStream()), true);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }).start();
    }

    private void closeConnection() {
        try {
            // 关闭Socket连接
            mSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}