acceptmessagethread.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 AcceptMessageThread extends Thread
{
    private JFrame frame;
    private ServerSocket serverSocket;
    
    public AcceptMessageThread(JFrame frame)
    {
        this.frame = frame;
        try
        {
            serverSocket = new ServerSocket(CharacterUtil.randomPort);
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
        
    }
    
    public void run()
    {
        while(true)
        {
            try
            {
                Socket socket = serverSocket.accept();
                InputStream inputStream = socket.getInputStream();
                byte[] buf = new byte[1024];
                int length = inputStream.read(buf);
                String message = new String(buf,0,length);
                
                if("SERVER_CLOSED".equals(message))
                {
                    JOptionPane.showMessageDialog(frame,"服务器已关闭，程序将退出！","错误",JOptionPane.ERROR_MESSAGE);
                    System.exit(0);//程序退出
                }
                
                
                
                ChatClient chatClient = (ChatClient)frame;
                chatClient.getJTextArea1().append(message + "\n");
                
                inputStream.close();
                socket.close();
                
            }
            catch(Exception ex)
            {
                ex.printStackTrace();
            }
        }
    }
    
}