如何从移动设备发送网络流与数据包并通过Android Studio上传文件至服务器

要实现移动设备直接以流的形式上传数据到服务器、全程不在本地保存数据的需求，核心是直接从数据源获取输入流，通过网络请求将流实时发送到服务器，避免将数据写入本地文件或缓存。下面是具体的实现方案：

一、使用OkHttp实现（推荐，简洁高效） #

OkHttp原生支持流式RequestBody，无需预先将数据加载到内存或存储到本地。

1. 自定义流式RequestBody #

创建一个RequestBody，直接对接你的数据源输入流：

RequestBody requestBody = new RequestBody() {
    @Override
    public MediaType contentType() {
        // 根据实际文件类型设置，示例为JPEG图片，其他类型如application/octet-stream（通用文件）
        return MediaType.parse("image/jpeg");
    }

    @Override
    public void writeTo(BufferedSink sink) throws IOException {
        // 替换为你的实际数据源输入流，比如相机拍摄的流、内存数据生成的流
        InputStream dataStream = getDataSourceInputStream();
        try {
            byte[] buffer = new byte[4096]; // 固定大小缓冲区，避免内存溢出
            int readBytes;
            while ((readBytes = dataStream.read(buffer)) != -1) {
                sink.write(buffer, 0, readBytes);
            }
        } finally {
            dataStream.close(); // 确保流关闭
        }
    }
};

比如如果是相机拍摄的内容，你可以通过CameraX的ImageCapture获取Image对象，再转换为InputStream，完全跳过本地存储步骤。

2. 发起上传请求 #

OkHttpClient client = new OkHttpClient.Builder().build();
Request uploadRequest = new Request.Builder()
        .url("你的服务器上传接口地址")
        .post(requestBody)
        .build();

client.newCall(uploadRequest).enqueue(new Callback() {
    @Override
    public void onFailure(Call call, IOException e) {
        // 处理上传失败逻辑，比如提示用户
        e.printStackTrace();
    }

    @Override
    public void onResponse(Call call, Response response) throws IOException {
        if (response.isSuccessful()) {
            // 上传成功，解析服务器响应
            String result = response.body().string();
            // 后续逻辑，比如更新UI
        } else {
            // 服务器返回错误，处理对应逻辑
        }
    }
});

二、原生HttpURLConnection实现（无第三方依赖） #

如果不想引入OkHttp，也可以用Android原生的HttpURLConnection实现流式上传：

// 必须在子线程执行网络请求
new Thread(() -> {
    HttpURLConnection conn = null;
    InputStream dataStream = null;
    try {
        URL uploadUrl = new URL("你的服务器上传接口地址");
        conn = (HttpURLConnection) uploadUrl.openConnection();
        conn.setRequestMethod("POST");
        conn.setDoOutput(true);
        conn.setRequestProperty("Content-Type", "image/jpeg"); // 匹配文件类型

        dataStream = getDataSourceInputStream();
        OutputStream outputStream = conn.getOutputStream();
        byte[] buffer = new byte[4096];
        int readBytes;
        while ((readBytes = dataStream.read(buffer)) != -1) {
            outputStream.write(buffer, 0, readBytes);
        }
        outputStream.flush();

        // 处理服务器响应
        if (conn.getResponseCode() == HttpURLConnection.HTTP_OK) {
            // 上传成功，读取响应内容
            InputStream responseStream = conn.getInputStream();
            // 解析响应
        } else {
            // 上传失败，处理错误
        }
    } catch (IOException e) {
        e.printStackTrace();
    } finally {
        try {
            if (dataStream != null) dataStream.close();
            if (conn != null) conn.disconnect();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}).start();

三、关键注意点 #

• 数据源流的获取：确保你的数据源直接提供InputStream，比如CameraX拍摄时避免写入本地文件，而是转换为InputStream；如果是从其他网络源转发，直接使用下载的InputStream，不落地存储。
• 内存优化：使用固定大小的缓冲区（如4096字节），避免一次性加载大量数据到内存，防止OOM。
• 权限配置：在AndroidManifest.xml中声明INTERNET权限，若涉及相机等硬件，还需声明CAMERA权限并在运行时请求。
• 服务器配合：服务器端需要支持流式接收，比如Spring Boot中可以直接读取请求体的输入流处理，无需先将文件保存到服务器本地再处理。

内容的提问来源于stack exchange，提问作者App tester 1 Softrix