概述:
TCP通信能實現(xiàn)兩臺計算機之間的數(shù)據(jù)交互兔甘,通信的兩端花吟,要嚴格區(qū)分為客戶端(Client)與服務(wù)端(Server)胞锰。
兩端通信時步驟:
- 服務(wù)端程序爽茴,需要事先啟動葬凳,等待客戶端的連接。
- 客戶端主動連接服務(wù)器端室奏,連接成功才能通信火焰。服務(wù)端不可以主動連接客戶端。
在Java中胧沫,提供了兩個類用于實現(xiàn)TCP通信程序: - 客戶端: java.net.Socket 類表示昌简。創(chuàng)建 Socket 對象占业,向服務(wù)端發(fā)出連接請求,服務(wù)端響應(yīng)請求纯赎,兩者建 立連接開始通信谦疾。
- 服務(wù)端: java.net.ServerSocket 類表示。創(chuàng)建 ServerSocket 對象犬金,相當于開啟一個服務(wù)念恍,并等待客戶端 的連接。
image.png
服務(wù)器沒有流晚顷,就使用客戶端的流與客戶端進行交互
代碼實現(xiàn)
實現(xiàn)步驟:
1.創(chuàng)建一個客戶端對象Socket,構(gòu)造方法綁定服務(wù)器的IP地址和端口號
2.使用Socket對象中的方法getOutputStream()獲取網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象
3.使用網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象中的方法write,給服務(wù)器發(fā)送數(shù)據(jù)
4.使用Socket對象中的方法getInputStream()獲取網(wǎng)絡(luò)字節(jié)輸入流InputStream對象
5.使用網(wǎng)絡(luò)字節(jié)輸入流InputStream對象中的方法read,讀取服務(wù)器回寫的數(shù)據(jù)
6.釋放資源(Socket)
注意:
1.客戶端和服務(wù)器端進行交互,必須使用Socket中提供的網(wǎng)絡(luò)流,不能使用自己創(chuàng)建的流對象
2.當我們創(chuàng)建客戶端對象Socket的時候,就會去請求服務(wù)器和服務(wù)器經(jīng)過3次握手建立連接通路
這時如果服務(wù)器沒有啟動,那么就會拋出異常ConnectException: Connection refused: connect
如果服務(wù)器已經(jīng)啟動,那么就可以進行交互了
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
/*
TCP通信的客戶端:向服務(wù)器發(fā)送連接請求,給服務(wù)器發(fā)送數(shù)據(jù),讀取服務(wù)器回寫的數(shù)據(jù)
表示客戶端的類:
java.net.Socket:此類實現(xiàn)客戶端套接字(也可以就叫“套接字”)峰伙。套接字是兩臺機器間通信的端點。
套接字:包含了IP地址和端口號的網(wǎng)絡(luò)單位
構(gòu)造方法:
Socket(String host, int port) 創(chuàng)建一個流套接字并將其連接到指定主機上的指定端口號该默。
參數(shù):
String host:服務(wù)器主機的名稱/服務(wù)器的IP地址
int port:服務(wù)器的端口號
成員方法:
OutputStream getOutputStream() 返回此套接字的輸出流瞳氓。
InputStream getInputStream() 返回此套接字的輸入流。
void close() 關(guān)閉此套接字栓袖。
*/
public class TCPClient {
public static void main(String[] args) throws IOException {
//1.創(chuàng)建一個客戶端對象Socket,構(gòu)造方法綁定服務(wù)器的IP地址和端口號
Socket socket = new Socket("127.0.0.1",8888);
//2.使用Socket對象中的方法getOutputStream()獲取網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象
OutputStream os = socket.getOutputStream();
//3.使用網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象中的方法write,給服務(wù)器發(fā)送數(shù)據(jù)
os.write("你好服務(wù)器".getBytes());
//4.使用Socket對象中的方法getInputStream()獲取網(wǎng)絡(luò)字節(jié)輸入流InputStream對象
InputStream is = socket.getInputStream();
//5.使用網(wǎng)絡(luò)字節(jié)輸入流InputStream對象中的方法read,讀取服務(wù)器回寫的數(shù)據(jù)
byte[] bytes = new byte[1024];
int len = is.read(bytes);
System.out.println(new String(bytes,0,len));
//6.釋放資源(Socket)
socket.close();
}
}
服務(wù)器的代碼實現(xiàn)
服務(wù)器的實現(xiàn)步驟:
1.創(chuàng)建服務(wù)器ServerSocket對象和系統(tǒng)要指定的端口號
2.使用ServerSocket對象中的方法accept,獲取到請求的客戶端對象Socket
3.使用Socket對象中的方法getInputStream()獲取網(wǎng)絡(luò)字節(jié)輸入流InputStream對象
4.使用網(wǎng)絡(luò)字節(jié)輸入流InputStream對象中的方法read,讀取客戶端發(fā)送的數(shù)據(jù)
5.使用Socket對象中的方法getOutputStream()獲取網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象
6.使用網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象中的方法write,給客戶端回寫數(shù)據(jù)
7.釋放資源(Socket,ServerSocket)
/*
TCP通信的服務(wù)器端:接收客戶端的請求,讀取客戶端發(fā)送的數(shù)據(jù),給客戶端回寫數(shù)據(jù)
表示服務(wù)器的類:
java.net.ServerSocket:此類實現(xiàn)服務(wù)器套接字匣摘。
構(gòu)造方法:
ServerSocket(int port) 創(chuàng)建綁定到特定端口的服務(wù)器套接字。
服務(wù)器端必須明確一件事情,必須的知道是哪個客戶端請求的服務(wù)器
所以可以使用accept方法獲取到請求的客戶端對象Socket
成員方法:
Socket accept() 偵聽并接受到此套接字的連接叽赊。
*/
public class TCPServer {
public static void main(String[] args) throws IOException {
//1.創(chuàng)建服務(wù)器ServerSocket對象和系統(tǒng)要指定的端口號
ServerSocket server = new ServerSocket(8888);
//2.使用ServerSocket對象中的方法accept,獲取到請求的客戶端對象Socket
Socket socket = server.accept();
//3.使用Socket對象中的方法getInputStream()獲取網(wǎng)絡(luò)字節(jié)輸入流InputStream對象
InputStream is = socket.getInputStream();
//4.使用網(wǎng)絡(luò)字節(jié)輸入流InputStream對象中的方法read,讀取客戶端發(fā)送的數(shù)據(jù)
byte[] bytes = new byte[1024];
int len = is.read(bytes);
System.out.println(new String(bytes,0,len));
//5.使用Socket對象中的方法getOutputStream()獲取網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象
OutputStream os = socket.getOutputStream();
//6.使用網(wǎng)絡(luò)字節(jié)輸出流OutputStream對象中的方法write,給客戶端回寫數(shù)據(jù)
os.write("收到謝謝".getBytes());
//7.釋放資源(Socket,ServerSocket)
socket.close();
server.close();
}
}
客戶端和服務(wù)器進行交互恋沃,需要服務(wù)器兩個客戶端兩個流,一共四個