Java中的TCP通信程式
TCP可以實作兩臺計算機之間的資料互動通信的兩端,要嚴格區分客戶端與服務端
兩端通信時的步驟:
1.服務端程式,需要事先啟動,等待客戶端連接
2.客戶端主動連接服務器端,才能成功通信,服務器端不可以主動鏈接客戶端
在java中兩個類用于實作TCP通信程式:
- 客戶端: java.net.Socket 類表示,創建 Socket 物件,向服務端發出連接請求,服務端回應請求,兩者建 立連接開始通信,
- 服務端: java.net.ServerSocket 類表示,創建 ServerSocket 物件,相當于開啟一個服務,并等待客戶端 的連接,
Socket類
socket類:該類實作客戶端套接字,套接字是指兩臺設備之間的端點
構造方法:
public Socket(String host,int port):創建套接字物件并將其連接到指定物件的主機上,如果指定的host為NULL,則相當于指定的地址為回送地址
回送地址
回送地址(127.x.x.x) 是本機回送地址(Loopback Address),主要用于網路軟體測驗以及本 地機行程間通信,無論什么程式,一旦使用回送地址發送資料,立即回傳,不進行任何網路傳輸,
構造舉例
Socket client=new Socket(“127.0.0.1”,666)
成員方法:
public InputStream getInputStream() : 回傳此套接字的輸入流, 如果此Scoket具有相關聯的通道,則生成的InputStream 的所有操作也關聯該通道, 關閉生成的InputStream也將關閉相關的Socket,
public OutputStream getOutputStream() : 回傳此套接字的輸出流, 如果此Scoket具有相關聯的通道,則生成的OutputStream 的所有操作也關聯該通道, 關閉生成的OutputStream也將關閉相關的Socket
public void close() :關閉此套接字, 一旦一個socket被關閉,它不可再使用, 關閉此socket也將關閉相關的InputStream和OutputStream ,
public void shutdownOutput() : 禁用此套接字的輸出流, 任何先前寫出的資料將被發送,隨后終止輸出流,
ServerSocket類
public ServerSocket(int port) :使用該構造方法在創建ServerSocket物件時,就可以將其系結到一個指 定的埠號上,引數port就是埠號
構造舉例代碼如下:
ServerSocket server=new ServerSocket(666)
成員方法 public Socket accept() :偵聽并接受連接,回傳一個新的Socket物件,用于和客戶端實作通信,
兩個需要明確的事情
1多個服務器端與客戶進行互動,服務器必須明確是和哪個客戶端進行互動,這個accept()方法用與獲取請求的客戶端物件
2.多個客戶端同時與服務器進行互動就需要使用多個io流物件
服務器是沒有io流的,服務器可以獲取到請求的客戶端物件的scoket,使用每一個客戶端Socket中提供的io流物件進行互動,
服務器端使用客戶端的位元組輸入流讀取客戶端發送的資料,
服務器端使用客戶端的位元組輸出流給客戶端回寫資料
即服務器端使用客戶端流與客戶端互動
好比生活中的我請客你買單

簡單的TCP網路程式圖解
- 【服務端】啟動,創建ServerSocket物件,等待連接, Socket client = new Socket("127.0.0.1", 6666); ServerSocket server = new ServerSocket(6666);
- 【客戶端】啟動,創建Socket物件,請求連接,
- 【服務端】接收連接,呼叫accept方法,并回傳一個Socket物件
- 【客戶端】Socket物件,獲取OutputStream,向服務端寫出資料
- 【服務端】Scoket物件,獲取InputStream,讀取客戶端發送的資料,
- 【服務端】Socket物件,獲取OutputStream,向客戶端回寫資料,
- 【客戶端】Scoket物件,獲取InputStream,決議回寫資料
- 【客戶端】釋放資源,斷開連接,

該方法 會一直阻塞直到建立連接,
下面寫一段簡單的客戶端與服務器端互動的代碼
服務器端代碼
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("服務器啟動等待連接:");
//創建服務器端物件
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);
//通過位元組陣列生成字串
String s = new String(bytes,0,read);
//輸出
System.out.println(s);
//向客戶端回傳資訊
OutputStream outputStream = accept.getOutputStream();
//回傳內容
outputStream.write("內容已經收到".getBytes());
//關閉資源
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 {
//創建Socket物件
Socket socket = new Socket("127.0.0.1", 8888);
//獲取輸出流
OutputStream outputStream = socket.getOutputStream();
//給服務端發送訊息
outputStream.write("你好".getBytes());
//創建輸入流物件
InputStream inputStream = socket.getInputStream();
//創建讀取的陣列
byte[] bytes = new byte[1024];
//獲取位元組陣列的長度
int read = inputStream.read(bytes);
//輸出結果
System.out.println(new String(bytes,0,read));
//關閉流
outputStream.close();
//關閉Socket物件
socket.close();
}
}
結果
服務器端

客戶端

以上就是Java中的TCP通信程式的一些基本操作,喜歡我的可以點贊收藏一波,我會不定期跟新文章,喜歡我的可以關注呀

轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/138752.html
標籤:Java
