網(wǎng)絡(luò)通信
局域網(wǎng)與因特網(wǎng)
服務(wù)器是指提供信息的計算機程序,客戶機是指請求信息的計算機或程序。
局域網(wǎng) 廣域網(wǎng)
網(wǎng)絡(luò)協(xié)議
網(wǎng)絡(luò)協(xié)議規(guī)定了計算機之間的物理、機械(網(wǎng)線與網(wǎng)卡的連接規(guī)定)、電氣(有效的電平范圍)等特征以及計算機之間的相互尋址規(guī)則、數(shù)據(jù)發(fā)生沖突的解決、長的數(shù)據(jù)如何分段傳送與接受等。
1 IP協(xié)議
到目前為止,IP地址用四個字節(jié),也就是32位的二進(jìn)制數(shù)來表示,稱為IPv4。為了便于使用,通常取用每個字節(jié)的十進(jìn)制數(shù),并且每個字節(jié)點用圓點隔開來表示IP地址,如192.168.1.1。
TCP/IP模式分為四層:由上到下分別為:應(yīng)用層>傳輸層>互聯(lián)網(wǎng)層>網(wǎng)絡(luò)層
端口和套接字
端口是英文port的意譯,可以認(rèn)為是設(shè)備與外界通訊交流的出口。端口可分為虛擬端口和物理端口,其中虛擬端口指計算機內(nèi)部或交換機路由器內(nèi)的端口,不可見。例如計算機中的80端口、21端口、23端口等。物理端口又稱為接口,是可見端口,計算機背板的RJ45網(wǎng)口,交換機路由器集線器等RJ45端口。電話使用RJ11插口也屬于物理端口的范疇。
套接字(Socked)用于將應(yīng)用程序與端口連接起來。套接字是一個假象的連接裝置。
TCP程序設(shè)計基礎(chǔ)
利用TCP協(xié)議進(jìn)行通信的兩個應(yīng)用程序是有主次之分的,一個稱為服務(wù)器程序,一個稱為客戶機程序。
1 服務(wù)器程序創(chuàng)建一個ServerSocket(服務(wù)器端套接字),調(diào)用accept()方法等待客戶機連接
<1> 在指定的端口上創(chuàng)建服務(wù)器套接字
<2> 通過accept()方法監(jiān)聽客戶端的連接 (該方法是一個阻塞方法如果沒有客戶端連接到服務(wù)器就一直保持阻塞狀態(tài))
<3> 啟動一個線程進(jìn)行I/O操作(每個客戶端在獨立的線程中執(zhí)行)
2 客戶端創(chuàng)建一個Socket,請求與服務(wù)器連接
基于HTTP協(xié)議
<1> 請求:請求行 - 命令 資源路徑 協(xié)議版本號
請求頭 - 鍵值對
空行(\r\n)
消息體- 發(fā)給服務(wù)器的數(shù)據(jù)
<2> 響應(yīng): 響應(yīng)行 - 協(xié)議版本 狀態(tài)碼
響應(yīng)頭 - 鍵值對
空行(\r\n)
消息體 - 服務(wù)器返回的數(shù)據(jù)
3 實例<客戶端與服務(wù)器之間的消息的傳遞>
<1> 客戶端
class Test03 {
public static void main(String[] args) throws Exception {
Scanner scanner = new Scanner(System.in);
try (Socket client = new Socket("127.0.0.1", 1234)) {
InputStream in = client.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(in));
OutputStream out = client.getOutputStream();
PrintStream ps = new PrintStream(out);
String tempStr = scanner.nextLine();
while (!tempStr.equals("bye")) {
ps.println(tempStr);
System.out.println(br.readLine());
tempStr = scanner.nextLine();
}
}
catch(Exception e) {
e.printStackTrace();
}
scanner.close();
}
}
<2> 服務(wù)器端
class ClientHandler implements Runnable {
private Socket client;
public ClientHandler(Socket client) {
this.client = client;
}
@Override
public void run() {
try {
InputStream in = client.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(in));
OutputStream out = client.getOutputStream();
PrintStream ps = new PrintStream(out);
String tempStr;
while ((tempStr = br.readLine()) != null) {
if (tempStr.equals("bye")) {
client.close();
break;
}
ps.println(tempStr);
}
}
catch (IOException e) {
e.printStackTrace();
}
}
}
class Test02 {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
// 1. 在指定的端口上創(chuàng)建服務(wù)器套接字
try (ServerSocket server = new ServerSocket(1234)) {
System.out.println("服務(wù)器已經(jīng)啟動...");
boolean isRunning = true;
while (isRunning) {
try {
// 2. 通過accept()方法監(jiān)聽客戶端的連接
// 該方法是一個阻塞方法如果沒有客戶端連接到服務(wù)器就一直保持阻塞狀態(tài)
Socket client = server.accept();
// 3. 啟動一個線程進(jìn)行I/O操作(每個客戶端在獨立的線程中執(zhí)行)
// new Thread(new ClientHandler(client)).start();
service.execute(new ClientHandler(client));
}
catch (IOException e) {
e.printStackTrace();
}
}
service.shutdown();
}
catch (IOException e) {
e.printStackTrace();
}
}
}