talkersendthread.java

基于的多线程方式多人在线聊天程序基于的多线程方式多人在线聊天程序基于的多线程方式多人在线聊天程序基于的多线程方式多人在线聊天程序基于的多线程方式多人在线聊天程序

/**
 * Write a description of class NTalk here.
 * 
 * @author (your name) 
 * @version (a version number or a date)
 */

import java.io.*;
import java.net.*;

public class TalkerSendThread extends Thread
{    
    Socket socket = null;
    
    public TalkerSendThread(Socket skt)
    {
        socket = skt;
    }

    public void run()
    {
        PrintWriter out = null;
        BufferedReader stdIn =null;
        try
        {  
            out = new PrintWriter(socket.getOutputStream(), true);
            stdIn = new BufferedReader(
                new InputStreamReader(System.in));
            String userInput = null;
            while (((userInput = stdIn.readLine())!= null)||(!userInput.equals("exit")))
            {
                out.println(userInput);
                out.flush();
            }
        }
        catch(UnknownHostException exc)
        {
            exc.printStackTrace();
        }
        catch(IOException exc)
        {
            exc.printStackTrace();
        }
        
        try
        {
            out.close();
            stdIn.close();
            socket.close();
        }
        catch(IOException exc)
        {
            exc.printStackTrace();
        }
    }
}