package cn.tedu.netextend;

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

/**@author skd
 *@version 创建时间：2021年3月25日下午6:38:40
 *需求：接收客户端输入的每行数据,服务器再把回应给到用户
 *服务器端:接收客户端输入的每行数据,服务器再把回应给到用户
 *这个类用来当做回声案例的服务器端
 * 1.启动服务器
 * 2.接收客户端的连接请求
 * 3.给每个用户分配对应的话务员
 * 4.话务员:主要负责和对应的客户端对象进行沟通I/O
 */
public class Server {
	public static void main(String[] args) {
		try {
			ServerSocket server = new ServerSocket(9999);
			Socket serverAccept = server.accept();
			Service s1 = new Service(serverAccept);
			Thread t1 = new Thread(s1,"话务员1");
			t1.start();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

class Service implements Runnable{
	Socket serverAccept;
	public Service() {
		
	}
	public Service(Socket serverAccept) {
		this.serverAccept=serverAccept;
	}
	@Override
	public void run() {
		BufferedReader in=null;
		PrintWriter out=null;
		try {
			in = new BufferedReader
					(new InputStreamReader(serverAccept.getInputStream()));
			String line=in.readLine();
			System.out.println("接收到客户端信息"+line);
			out=new PrintWriter
					(new OutputStreamWriter(serverAccept.getOutputStream()));
			out.write("world");
			out.flush();
		} catch (IOException e) {
			e.printStackTrace();
		}finally {
			
			try {
				out.close();
				in.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
	
}