main.java

scoket 网络聊天室支持私聊

package chenmin.client;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.*;

public class Main {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		String ip;
		int port;
		// TODO Auto-generated method stub
		if(args.length == 2)
		{
			ip=args[0];
			port=Integer.parseInt(args[1]);
		}
		else
		{
			ip="127.0.0.1";
			port=8001;
		}
		try {
			Socket s=new Socket(InetAddress.getByName(ip),port);
			InputStream ips=s.getInputStream();
			OutputStream ops=s.getOutputStream();
			PrintWriter pw = new PrintWriter(ops);
			//将socket相关的输入流ips转换为字符流，再加上一个缓冲。
			BufferedReader brNet = new BufferedReader(new InputStreamReader(ips));
			//TcpClientListerner tcl=new TcpClientListerner(brNet);
			ClientConsole cc=new ClientConsole();
			ChatJFrame cj=new ChatJFrame(brNet,"");
			cj.setVisible(false);
			UserLogin ul=new UserLogin();
			//new Thread(tcl).start();
			new Thread(cc).start();
			//new Thread(cj).start();
			while(true)
			{
				if(cc.getRefresh())
				{
					pw.println(cc.getWho());
					pw.println(cc.getWord());
					pw.flush();
					cc.setRefresh(false);
				}
				if(ul.refresh)
				{
					pw.println("system");
					pw.println("name:"+ul.username);
					pw.flush();
					ul.refresh=false;
					cj=new ChatJFrame(brNet,ul.username);
					new Thread(cj).start();
				}
				if(cj.refresh)
				{
					pw.println(cj.who);
					pw.println(cj.word);
					pw.flush();
					cj.refresh=false;
				}
				
				
			}
			
			
			
			
			
			
		} catch (NumberFormatException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		

	}

}