要将数据发送到我的 FTP 服务器上的文件，我需要创建一个自定义 InputStream 实现，它逐行读取数据库数据，将其转换为 CSV 并通过其 read() 方法发布：从数据库中，我得到带有数据的 List<Application> 对象。对于每个Application 对象，我想在 CSV 文件中创建一行。
我的想法是在构造函数中加载所有数据，然后覆盖读取方法。我需要重写所有 InputStream 的方法吗？我尝试在谷歌上搜索一些示例，但没有成功 - 你最终能给我一个链接吗？
【问题讨论】：
标签： java ftp inputstream java-io
您只需要实现the read() method without parameters。所有其他方法都作为对该方法的调用来实现。出于性能原因（甚至是易于实现），实现the three-argument read() method instead 并根据该方法重新实现无参数read() 方法可能更容易。
【讨论】：
available() 来知道要准备多少字节，所以我会说流在默认实现下可以正常工作。
available() 仅被定义为估计值。在我看来，依赖估计是准确的是错误的。
我在实现 InputStream 时遇到的一些非常重要的点。
覆盖可用（）。正如 Javadoc 所说：
InputStream 类的可用方法总是返回 0。 这个方法应该被子类覆盖。
不覆盖此方法将导致任何尝试测试此流是否可读返回 false。例如，如果您将 inputStream 提供给 inputStreamReader，当您调用 reader.ready() 时，此阅读器将始终返回 false。
在read() 中返回 -1。文档没有强调它：
如果由于到达流的末尾而没有可用的字节，则返回值 -1。此方法会一直阻塞，直到输入数据可用、检测到流结束或引发异常。
如果您选择在没有可用数据时阻止read()，则在某些情况下您必须记住return -1。不这样做可能会导致另一个read(byte b[], int off, int len) 阻止源中的以下代码：
for (; i < len ; i++) {// default len is a relative large number (8192 - readPosition)
c = read();
if (c == -1) {
break;
}
b[off + i] = (byte)c;
}
这会导致一些（如果不是全部）高级读取块，例如读者的readLine(), read() 等。
【讨论】：
对于可能较大的数据，您可以使用来自guava 的 com.google.common.io.FileBackedOutputStream。
Javadoc：一个 OutputStream，它开始缓冲到一个字节数组，但一旦数据达到可配置的大小，就会切换到文件缓冲。
使用out.getSupplier().getInput()，您可以获得您的 InputStream。
【讨论】：
完全没有必要创建自定义InputStream。使用ByteArrayInputStream，类似这样：
public static InputStream createStream(){
final String csv = createCsvFromDataBaseValues();
return new ByteArrayInputStream(csv.getBytes());
}
特别是给出这句话：
我的想法是加载所有数据 构造函数，然后覆盖读取 方法。
如果您这样做，则通过实现自定义InputStream 将一无所获。它几乎等同于我上面概述的方法。
【讨论】：
Application对象中；每个在 CSV 文件中生成大约 100 个字符的行。在内存中生成这么长的字符串是个好主意，还是制作一个临时文件并在完成后传输它会更好？
StringBuilder- 和 File 支持的版本.
为什么需要自定义输入流？为什么不直接将生成的 csv 数据写入正在写入 ftp 服务器的输出流？
【讨论】：
如果数据不是太大，你可以：
String.getBytes(encoding)）ByteArrayInputStream中的字节数组
【讨论】：