Android Agent 开发入门指南：从零构建高效代理服务

1次阅读

没有评论

共计 3637 个字符，预计需要花费 10 分钟才能阅读完成。

在 Android 开发中，我们经常需要处理网络请求代理的需求。比如在爬虫应用中转发请求、在企业级应用中实现统一鉴权、或者在测试环境中模拟网络延迟。直接使用系统提供的网络 API 往往存在以下局限性：

无法灵活修改请求头和响应体
难以实现请求的集中管理和监控
缺乏跨应用的统一代理方案
性能优化空间有限

在 Android 平台上，常见的进程间通信方式有以下几种：

Socket：
优点：跨平台、灵活、性能好
缺点：需要自己处理连接管理和协议设计
Binder：
优点：Android 原生支持、安全性好
缺点：仅限 Android 平台、使用复杂
HTTP：
优点：简单易用、标准化
缺点：性能开销大、不适合高频通信

对于 Agent 服务，我们推荐使用 Socket 方案，因为它在性能和灵活性之间取得了良好的平衡。

首先创建一个基本的 Socket 服务器：

public class AgentServer {
    private static final int PORT = 8888;
    private ServerSocket serverSocket;

    public void start() {
        try {serverSocket = new ServerSocket(PORT);
            while (true) {Socket clientSocket = serverSocket.accept();
                // 处理客户端连接
                new ClientHandler(clientSocket).start();}
        } catch (IOException e) {e.printStackTrace();
        }
    }
}

为了处理多个并发连接，我们使用线程池：

private ExecutorService threadPool = Executors.newFixedThreadPool(10);

// 在 accept 后
threadPool.execute(new ClientHandler(clientSocket));

推荐使用 Protocol Buffers 或简单的 JSON 格式：

// 使用 JSON 的示例
String requestJson = "{\"url\":\"https://example.com\",\"method\":\"GET\"}";
OutputStream output = socket.getOutputStream();
output.write(requestJson.getBytes(StandardCharsets.UTF_8));

public class AgentServer {
    private static final int PORT = 8888;
    private ServerSocket serverSocket;
    private ExecutorService threadPool = Executors.newFixedThreadPool(10);

    public void start() {
        try {serverSocket = new ServerSocket(PORT);
            System.out.println("Server started on port" + PORT);

            while (true) {Socket clientSocket = serverSocket.accept();
                threadPool.execute(new ClientHandler(clientSocket));
            }
        } catch (IOException e) {e.printStackTrace();
        } finally {stop();
        }
    }

    private static class ClientHandler implements Runnable {
        private final Socket clientSocket;

        ClientHandler(Socket socket) {this.clientSocket = socket;}

        @Override
        public void run() {
            try {InputStream input = clientSocket.getInputStream();
                BufferedReader reader = new BufferedReader(new InputStreamReader(input, StandardCharsets.UTF_8));

                String line;
                while ((line = reader.readLine()) != null) {
                    // 处理请求
                    System.out.println("Received:" + line);

                    // 模拟处理并返回响应
                    String response = "Processed:" + line;
                    OutputStream output = clientSocket.getOutputStream();
                    output.write((response + "\n").getBytes(StandardCharsets.UTF_8));
                    output.flush();}
            } catch (IOException e) {e.printStackTrace();
            } finally {
                try {clientSocket.close();
                } catch (IOException e) {e.printStackTrace();
                }
            }
        }
    }

    public void stop() {
        try {if (serverSocket != null) {serverSocket.close();
            }
            threadPool.shutdown();} catch (IOException e) {e.printStackTrace();
        }
    }
}

使用连接池复用 Socket 连接，减少创建和销毁的开销：

private static final int MAX_POOL_SIZE = 20;
private static final BlockingQueue<Socket> connectionPool = 
    new LinkedBlockingQueue<>(MAX_POOL_SIZE);

// 获取连接
Socket socket = connectionPool.poll(100, TimeUnit.MILLISECONDS);
if (socket == null || !socket.isConnected()) {socket = new Socket(host, port);
}

// 归还连接
if (socket.isConnected()) {connectionPool.offer(socket);
}

保持长连接活跃：

// 客户端定期发送心跳
new Timer().scheduleAtFixedRate(new TimerTask() {
    @Override
    public void run() {
        try {output.write("HEARTBEAT\n".getBytes());
            output.flush();} catch (IOException e) {e.printStackTrace();
        }
    }
}, 0, 30000); // 每 30 秒

对大流量数据进行压缩：

// 发送压缩数据
GZIPOutputStream gzipOS = new GZIPOutputStream(socket.getOutputStream());
gzipOS.write(data);
gzipOS.finish();

线程安全问题 ：
避免在多个线程中共享 Socket 实例
使用线程安全的集合类管理连接
内存泄漏 ：
确保及时关闭不用的 Socket 和流
使用 try-with-resources 语句
连接超时 ：
设置合理的连接超时时间
实现重试机制

身份验证 ：

// 简单的 token 验证
String token = "SECRET_TOKEN";
output.write((token + "\n").getBytes());

// 服务端验证
String clientToken = reader.readLine();
if (!token.equals(clientToken)) {socket.close();
    return;
}

数据加密 ：

使用 SSL/TLS 加密通信：

SSLServerSocketFactory sslServerSocketFactory = 
    (SSLServerSocketFactory) SSLServerSocketFactory.getDefault();
ServerSocket serverSocket = sslServerSocketFactory.createServerSocket(PORT);