public static void main(String[] args) {
	Socket socket = null;
	try {
		//與服務(wù)端連接
		socket = new Socket("127.0.0.1", 5000);
		//從 socket 管道中獲取字節(jié)輸出流
		OutputStream os = socket.getOutputStream();
		//將字節(jié)輸出流包裝為打印流
		PrintStream ps = new PrintStream(os);
		//發(fā)一行數(shù)據(jù)
		ps.println("Hi BIO! 與服務(wù)端通信成功");
		ps.flush();
	} catch (IOException e) {
		e.printStackTrace();
	}
}

 public static void main(String[] args) {
 	System.out.println("===服務(wù)端啟動===");
 	ServerSocket serverSocket = null;
 	try {
 		//注冊端口
		serverSocket = new ServerSocket(5000);
		//監(jiān)聽客戶端請求
		Socket socket = serverSocket.accept();
		//從 socket 管道中獲取字節(jié)輸入流
		InputStream is = socket.getInputStream();
		//將字節(jié)輸入流包裝為緩沖字符輸入流
		BufferedReader br = new BufferedReader(new InputStreamReader(is));
		
		String msg;
		//讀一行數(shù)據(jù)
		if ((msg = br.readLine()) != null) {
			System.out.println("服務(wù)端接收客戶端信息為：" + msg);
		}
	}catch (Exception e){
		System.out.println(e.getMessage());
	}
}

public static void main(String[] args) {
    try {
        Socket socket = new Socket("localhost",9988);
        OutputStream os = socket.getOutputStream();
        PrintStream ps = new PrintStream(os);
        Scanner scanner = new Scanner(System.in);
        while (true){
            System.out.println("請輸入：");
            String input = scanner.nextLine();
            ps.println(input);
            ps.flush();
        }
     } catch (IOException e) {
     	e.printStackTrace();
     }
}

public static void main(String[] args) {
    System.out.println("===服務(wù)端啟動===");
    try {
         ServerSocket ss = new ServerSocket(9988);
         Socket socket = ss.accept();
         InputStream is = socket.getInputStream();
         BufferedReader br = new BufferedReader(new InputStreamReader(is));
         String message;
         while ((message = br.readLine()) != null){
             System.out.println("服務(wù)端接收客戶端信息為：" + message);
         }
     } catch (IOException e) {
		e.printStackTrace();
     }
}

public void listen() throws IOException {
	ServerSocket serverSocket = null;
	try {
		log.info("服務(wù)啟動監(jiān)聽");
		serverSocket = new ServerSocket(9988);
		//循環(huán)接收到客戶端的連接
		while (true) {
			Socket socket = serverSocket.accept();
			//得到連接后，開啟一個線程處理連接
			handleSocket(socket);
		}
	} finally {
		if(serverSocket != null){
			serverSocket.close();
		}
	}
}

private void handleSocket(Socket socket) {
	HandleSocket socketHandle = new HandleSocket(socket);
	new Thread(socketHandle).start();
}

public void run() {
	BufferedInputStream bufferedInputStream = null;
	BufferedOutputStream bufferedOutputStream  = null;
	try {
		bufferedInputStream = new BufferedInputStream(socket.getInputStream());
		byte[] bytes = new byte[1024];
		int len ;
		if ((len = bufferedInputStream.read(bytes)) > -1) {
			String result = new String(bytes,0,len);
            System.out.println("本次接收到的結(jié)果：" + result);
        }
        System.out.println("回復(fù)信息給客戶端：");
        bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());
        String outString = Thread.currentThread().getName() + "接收到了";
        bufferedOutputStream.write(outString.getBytes());
        bufferedOutputStream.flush();
	} catch (IOException e) {
		System.out.println("處理異常：" + e.getMessage());
	} finally {
		try {
			if (bufferedInputStream != null) {
				bufferedInputStream.close();
			}
			if (bufferedOutputStream != null) {
				bufferedOutputStream.close();
			}
		}catch (IOException e){
			System.out.println("關(guān)閉流異常：" + e.getMessage());
		}
	}
}

public void start() throws IOException {
	Socket socket = new Socket("127.0.0.1", 8081);
	String msg = "Hi,This is the BioClient";
	BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());
	byte[] bytes = msg.getBytes();
	bufferedOutputStream.write(bytes);
	bufferedOutputStream.flush();
	System.out.println("發(fā)送完畢");
	BufferedInputStream bufferedInputStream = new BufferedInputStream(socket.getInputStream());
	byte[] inBytes = new byte[1024];
	int len;
	if ((len = bufferedInputStream.read(inBytes)) != -1) {
		String result = new String(inBytes, 0, len);
		System.out.println("接收到的消息="+result);
	}
	bufferedOutputStream.close();
	bufferedInputStream.close();
	socket.close();
}

public class Server {

    // 定義一個靜態(tài)集合
    public static List<Socket> allSocketOnLine = new ArrayList();

    public static void main(String[] args) {
        try {
            ServerSocket ss = new ServerSocket(9999);
            while (true){
                Socket socket = ss.accept();
                // 把登錄的客戶端socket存入到一個在線的集合中去
                allSocketOnLine.add(socket);
                // 為當(dāng)前登錄成功的socket分配一個獨(dú)立的線程來處理
                new ServerReaderThread(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

public class ServerReaderThread extends Thread{

    private Socket socket;
    
    public ServerReaderThread(Socket socket){
        this.socket = socket;
    }
    
    @Override
    public void run() {
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            String msg;
            while ((msg = br.readLine()) != null) {
                // 發(fā)送給所有的在線socket
                sendMsgToAllClient(msg);
            }
        } catch (Exception e) {
            System.out.println("有人下線了");
            Server.allSocketOnLine.remove(socket);
        }

    }

    /**
     * 把當(dāng)前客戶端發(fā)來的消息發(fā)送給全部的在線socket
     * @param msg
     */
    private void sendMsgToAllClient(String msg) throws IOException {
        for (Socket sk : Server.allSocketOnLine) {
            PrintWriter pw = new PrintWriter(sk.getOutputStream());
            pw.println(msg);
            pw.flush();
        }
    }
    
}