serverlistenthread.java

用JAVA实现聊天系统,能够实现多线程,多个用户同时聊天.

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import javax.swing.event.*;
import java.io.*;
import java.net.*;

public class ServerListenThread extends Thread{
	ServerSocket server;//监听套接字
	JComboBox combobox;//组合框
	JTextArea textarea;//区编辑框
	JLabel jlabel;//标签
	User userinfolist;//用户信息链表
	Dan client;//单个用户信息
	ServerReceiveThread recvthread;//服务器接收线程
	public boolean isstop;
	public ServerListenThread(ServerSocket server,JComboBox combobox,JTextArea textarea,JLabel jlabel,User userinfolist)
	{//构造函数
		this.server=server;
		this.combobox=combobox;
		this.textarea=textarea;
		this.jlabel=jlabel;
		this.userinfolist=userinfolist;
		isstop=false;
	}
	public void run()//服务器监听线程的执行体
	{
		while(!isstop&&!server.isClosed())//如果监听监听套接字处于打开状态
		{
			try
			{
				client=new Dan();//创建单个用户节点
				client.socket=server.accept();//监听客户端连接
				client.output=new ObjectOutputStream(client.socket.getOutputStream());
				client.output.flush();//得到套接字的输入流
				client.input=new ObjectInputStream(client.socket.getInputStream());
				client.username=(String)client.input.readObject();//读取用户昵称
				combobox.addItem(client.username);//组合框内显示用户名
				userinfolist.add(client);//在链表中加入该用户
				textarea.append("用户"+client.username+"上线了"+"\n");//在区编辑框内显示该用户上线的提示
				jlabel.setText("在线用户"+userinfolist.getCount()+"人\n");//在标签内显示当前在线用户的个娄
				recvthread=new ServerReceiveThread(textarea,jlabel,combobox,client,userinfolist);//创建器接收线程
				recvthread.start();//线程起动
			}catch(Exception e)
			{;
			}
		}
	}
}