talkerrecvthread.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 TalkerRecvThread extends Thread
{    
    Socket socket = null;
    
    public TalkerRecvThread(Socket skt)
    {
        socket = skt;
    }
        
    public void run()
    { 
        BufferedReader in = null;
        try
        {  
            in = new BufferedReader(
                 new InputStreamReader(socket.getInputStream()));
            String netInput= null;
            while((netInput = in.readLine())!= null)
            {
                System.out.println(netInput);               
            }
        }
        catch(UnknownHostException exc)
        {
            exc.printStackTrace();
        }
        catch(IOException exc)
        {
            exc.printStackTrace();
        }
        
        try
        {
            in.close();
            socket.close();
        }
        catch(IOException exc)
        {
            exc.printStackTrace();
        }
    }
}