大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
本篇文章为大家展示了在java中写入管道流上出现报错如何解决,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。
创新互联公司是工信部颁发资质IDC服务器商,为用户提供优质的成都服务器托管服务
Java主要应用于:1. web开发;2. Android开发;3. 客户端开发;4. 网页开发;5. 企业级应用开发;6. Java大数据开发;7.游戏开发等。
1.创建和连接管道两端的两种方法
(1)创建管道输入和输出流并连接它们。它使用connect方法连接两个流。
PipedInputStream pis = new PipedInputStream(); PipedOutputStream pos = new PipedOutputStream(); pis.connect(pos); /* Connect the two ends */
(2)创建管道输入和输出流并连接它们。它通过将输入管道流传递到输出流构造器来连接两个流。
PipedInputStream pis = new PipedInputStream(); PipedOutputStream pos = new PipedOutputStream(pis);
2.写入报错分析
在线程Sender中向管道流中写入一个字符串,写入后关闭该管道流;在线程Reciever中读取该字符串。
import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.PipedInputStream; import java.io.PipedOutputStream; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; public class PipedStreamExam1 { public static void main(String[] args) { ExecutorService executorService = Executors.newCachedThreadPool(); try { //创建管道流 PipedOutputStream pos = new PipedOutputStream(); PipedInputStream pis = new PipedInputStream(pos); //创建线程对象 Sender sender = new Sender(pos); Reciever reciever = new Reciever(pis); //运行子线程 executorService.execute(sender); executorService.execute(reciever); } catch (IOException e) { e.printStackTrace(); } //等待子线程结束 executorService.shutdown(); try { executorService.awaitTermination(1, TimeUnit.DAYS); } catch (InterruptedException e) { e.printStackTrace(); } } static class Sender extends Thread { private PipedOutputStream pos; public Sender(PipedOutputStream pos) { super(); this.pos = pos; } @Override public void run() { try { String s = "This is a good day. 今天是个好天气。"; System.out.println("Sender:" + s); byte[] buf = s.getBytes(); pos.write(buf, 0, buf.length); pos.close(); } catch (IOException e) { e.printStackTrace(); } } } static class Reciever extends Thread { private PipedInputStream pis; public Reciever(PipedInputStream pis) { super(); this.pis = pis; } @Override public void run() { try { ByteArrayOutputStream baos = new ByteArrayOutputStream(); byte[] buf = new byte[1024]; int len = 0; while ((len = pis.read(buf)) != -1) { baos.write(buf, 0, len); } byte[] result = baos.toByteArray(); String s = new String(result, 0, result.length); System.out.println("Reciever:" + s); } catch (IOException e) { e.printStackTrace(); } } } }
注意,若管道流没有关闭,则使用这种方法读取管道中的信息会报错:
while ((len = pis.read(buf)) != -1) { baos.write(buf, 0, len); }
错误代码为java.io.IOException: Write end dead;发生这个错误的原因在于,由于管道未关闭,所以read语句不会读到-1,因此PipedInputStream会持续从管道中读取数据,但是因为Sender线程已经结束,所以会抛出“Write end dead”异常。
上述内容就是在java中写入管道流上出现报错如何解决,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联行业资讯频道。