其中一个写入PipedOutputStream，另一个从相应的PipedInputStream读取。背景是，一个线程正在从远程服务器下载一些数据，并通过管道流将其复用到其他几个线程。问题是，有时(特别是在下载大型(>50 is )文件时)我得到了java.io.IOException:管道坏了的试图从PipedInputStream读取。Javadoc说A pipe is said to be broken if a thread that was providing data bytes to t
浏览 5提问于2009-12-08得票数 22
回答已采纳
它以前是工作的，但当我重新运行我们的批处理加载器时，它给出了错误，没有足够的磁盘空间，所以我增加了磁盘大小，然后再次运行，然后我得到了管道中断错误，如下所示 at com.google.cloud.hadoop.util.AbstractGoogleAsyncWriteChannel.waitForCompletionAndThrowIfUploadFailed
浏览 2提问于2017-01-04得票数 2
我可以在日志中看到正在与远程SFTP服务器建立连接，但在关闭连接时抛出错误，如下所示：java.io.IOException: Pipe closedCould not close stream at java.io.PipedInputStream.read(Pip
浏览 2提问于2019-11-19得票数 0
我如何从代码内部管理它们？import sys.process._我简单地得到了下面的堆栈跟踪。java.io.IOException: Pipe closedat java.io.PipedInputStream.awa
浏览 0提问于2015-01-26得票数 2
这是异常日志 Process: com.example.chatkt1, PID: 805 at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
at sun.nio.ch.SocketDispatcher.write} catch (e: IOException) {
浏览 7提问于2021-03-15得票数 0
回答已采纳
但是这并不适用于JDK；我需要能够实现.因此，我选择使用Pipe{Input,Output}Stream。 extends InputStream private final Future<Void> future; [ IDEA specific stack trace e
浏览 6提问于2014-12-13得票数 0
回答已采纳
2回答
a = new PipedInputStream(); // create a line oriented pipex;
public Son(PipedInputStream</e
浏览 2提问于2014-07-11得票数 1
回答已采纳
Caused by: org.springframework.core.NestedIOException: failed to write file; nested exception is 4: java.io.IOException: Pipe closed at com.jcraft.jsch.ChannelSftp.o
浏览 0提问于2014-10-17得票数 1
我有一个InputStream，我可以从中读取字符。我想让多个读者访问这个InputStream。似乎实现这一点的一种合理方法是将传入数据写入StringBuffer或StringBuilder，并让多个读取器读取这些数据。不幸的是，StringBufferInputStream已被弃用。StringReader读取的是字符串，而不是不断更新的可变对象。我有什么选择？写我自己的？
浏览 5提问于2011-02-18得票数 17
回答已采纳
1回答
管道流和倒计时锁存器
、、、
是否知道我做错了什么，或者关于如何更好地处理具有多个处理流的单个流的建议。谢谢。RunTestPipePool Terminating");}C:\Users\matty\Documents\workspace\test_pipe\bin>echo hello world | java -jar RuRunTestPipePool Terminatingjava.io.IOException: Writ
浏览 3提问于2013-05-06得票数 1
回答已采纳
为什么会出现此错误，以及如何调试/抑制它？Failed to write flow file to stdin due to Broken pipe: java.io.IOException: Broken pipe ?
浏览 40提问于2019-06-29得票数 0
回答已采纳
java.io.DataInputStream;import java.io.File;import java.io.IOException_count++; this.writeKeyToPipe(this._key);
/* write
浏览 1提问于2014-05-31得票数 0
我在Scala中有以下代码： val pis = new PipedInputStream(pos)这很好，但出于某些原因，有时我会得到以下堆栈：java.io.IOException: Pipe closedat java.io.PipedInputStream.checkStateForR
浏览 4提问于2015-04-18得票数 3
回答已采纳
我正在使用Java中的套接字，当套接字被另一端关闭时，我可能会得到如下异常：java.io.IOException: Connection但是，如果我在另一种语言环境下运行Java，错误可能会变成：java.io.IOException
浏览 0提问于2016-09-11得票数 3
在非常罕见的情况下，管道会失败，这条消息如下： at java.io.PipedInputStream.checkStateForReceive(PipedInputStream.java:260) at如何进一步排除此随机错误？
浏览 4提问于2020-02-10得票数 0
我需要这样做，因为我确实希望避免new ByteArrayInputStream(baos.toByteArray())，这使得两个数据新副本。 pos.write(bytes); try (InputStream is = new PipedInputStreamURLConnection.guessContentTypeFromStream(is);}
catch (IO
浏览 3提问于2021-08-12得票数 0
2回答
听起来它应该已经在java中实现了，但是我花了几个小时试图找到/理解几个类，我不知道它是否能实现我想要的，以及如何使用它。
浏览 8提问于2014-03-11得票数 2
回答已采纳
我有一个只有map的hadoop作业，它在工作期间抛出了几个IO异常：2) java.io.IOException:管道关闭 at java.io.PipedInputStream.read(PipedInputStream.java:310)
浏览 23提问于2017-03-15得票数 1
3回答
而且我的网站不是SSL，所以我避免使用ssl://smtp.googlemail.com，而不是使用smtp.googlemail.com，我还尝试了使用ssl://smtp.googlemail.com: Notice
Message: fwrite(): send of 6
浏览 7提问于2016-07-13得票数 2
[Device]: Error during Sync: Broken pipe Caused by: java.io.IOException: Broken pipe
a
浏览 1提问于2018-02-13得票数 1
云服务器
ICP备案
对象存储
云点播
智聆口语评测
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号