package org.zh.test;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Server {
	
	public static void main(String[] args) throws IOException {
		System.out.println("正在启动服务器...");
		
		// 1.创建服务器端对象（端口号，如启动报错，请更改端口号）
		ServerSocket ser = new ServerSocket(1423);
		
		System.out.println("已经启动服务器，等待乙连接...");
		
		Socket socket = null;
		
		// 2.获取客户端对象
		socket = ser.accept();
		OutputStream outputStream = socket.getOutputStream(); 	//输出流
		
		while (true) {
			
			// 获取ip地址（现在不做任何用处，测试可以将“30行”注释去掉）
			String ip = socket.getInetAddress().getHostAddress();
			//System.out.println("ip地址为：" + ip);
			
			// 3.通过客户端对象获取Socket流对象
			InputStream inputStream = socket.getInputStream();
			
			byte[] bs = new byte[1024];
			int len = inputStream.read(bs);
			String strlist = new String(bs, 0, len);
			
			System.err.println("乙发来信息：" + strlist);
			
			Scanner scanner = new Scanner(System.in);
			
			// 输入内容
			System.out.println("请您（服务端）输入回复信息：");
			String next = scanner.next();
			
			// 4.将信息发送给乙
			outputStream.write(next.getBytes());
			
			
		}
		
	}

}