chatclient.java

java实现的网络聊天室程序

import java.io.*;
import java.net.*;
import java.util.StringTokenizer;

public class ChatClient
{
    public static void main(String [] args)
    {
        String IP = "localhost";
        int port = 8189;
        if(args.length < 2)
        {
            try
            {
                System.out.println("please input the IP and port, such as: 219.229.136.105:8189");
                BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
                String temp = in.readLine();
                if(!temp.equals(""))
                {
                    StringTokenizer st = new StringTokenizer(temp, ":");
                    IP = st.nextToken();
                    port = Integer.parseInt(st.nextToken());
                }
            }
            catch(IOException e)
            {
                e.printStackTrace();
            }
        }
        else
        {
            IP = args[0];
            port = Integer.parseInt(args[1]);
            System.out.println("your IP is : " + IP + " : " + port);
        }

        try
        {
            Socket s = new Socket(IP, port);
            BufferedReader receive = new BufferedReader(new InputStreamReader(s.getInputStream()));
            PrintWriter send = new PrintWriter(s.getOutputStream(), true);
            System.out.println("congratulations! connect successful\nyou can begin your chating");
            ReceiveThread t = new ReceiveThread(receive);
            t.start();
            boolean flag = true;
            try
            {
                while (flag)
                {
                    System.out.println("<<<");
                    BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
                    String context = in.readLine();
                    if (context.equals("BYE"))
                    {
                        flag = false;
                        send.println(context);
                    }
                    else
                        send.println(context);
                }
            }
            catch(IOException e)
            {
                e.printStackTrace();
            }
            System.out.println("get ready to exit");
            t.end();
            System.out.println("receive.close()");
            receive.close();
            System.out.println("send.close()");
            send.close();
            System.out.println("s.close()");
            s.close();
            System.out.println("exit");
            System.exit(0);
        }
        catch(IOException e)
        {
            e.printStackTrace();
        }
    }
}