阻塞式简易http服务器

• 说明

        使用java.net包的ServerSocket也是阻塞的，所以下面的实例把ServerSocketChannel换成ServerSocket效果一样。

---

•  后台代码

package study.socket.tcp.block.httpserver;

import java.io.FileInputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.nio.channels.FileChannel;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 阻塞式简易http服务器
 * @author yj
 *
 */
public class SimpleHttpServer {

    private int port = 8080;
    private ServerSocketChannel serverSocketChannel = null;
    private ExecutorService executorService;
    private static final int POOL_MULTIPE = 4;
    
    public SimpleHttpServer() throws Exception {
        executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_MULTIPE);
        serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.socket().setReuseAddress(true);
        serverSocketChannel.socket().bind(new InetSocketAddress(port));
        System.out.println("服务器启动");
    }
    
    public void service() {
        while(true) {
            System.out.println("服务器接收到客户端请求");
            SocketChannel socketChannel = null;
            try {
                socketChannel = serverSocketChannel.accept();
            } catch (IOException e) {
                e.printStackTrace();
            }
            executorService.execute(new Handler(socketChannel));
            System.out.println("服务端处理完客户端请求");
        }
    }
    
    private class Handler implements Runnable {

        private SocketChannel socketChannel;
        
        public Handler(SocketChannel socketChannel) {
            this.socketChannel = socketChannel;
        }
        
        @Override
        public void run() {
            handler();
        }
        
        private void handler() {
            FileInputStream fis = null;
            try{
                new Thread().sleep(60000);
                Socket socket = socketChannel.socket();
                System.out.println("接受到客户连接来自：" + socket.getInetAddress() + ":" + socket.getPort());
                ByteBuffer bb = ByteBuffer.allocate(1024);
                socketChannel.read(bb);
                bb.flip();
                String request = decode(bb);
                System.out.println("客户端请求消息：" + request);
                //生成http响应消息
                StringBuffer sb = new StringBuffer("HTTP/1.1 200 OK
");
                sb.append("Content-Type:text/html

");
                //发送http响应第一行和响应头
                socketChannel.write(encode(sb.toString()));
                
                //获取http请求的第一行
                String firstLineOfRequst = request.substring(0, request.indexOf("
"));
                String filePath = SimpleHttpServer.class.getResource("/").getPath();
                System.out.println("路径：" + filePath);
                System.out.println("测试");
                if(firstLineOfRequst.indexOf("login.html") != -1) {
                    fis = new FileInputStream(filePath + "study/socket/block/httpserver/login.html");
                }else {
                    fis = new FileInputStream(filePath + "study/socket/block/httpserver/hello.html");
                } 
                FileChannel fc = fis.getChannel();
                fc.transferTo(0, fc.size(), socketChannel);
            }catch(Exception e){
                e.printStackTrace();
            }finally {
                try {
                    if(fis != null) {
                        fis.close();
                    }
                    if(socketChannel != null) {
                        socketChannel.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        
        private String decode(ByteBuffer bb) throws Exception{
            Charset charset  =  Charset.forName("utf-8");
            CharsetDecoder decoder  =  charset.newDecoder();
            CharBuffer charBuffer  =  decoder.decode(bb);
            System.out.println( " charBuffer= "   +  charBuffer);
            System.out.println(charBuffer.toString());
            System.out.println("编码");
            return  charBuffer.toString();
        }
        
        private ByteBuffer encode(String str) {
            System.out.println("解码");
            return ByteBuffer.wrap(str.getBytes());
        }
        
    }
    
    public static void main(String[] args) {
        try {
            new SimpleHttpServer().service();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

---

• hello.html文件

        html文件放在类的同级目录下，如果放其他目录下，上面后台代码需要改变取html文件路径。

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>Insert title here</title>
</head>
<body>
    <h1>hello</h1>
</body>
</html>

---

• login.html文件

        html文件放在类的同级目录下，如果放其他目录下，上面后台代码需要改变取html文件路径。

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>Insert title here</title>
</head>
<body>
    <h1>login</h1>
</body>
</html>

• 测试

       浏览器中输入：http://ip:port/或http://ip:port/hello.html访问hello.html,输入：http://ip:port/login.html访问login.html