用java實現簡單TCP服務器監聽

---------------------------------------------服務端-----------------------------------------------

 1 package C;
import java.io.*;
import java.net.*;

public class Server extends ServerSocket            
{
    public Server(int serverPort) throws IOException
    {
        super(serverPort);
        try
        {
            while (true)
            {
                Socket socket = accept();
                new ServerThread(socket);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        finally {
            close();
        }
    }
    class ServerThread extends Thread       /*建立服務端線程*/
    {
        private Socket socket;
        private BufferedReader in;
        private PrintWriter out;
        public ServerThread(Socket s) throws IOException
        {
            this.socket = s;
            in = new BufferedReader(new InputStreamReader(
                    socket.getInputStream(), "GB2312"));        /*國標碼*/
            out = new PrintWriter(socket.getOutputStream(),true);
            start();                /*開始線程*/
        }

        public void run()
        {
                    try {
                while (true)
                {
                    String line = in.readLine();
                    if ("finish".equals(line))
                    {
                        System.out.println("服務器已停止監聽");
                        break;
                    }
                    System.out.println("接收到的數據：" + line);
                    String msg = "'" + line + "'已傳輸到服務器端.";
                    out.println(msg);
                    out.flush();
                }
                out.close();
                in.close();
                socket.close();
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }
        }
    }
        public static void main(String[] args) throws IOException
        {
            System.out.println("服務器開始運行......");
            new Server(2333);       /*綁定端口號*/
        }

}

---------------------------------------------客戶端-----------------------------------------------

 1 package C;
import java.io.*;
import java.net.*;

    public class Client
    {
        private Socket socket;                  /*定義socket連接*/
        private BufferedReader reader;          /*從字符輸入流讀取文本*/
        private PrintWriter writer;             /*打印到文本輸出流*/

        public Client(int serverPort) {                 /*定義客戶端端口號*/
            try {                                                       /*拋異常*/
                socket = new Socket("123.206.78.55", serverPort);
                reader = new BufferedReader(
                        new InputStreamReader(socket.getInputStream()));        /*標准輸入輸出流*/
                writer = new PrintWriter(socket.getOutputStream());

                while (true)
                {

                    BufferedReader in = new BufferedReader(
                            new InputStreamReader(System.in));
                    String message = in.readLine();
                    writer.println(message);
                    writer.flush();                             /*不關閉流，清空輸入緩存區*/

                    if ("finish".equals(message))
                    {
                        System.out.println("服務器已停止監聽");
                        break;
                    }
                    String received = reader.readLine();
                    System.out.println(received);
                }

                writer.close();
                reader.close();            /*關閉流*/
                socket.close();

            }
            catch (UnknownHostException ex)
            {
                ex.printStackTrace();
            }
            catch (IOException ex)
            {
                ex.printStackTrace();       /*在命令行打印異常信息在程序中出錯的位置及原因*/
            }
        }



        public static void main(String[] args)
        {
             new Client(2333);      /*綁定端口號*/
        }
    }

服務端是通過客戶端的流式輸入來實現監聽和停止監聽的。