如何用JAVA的socket-創(chuàng)新互聯(lián)

這篇文章主要講解了“如何用JAVA的socket”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“如何用JAVA的socket”吧！

成都創(chuàng)新互聯(lián)長期為成百上千客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺(tái)，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為米東企業(yè)提供專業(yè)的成都網(wǎng)站建設(shè)、成都網(wǎng)站制作，米東網(wǎng)站改版等技術(shù)服務(wù)。擁有10余年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。

JAVA 中原生的 socket 通信機(jī)制

當(dāng)前環(huán)境

  1. jdk == 1.8

知識(shí)點(diǎn)

  • socket 的連接處理

  • IO 輸入、輸出流的處理

  • 請求數(shù)據(jù)格式處理

  • 請求模型優(yōu)化

場景

這里采用最簡單的一請求一響應(yīng)模型為例，假設(shè)我們現(xiàn)在需要向 baidu 站點(diǎn)進(jìn)行通信。

建立 socket 連接

首先，我們需要建立 socket 連接（核心代碼）

import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
// 初始化 socket
Socket socket = new Socket();
// 初始化遠(yuǎn)程連接地址
SocketAddress remote = new InetSocketAddress(host, port);
// 建立連接
socket.connect(remote);

處理 socket 輸入輸出流

成功建立 socket 連接后，我們就能獲得它的輸入輸出流，通信的本質(zhì)是對輸入輸出流的處理。通過輸入流，讀取網(wǎng)絡(luò)連接上傳來的數(shù)據(jù)，通過輸出流，將本地的數(shù)據(jù)傳出給遠(yuǎn)端。

socket 連接實(shí)際與處理文件流有點(diǎn)類似，都是在進(jìn)行 IO 操作。

獲取輸入、輸出流代碼如下：

// 輸入流
InputStream in = socket.getInputStream();
// 輸出流
OutputStream out = socket.getOutputStream();

關(guān)于 IO 流的處理，我們一般會(huì)用相應(yīng)的包裝類來處理 IO 流，如果直接處理的話，我們需要對 byte[] 進(jìn)行操作，而這是相對比較繁瑣的。如果采用包裝類，我們可以直接以string、int等類型進(jìn)行處理，簡化了 IO 字節(jié)操作。

下面以 BufferedReader 與 PrintWriter 作為輸入輸出的包裝類進(jìn)行處理。

// 獲取 socket 輸入流
private BufferedReader getReader(Socket socket) throws IOException {
    InputStream in = socket.getInputStream();
    return new BufferedReader(new InputStreamReader(in));
}
// 獲取 socket 輸出流
private PrintWriter getWriter(Socket socket) throws IOException {
    OutputStream out = socket.getOutputStream();
    return new PrintWriter(new OutputStreamWriter(out));
}

數(shù)據(jù)請求與響應(yīng)

有了 socket 連接、IO 輸入輸出流，下面就該向發(fā)送請求數(shù)據(jù)，以及獲取請求的響應(yīng)結(jié)果。

因?yàn)橛辛?IO 包裝類的支持，我們可以直接以字符串的格式進(jìn)行傳輸，由包裝類幫我們將數(shù)據(jù)裝換成相應(yīng)的字節(jié)流。

因?yàn)槲覀兣c baidu 站點(diǎn)進(jìn)行的是 HTTP 訪問，所有我們不需要額外定義輸出格式。采用標(biāo)準(zhǔn)的 HTTP 傳輸格式，就能進(jìn)行請求響應(yīng)了（某些特定的 RPC 框架，可能會(huì)有自定義的通信格式）。

請求的數(shù)據(jù)內(nèi)容處理如下：

public class HttpUtil {
    public static String compositeRequest(String host){
        return "GET / HTTP/1.1\r\n" +
                "Host: " + host + "\r\n" +
                "User-Agent: curl/7.43.0\r\n" +
                "Accept: */*\r\n\r\n";
    }
}

發(fā)送請求數(shù)據(jù)代碼如下：

// 發(fā)起請求
PrintWriter writer = getWriter(socket);
writer.write(HttpUtil.compositeRequest(host));
writer.flush();

接收響應(yīng)數(shù)據(jù)代碼如下：

