高性能的java内容服务器

使用Java NIO实现高性能内容服务器

Java NIO（New IO）是一种Java API，该API在Java 1.4中引入。 NIO提供了比传统的Java IO API更高效的方式来处理输入/输出操作。它可以在不使用多线程的情况下处理高并发连接。

下面是一个简单的Java NIO内容服务器实现：

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.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
 
public class ContentServer {
     
    private Selector selector;
     
    public void startServer() throws IOException{
         
        //创建Selector
        selector = Selector.open();
         
        //创建ServerSocketChannel并绑定到本地端口
        ServerSocketChannel serverChannel = ServerSocketChannel.open();
        serverChannel.configureBlocking(false);
        serverChannel.bind(new InetSocketAddress(8080));
         
        //注册ServerSocketChannel到Selector，并指定感兴趣的事件为'接收新连接”
        serverChannel.register(selector, SelectionKey.OP_ACCEPT);
         
        while(true){
            //selector阻塞等待事件发生
            int readyChannels = selector.select();
            if(readyChannels == 0) continue;
             
            //遍历所有已发生的事件
            Iterator<SelectionKey> keyIterator = selector.selectedKeys().iterator();
            while(keyIterator.hasNext()){
                SelectionKey key = keyIterator.next();
                 
                //有新的连接请求
                if(key.isAcceptable()){
                    ServerSocketChannel server = (ServerSocketChannel)key.channel();
                     
                    //获取新连接的SocketChannel
                    SocketChannel client = server.accept();
                    client.configureBlocking(false);
                     
                    //将新连接的SocketChannel注册到Selector，并指定感兴趣的事件为'读取数据”
                    client.register(selector, SelectionKey.OP_READ);
                }
                 
                //有数据可读
                if(key.isReadable()){
                    SocketChannel client = (SocketChannel)key.channel();
                     
                    //读取数据
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    client.read(buffer);
                     
                    //处理数据
                    String content = new String(buffer.array()).trim();
                    System.out.println(content);
                     
                    //将数据返回给客户端
                    ByteBuffer responseBuffer = ByteBuffer.wrap(("Hello " + content + "\n").getBytes());
                    client.write(responseBuffer);
                }
                 
                //从已发生事件的集合中移除当前事件，否则会重复处理
                keyIterator.remove();
            }