talkthread.java

本系统用户为企业内部员工

package servertalk;

import java.net.Socket;

/**
 * 开启线程处理客户端信息
 *
 *
 *
 * @author zhoujian
 * @version 1.00
 */

public class TalkThread extends Thread
{
    Socket cs;
    public TalkThread(Socket cs)
    {
        this.cs = cs;
        this.start();
    }

    public void run()
    {
        try
        {
            String msg;
            while (true)
            {
                 msg = TcpSocket.recv(cs);
                 TalkService.procMsg(msg,cs); //将接受的信息交给其他类处理
            }
        }
        catch(Exception e)
        {
        	System.out.println(e.toString());
        }
    }
}