import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

/**
 * 聊天室客户端
 *
 * @author HeFahai
 *
 */
public class Client {
    /*
     * java.net.Socket 封装了TCP通讯协议，使用它与远程计算机进行网络通讯。
     */
    private Socket socket;

    /**
     * 构造方法,用来初始化客户端
     *
     * @throws IOException
     * @throws UnknownHostException
     */
    public Client() throws UnknownHostException, IOException {
        /*
         * 实例化Socket是需要传入两个参数 1:服务器端IP地址 2:服务器端端口 通过IP地址可以找到网络上的服务端所在的计算机
         * 通过端口可以连接到该计算机上的服务端应用程序
         *
         * 实例化Scoket的过程就是建立连接的过程，所以若 连接服务端失败，就会抛出异常。
         */
        System.out.println("正在与服务端建立连接...");
        socket = new Socket("localhost", 8088);
        System.out.println("服务端已连接成功!");
    }

    /**
     * 客户端的启动方法，从这里开始执行客户端逻辑
     */
    public void start() {
        Scanner scan = new Scanner(System.in);
        try {
            OutputStream out = socket.getOutputStream();

            OutputStreamWriter osw = new OutputStreamWriter(out, "UTF-8");

            PrintWriter pw = new PrintWriter(osw, true);

            // 启动读取服务端发过来消息的线程
            ServerHander serverHander = new ServerHander();
            Thread t = new Thread(serverHander);
            t.start();

            System.out.println("开始聊天吧!");
            while (true) {
                pw.println(scan.nextLine());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            scan.close();
        }
        
    }

    public static void main(String[] args) {
        try {
            Client client = new Client();
            client.start();
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("客户端启动失败!");
        }
    }

    /**
     * 该线程用来循环接受服务端发送过来的消息并输出到客户端的控制台上。
     *
     * @author HeFahai
     *
     */
    private class ServerHander implements Runnable {
        public void run() {
            try {
                InputStream in = socket.getInputStream();

                InputStreamReader isr = new InputStreamReader(in, "UTF-8");

                BufferedReader br = new BufferedReader(isr);

                String message = null;
                while ((message = br.readLine()) != null) {
                    System.out.println(message);
                }

            } catch (Exception e) {

            }
        }
    }

}

聊天室客户端源码