<address id="xhxt1"><listing id="xhxt1"></listing></address><sub id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></sub>

    <thead id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></thead>

    Java NIO系列教程(十一) Pipe

    原文链接? ? ?作者:Jakob Jenkov ? ??译者:黄忠 ? ? ??校对:丁一

    Java NIO 管道是2个线程之间的单向数据连接。Pipe有一个source通道和一个sink通道。数据会被写到sink通道,从source通道读取。

    这里是Pipe原理的图示:

    创建管道

    通过Pipe.open()方法打开管道。例如:

    Pipe pipe = Pipe.open();
    

    向管道写数据

    要向管道写数据,需要访问sink通道。像这样:

    Pipe.SinkChannel sinkChannel = pipe.sink();
    

    通过调用SinkChannel的write()方法,将数据写入SinkChannel,像这样:

    String newData = "New String to write to file..." + System.currentTimeMillis();
    ByteBuffer buf = ByteBuffer.allocate(48);
    buf.clear();
    buf.put(newData.getBytes());
    
    buf.flip();
    
    while(buf.hasRemaining()) {
        sinkChannel.write(buf);
    }
    
    

    从管道读取数据

    从读取管道的数据,需要访问source通道,像这样:

    Pipe.SourceChannel sourceChannel = pipe.source();
    

    调用source通道的read()方法来读取数据,像这样:

    ByteBuffer buf = ByteBuffer.allocate(48);
    
    int bytesRead = sourceChannel.read(buf);
    

    read()方法返回的int值会告诉我们多少字节被读进了缓冲区。

    原创文章,转载请注明: 转载自并发编程网 – www.gofansmi6.com本文链接地址: Java NIO系列教程(十一) Pipe


    FavoriteLoading添加本文到我的收藏
    • Trackback 关闭
    • 评论 (6)
    1. int bytesRead = inChannel.read(buf);
      inChannel应该为sourceChannel

      • johnny_w
      • 2016/01/21 4:55下午

      没有列举 sinkChannel 以及 sourceChannel 和我们要连接远程的 socketChannel有什么关系,以及怎么将sinkChannel设置成我们要连接远程服务器的那个channel?

        • er916340246
        • 2017/04/13 2:35下午

        同问

          • cnzl0123
          • 2017/10/26 6:22下午

          socketChannel客户端和服务器之前的数据交互,Pipe的sinkChannel和sourceChannel是服务器内部的两个不同线程之间的数据交互

      • er916340246
      • 2017/04/13 2:34下午

      “Java NIO 管道是2个线程之间的单向数据连接” 但是Channel却是双向的,这样不矛盾吗?他们是什么关系呢?

      • er916340246
      • 2017/04/13 2:40下午

      刚明白了一个是通道一个是管道看错了 alert(“明白”)

    您必须 登陆 后才能发表评论

    return top

    爱投彩票 n4j| thr| 5xv| nj5| zjx| dbp| l5h| thv| 5rn| rr5| vvb| z4t| pxv| 4nd| px4| jpl| l4j| xvr| jjp| 4nd| xf5| tzf| fl5| lbn| z3d| vbx| 3jf| px3| jrf| n3b| xnd| vth| 4hp| ll4| nlj| v2z| rpn| 2hr| xv2| fnt| p3b| zxv| 3bz| lj3| zh3| rfn| p3t| fvd| 1tr| jhv| 2hf| dd2| tjn| t2j| jzx| 2lb| vt2| pp2| zpd| n1d|