// 讀取響應(yīng)
String msg;
BufferedReader reader = getReader(socket);
while ((msg = reader.readLine()) != null){
    System.out.println(msg);
}

結(jié)果展示

至此，講完了原生 socket 下的創(chuàng)建連接、發(fā)送請求與接收響應(yīng)的所有核心代碼。

完整代碼如下：

import java.io.*;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
import com.test.network.util.HttpUtil;
public class SocketHttpClient {
    public void start(String host, int port) {
        // 初始化 socket
        Socket socket = new Socket();
        try {
            // 設(shè)置 socket 連接
            SocketAddress remote = new InetSocketAddress(host, port);
            socket.setSoTimeout(5000);
            socket.connect(remote);
            // 發(fā)起請求
            PrintWriter writer = getWriter(socket);
            System.out.println(HttpUtil.compositeRequest(host));
            writer.write(HttpUtil.compositeRequest(host));
            writer.flush();
            // 讀取響應(yīng)
            String msg;
            BufferedReader reader = getReader(socket);
            while ((msg = reader.readLine()) != null){
                System.out.println(msg);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    private BufferedReader getReader(Socket socket) throws IOException {
        InputStream in = socket.getInputStream();
        return new BufferedReader(new InputStreamReader(in));
    }
    private PrintWriter getWriter(Socket socket) throws IOException {
        OutputStream out = socket.getOutputStream();
        return new PrintWriter(new OutputStreamWriter(out));
    }
}

下面，我們通過實(shí)例化一個(gè)客戶端，來展示 socket 通信的結(jié)果。

public class Application {
    public static void main(String[] args) {
        new SocketHttpClient().start("www.baidu.com", 80);
    }
}

結(jié)果輸出：

如何用JAVA的socket

請求模型優(yōu)化

這種方式，雖然實(shí)現(xiàn)功能沒什么問題。但是我們細(xì)看，發(fā)現(xiàn)在 IO 寫入與讀取過程，是發(fā)生了 IO 阻塞的情況。即：

// 會(huì)發(fā)生 IO 阻塞
writer.write(HttpUtil.compositeRequest(host));
reader.readLine();

所以如果要同時(shí)請求10個(gè)不同的站點(diǎn)，如下：

public class SingleThreadApplication {
    public static void main(String[] args) {
        // HttpConstant.HOSTS 為 站點(diǎn)集合
        for (String host: HttpConstant.HOSTS) {
            new SocketHttpClient().start(host, HttpConstant.PORT);
        }
    }
}

它一定是第一個(gè)請求響應(yīng)結(jié)束后，才會(huì)發(fā)起下一個(gè)站點(diǎn)處理。

這在服務(wù)端更明顯，雖然這里的代碼是客戶端連接，但是具體的操作和服務(wù)端是差不多的。請求只能一個(gè)個(gè)串行處理，這在響應(yīng)時(shí)間上肯定不能達(dá)標(biāo)。

  • 多線程處理

有人覺得這根本不是問題，JAVA 是多線程的編程語言。對于這種情況，采用多線程的模型再合適不過。

public class MultiThreadApplication {
    public static void main(String[] args) {
        for (final String host: HttpConstant.HOSTS) {
            Thread t = new Thread(new Runnable() {
                public void run() {
                    new SocketHttpClient().start(host, HttpConstant.PORT);
                }
            });
            t.start();
        }
    }
}

這種方式起初看起來挺有用的，但并發(fā)量一大，應(yīng)用會(huì)起很多的線程。都知道，在服務(wù)器上，每一個(gè)線程實(shí)際都會(huì)占據(jù)一個(gè)文件句柄。而服務(wù)器上的句柄數(shù)是有限的，而且大量的線程，造成的線程間切換的消耗也會(huì)相當(dāng)?shù)拇?。所以這種方式在并發(fā)量大的場景下，一定是承載不住的。

  • 多線程 + 線程池 處理

既然線程太多不行，那我們控制一下線程創(chuàng)建的數(shù)目不就行了。只啟動(dòng)固定的線程數(shù)來進(jìn)行 socket 處理，既利用了多線程的處理，又控制了系統(tǒng)的資源消耗。

public class ThreadPoolApplication {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(8);
        for (final String host: HttpConstant.HOSTS) {
            Thread t = new Thread(new Runnable() {
                public void run() {
                    new SocketHttpClient().start(host, HttpConstant.PORT);
                }
            });
            executorService.submit(t);
            new SocketHttpClient().start(host, HttpConstant.PORT);
        }
    }
}

關(guān)于啟動(dòng)的線程數(shù)，一般 CPU 密集型會(huì)設(shè)置在 N+1（N為CPU核數(shù)），IO 密集型設(shè)置在 2N + 1。

這種方式，看起來是最優(yōu)的了。那有沒有更好的呢，如果一個(gè)線程能同時(shí)處理多個(gè) socket 連接，并且在每個(gè) socket 輸入輸出數(shù)據(jù)沒有準(zhǔn)備好的情況下，不進(jìn)行阻塞，那是不是更優(yōu)呢。這種技術(shù)叫做“IO多路復(fù)用”。在 JAVA 的 nio 包中，提供了相應(yīng)的實(shí)現(xiàn)。

補(bǔ)充1：TCP客戶端與服務(wù)端

public class TCP客戶端 {
    public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
  public void run() {
                try {
                    Socket s = new Socket("127.0.0.1",1234);    //構(gòu)建IO
  InputStream is = s.getInputStream();
  OutputStream os = s.getOutputStream();    BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
  //向服務(wù)器端發(fā)送一條消息
  bw.write("測試客戶端和服務(wù)器通信，服務(wù)器接收到消息返回到客戶端\n");
  bw.flush();    //讀取服務(wù)器返回的消息
  BufferedReader br = new BufferedReader(new InputStreamReader(is));
  String mess = br.readLine();
  System._out_.println("服務(wù)器："+mess);
  } catch (UnknownHostException e) {
                    e.printStackTrace();
  } catch (IOException e) {
                    e.printStackTrace();
  }
            }
        }).start();
  }
}
public class TCP服務(wù)端 {
    public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
  public void run() {
                try {
                    ServerSocket ss = new ServerSocket(1234);
 while (true) {
                        System._out_.println("啟動(dòng)服務(wù)器....");
  Socket s = ss.accept();
  System._out_.println("客戶端:" + s.getInetAddress().getLocalHost() + "已連接到服務(wù)器");
  BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
  //讀取客戶端發(fā)送來的消息
  String mess = br.readLine();
  System._out_.println("客戶端：" + mess);
  BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
  bw.write(mess + "\n");
  bw.flush();
  }
                } catch (IOException e) {
                    e.printStackTrace();
  }
            }
        }).start();
  }
}

