【发布时间】:2015-10-04 19:52:55
【问题描述】:
目前我正在尝试为我的 Android 设备创建一个小套接字应用程序。
我想通过套接字连接将大文件 (~500MB) 发送到我的笔记本电脑/PC 或其他任何东西。我在我的 Android 设备上使用套接字客户端连接到我的 PC 上的套接字服务器,但是,当我尝试发送测试字段 (~460MB) 时,我的应用程序崩溃并显示:
"Throwing OutOfMemoryError"分配441616290字节失败 分配 4194304 个可用字节和 90MB 直到 OOM""
我猜我的客户无法处理这个文件大小。所以我的问题是:有没有办法通过 TCP 套接字连接来处理这么大的文件?我的代码适用于小文件(例如 5MB),但适用于较大的文件。
这是我目前所拥有的:
在我的安卓设备上运行的客户端:
private class Connecting extends AsyncTask<String, Integer, String>
{
@Override
protected String doInBackground(String... serverAdd)
{
String filePath = "Path to file";
File sdFile = new File(filePath);
try {
client = new Socket("ip", "port");
outputStream = client.getOutputStream();
byte[] buffer = new byte[1024];
FileInputStream in = new FileInputStream(sdFile);
int rBytes;
while((rBytes = in.read(buffer, 0, 1024)) != -1)
{
outputStream.write(buffer, 0, rBytes);
}
outputStream.flush();
outputStream.close();
client.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
}
服务器端:
public class Main {
private static ServerSocket serverSocket;
private static Socket clientSocket;
private static InputStream inputStream;
private static FileOutputStream fileOutputStream;
private static BufferedOutputStream bufferedOutputStream;
private static int filesize = 10000000;
private static int bytesRead;
private static int current = 0;
public static void main(String[] args) throws IOException {
serverSocket = new ServerSocket(10898);
System.out.println("Server started. Listening to the port 10898");
clientSocket = serverSocket.accept();
byte[] mybytearray = new byte[filesize];
inputStream = clientSocket.getInputStream();
fileOutputStream = new FileOutputStream("E:\\output.zip");
bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
System.out.println("Receiving...");
bytesRead = inputStream.read(mybytearray, 0, mybytearray.length);
current = bytesRead;
do {
bytesRead = inputStream.read(mybytearray, current, (mybytearray.length - current));
if (bytesRead >= 0) {
current += bytesRead;
}
} while (bytesRead > -1);
bufferedOutputStream.write(mybytearray, 0, current);
bufferedOutputStream.flush();
bufferedOutputStream.close();
inputStream.close();
clientSocket.close();
serverSocket.close();
System.out.println("Sever recieved the file");
}
}
问候
[编辑]:客户端代码。
【问题讨论】:
-
您需要将文件分成更小的文件,通常称为块。这是一个示例,在 C 中:stackoverflow.com/questions/1628587/…
-
不要一次读入整个文件,分小块读。
-
好的,谢谢你提供的信息,我需要一些时间来研究这段代码,因为我不熟悉 c。
-
只需使用与发送相同的代码来接收。在将其写入文件之前,无需将整个输入读入内存。