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\r\n");

                 sb.append("Content-Type:text/html\r\n\r\n");

                 //发送http响应第一行和响应头

                 socketChannel.write(encode(sb.toString()));

                 //获取http请求的第一行

                 String firstLineOfRequst = request.substring(0, request.indexOf("\r\n"));

                 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();

         }

     }

 }

 <!DOCTYPE html>

 <html>

 <head>

 <meta charset="UTF-8">

 <title>Insert title here</title>

 </head>

 <body>

     <h1>hello</h1>

 </body>

 </html>

 <!DOCTYPE html>

 <html>

 <head>

 <meta charset="UTF-8">

 <title>Insert title here</title>

 </head>

 <body>

     <h1>login</h1>

 </body>

 </html>