初探Java Socket

張漢慶發(fā)布于2019-08-15 14:48 / 3146人閱讀

摘要：綁定完成后允許套接字進(jìn)行連接并等待連接。服務(wù)端根據(jù)報文返回響應(yīng)，并關(guān)閉連接。單線程服務(wù)器多進(jìn)程及多線程服務(wù)器復(fù)用服務(wù)器復(fù)用的多線程服務(wù)器單線程服務(wù)器一次只處理一個請求，直到其完成為止。

前言

本篇文章將涉及以下內(nèi)容：

IO實現(xiàn)Java Socket通信

NIO實現(xiàn)Java Socket通信

閱讀本文之前最好了解過：

Java IO

Java NIO

Java Concurrency

TCP/IP協(xié)議

TCP 套接字

TCP套接字是指IP號+端口號來識別一個應(yīng)用程序，從而實現(xiàn)端到端的通訊。其實一個套接字也可以被多個應(yīng)用程序使用，但是通常來說承載的是一個應(yīng)用程序的流量。建立在TCP連接之上最著名的協(xié)議為HTTP，我們?nèi)粘Ｉ钪惺褂玫臑g覽器訪問網(wǎng)頁通常都是使用HTTP協(xié)議來實現(xiàn)的。

先來了解一下通過TCP套接字實現(xiàn)客戶端和服務(wù)器端的通信。

在TCP客戶端發(fā)出請求之前，服務(wù)器會創(chuàng)建新的套接字(socket)，并將套接字綁定到某個端口上去(bind)，默認(rèn)情況下HTTP服務(wù)的端口號為80。綁定完成后允許套接字進(jìn)行連接(listen)并等待連接(accept)。這里的accept方法會掛起當(dāng)前的進(jìn)程直到有Socket連接。

在服務(wù)器準(zhǔn)備就緒后，客戶端就可以發(fā)起Socket連接?？蛻舳双@取服務(wù)器的Socket套接字(IP號:端口號)，并新建一個本地的套接字。然后連同本地的套接字發(fā)送到服務(wù)器上。

服務(wù)器accept該請求并讀取該請求。這里面包括有TCP的三次連接過程。連接建立之后，客戶端發(fā)送HTTP請求并等待響應(yīng)。服務(wù)端根據(jù)HTTP報文返回響應(yīng)，并關(guān)閉連接。

Web Server

當(dāng)下的Web服務(wù)器能夠同時支持?jǐn)?shù)千條連接，一個客戶端可能向服務(wù)器打開一條或多條連接，這些連接的使用狀態(tài)各不相同，使用率也差異很大。如何有效的利用服務(wù)器資源提供低延時的服務(wù)成了每個服務(wù)器都需要考慮的問題。根據(jù)服務(wù)器的處理方式，可以分為以下4種服務(wù)器，我們也將分別對其進(jìn)行簡單的實現(xiàn)。

單線程服務(wù)器

多進(jìn)程及多線程服務(wù)器

復(fù)用IO服務(wù)器

復(fù)用的多線程服務(wù)器

單線程服務(wù)器

一次只處理一個請求，直到其完成為止。一個事務(wù)處理結(jié)束后，才會去處理下一條連接。實現(xiàn)簡單，但是性能堪憂。

多進(jìn)程及多線程服務(wù)器

可以根據(jù)需要創(chuàng)建，或預(yù)先創(chuàng)建一下線程/進(jìn)程。可以為每條連接分配一個線程/進(jìn)程。但是當(dāng)強(qiáng)求數(shù)量過多時，過多的線程會導(dǎo)致內(nèi)存和系統(tǒng)資源的浪費(fèi)。

復(fù)用I/O服務(wù)器

在復(fù)用結(jié)構(gòu)中，會同時監(jiān)視所有連接上的活動，當(dāng)連接狀態(tài)發(fā)生變化時，就對那條連接進(jìn)行少量的處理。處理結(jié)束后，就將連接返回到開放連接列表中，等待下一次狀態(tài)的變化。之后在有事情可做時才會對連接進(jìn)行處理。在空閑連接上等待的時候不會綁定線程和進(jìn)程。

復(fù)用的多線程服務(wù)器

多個線程(對應(yīng)多個CPU)中的每一個都在觀察打開的連接（或是打開連接中的一個子集）。并對每條連接的狀態(tài)變化時執(zhí)行任務(wù)。

Socket通信基本實現(xiàn)

根據(jù)我們上面講述的Socket通信的步驟，在Java中我們可以按照以下方式逐步建立連接：

首先開啟服務(wù)器端的SocketServer并且將其綁定到一個端口等待Socket連接：

