serverlisten.java

网络通信系统

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

public class ServerListen extends Thread{//服务器端监听连接请求
  ServerSocket serversocket;//服务器端的接口
  JTextArea usershow;//用户列表窗口
  JTextArea messageshow;//消息窗口
  UserLinkList userlinklist;//用户链表
  Node client;//用户链表结点
  ServerRecSen serverrecsen;//服务器端信息收发程序
  
  public ServerListen(ServerSocket serversocket,JTextArea usershow,
		               JTextArea messageshow,UserLinkList userlinklist){
	this.serversocket = serversocket;
	this.usershow = usershow;
	this.messageshow = messageshow;
	this.userlinklist = userlinklist;	  
  }
  
  public void run(){//启动监听连接请求线程
	while(!serversocket.isClosed()){
	  try{
		client = new Node();//新建用户链表结点
	    client.socket = serversocket.accept();//监听客户端连接请求
	    client.output = new ObjectOutputStream(client.socket.getOutputStream());
	    client.output.flush();
	    client.input = new ObjectInputStream(client.socket.getInputStream());
	    client.username = (String)client.input.readObject();
	    
	    usershow.append(client.username+'\n');
	    userlinklist.addUser(client);
	    messageshow.append("欢迎用户<"+client.username+">来到无忧之家聊天室\n");
	    
	    serverrecsen = new ServerRecSen(usershow,messageshow,userlinklist,client);
	    serverrecsen.start();
	  }
	  catch(Exception e){
	    //System.out.println(e);
	  }
	}
  }
  
}