Socket结合Thread简单实例

（1）Server类

public class Server {
    public static void main(String[] args) {
        ServerSocket server = null;
        try {
            server = new ServerSocket(9000);
            while(true) {
                Socket socket = server.accept();
                MyThread myThread = new MyThread(socket);
                myThread.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

（2）MyThread类

public class MyThread extends Thread {
    private Socket socket;
    public MyThread(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        InputStream is = null;
        try {
            is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String message = br.readLine();
            System.out.println("客户端发来的消息："+message);
            is.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

（3）Client类

public class Client {
    public static void main(String[] args) {
        Socket socket = null;
        try {
            socket = new Socket("localhost", 9000);
            OutputStream os = socket.getOutputStream();
            os.write("hello".getBytes());
            os.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}