serverlisten.java

基于netbeans的java桌面应用程序合集

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package org.Adam;
import java.net.*;
import java.io.*;
import javax.swing.*;
/**
 *
 * @author Administrator
 */
public class ServerListen extends Thread{
ServerSocket serversocket=null;
    JTextArea jTextArea1;
    JTextField jTextField;
    JComboBox jComboBox1;
    UserLinkList userlink;
    ServerReceive receive;
    public boolean isStop;
    Node client;
    public ServerListen(ServerSocket serversocket,JTextArea jTextArea,JTextField jTextField,JComboBox jComboBox1,UserLinkList userlink ) {
        this.serversocket=serversocket;
        this.jTextField=jTextField;
        this.jTextArea1=jTextArea;
        this.jComboBox1=jComboBox1;
        this.userlink=userlink;
        isStop=false;
    }
    public void run() {
        if(!isStop || !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();
                
                //show how much people on line
                this.jComboBox1.addItem(client.username);
                userlink.AddUser(client);
                this.jTextArea1.append("用户 " + client.username + " 上线" + "\n");
                this.jTextField.setText("在线用户" + userlink.getCount() + "人\n" );
                receive=new ServerReceive(jTextArea1,jTextField,jComboBox1,client,userlink);
                receive.start();
            }catch(Exception f){
                f.getMessage();
               // serversocket.close();
            }
        }
    }
}