java Socket和ServerSocket多線程編程

   這是在一本java教材上看到的，做了點修改。具體本教材記不清楚了，Sorry.放在這里，只是讓自己需要的時候能夠容易找到。

     程序分兩部分，服務端和客戶端。先把服務端運行起來，在運行客戶端。整個過程就是客戶端想服務端發送String,服務端再返回。客戶端的String由鍵盤輸入得到。

服務器端。

package net.tcp;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Server extends Thread
{

    ServerSocket server = null;
    Socket sk = null;
    BufferedReader rdr = null;
    PrintWriter wtr = null;

    public Server()
    {
        try
        {
            server = new ServerSocket(1987);
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
    }

    public void run()
    {

        while (true)
            {
                System.out.println("Listenning...");
                try
                {
//                  每個請求交給一個線程去處理
                    sk = server.accept();
                    ServerThread th = new ServerThread(sk);
                    th.start();
                    sleep(1000);
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                }

            }
    }

    public static void main(String [] args)
    {
        new Server().start();
    }






    class ServerThread extends Thread
    {

        Socket sk = null;
        public ServerThread(Socket sk)
        {
            this.sk = sk;
        }
        public void run()
        {
            try
            {
                wtr = new PrintWriter(sk.getOutputStream());
                rdr = new BufferedReader(new InputStreamReader(sk
                        .getInputStream()));
                String line = rdr.readLine();
                System.out.println("從客戶端來的信息：" + line);
//              特別，下面這句得加上     “\n”,
                wtr.println("你好，服務器已經收到您的信息！'" + line + "'\n");
                wtr.flush();
                System.out.println("已經返回給客戶端！");
            }
            catch (IOException e)
            {
                e.printStackTrace();
            }

        }

    }

}

客戶端：

package net.tcp;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class Client extends Thread
{

    Socket sk = null;
    BufferedReader reader = null;
    PrintWriter wtr = null;
    BufferedReader keyin = null;

    public Client()
    {
        keyin = new BufferedReader(new InputStreamReader(System.in));
        try
        {
            sk = new Socket("127.0.0.1", 1987);
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }

    }

    public void run()
    {
        try
        {
            reader = new BufferedReader(new InputStreamReader(sk
                    .getInputStream()));
            wtr = new PrintWriter(sk.getOutputStream());
            String get = keyin.readLine();

            while (true)
            {
                if (get != null & get.length() > 0)
                {
                    wtr.println(get);
                    wtr.flush();
//                  wtr.close();
//                  System.out.println(get + "發送完畢");
                }
                if (reader != null)
                {
                    String line = reader.readLine();
                    System.out.println("從服務器來的信息：" + line);

                }

            }
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }

    public static void main(String [] args)
    {
        new Client().start();
    }
}

分享到：