ServerSocket serverSocket = new ServerSocket(PORT_ID:int);
Socket socket = serverSocket.accept();

當(dāng)沒有Socket連接時，服務(wù)器會在accept方法處阻塞。

然后我們在客戶端新建一個Socket套接字并且連接服務(wù)器：

Socket socket = new Socket(SERVER_SOCKET_IP, SERVER_SOCKET_PORT);
socket.setSoTimeout(100000);

如果連接失敗的話，將會拋出異常說明服務(wù)器當(dāng)前不可以使用。
連接成功給的話，客戶端就可以獲取Socket的輸入流和輸出流并發(fā)送消息。寫入Socket的輸出流的信息將會先存儲在客戶端本地的緩存隊列中，滿足一定條件后會flush到服務(wù)器的輸入流。服務(wù)器獲取輸入后可以解析輸入的數(shù)據(jù)，并且將響應(yīng)內(nèi)容寫入服務(wù)器的輸出流并返回客戶端。最后客戶端從輸入流讀取數(shù)據(jù)。

客戶端獲取Socket輸入輸出流，這里將字節(jié)流封裝為字符流。

//獲取Socket的輸出流，用來發(fā)送數(shù)據(jù)到服務(wù)端
PrintStream out = new PrintStream(socket.getOutputStream());
//獲取Socket的輸入流，用來接收從服務(wù)端發(fā)送過來的數(shù)據(jù)
BufferedReader buf =  new BufferedReader(new InputStreamReader(socket.getInputStream()));

客戶端發(fā)送數(shù)據(jù)并等待響應(yīng)

String str = "hello world";
out.println(str);
String echo = buf.readLine();
System.out.println("收到消息：" + echo);

這里需要注意的是，IO流是阻塞式IO，因此在讀取服務(wù)端響應(yīng)的過程中（即buf.reaLine()這一行）會阻塞直到收到服務(wù)器響應(yīng)。

客戶端發(fā)送結(jié)束之后不要忘了關(guān)閉IO和Socket通信。

out.close();
buf.close();
socket.close();

服務(wù)器對消息的處理和客戶端類似，后面會貼上完整代碼。

Java Socket通信阻塞式通信實現(xiàn)

這里我們對上述的理論進(jìn)行簡單的實現(xiàn)。這里我們實現(xiàn)一個簡單的聊天室，只不過其中一方是Server角色而另一個為Client角色。二者都通過System.in流輸入數(shù)據(jù)，并發(fā)送給對方。正如我們前面所說，IO流的通信是阻塞式的，因此在等待對方響應(yīng)的過程中，進(jìn)程將會掛起，我們這時候輸入的數(shù)據(jù)將要等到下一輪會話中才能被讀取。

client端

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

public class SocketClient {

    public static void send(String server, int port){
        try {
            Socket socket = new Socket(server, port);
            socket.setSoTimeout(100000);

            System.out.println("正在連接服務(wù)器");

            //從控制臺讀入數(shù)據(jù)
            BufferedReader input = new BufferedReader(new InputStreamReader(System.in));

            //獲取Socket的輸出流，用來發(fā)送數(shù)據(jù)到服務(wù)端
            PrintStream out = new PrintStream(socket.getOutputStream());
            //獲取Socket的輸入流，用來接收從服務(wù)端發(fā)送過來的數(shù)據(jù)
            BufferedReader buf =  new BufferedReader(new InputStreamReader(socket.getInputStream()));
            boolean running = true;
            while(running){
                System.out.print("輸入信息：");
                String str = input.readLine();
                out.println(str);

                if("bye".equals(str)){
                    running = false;
                }else{
                    try{
                        //從服務(wù)器端接收數(shù)據(jù)有個時間限制（系統(tǒng)自設(shè)，也可以自己設(shè)置），超過了這個時間，便會拋出該異常
                        String echo = buf.readLine();
                        System.out.println("收到消息：" + echo);
                    }catch(SocketTimeoutException e){
                        System.out.println("Time out, No response");
                    }
                }
            }

            input.close();
            socket.close();

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
        }
    }

    public static void main(String[] args){
        send("127.0.0.1", 2048);
    }
}

Server端

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

public class SocketServer {

    public static void main(String[] args) throws IOException {
        //服務(wù)端在2048端口監(jiān)聽客戶端請求的TCP連接
        ServerSocket server = new ServerSocket(2048);
        Socket client = null;
        boolean f = true;
        while(f){
            //等待客戶端的連接，如果沒有獲取連接
            client = server.accept();
            System.out.println("與客戶端連接成功！");
            //為每個客戶端連接開啟一個線程
            new Thread(new ServerThread(client)).start();

        }
        server.close();
    }

}

