myserverreadthread.java

我自己写的代码

import java.io.*;
import java.net.*;

public class MyServerReadThread implements Runnable {

	BufferedReader br;
	
	public MyServerReadThread(BufferedReader br) {
		this.br = br;
	}

	public void run() {

		String strLine = "";
		while (true) {
			try {
				strLine = br.readLine();
			} catch (IOException e) {
				
				e.printStackTrace();
			}

			System.out.print("接收到客户端 "+Thread.currentThread()+" 发来的信息  ：");
			System.out.println(strLine);
			
			if (strLine.equalsIgnoreCase("quit")) {
				try {
					br.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
				break;
			}
		}

	}

}