補(bǔ)充2：UDP客戶端和服務(wù)端

public class UDP客戶端 {
    public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
  public void run() {
                byte []arr = "Hello Server".getBytes();
 try {
                    InetAddress inetAddress = InetAddress.getLocalHost();
  DatagramSocket datagramSocket = new DatagramSocket();
  DatagramPacket datagramPacket = new DatagramPacket(arr, arr.length, inetAddress, 1234);
  datagramSocket.send(datagramPacket);
  System._out_.println("send end");
  } catch (UnknownHostException e) {
                    e.printStackTrace();
  } catch (SocketException e) {
                    e.printStackTrace();
  } catch (IOException e) {
                    e.printStackTrace();
  }
            }
        }).start();
  }
}
public class UDP服務(wù)端 {
    public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
  public void run() {
                try {
                    DatagramSocket datagramSocket = new DatagramSocket(1234);
 byte[] buffer = new byte[1024];
  DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
  datagramSocket.receive(packet);
  System._out_.println("server recv");
  String msg = new String(packet.getData(), "utf-8");
  System._out_.println(msg);
  } catch (SocketException e) {
                    e.printStackTrace();
  } catch (IOException e) {
                    e.printStackTrace();
  }
            }
        }).start();
  }
}

感謝各位的閱讀，以上就是“如何用JAVA的socket”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對如何用JAVA的socket這一問題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！

文章題目：如何用JAVA的socket-創(chuàng)新互聯(lián)
分享鏈接：http://www.muchs.cn/article4/ceooie.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、用戶體驗(yàn)、App設(shè)計(jì)、全網(wǎng)營銷推廣、搜索引擎優(yōu)化、外貿(mào)網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)

外貿(mào)網(wǎng)站建設(shè)