talkersendthread.java

来自「基于的多线程方式多人在线聊天程序基于的多线程方式多人在线聊天程序基于的多线程方式」· Java 代码 · 共 57 行

/**
 * 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();
        }
    }
}