blocks|key|1429709|text|如果只使用|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1429710|void+feedInputToOutput(InputStream+in,+OutputStream+out)+{
+++IOUtils.copy(in,+out);
}|code-block|syntax|javascript|1429711|然后就完了吗？|1429712|来自jakarta+apache+commons的i/o库，它已经被大量的项目使用，所以你可能已经在你的类路径中拥有了jar。|1429713|entityMap^0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|N|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|O|8|@]|9|@]|A|$]]|$1|I|3|J|5|6|7|P|8|@]|9|@]|A|$]]|$1|K|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|L|$]]

How about just using

<pre><code>void feedInputToOutput(InputStream in, OutputStream out) {
 IOUtils.copy(in, out);
}
</code></pre>

and be done with it?

from jakarta apache commons i/o library which is used by a huge amount of projects already so you probably already have the jar in your classpath already.

blocks|key|1429748|text|以异步的方式实现它。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1429749|void+inputStreamToOutputStream(final+InputStream+inputStream,+final+OutputStream+out)+{
++++Thread+t+=+new+Thread(new+Runnable()+{

++++++++public+void+run()+{
++++++++++++try+{
++++++++++++++++int+d;
++++++++++++++++while+((d+=+inputStream.read())+!=+-1)+{
++++++++++++++++++++out.write(d);
++++++++++++++++}
++++++++++++}+catch+(IOException+ex)+{
++++++++++++++++//TODO+make+a+callback+on+exception.
++++++++++++}
++++++++}
++++});
++++t.setDaemon(true);
++++t.start();
}|code-block|syntax|javascript|1429750|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

Asynchronous way to achieve it. 

<pre><code>void inputStreamToOutputStream(final InputStream inputStream, final OutputStream out) {
 Thread t = new Thread(new Runnable() {

 public void run() {
 try {
 int d;
 while ((d = inputStream.read()) != -1) {
 out.write(d);
 }
 } catch (IOException ex) {
 //TODO make a callback on exception.
 }
 }
 });
 t.setDaemon(true);
 t.start();
}
</code></pre>

blocks|key|1214936|text|为了完整起见，guava还提供了一个handy+utility|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|1214937|ByteStreams.copy(input,+output);|code-block|syntax|javascript|1214938|entityMap|0|LINK|mutability|MUTABLE|url|https://code.google.com/p/guava-libraries|1|http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/io/ByteStreams.html#copy%2528java.io.InputStream,%2520java.io.OutputStream%2529^0|7|5|0|I|D|1|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@$A|T|B|U|1|V]|$A|W|B|X|1|Y]]|C|$]]|$1|D|3|E|5|F|7|Z|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|10|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]|Q|$5|L|M|N|C|$O|R]]]]

For completeness, <a href="https://code.google.com/p/guava-libraries">guava</a> also has a <a href="http://docs.guava-libraries.googlecode.com/git/javadoc/com/google/common/io/ByteStreams.html#copy%28java.io.InputStream,%20java.io.OutputStream%29">handy utility</a> for this

<pre><code>ByteStreams.copy(input, output);
</code></pre>

blocks|key|1214970|text|BUFFER_SIZE是要读取的chucks的大小。应大于1kb且小于10MB。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1214971|private+static+final+int+BUFFER_SIZE+=+2+*+1024+*+1024;
private+void+copy(InputStream+input,+OutputStream+output)+throws+IOException+{
++++try+{
++++++++byte[]+buffer+=+new+byte[BUFFER_SIZE];
++++++++int+bytesRead+=+input.read(buffer);
++++++++while+(bytesRead+!=+-1)+{
++++++++++++output.write(buffer,+0,+bytesRead);
++++++++++++bytesRead+=+input.read(buffer);
++++++++}
++++//If+needed,+close+streams.
++++}+finally+{
++++++++input.close();
++++++++output.close();
++++}
}|code-block|syntax|javascript|1214972|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

BUFFER_SIZE is the size of chucks to read in. Should be > 1kb and &lt; 10MB.

<pre><code>private static final int BUFFER_SIZE = 2 * 1024 * 1024;
private void copy(InputStream input, OutputStream output) throws IOException {
 try {
 byte[] buffer = new byte[BUFFER_SIZE];
 int bytesRead = input.read(buffer);
 while (bytesRead != -1) {
 output.write(buffer, 0, bytesRead);
 bytesRead = input.read(buffer);
 }
 //If needed, close streams.
 } finally {
 input.close();
 output.close();
 }
}
</code></pre>

blocks|key|1429847|text|这是一个干净、快速的Scala版本(没有堆栈溢出)：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1429848|++import+scala.annotation.tailrec
++import+java.io._

