網(wǎng)絡通信
局域網(wǎng)與因特網(wǎng)
服務器是指提供信息的計算機程序,客戶機是指請求信息的計算機或程序温峭。
局域網(wǎng) 廣域網(wǎng)
網(wǎng)絡協(xié)議
網(wǎng)絡協(xié)議規(guī)定了計算機之間的物理、機械(網(wǎng)線與網(wǎng)卡的連接規(guī)定)乞娄、電氣(有效的電平范圍)等特征以及計算機之間的相互尋址規(guī)則却桶、數(shù)據(jù)發(fā)生沖突的解決、長的數(shù)據(jù)如何分段傳送與接受等蒙挑。
1 IP協(xié)議
到目前為止宗侦,IP地址用四個字節(jié),也就是32位的二進制數(shù)來表示脆荷,稱為IPv4凝垛。為了便于使用懊悯,通常取用每個字節(jié)的十進制數(shù)蜓谋,并且每個字節(jié)點用圓點隔開來表示IP地址,如192.168.1.1炭分。
TCP/IP模式分為四層:由上到下分別為:應用層>傳輸層>互聯(lián)網(wǎng)層>網(wǎng)絡層
端口和套接字
端口是英文port的意譯桃焕,可以認為是設備與外界通訊交流的出口。端口可分為虛擬端口和物理端口捧毛,其中虛擬端口指計算機內(nèi)部或交換機路由器內(nèi)的端口观堂,不可見。例如計算機中的80端口呀忧、21端口师痕、23端口等。物理端口又稱為接口而账,是可見端口胰坟,計算機背板的RJ45網(wǎng)口,交換機路由器集線器等RJ45端口泞辐。電話使用RJ11插口也屬于物理端口的范疇笔横。
套接字(Socked)用于將應用程序與端口連接起來竞滓。套接字是一個假象的連接裝置。
TCP程序設計基礎
利用TCP協(xié)議進行通信的兩個應用程序是有主次之分的吹缔,一個稱為服務器程序商佑,一個稱為客戶機程序。
1 服務器程序創(chuàng)建一個ServerSocket(服務器端套接字)厢塘,調(diào)用accept()方法等待客戶機連接
<1> 在指定的端口上創(chuàng)建服務器套接字
<2> 通過accept()方法監(jiān)聽客戶端的連接 (該方法是一個阻塞方法如果沒有客戶端連接到服務器就一直保持阻塞狀態(tài))
<3> 啟動一個線程進行I/O操作(每個客戶端在獨立的線程中執(zhí)行)
2 客戶端創(chuàng)建一個Socket茶没,請求與服務器連接
基于HTTP協(xié)議
<1> 請求:請求行 - 命令 資源路徑 協(xié)議版本號
請求頭 - 鍵值對
空行(\r\n)
消息體- 發(fā)給服務器的數(shù)據(jù)
<2> 響應: 響應行 - 協(xié)議版本 狀態(tài)碼
響應頭 - 鍵值對
空行(\r\n)
消息體 - 服務器返回的數(shù)據(jù)
3 實例<客戶端與服務器之間的消息的傳遞>
<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> 服務器端
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)建服務器套接字
try (ServerSocket server = new ServerSocket(1234)) {
System.out.println("服務器已經(jīng)啟動...");
boolean isRunning = true;
while (isRunning) {
try {
// 2. 通過accept()方法監(jiān)聽客戶端的連接
// 該方法是一個阻塞方法如果沒有客戶端連接到服務器就一直保持阻塞狀態(tài)
Socket client = server.accept();
// 3. 啟動一個線程進行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();
}
}
}