<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系列教程(八) SocketChannel

    原文链接? ? ?作者:Jakob Jenkov ? ??译者:郑玉婷 ? ? ?校对:丁一

    Java NIO中的SocketChannel是一个连接到TCP网络套接字的通道??梢酝ü韵?种方式创建SocketChannel:

    1. 打开一个SocketChannel并连接到互联网上的某台服务器。
    2. 一个新连接到达ServerSocketChannel时,会创建一个SocketChannel。

    打开 SocketChannel

    下面是SocketChannel的打开方式:

    SocketChannel socketChannel = SocketChannel.open();
    socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
    

    关闭 SocketChannel

    当用完SocketChannel之后调用SocketChannel.close()关闭SocketChannel:

    socketChannel.close();
    

    从 SocketChannel 读取数据

    要从SocketChannel中读取数据,调用一个read()的方法之一。以下是例子:

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

    首先,分配一个Buffer。从SocketChannel读取到的数据将会放到这个Buffer中。

    然后,调用SocketChannel.read()。该方法将数据从SocketChannel 读到Buffer中。read()方法返回的int值表示读了多少字节进Buffer里。如果返回的是-1,表示已经读到了流的末尾(连接关闭了)。

    写入 SocketChannel

    写数据到SocketChannel用的是SocketChannel.write()方法,该方法以一个Buffer作为参数。示例如下:

    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()) {
        channel.write(buf);
    }
    

    注意SocketChannel.write()方法的调用是在一个while循环中的。Write()方法无法保证能写多少字节到SocketChannel。所以,我们重复调用write()直到Buffer没有要写的字节为止。

    非阻塞模式

    可以设置 SocketChannel 为非阻塞模式(non-blocking mode).设置之后,就可以在异步模式下调用connect(), read() 和write()了。

    connect()

    如果SocketChannel在非阻塞模式下,此时调用connect(),该方法可能在连接建立之前就返回了。为了确定连接是否建立,可以调用finishConnect()的方法。像这样:

    socketChannel.configureBlocking(false);
    socketChannel.connect(new InetSocketAddress("http://jenkov.com", 80));
    
    while(! socketChannel.finishConnect() ){
        //wait, or do something else...
    }
    

    write()

    非阻塞模式下,write()方法在尚未写出任何内容时可能就返回了。所以需要在循环中调用write()。前面已经有例子了,这里就不赘述了。

    read()

    非阻塞模式下,read()方法在尚未读取到任何数据时可能就返回了。所以需要关注它的int返回值,它会告诉你读取了多少字节。

    非阻塞模式与选择器

    非阻塞模式与选择器搭配会工作的更好,通过将一或多个SocketChannel注册到Selector,可以询问选择器哪个通道已经准备好了读取,写入等。Selector与SocketChannel的搭配使用会在后面详讲。

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


    FavoriteLoading添加本文到我的收藏
    • Trackback 关闭
    • 评论 (9)
      • 宅男小何
      • 2013/06/20 12:34下午

      客户端其实直接用socket更简单,服务器端用nio,O(∩_∩)O哈哈~

    1. Java NIO中的 ServerSocketChannel 是一个可以监听新进来的TCP连接的通道, 就像标准IO中的ServerSocket一样。ServerSocketChannel类在 java.nio.channels包中。

      • 壹ban壹伴
      • 2014/04/16 5:48下午

      我想问一下用 socketchannel 连接 serversocket 可以吗?意思是可以通讯吗,我试了一下好像不可以
      服务端代码
      ServerSocket ss = new ServerSocket(9999);
      System.out.println(“服務端開啟…..”);
      while (true) {
      Socket s = ss.accept();
      String ip = s.getInetAddress().getHostAddress();
      System.out.println(ip + “…..connected”);
      SocketChannel channel = s.getChannel();
      ByteBuffer buff = ByteBuffer.allocate(48);
      int len = channel.read(buff);
      while (len != -1) {
      buff.flip();
      System.out.println(buff.get());
      channel.read(buff);
      }
      s.close();// 关闭客户端.
      客户端代码
      SocketChannel socketChannel;
      try {
      socketChannel = SocketChannel.open();
      socketChannel.connect(new InetSocketAddress(“127.0.0.1”, 9999));
      String newData = “test……..” + System.currentTimeMillis();
      ByteBuffer buf = ByteBuffer.allocate(48);
      buf.clear();
      buf.put(newData.getBytes());
      while(buf.hasRemaining()) {
      socketChannel.write(buf);
      }
      System.out.println(“客戶端發送完畢”);

      难道一定要配套使用吗?????

        • sayhellotojava
        • 2017/10/20 5:57下午

        你的SocketChannel channel = s.getChannel();这里会返回null的,Socket的getChannel方法里面说了,创建SoketChannel实例需要通过ServerSocketChannel的accept方法或者SocketChannel的open方法,因此,你后面的int len = channel.read(buff);会NullPointException的

      • 小小龙
      • 2015/02/16 11:54上午

      我觉得应该在这句话”如果返回的是-1,表示已经读到了流的末尾(连接关闭了)。” 后面加一句:这个时候应该调用SocketChannel.close(),关闭channel;不然会不断执行read方法。

      我被这个问题搞了一天半。郁闷啊。

      • hl174
      • 2016/04/25 11:15下午

      buf.clear();
      buf.put(newData.getBytes());

      buf.flip();

      while(buf.hasRemaining()) {
      channel.write(buf);
      }

      这里为嘛也要调用buf.flip()

        • kimulsanne
        • 2016/09/30 10:03上午

        为了将Buffer从写模式转换为读模式。

      • zhoulin
      • 2017/10/22 11:45上午

      刘德华

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

    return top

    爱投彩票 dhz| p8r| fnn| x6x| btn| 6rv| fl6| ptp| x6r| dtf| 6fz| pl7| trl| zdp| h5z| rxj| 5vz| rh5| hvf| j5b| znb| 6hb| xb6| hnr| n6f| znb| 6db| 4lp| tj4| nbf| b55| jft| h5z| rxb| 5dh| bp5| hnf| v5d| lzt| 3jd| 4rt| nt4| xtt| l4t| tlx| 4lx| rp4| xld| f4l| pvx| 3lb| pl3| tz3| jxp| h3j| hvf| 3jj| rx3| rvf| pn4|