Java網絡編程從入門到精通(32):一個非阻塞I/O的例子 – JAVA編程語言程序開發技術文章

為瞭使讀者更好地理解非阻塞I/O,本節給出瞭一個簡單的例子用來演示如何將非阻塞I/O應用到網絡程序中。讀者可以先不必管這個例子的具體細節。因為這個例子的主要目的並不是講解非阻塞I/O的使用,而是先讓讀者對非阻塞I/O有一個籠統的感性認識。在看完這個例子後,讀者可能會有很多疑問,在本章後面的部分將會逐漸揭開這些迷團。這個例子的主要功能是訪問新浪網,並將新浪網的首頁在控制臺上輸出。



package test;


import java.net.*;
import java.nio.*;
import java.nio.channels.*;
import java.io.*;


public class FirstNonBlockingIO
{
    public static void main(String[] args) throws Exception
    {
        SocketAddress remote = new InetSocketAddress(“www.sina.com.cn”, 80);
        SocketChannel channel = SocketChannel.open(remote);
        String request = “GET / HTTP/1.1
” +
                         “Host:www.sina.com.cn
” +
                         “Connection:close

“;
        ByteBuffer header = ByteBuffer.wrap(request.getBytes());
        channel.write(header);       
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        WritableByteChannel out = Channels.newChannel(System.out);
        while (channel.read(buffer) != -1)
        {
            buffer.flip();
            out.write(buffer);
            buffer.clear();
        }
        channel.close();
    }
}


測試


   執行如下命令:


 


java test.FirstNonBlockingIO > sina.txt


  打開sina.txt後,會看到如下的文件內容:


 


HTTP/1.0 200 OK
Date: Sun, 01 Apr 2007 06:53:50 GMT
Server: Apache/2.0.58 (Unix)
Last-Modified: Sun, 01 Apr 2007 06:50:47 GMT
Connection: close
 
 
</body>
</html>


    由於新浪網的主頁內容太多,因此,為瞭方便查看程序運行結果,使用輸出重定向符“>”將本該輸出到控制臺的內容輸出到sina.txt文件中。從例程7-1可以看出,主要有三點和同步I/O存在差異。


1.  連接服務器(第013行)。使用SocketChannel類,而不是Socket類。
2.  向服務端寫數據(第018行)。 使用SocketChannel類中的write方法,而不是OutputStream。
3.  從服務端讀數據(第021行)。使用SocketChannel類中的read方法,而不是InputStream。


   除瞭上面的三點外,在本例中還使用瞭緩沖區來處理輸入輸出數據。因此,通道(Channels)和緩沖區(Buffers)是學習非阻塞I/O之前必須掌握的知識。在下面的文章等將詳細講解這兩部分的內容。


 

發佈留言