package Socket;

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


/**
 * 服务端
 * 客户端服务端发信息给服务端
 * @author Koali
 *
 */
public class Demo1 {
        public static void test1() {
                try {
                        ServerSocket serverSocket = new ServerSocket(8888);
                        System.out.println("*****服务端启动******");
                        Socket socket = serverSocket.accept();
                        System.out.println("客户端的IP："+socket.getInetAddress());
                        InputStream inputStream = socket.getInputStream();
                        OutputStream outputStream = socket.getOutputStream();
                        PrintWriter writer = new PrintWriter(outputStream);
                        Scanner sc = new Scanner(inputStream);
                        byte[] reciveMsgBuf = new byte[1024];
                        int reciveMsgSize;
                        String msg = "";
                        while((reciveMsgSize = inputStream.read(reciveMsgBuf))!=-1) {
                                System.out.println("客户端："+new String(reciveMsgBuf,0,reciveMsgSize));
                                writer.print("hello i am Server");
                        }
                        sc.close();
                        inputStream.close();
                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }
        
        public static void main(String[] args) {
                test1();
        }
}