talkerrecvthread.java

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

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