java - Android Socket TCP 数据丢失
问题描述
我无法使用 WiFi-Direct 传输整个文件。文件发送者指示整个文件已被复制到套接字输出流。文件接收器只接收大约一半的文件。
我查看了原始文件的内容和存储接收数据的文件的内容,发现接收方只接收原始文件的片段。例如,它将接收字节 0-100,然后跳转到字节 245-350。
为什么接收方只接收文件的零碎部分,而不是整个文件?
文件接收逻辑
private class FileReceiveThread(val channel: Channel) : TransmissionThread() {
private var mFileName: String = ""
private var mFileSize: Long = 0L
private var mBytesReceivedTotal = 0L
override fun run() {
try {
Timber.d("File receive thread running: fileSize=$mFileSize, fileName=$mFileName")
val outputFile = File.createTempFile("file", "")
val fileOutput = outputFile.outputStream()
val channelInput = channel.getInputStream().unwrap()
val inputBuffer = ByteArray(FILE_TX_BUFFER_SIZE)
var bytesReceived = channelInput.read(inputBuffer)
while (bytesReceived > 0) {
fileOutput.write(inputBuffer)
mBytesReceivedTotal += bytesReceived
Timber.d("Received $mBytesReceivedTotal total bytes")
bytesReceived = channelInput.read(inputBuffer)
}
onTransmitComplete?.invoke()
} catch (e: Exception) {
e.printStackTrace()
}
}
fun start(filename: String, size: Long) {
mFileName = filename
mFileSize = size
start()
}
}
文件发送逻辑
private class FileSendThread : TransmissionThread() {
var mFile: File? = null
var mOutputStream: OutputStream? = null
override fun run() {
if (mFile != null && mOutputStream != null) {
val inputStream = mFile!!.inputStream()
val channelStream = mOutputStream!!
val buffer = ByteArray(FILE_TX_BUFFER_SIZE)
var bytesRead = inputStream.read(buffer)
var totalBytesRead = 0L + bytesRead
while (bytesRead > 0) {
Timber.v("Read $bytesRead, total $totalBytesRead")
channelStream.write(buffer)
bytesRead = inputStream.read(buffer)
totalBytesRead += bytesRead
}
Timber.d("Wrote file to output stream")
inputStream.close()
Timber.d("No more data to send")
onTransmitComplete?.invoke()
} else Timber.d("Parameters null: file=$mFile")
}
fun start(file: File, stream: OutputStream) {
mFile = file
mOutputStream = stream
start()
}
}
解决方案
while (inputStream.read(buffer) > 0) {
channelStream.write(buffer)
}
read() 通常不会填满整个缓冲区。因此,如果您写入缓冲区,那么只要它被填充即可。
var totalbytesread = 0;
var nread;
while ((nread = inputStream.read(buffer)) > 0) {
channelStream.write(buffer, 0, nread)
totalbytesread += nread;
}
channelStream.close()';
记录读取的总字节数。您的原始代码会导致接收到的文件更大,因此还有其他内容需要发现..
推荐阅读
- excel - Excel 多个值求和
- c# - 如何使用 stringbuilder 在 c# 中创建和下载 pdf 文件?
- python - 深度学习:验证损失波动剧烈,但训练损失稳定
- java - 按字母顺序排序会更改 ArrayList 中项目的位置,因此单击侦听器不匹配
- javascript - javascript 中的方法承诺不在对话框流上运行
- json - 在休眠中显示 JSON 双向映射
- python - 从熊猫数据框中删除重复的列索引
- mongodb - 查询以查找所有非零毫秒的文档
- webrtc - 实现类似whatsapp的视频聊天的最佳SDK?
- ruby - 访问 iframe 中的元素