serverreceivethread.java

本例中聊天服务器默认于本地8000端口建立服务； 本例中聊天客户端默认连接59.64.7.48地址8000端口服务器；因为客户端没有提供服务器IP设置接口

/*
 * Created on 2004-12-14
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */

/**
 * @author mq
 *
 * To change the template for this generated type comment go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
import javax.swing.*;
import java.io.*;
import java.net.*;

public class ServerReceiveThread extends Thread {
	JTextArea textarea;
	JTextField textfield;
	JComboBox combobox;
	Node client;
	UserInfoList userInfoList;
	
	public boolean isStop;
	
	public ServerReceiveThread(
		JTextArea textarea,
		JTextField textfield,
		JComboBox combobox,
		Node client,
		UserInfoList userInfoList)
	{
		this.textarea = textarea;
		this.textfield = textfield;
		this.client = client;
		this.userInfoList = userInfoList;
		this.combobox = combobox;
		
		isStop = false;
	}
	
	public void run()
	{
		sendUserList();	//send new userlist to all person
		
		while(!isStop && !client.socket.isClosed())
		{
			try
			{
				String type = (String)client.input.readObject();
				
				if(type.equalsIgnoreCase("聊天信息"))
				{
					String toSomebody = (String)client.input.readObject();
					String status  = (String)client.input.readObject();
					String action  = (String)client.input.readObject();
					String message = (String)client.input.readObject();
					
					String msg = client.username 
						   + action 
						   + "对" 
						   + toSomebody 
						   + "说" 
						   + message 
						   + "\n";
					if(status.equalsIgnoreCase("悄悄话"))
					{
						msg = "[悄悄话]" + msg;
					}
					textarea.append(msg);
					
					if(toSomebody.equalsIgnoreCase("all"))
					{
						sendToAll(msg);
					}
					else
					{
						try
						{
							client.output.writeObject("聊天信息");
							client.output.flush();
							client.output.writeObject(msg);
							client.output.flush();
						}
						catch (Exception e)
						{
							//
						}
						
						Node node = userInfoList.find(toSomebody);
						
						if(node != null)
						{
							node.output.writeObject("聊天信息"); 
							node.output.flush();
							node.output.writeObject(msg);
							node.output.flush();
						}
					}
				}
				else if(type.equalsIgnoreCase("用户下线"))
				{
					Node node = userInfoList.find(client.username);
					userInfoList.del(node);
					
					String msg = "用户" + client.username + "下线\n";
					int count = userInfoList.getCount();

					combobox.removeAllItems();
					combobox.addItem("all");
					int i = 0;
					while(i < count)
					{
						node = userInfoList.find(i);
						if(node == null) 
						{
							i ++;
							continue;
						} 
			
						combobox.addItem(node.username);
						i++;
					}
					combobox.setSelectedIndex(0);

					textarea.append(msg);
					textfield.setText("在线用户" + userInfoList.getCount() + "人\n");
					
					sendToAll(msg);
					sendUserList();	//refresh userlist
					
					break;
				}
			}
			catch (Exception e)
			{
				//
			}
		}
	}
	
	public void sendToAll(String msg)
	{
		int count = userInfoList.getCount();
		
		int i = 0;
		while(i < count)
		{
			Node node = userInfoList.find(i);
			if(node == null) 
			{
				i ++;
				continue;
			} 
			
			try
			{
				node.output.writeObject("聊天信息");
				node.output.flush();
				node.output.writeObject(msg);
				node.output.flush();
			}
			catch (Exception e)
			{
				//
			}
			
			i++;
		}
	}
	
	public void sendUserList()
	{
		String userlist = "";
		int count = userInfoList.getCount();

		int i = 0;
		while(i < count)
		{
			Node node = userInfoList.find(i);
			if(node == null) 
			{
				i ++;
				continue;
			} 
			
			userlist += node.username;
			userlist += '\n';
			i++;
		}
		
		i = 0;
		while(i < count)
		{
			Node node = userInfoList.find(i);
			if(node == null) 
			{
				i ++;
				continue;
			} 
			
			try
			{
				node.output.writeObject("用户列表");
				node.output.flush();
				node.output.writeObject(userlist);
				node.output.flush();
			}
			catch (Exception e)
			{
				//
			}
			i++;
		}		
	}
}