1

我必须向其写入数据，Amazon S3并使用如下OutputStream方式写入数据InputStream

    final PipedOutputStream outputStream = new PipedOutputStream();
    final PipedInputStream inputStream;
    try {
        inputStream = new PipedInputStream(outputStream);
        new Thread(
                new Runnable() {
                    @Override
                    public void run() {
                        PutObjectRequest putObjectRequest = new PutObjectRequest(S3EnvironmentConfigurator.BucketTypes.source.name(), getProposalName(uniqueId), inputStream, null);
                        amazonS3Client.putObject(putObjectRequest);
                        try {
                            inputStream.close();
                        } catch (IOException e) {

                        }
                    }
                }
        ).start();

现在amazonS3Client.putObject看起来像

  @Override
    public PutObjectResult putObject(@Nonnull final PutObjectRequest putObjectRequest)
            throws AmazonClientException, AmazonServiceException {

        try {
            InputStreamReader is = new InputStreamReader(new GZIPInputStream(putObjectRequest.getInputStream()));
            StringBuilder sb=new StringBuilder();
            BufferedReader br = new BufferedReader(is);
            String read = br.readLine();
            while(read != null) {
                System.out.println(read);
                read =br.readLine();

            }
        } catch (IOException e) {
            //ignore
        }
    return super.putObject(putObjectRequest);
  • 这当前在控制台上打印出内容

需要

我该怎么做 

while (putObjectRequest.getInputStream() is not completely available) {
   // wait
}

// write inputStream, the entire InputStream is ready and available for processing
4

2 回答 2

1

一旦侧写关闭它OutputStream，InputStream将传递任何尚未读取的字节，然后下一个read()将返回 -1 以指示输入结束。

值字节作为int0 到 255 范围内的 an 返回。如果由于到达流的末尾而没有可用的字节，则返回值 -1。此方法会一直阻塞，直到输入数据可用、检测到流结束或引发异常。

如果边写close()在完成时失败，那么阅读器将阻塞等待更多输入，直到写入过程关闭。

于 2012-09-05T20:54:22.463 回答
1

您可以将所有数据复制到字节缓冲区，从而确保您已从输入流中读取所有数据。然后根据这个缓冲区创建新的输入流。就像是：

byte[] array = IOUtils.toByteArray(inputStream);
InputStream newInputStream = new ByteArrayInputStream(array);

来自 apache commons 的IOUtils 。

于 2012-09-05T20:58:46.477 回答