threadchat.java

Java编写的简单网络聊天程序

package com.client.connect;
import java.io.IOException;
import java.util.StringTokenizer;


public class ThreadChat extends Thread 
{
	public net NET;
	public ThreadChat(net neted) 
	{
		this.NET = neted;
	}
	public void run() 
	{
		while(true)
        {
        	try{

        		//获取输入流
        		String str = NET.input.readUTF();
        		//将输入流中字符存入变量str
        	
        		//将输入流中字符显示到文本区
                if(str.startsWith("/online "))
                {
                	String online=str.substring(8);
                	//NET.pad.userList.remove("当前没有人上线!");
                	NET.pad.userList.removeAll();
                	
                	StringTokenizer token = new StringTokenizer(online," ");
                	String strtoken;
                	while(token.hasMoreTokens())
                	{
                		strtoken = (String) token.nextToken(" ");
                	    NET.pad.userList.add(strtoken);
                	}
                	NET.pad.userList.add("[您要对所有人说请选这里]");
                	NET.pad.userList.select(0);
                }
                else if(str.startsWith("/toall "))
                {
                	StringTokenizer token = new StringTokenizer(str," ");
                	String tokensigel=(String) token.nextToken(" ");
                	String sourcename=(String) token.nextToken(" ");
                	 NET.pad.tta.append(sourcename+"对所有人说: "+
                			 str.substring(tokensigel.length()+sourcename.length()+2)+"\n");
                }
                else
                {
                	StringTokenizer userToken = 
    	        		new StringTokenizer(str, " ");
    	           String source=userToken.nextToken(" ");
    	           NET.pad.tta.append("[悄悄话]");
                   NET.pad.tta.append(source);
        		   NET.pad.tta.append("对我说: ");
        		   NET.pad.tta.append(str.substring(source.length()+1));
        		   NET.pad.tta.append("\n");
                }
        	}catch(IOException ef){}
        }
	}

}