package com.example.aimei.controller;

import java.io.InputStream;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

 * @author yuanzipeng

 * @date 2018/11/21

 */

public class OioServer {

    public static void main(String[] args) throws Exception {

        //加线程

        ExecutorService threadPool = Executors.newCachedThreadPool();

        //创建ServerSocket服务

        ServerSocket serverSocket = new ServerSocket(5566);

        System.out.println("服务端启动!");

        while (true) {

            //获取一个套接字（阻塞）

            Socket socket = serverSocket.accept();

            System.out.println("来一个客户端!");

            threadPool.execute(new Runnable() {

                @Override

                public void run() {

                    //业务处理

                    handle(socket);

                }

            });

        }

    }

    public static void handle(Socket socket) {

        try {

            byte[] bytes = new byte[1024];

            InputStream inputStream = socket.getInputStream();

            while (true) {

                //读取数据（阻塞）

                int read = inputStream.read(bytes);

                if (read != -1) {

                    System.out.println(new String(bytes, 0, read));

                } else {

                    break;

                }

            }

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            System.out.println("Socke关闭!");

            try {

                socket.close();

            } catch (Exception e) {

                e.printStackTrace();

            }

        }

    }

}