package com.imooc.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 *
 * 基于TCP协议的Socket通信
 * 服务端
 *
 */
public class Server {
    public static void main(String[] args){
        try {
            //1、创建一个服务器端Socket,即serverSocket,指定绑定的端口并监听次端口
            ServerSocket serverSocket = new ServerSocket(8888);
            //2、调用accept()方法开始监听，等待客户端的连接
            System.out.println("***服务器即将启动，等待客户端的连接***");
            Socket socket = serverSocket.accept();
            //3、获取一个输入流用来读取客户端所发送的登录信息
            InputStream is = socket.getInputStream(); //字节输入流
            InputStreamReader isr = new InputStreamReader(is);//将字节流转换为字符流
            BufferedReader br = new BufferedReader(isr);//为输入流添加缓冲
            String info = null;
            while((info = br.readLine())!=null){//循环读取客户端的信息
                System.out.println("我是服务器,客户端说："+info);
            }
            socket.shutdownInput();//关闭输入流
            //4、获取输出流用来响应客户端的请求
            OutputStream os = socket.getOutputStream();
            PrintWriter pw = new PrintWriter(os);
            pw.write("欢迎您！");
            pw.flush();
            
            
            
            //5、关闭资源
            pw.close();
            os.close();
            br.close();
            isr.close();
            is.close();
            socket.close();
            serverSocket.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}