++implicit+class+InputStreamOps(in:+InputStream)+{
++++def+>(out:+OutputStream):+Unit+=+pipeTo(out)

++++def+pipeTo(out:+OutputStream,+bufferSize:+Int+=+1<<10):+Unit+=+pipeTo(out,+Array.ofDim[Byte](bufferSize))

++++@tailrec+final+def+pipeTo(out:+OutputStream,+buffer:+Array[Byte]):+Unit+=+in.read(buffer)+match+{
++++++case+n+if+n+>+0+=>
++++++++out.write(buffer,+0,+n)
++++++++pipeTo(out,+buffer)
++++++case+_+=>
++++++++in.close()
++++++++out.close()
++++}
++}|code-block|syntax|javascript|1429849|这使得可以使用>符号，例如inputstream+>+outputstream，也可以传入自定义缓冲区/大小。|offset|length|style|CODE|1429850|entityMap^0|0|0|7|1|D|Q|0^^$0|@$1|2|3|4|5|6|7|O|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|P|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|Q|8|@$I|R|J|S|K|L]|$I|T|J|U|K|L]]|9|@]|A|$]]|$1|M|3|-4|5|6|7|V|8|@]|9|@]|A|$]]]|N|$]]

This is a Scala version that is clean and fast (no stackoverflow):

<pre><code> import scala.annotation.tailrec
 import java.io._

 implicit class InputStreamOps(in: InputStream) {
 def &gt;(out: OutputStream): Unit = pipeTo(out)

 def pipeTo(out: OutputStream, bufferSize: Int = 1&lt;&lt;10): Unit = pipeTo(out, Array.ofDim[Byte](bufferSize))

 @tailrec final def pipeTo(out: OutputStream, buffer: Array[Byte]): Unit = in.read(buffer) match {
 case n if n &gt; 0 =&gt;
 out.write(buffer, 0, n)
 pipeTo(out, buffer)
 case _ =&gt;
 in.close()
 out.close()
 }
 }
</code></pre>

This enables to use <code>&gt;</code> symbol e.g. <code>inputstream &gt; outputstream</code> and also pass in custom buffers/sizes.

blocks|key|1429889|text|JDK+9已经为此功能添加了InputStream#transferTo(OutputStream+out)。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1429890|entityMap|0|LINK|mutability|MUTABLE|url|http://openjdk.java.net/projects/jdk9/|1|https://docs.oracle.com/javase/9/docs/api/java/io/InputStream.html#transferTo-java.io.OutputStream-^0|E|14|0|5|0|E|14|1|0^^$0|@$1|2|3|4|5|6|7|P|8|@$9|Q|A|R|B|C]]|D|@$9|S|A|T|1|U]|$9|V|A|W|1|X]]|E|$]]|$1|F|3|-4|5|6|7|Y|8|@]|D|@]|E|$]]]|G|$H|$5|I|J|K|E|$L|M]]|N|$5|I|J|K|E|$L|O]]]]

<a href="http://openjdk.java.net/projects/jdk9/" rel="noreferrer">JDK 9</a> has added <a href="https://docs.oracle.com/javase/9/docs/api/java/io/InputStream.html#transferTo-java.io.OutputStream-" rel="noreferrer"><code>InputStream#transferTo(OutputStream out)</code></a> for this functionality.

update in java9: <a href="https://docs.oracle.com/javase/9/docs/api/java/io/InputStream.html#transferTo-java.io.OutputStream-" rel="noreferrer">https://docs.oracle.com/javase/9/docs/api/java/io/InputStream.html#transferTo-java.io.OutputStream-</a>

I saw some similar, but not-quite-what-i-need threads.

I have a server, which will basically take input from a client, client A, and forward it, byte for byte, to another client, client B.

I'd like to connect my inputstream of client A with my output stream of client B. Is that possible? What are ways to do that?

Also, these clients are sending each other messages, which are somewhat time sensitive, so buffering won't do. I do not want a buffer of say 500 and a client sends 499 bytes and then my server holds off on forwarding the 500 bytes because it hasn't received the last byte to fill the buffer.

Right now, I am parsing each message to find its length, then reading length bytes, then forwarding them. I figured (and tested) this would be better than reading a byte and forwarding a byte over and over because that would be very slow. I also did not want to use a buffer or a timer for the reason I stated in my last paragraph — I do not want messages waiting a really long time to get through simply because the buffer isn't full.

What's a good way to do this?

Connecting an input stream to an outputstream

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

在java9中更新：我看到了一些类似的，但不完全是我所需要的线程。我有一个服务器，它基本上会从一个客户端(客户端A )获取输入，然后逐字节地将其转发到另一个客户端(客户端B )。我想把客户端A的输入流和客户端B的输出流连接起来，可以吗？有什么方法可以做到这一点呢？此外，这些客户端相互发送消息，这在一定程度上是时间敏感的...

问将输入流连接到输出流
EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问将输入流连接到输出流EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问将输入流连接到输出流
EN