作者：未知 来源：月光软件站 加入时间：2005-2-28　月光软件站

这只是一个简单的示例，如果你想了解HTTP的详细内容可参考我的一个开源项目JQuickDown

/*
 * Created on 2005-2-1
 *
 * CopyRight by lxleaves_zhang
 */
package test;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.nio.channels.spi.SelectorProvider;
import java.util.Iterator;

public class NIOTest {
    public static SocketChannel createSocketChannel(String host, int port)
            throws IOException {
        SocketChannel sc = SocketChannel
                .open(new InetSocketAddress(host, port));
        sc.configureBlocking(false);
        return sc;
    }

    public static final String host = "www.163.com";

    public static final String path = "/";

    public static final int port = 80;

    public static final byte[] req = ("GET " + path + " HTTP/1.0\r\nHost:"
            + host + "\r\n\r\n").getBytes();

    public static void main(String[] args) {
        Selector sel = null;
        ByteBuffer buf = ByteBuffer.allocate(256);
        SocketChannel sc[] = new SocketChannel[2];
        try {
            sel = SelectorProvider.provider().openSelector();
            sc[0] = createSocketChannel(host, port);
            sc[1] = createSocketChannel(host, port);
            buf.put(req);
            buf.flip();
            sc[0].write(buf);
            buf.flip();
            sc[1].write(buf);
            sc[0].register(sel, sc[0].validOps());
            sc[1].register(sel, sc[1].validOps());
        } catch (IOException e) {
            e.printStackTrace();
        }
        while (sel.isOpen()) {
            try {
                sel.select();
            } catch (IOException e) {
                e.printStackTrace();
            }
            Iterator it = sel.selectedKeys().iterator();
            while (it.hasNext()) {
                SelectionKey sk = (SelectionKey) it.next();
                it.remove();
                SocketChannel next = (SocketChannel) sk.channel();
                buf.clear();
                try {
                    // check whether finish
                    if (next.read(buf) == -1) {
                        sk.cancel();
                        next.close();

                        if (!it.hasNext()) {
                            sel.close();
                        }
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
                buf.flip();
                if (buf.limit() == 0)
                    continue;
                byte b[] = new byte[buf.limit()];
                buf.get(b);
                // System.out.println(next == sc[0]);
                if (next == sc[0])
                    System.out.print(new String(b));
                else
                    System.err.print(new String(b));
            }
        }
    }
}

相关软件：