服務(wù)器處理數(shù)據(jù)

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;

public class ServerThread implements Runnable{
    private Socket client = null;
    public ServerThread(Socket client){
        this.client = client;
    }

    @Override
    public void run() {
        try{
            //獲取Socket的輸出流，用來向客戶端發(fā)送數(shù)據(jù)
            PrintStream out = new PrintStream(client.getOutputStream());

            //獲取Socket的輸入流，用來接收從客戶端發(fā)送過來的數(shù)據(jù)
            BufferedReader buf = new BufferedReader(new InputStreamReader(client.getInputStream()));

            BufferedReader serverResponse = new BufferedReader(new InputStreamReader(System.in));
            boolean flag =true;
            while(flag){
                //接收從客戶端發(fā)送過來的數(shù)據(jù)
                String str =  buf.readLine();
                System.out.println("收到消息：" + str);
                if(str == null || "".equals(str)){
                    flag = false;
                }else{
                    if("bye".equals(str)){
                        flag = false;
                    }else{
                        //將接收到的字符串前面加上echo，發(fā)送到對應(yīng)的客戶端
                        System.out.print("發(fā)送回復(fù)：");
                        String response  = serverResponse.readLine();
                        out.println(response);
                    }
                }
            }
            out.close();
            client.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

可以和小伙伴試試看，分別啟動SocketServer和SocketClient并進(jìn)行通信。不過前提是你們兩個需要在一個局域網(wǎng)中。

Java實現(xiàn)單線程服務(wù)器

上面的服務(wù)器其實只在主線程監(jiān)聽了一個Socket連接，并在30秒之后將其自動關(guān)閉了。我們將實現(xiàn)一個經(jīng)典的單線程服務(wù)器。原理和上面相似，這里我們可以直接通過向服務(wù)器發(fā)送HTTP請求來驗證該服務(wù)器的運(yùn)行。

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

public class SingleThreadServer implements Runnable{

    private ServerSocket serverSocket;

    public SingleThreadServer(ServerSocket serverSocket){
        this.serverSocket = serverSocket;
    }
    @Override
    public void run() {
        Socket socket = null;
        try{
            while (!Thread.interrupted()){
                socket = serverSocket.accept();

                //谷歌瀏覽器每次會發(fā)送兩個請求
                //一次用于獲取html
                //一次用于獲取favicon
                //如果獲取favicon成功就緩存，否則會一直請求獲得favicon
                //而火狐瀏覽器第一次也會發(fā)出這兩個請求
                //在獲得favicon失敗后就不會繼續(xù)嘗試獲取favicon
                //因此使用谷歌瀏覽器訪問該Server的話，你會看到 連接成功 被打印兩次
                System.out.println("連接成功");
                process(socket);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                socket.close();
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    private void process(Socket socket){
        try {

            InputStreamReader inputStreamReader = null;
            BufferedOutputStream bufferedOutputStream = null;
            try{
                inputStreamReader = new InputStreamReader(socket.getInputStream());
                bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());

                //這里無法正常讀取輸入流，因為在沒有遇到EOF之前，流會任務(wù)socket輸入尚未結(jié)束，將會繼續(xù)等待直到socket中斷
                //所以這里我們將暫時不讀取Socket的輸入流中的內(nèi)容。
                //int size;
                //char[] buffer = new char[1024];
                //StringBuilder stringBuilder = new StringBuilder();
                //while ((size = inputStreamReader.read(buffer)) > 0){
                  //  stringBuilder.append(buffer, 0, size);
                //}


                byte[] responseDocument = " Hello World ".getBytes("UTF-8");
                byte[] responseHeader = ("HTTP/1.1 200 OK
Content-Type: text/html; charset=UTF-8
Content-Length: " + responseDocument.length + "

").getBytes("UTF-8");

                bufferedOutputStream.write(responseHeader);
                bufferedOutputStream.write(responseDocument);
            }finally {
                bufferedOutputStream.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

該服務(wù)器用單一線程處理每次請求，每個線程都將等待服務(wù)器處理完上一個請求之后才能獲得響應(yīng)。這里需要注意，純HTTP請求的輸入流的讀取會遇到輸入流阻塞的問題，因為HTTP請求并沒有輸入流可識別的EOF標(biāo)記。從而導(dǎo)致服務(wù)器一直掛起在讀取輸入流的地方。它的解決方法如下：

客戶端關(guān)閉Socket連接，強(qiáng)制服務(wù)器關(guān)閉該Socket連接。但是同時也丟失服務(wù)器響應(yīng)

自定義協(xié)議，從而服務(wù)器可以識別數(shù)據(jù)的終點(diǎn)。

啟動服務(wù)器

public static void main(String[] args) throws IOException, InterruptedException {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        ServerSocket serverSocket = new ServerSocket(2048);
        executorService.execute(new SingleThreadServer(serverSocket));

//        TimeUnit.SECONDS.sleep(10);
//        System.out.println("shut down server");
//        executorService.shutdownNow();
    }

注意要先關(guān)閉之前占用2048端口號的服務(wù)器。

我們也可以使用代碼來測試：

import java.io.*;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class TestSingleThreadServer {

    public static void main(String[] args) throws InterruptedException {
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0 ; i<10 ; i++){
            final int threadId = i;
            executorService.execute(() ->{

                try {
                    Socket socket = new Socket("127.0.0.1", 20006);
                    socket.setSoTimeout(5000);

                    BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                    String line = bufferedReader.readLine();

                    System.out.println(threadId + ":" + line);

                    socket.close();;
                } catch (IOException e) {
                    e.printStackTrace();
                }

            });

        }

        TimeUnit.SECONDS.sleep(40);
        executorService.shutdownNow();
    }
}

Java實現(xiàn)多線程服務(wù)器

這里我們將為每一個Socket連接提供一個線程來處理?；緦崿F(xiàn)和上面差不多，只是將每一個Socket連接丟給一個額外的線程來處理。這里可以參考前面的簡易聊天室來試著自己實現(xiàn)以下。

Java NIO實現(xiàn)復(fù)用服務(wù)器

NIO的出現(xiàn)改變了舊式Java讀取IO流的方式。首先，它支持非阻塞式讀取，其次它可以使用一個線程來管理多個信道。多線程表面上看起來可以同時處理多個Socket通信，但是多線程的管理本身也消耗相當(dāng)多的資源。其次，很多信道的使用率往往并不高，一些信道往往并不是連通狀態(tài)中。如果我們可以將資源直接賦予當(dāng)前活躍的Socket通信的話，可以明顯的提高資源利用率。

先附上參考資料將在后序更新。

參考書籍

HTTP權(quán)威指南
Java TCP/IP Socket 編程
Java Multithread servers
Java NIO ServerSocketChannel

想要了解更多開發(fā)技術(shù)，面試教程以及互聯(lián)網(wǎng)公司內(nèi)推，歡迎關(guān)注我的微信公眾號！將會不定期的發(fā)放福利哦~

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/68829.html

發(fā)表評論

登陸后可評論

0條評論

張漢慶

男|高級講師

我要關(guān)注我要私信

TA的文章

#11.11#iON Cloud：洛杉磯/圣何塞2核2G內(nèi)存云服務(wù)器$11.11/月或$111.1/

閱讀 852·2021-11-16 11:56
中國國旅大學(xué)校園市場調(diào)研方案

閱讀 1676·2021-11-16 11:45
利用小基助手瀏覽器插件和小程序可隨時關(guān)注基金收益數(shù)據(jù)

閱讀 3124·2021-10-08 10:13
什么是主機(jī)名-手機(jī)正常的主機(jī)名是什么？

閱讀 4113·2021-09-22 15:27
Sticky Foolter 幾種實現(xiàn)方式

閱讀 734·2019-08-30 11:03
重學(xué)前端學(xué)習(xí)筆記（二十二）--選擇器的機(jī)制

閱讀 652·2019-08-30 10:56
讓你的 webpack sass 和 css 處理性能 10 倍提升

閱讀 957·2019-08-29 15:18
匠心打造Vue側(cè)滑菜單組件

閱讀 1750·2019-08-29 14:05

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

初探Java Socket

相關(guān)文章

Netty4.x 源碼實戰(zhàn)系列（一）：ServerBootstrap 與 Bootstrap 初探

初探ZeroMQ

初探WebSocket

發(fā)表評論

0條評論

張漢慶

男|高級講師

TA的文章

#11.11#iON Cloud：洛杉磯/圣何塞2核2G內(nèi)存云服務(wù)器$11.11/月或$111.1/

中國國旅大學(xué)校園市場調(diào)研方案

利用小基助手瀏覽器插件和小程序可隨時關(guān)注基金收益數(shù)據(jù)

什么是主機(jī)名-手機(jī)正常的主機(jī)名是什么？

Sticky Foolter 幾種實現(xiàn)方式

重學(xué)前端學(xué)習(xí)筆記（二十二）--選擇器的機(jī)制

讓你的 webpack sass 和 css 處理性能 10 倍提升

匠心打造Vue側(cè)滑菜單組件

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

初探Java Socket

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！