tcpsocket.java~1~

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

package servertalk;


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


public class TcpSocket
{
    public TcpSocket() throws Exception
    {
        listen();
    }

    public void listen() throws Exception
    {
        ServerSocket ls = new ServerSocket(8000);
        Socket cs;
        while(true)
        {
            cs = ls.accept();
            new TalkThread(cs);
        }
    }

    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);
       // System.out.println(msg);
    }
}