部分中的java FileOutputStream不起作用
我正在为我的一个应用程序开发一个文件传输功能。我的文件传输实现是以对象的形式发送一个文件，其中包含有关文件的信息以及发送的字节。但是，我注意到，只有将所有接收到的字节保存在一个列表中，然后立即将其写入文件，我才能真正写入该文件。如果我尝试部分写入该文件，结果会是一个空文件，就好像该文件根本没有被写入一样
下面是我的方法，它读取原始文件，然后将其分部分发送：
public void sendFile(File src) {
try {
BufferedInputStream is = new BufferedInputStream(new FileInputStream(src));
Message msg = new Message(MType.FILE_OPEN, true);
com.transmit(msg);
byte[] buf = new byte[Utility.bufferSize];
msg = new Message(MType.FILE_NAME, src.getName());
msg.setValue(MType.FILE_SIZE, Files.size(src.toPath()));
com.transmit(msg);
for (int count = is.read(buf); count > 0; count = is.read(buf)) {
msg = new Message(MType.FILE_NAME, src.getName());
msg.setValue(MType.FILE_SIZE, Files.size(src.toPath()));
msg.setValue(MType.FILE_BYTE, buf);
msg.setValue(MType.FILE_COUNT, count);
com.transmit(msg);
}
msg = new Message(MType.FILE_NAME, src.getName());
msg.setValue(MType.FILE_SIZE, Files.size(src.toPath()));
msg.setValue(MType.FILE_CLOSE, true);
is.close();
com.transmit(msg);
} catch (IOException e) {
sender.getChatRoomController().error(ProgramError.ATTACH_FILE);
Utility.log(e);
e.printStackTrace();
}
}
下面是我在另一端接收消息对象的方法：
public void readFile(Message msg) {
if (msg.hasID(MType.FILE_NAME)) {
String name = msg.getValue(MType.FILE_NAME).toString();
long size = (long) msg.getValue(MType.FILE_SIZE);
File file = new File(Directories.fDir.getDirectory(), name);
TempFile tf = new TempFile(file);
if (!map.containsKey(file)) {
if (!file.exists()) {
try {
file.createNewFile();
} catch (IOException e) {
e.printStackTrace();
}
}
map.put(file, tf);
} else {
tf = map.get(file);
}
if (msg.hasValue(MType.FILE_BYTE)) {
byte[] buf = (byte[]) msg.getValue(MType.FILE_BYTE);
int count = (int) msg.getValue(MType.FILE_COUNT);
tf.addEntry(buf, count);
}
if (msg.hasValue(MType.FILE_CLOSE)) {
tf.writeFile(true);
map.remove(file);
if (sender instanceof Server) {
Server server = (Server) sender;
msg = new Message(MType.FILE_NAME, name);
msg.setValue(MType.FILE_SIZE, size);
msg.setValue(MType.FILE_ATTACHMENT, server.getFileID());
addFile(file, server);
server.broadcast(msg);
}
}
}
}
下面是我的TempFile类：
public class TempFile {
private ArrayList<Byte[]> data;
private ArrayList<Integer> counts;
private File file;
public TempFile(File file) {
data = new ArrayList<>();
counts = new ArrayList<>();
this.file = file;
}
public void addEntry(byte[] data, int count) {
this.data.add(Utility.toWrapper(data));
this.counts.add(count);
}
public void writeFile(boolean append) {
try {
BufferedOutputStream os = new BufferedOutputStream(new FileOutputStream(file));
for (int i = 0; i < data.size(); i++) {
byte[] chunk = Utility.toPrimitive(data.get(i));
int count = counts.get(i);
os.write(chunk, 0, count);
}
os.flush();
os.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
这是我的另一个实现，它涉及实际的临时文件：
public class TempFile2 {
private File file;
private File tempFile;
private FileOutputStream os;
public TempFile2(File file) {
this.file = file;
this.tempFile = new File(file.getParent(), FilenameUtils.getBaseName(file.getName()) + ".tmp");
if (!tempFile.exists()) {
try {
tempFile.createNewFile();
} catch (IOException e) {
e.printStackTrace();
}
}
try {
os = new FileOutputStream(tempFile);
} catch (FileNotFoundException e) {
e.printStackTrace();
}
}
public void addEntry(byte[] data, int count) {
try {
os.write(data, 0, count);
} catch (IOException e) {
e.printStackTrace();
}
}
public void writeFile() {
try {
os.close();
Files.copy(tempFile.toPath(), file.toPath(), StandardCopyOption.REPLACE_EXISTING);
} catch (IOException e) {
e.printStackTrace();
}
}
}
# 1 楼答案
要使其工作，您需要在运行时刷新输出流
事实上，您可以在每次接收到数据块时打开和关闭输出流，而不是保持其打开状态：
还有，我有一个建议
read（）操作可能只读取几个字节，但您当前的实现无论如何都会发送整个数组。一种解决方案是制作一个新的更小的阵列来保存数据：
我认为更好的解决方案是在这里使用Base64类，并发送字节数组的序列化版本，而不是字节数组本身