acceptuserslistthread.java

达内学习时老师写的一个即时通信系统源码,有一定的学习价值!

package com.project.chat.client;

import java.io.*;
import java.net.*;
import javax.swing.*;
import java.util.*;
import com.project.util.CharacterUtil;

public class AcceptUsersListThread extends Thread
{
    private JFrame frame;
    private ServerSocket serverSocket;
    
    public AcceptUsersListThread(JFrame frame)
    {
        this.frame = frame;
        try
        {
            serverSocket = new ServerSocket(CharacterUtil.randomPort2);
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
        
    }
    
    public void run()
    {System.out.println("接收用户列表");
        while(true)
        {
            try
            {
                Socket socket = serverSocket.accept();
                InputStream inputStream = socket.getInputStream();
                byte[] buf = new byte[4096];
                int length = inputStream.read(buf);
                String usersList = new String(buf,0,length);
                
                ChatClient chatClient = (ChatClient)frame;
                chatClient.getJTextArea2().setText(usersList);
                
                inputStream.close();
                socket.close();
                
            }
            catch(Exception ex)
            {
                ex.printStackTrace();
            }
        }
        
    }
}