tcpsocket.java~2~

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

package servertalk;


import java.net.ServerSocket;
import java.net.Socket;
import java.io.*;

/**
 * 通过套接字技术将客户端信息采集
 *
 * 
 *
 * @zhoujian 
 * @version 1.00 06/01/11
 */
public class TcpSocket
{
    public TcpSocket()
    {
        try{
          listen();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }

    public void listen() throws Exception
    {
    	//设置服务器端口为8000
        ServerSocket ls = new ServerSocket(8000);
        Socket cs;
        while(true)
        {
            cs = ls.accept();
            new TalkThread(cs);  //开启多线程TalkThread负责处理客户端的信息
        }
    }

    public static String recv(Socket cs) throws Exception
    {
        BufferedReader br = new BufferedReader(new InputStreamReader(
                    			cs.getInputStream()));
        return br.readLine();
    }

    public static void send(Socket cs, String msg) throws Exception
    {

        OutputStream ops=cs.getOutputStream();
        PrintWriter pr = new PrintWriter(ops,true);
        pr.println(msg);
       //将信息发给朋友客户端
    }
}