TCP Socket如何使用

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

Java為TCP協(xié)議提供了兩個(gè)類，分別在客戶端編程和服務(wù)器端編程中使用它們。在應(yīng)用程序開(kāi)始通信之前，需要先創(chuàng)建一個(gè)連接，由客戶端程序發(fā)起；而服務(wù)器端的程序需要一直監(jiān)聽(tīng)著主機(jī)的特定端口號(hào)，等待客戶端的連接。在客戶端中我們只需要使用Socket實(shí)例，而服務(wù)端要同時(shí)處理ServerSocket實(shí)例和Socket實(shí)例;二者并且都使用OutputStream和InpuStream來(lái)發(fā)送和接收數(shù)據(jù)。

學(xué)習(xí)一種知識(shí)***的方式就是使用它，通過(guò)前面的筆記，我們已經(jīng)知道如何獲取主機(jī)的地址信息，現(xiàn)在我們通過(guò)一個(gè)簡(jiǎn)單的程序來(lái)初步學(xué)習(xí)傳輸層使用了TCP協(xié)議的Socket編程。

TCP服務(wù)器端

在Socket編程中，服務(wù)器端遠(yuǎn)比客戶端要復(fù)雜得多。服務(wù)器端的工作就是建立一個(gè)通信終端，被動(dòng)的等待客戶端的連接。下面這個(gè)服務(wù)器端程序的示例的作用是：監(jiān)聽(tīng)從控制臺(tái)輸入獲取的端口號(hào)，并且將客戶端發(fā)送過(guò)來(lái)的消息，再發(fā)送回去。

import java.net.*;   import java.text.MessageFormat;   import java.io.*;      public class TCPEchoServer {          private static final int BUFSIZE = 32;          /**        * @param args    */      public static void main(String[] args) throws IOException {           // TODO Auto-generated method stub    // 從控制臺(tái)獲取需要監(jiān)聽(tīng)的端口號(hào)           if (args.length != 1)               throw new IllegalArgumentException("Parameter(s):<Port>");           // 獲取端口號(hào)           int servPort = Integer.parseInt(args[0]);           // 實(shí)例化一個(gè)ServerSocket對(duì)象實(shí)例           ServerSocket servSocket = new ServerSocket(servPort);           System.out.println(MessageFormat.format("開(kāi)始啟動(dòng)監(jiān)聽(tīng)，端口號(hào):{0}", args[0]));              // 初始接收數(shù)據(jù)的總字節(jié)數(shù)           int recvMsgSize;           // 接收數(shù)據(jù)的緩沖區(qū)           byte[] receiveBuf = new byte[BUFSIZE];              // 循環(huán)迭代，監(jiān)聽(tīng)端口號(hào),處理新的連接請(qǐng)求           while (true) {               // 阻塞等待，每接收到一個(gè)請(qǐng)求就創(chuàng)建一個(gè)新的連接實(shí)例               Socket clntSocket = servSocket.accept();               // 獲取連接的客戶端的 SocketAddress               SocketAddress clientAddress = clntSocket.getRemoteSocketAddress();               // 打印輸出連接客戶端地址信息               System.out.println("Handling client at" + clientAddress);               // 從客戶端接收數(shù)據(jù)的對(duì)象               InputStream in = clntSocket.getInputStream();               // 向客戶端發(fā)送數(shù)據(jù)的對(duì)象               OutputStream out = clntSocket.getOutputStream();               // 讀取客戶端發(fā)送的數(shù)據(jù)后，再發(fā)送到客戶端               while ((recvMsgSize = in.read(receiveBuf)) != -1) {                   out.write(receiveBuf, 0, recvMsgSize);               }               // 客戶端關(guān)閉連接時(shí)，關(guān)閉連接               System.out.println(" 客戶端關(guān)閉連接");               clntSocket.close();           }          }      }

TCP客戶端

在Socket編程中，首先客戶端需要向服務(wù)器端發(fā)送，然后被動(dòng)的等待服務(wù)器端的響應(yīng)。下面的示例中：我們向服務(wù)器端發(fā)送信息，等待服務(wù)器端發(fā)送的消息，并打印顯示出來(lái)。

import java.io.*;   import java.net.Socket;   import java.net.SocketException;      public class TCPEchoClient {          /**        * @param args        * @throws IOException     */      public static void main(String[] args) throws IOException {           // TODO Auto-generated method stub    // 判斷從控制臺(tái)接受的參數(shù)是否正確           if ((args.length < 2) || (args.length > 3))               throw new IllegalArgumentException(                       "Parameter(s):<Server><Word>[<Port>]]");           // 獲取服務(wù)器地址           String server = args[0];           // 獲取需要發(fā)送的信息           byte[] data = args[1].getBytes();           // 如果有三個(gè)從參數(shù)那么就獲取發(fā)送信息的端口號(hào)，默認(rèn)端口號(hào)為8099           int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 8099;           // 根據(jù)服務(wù)器地址和端口號(hào)實(shí)例化一個(gè)Socket實(shí)例           Socket socket = new Socket(server, servPort);           System.out.println("Connected to server...sending echo string");           // 返回此套接字的輸入流，即從服務(wù)器接受的數(shù)據(jù)對(duì)象           InputStream in = socket.getInputStream();           // 返回此套接字的輸出流，即向服務(wù)器發(fā)送的數(shù)據(jù)對(duì)象           OutputStream out = socket.getOutputStream();           // 向服務(wù)器發(fā)送從控制臺(tái)接收的數(shù)據(jù)           out.write(data);           // 接收數(shù)據(jù)的計(jì)數(shù)器，將寫入數(shù)據(jù)的初始偏移量           int totalBytesRcvd = 0;           // 初始化接收數(shù)據(jù)的總字節(jié)數(shù)           int bytesRcvd;           while (totalBytesRcvd < data.length) {               // 服務(wù)器關(guān)閉連接，則返回 -1,read方法返回接收數(shù)據(jù)的總字節(jié)數(shù)               if ((bytesRcvd = in.read(data, totalBytesRcvd, data.length                       - totalBytesRcvd)) == -1)                   throw new SocketException("與服務(wù)器的連接已關(guān)閉");               totalBytesRcvd += bytesRcvd;           }           // 打印服務(wù)器發(fā)送來(lái)的數(shù)據(jù)           System.out.println("Received:" + new String(data));           // 關(guān)閉連接           socket.close();          }      }

首先運(yùn)行服務(wù)器端,監(jiān)聽(tīng)8099端口：

接著運(yùn)行客戶端程序，并且向服務(wù)器端發(fā)送消息：

再次查看我們的服務(wù)器端控制臺(tái)，我們可以看到前面客戶端連接的地址信息：

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