欧美成人免费全部,乱子轮熟睡1区

快捷導(dǎo)航

Java實(shí)現(xiàn)基于TCP的通訊程序?qū)嵗馕?/h1>

更新時間：2020年07月24日 11:34:12 作者：一只胡說八道的猴子

這篇文章主要介紹了Java實(shí)現(xiàn)基于TCP的通訊程序?qū)嵗馕?，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

Java中的TCP通信程序

TCP可以實(shí)現(xiàn)兩臺計(jì)算機(jī)之間的數(shù)據(jù)交互通信的兩端，要嚴(yán)格區(qū)分客戶端與服務(wù)端
兩端通信時的步驟：
1.服務(wù)端程序，需要事先啟動，等待客戶端連接
2.客戶端主動連接服務(wù)器端，才能成功通信，服務(wù)器端不可以主動鏈接客戶端

在java中兩個類用于實(shí)現(xiàn)TCP通信程序：

客戶端： java.net.Socket 類表示。創(chuàng)建 Socket 對象，向服務(wù)端發(fā)出連接請求，服務(wù)端響應(yīng)請求，兩者建立連接開始通信。
服務(wù)端： java.net.ServerSocket 類表示。創(chuàng)建 ServerSocket 對象，相當(dāng)于開啟一個服務(wù)，并等待客戶端的連接。

Socket類

socket類：該類實(shí)現(xiàn)客戶端套接字，套接字是指兩臺設(shè)備之間的端點(diǎn)

構(gòu)造方法：
public Socket（String host，int port）：創(chuàng)建套接字對象并將其連接到指定對象的主機(jī)上，如果指定的host為NULL，則相當(dāng)于指定的地址為回送地址
回送地址
回送地址(127.x.x.x) 是本機(jī)回送地址（Loopback Address），主要用于網(wǎng)絡(luò)軟件測試以及本地機(jī)進(jìn)程間通信，無論什么程序，一旦使用回送地址發(fā)送數(shù)據(jù)，立即返回，不進(jìn)行任何網(wǎng)絡(luò)傳輸。
構(gòu)造舉例

Socket client=new Socket（“127.0.0.1”，666）

成員方法：
public InputStream getInputStream() ：返回此套接字的輸入流。如果此Scoket具有相關(guān)聯(lián)的通道，則生成的InputStream 的所有操作也關(guān)聯(lián)該通道。關(guān)閉生成的InputStream也將關(guān)閉相關(guān)的Socket。

public OutputStream getOutputStream() ：返回此套接字的輸出流。如果此Scoket具有相關(guān)聯(lián)的通道，則生成的OutputStream 的所有操作也關(guān)聯(lián)該通道。關(guān)閉生成的OutputStream也將關(guān)閉相關(guān)的Socket

public void close() ：關(guān)閉此套接字。一旦一個socket被關(guān)閉，它不可再使用。關(guān)閉此socket也將關(guān)閉相關(guān)的InputStream和OutputStream 。
public void shutdownOutput() ：禁用此套接字的輸出流。任何先前寫出的數(shù)據(jù)將被發(fā)送，隨后終止輸出流。

ServerSocket類

public ServerSocket(int port) ：使用該構(gòu)造方法在創(chuàng)建ServerSocket對象時，就可以將其綁定到一個指定的端口號上，參數(shù)port就是端口號
構(gòu)造舉例代碼如下：

ServerSocket server=new ServerSocket（666）

成員方法 public Socket accept() ：偵聽并接受連接，返回一個新的Socket對象，用于和客戶端實(shí)現(xiàn)通信。
兩個需要明確的事情
1多個服務(wù)器端與客戶進(jìn)行交互，服務(wù)器必須明確是和哪個客戶端進(jìn)行交互，這個accept（）方法用與獲取請求的客戶端對象
2.多個客戶端同時與服務(wù)器進(jìn)行交互就需要使用多個io流對象
服務(wù)器是沒有io流的，服務(wù)器可以獲取到請求的客戶端對象的scoket，使用每一個客戶端Socket中提供的io流對象進(jìn)行交互。
服務(wù)器端使用客戶端的字節(jié)輸入流讀取客戶端發(fā)送的數(shù)據(jù)，
服務(wù)器端使用客戶端的字節(jié)輸出流給客戶端回寫數(shù)據(jù)
即服務(wù)器端使用客戶端流與客戶端交互
好比生活中的我請客你買單

簡單的TCP網(wǎng)絡(luò)程序圖解

【服務(wù)端】啟動,創(chuàng)建ServerSocket對象，等待連接。 Socket client = new Socket("127.0.0.1", 6666); ServerSocket server = new ServerSocket(6666);
【客戶端】啟動,創(chuàng)建Socket對象，請求連接。
【服務(wù)端】接收連接,調(diào)用accept方法，并返回一個Socket對象
【客戶端】Socket對象，獲取OutputStream，向服務(wù)端寫出數(shù)據(jù)
【服務(wù)端】Scoket對象，獲取InputStream，讀取客戶端發(fā)送的數(shù)據(jù)。
【服務(wù)端】Socket對象，獲取OutputStream，向客戶端回寫數(shù)據(jù)。
【客戶端】Scoket對象，獲取InputStream，解析回寫數(shù)據(jù)
【客戶端】釋放資源，斷開連接。

該方法會一直阻塞直到建立連接。

下面寫一段簡單的客戶端與服務(wù)器端交互的代碼

服務(wù)器端代碼

package Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
 public static void main(String[] args) throws IOException {
  System.out.println("服務(wù)器啟動等待連接：");
  //創(chuàng)建服務(wù)器端對象
  ServerSocket serverSocket = new ServerSocket(8888);
  //使用accept方法接受socket對象
  Socket accept = serverSocket.accept();
  //通過socket獲取輸入流
  InputStream inputStream = accept.getInputStream();
  //會不會阻塞
  System.out.println("XXXXXXXXXXXXXXXXX");
  byte[] bytes = new byte[1024];
  int read = inputStream.read(bytes);
  //通過字節(jié)數(shù)組生成字符串
  String s = new String(bytes,0,read);
  //輸出
  System.out.println(s);
  //向客戶端返回信息
  OutputStream outputStream = accept.getOutputStream();
  //返回內(nèi)容
  outputStream.write("內(nèi)容已經(jīng)收到".getBytes());
  //關(guān)閉資源
  inputStream.close();
  serverSocket.close();
 }
}

客戶端代碼

package Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class Client {
 public static void main(String[] args) throws IOException {
  //創(chuàng)建Socket對象
  Socket socket = new Socket("127.0.0.1", 8888);
  //獲取輸出流
  OutputStream outputStream = socket.getOutputStream();
  //給服務(wù)端發(fā)送消息
  outputStream.write("你好".getBytes());
  //創(chuàng)建輸入流對象
  InputStream inputStream = socket.getInputStream();
  //創(chuàng)建讀取的數(shù)組
  byte[] bytes = new byte[1024];
  //獲取字節(jié)數(shù)組的長度
  int read = inputStream.read(bytes);
  //輸出結(jié)果
  System.out.println(new String(bytes,0,read));
  //關(guān)閉流
  outputStream.close();
  //關(guān)閉Socket對象
  socket.close();
 }
}

結(jié)果

服務(wù)器端