作為的抽象子類，用來處理針對(duì)Http協(xié)議的請(qǐng)求，可以設(shè)置連接超時(shí)、讀取超時(shí)、以及請(qǐng)求的其他屬性，是服務(wù)間通信的常用方式；
public?class?TestHttp?{
????public?static?void?main(String[]?args)?throws?Exception?{
????????//?訪問?網(wǎng)址?內(nèi)容
????????URL?url?=?new?URL("https://www.jd.com");
????????HttpURLConnection?httpUrlConnection?=?(HttpURLConnection)?url.openConnection();
????????printHttp(httpUrlConnection);
????????//?請(qǐng)求?服務(wù)?接口
????????URL?api?=?new?URL("http://localhost:8082/info/99");
????????HttpURLConnection?apiConnection?=?(HttpURLConnection)?api.openConnection();
????????apiConnection.setRequestMethod("GET");
????????apiConnection.setConnectTimeout(3000);
????????printHttp(apiConnection);
????}
????private?static?void?printHttp?(HttpURLConnection?httpUrlConnection)?throws?Exception{
????????try?(InputStream?inputStream?=?httpUrlConnection.getInputStream())?{
????????????BufferedReader?bufferedReader?=?new?BufferedReader(new?InputStreamReader(inputStream,?StandardCharsets.UTF_8));
????????????String?line?;
????????????while?((line?=?bufferedReader.readLine())?!=?null)?{
????????????????System.out.println(line);
????????????}
????????}
????}
}
三、通信編程1、
也被稱為套接字，是兩臺(tái)設(shè)備之間通信的端點(diǎn)，會(huì)把網(wǎng)絡(luò)連接當(dāng)成流處理，則數(shù)據(jù)以IO形式傳輸，這種方式在當(dāng)前被普遍采用；
從網(wǎng)絡(luò)編程直接跳到套接字，概念上確實(shí)有較大跨度，概念過度抽象時(shí)，可以看看源碼的核心結(jié)構(gòu)，在理解時(shí)會(huì)輕松很多，在JDK中重點(diǎn)看抽象類；
public?abstract?class?SocketImpl?implements?SocketOptions?{
????//?Socket對(duì)象，客戶端和服務(wù)端
????Socket?socket?=?null;
????ServerSocket?serverSocket?=?null;
????//?套接字的文件描述對(duì)象
????protected?FileDescriptor?fd;
????//?套接字的路由IP地址
????protected?InetAddress?address;
????//?套接字連接到的遠(yuǎn)程主機(jī)上的端口號(hào)
????protected?int?port;
????//?套接字連接到的本地端口號(hào)
????protected?int?localport;
}
套接字的抽象實(shí)現(xiàn)類，是實(shí)現(xiàn)套接字的所有類的公共超類，可以用于創(chuàng)建客戶端和服務(wù)器套接字；
所以到底如何理解概念？從抽象類中來看，套接字就是指代網(wǎng)絡(luò)通訊中系統(tǒng)資源的核心標(biāo)識(shí)，比如通訊方IP地址、端口、狀態(tài)等；
2、
創(chuàng)建服務(wù)端，并且在8989端口監(jiān)聽，接收客戶端的連接請(qǐng)求和相關(guān)信息，并且響應(yīng)客戶端，發(fā)送指定的數(shù)據(jù)；
public?class?SocketServer?{
????public?static?void?main(String[]?args)?throws?Exception?{
????????//?1、創(chuàng)建Socket服務(wù)端
????????ServerSocket?serverSocket?=?new?ServerSocket(8989);
????????System.out.println("socket-server:8989，waiting?connect...");
????????//?2、方法阻塞等待，直到有客戶端連接
????????Socket?socket?=?serverSocket.accept();
????????System.out.println("socket-server:8989，get?connect:"+socket.getPort());
????????//?3、輸入流，輸出流
????????InputStream?inStream?=?socket.getInputStream();
????????OutputStream?outStream?=?socket.getOutputStream();
????????//?4、數(shù)據(jù)接收和響應(yīng)
????????byte[]?buf?=?new?byte[1024];
????????int?readLen?=?0;
????????while?((readLen=inStream.read(buf))?!=?-1){
????????????//?接收數(shù)據(jù)
????????????String?readVar?=?new?String(buf,?0,?readLen)?;
????????????if?("exit".equals(readVar)){
????????????????break?;
????????????}
????????????System.out.println("recv："+readVar+"；time："+DateTime.now().toString(DatePattern.NORM_DATETIME_PATTERN));
????????????//?響應(yīng)數(shù)據(jù)
????????????outStream.write(("resp-time："+DateTime.now().toString(DatePattern.NORM_DATETIME_PATTERN)).getBytes());
????????}
????????//?5、資源關(guān)閉
????????outStream.close();
????????inStream.close();
????????socket.close();
????????serverSocket.close();
????????System.out.println("socket-server:8989，exit...");
????}
}
需要注意的是步驟2輸出的端口號(hào)是隨機(jī)不確定的網(wǎng)絡(luò)編程實(shí)現(xiàn)文件傳輸，結(jié)合jps和lsof -i tcp:port命令查看進(jìn)程和端口號(hào)的占用情況；
3、
創(chuàng)建客戶端，并且連接到服務(wù)端，讀取命令行輸入的內(nèi)容并發(fā)送到服務(wù)端，并且輸出服務(wù)端的響應(yīng)數(shù)據(jù)；
public?class?SocketClient?{
????public?static?void?main(String[]?args)?throws?Exception?{
????????//?1、創(chuàng)建Socket客戶端
????????Socket?socket?=?new?Socket(InetAddress.getLocalHost(),?8989);
????????System.out.println("server-client，connect?to:8989");
????????//?2、輸入流，輸出流
????????OutputStream?outStream?=?socket.getOutputStream();
????????InputStream?inStream?=?socket.getInputStream();
????????//?3、數(shù)據(jù)發(fā)送和響應(yīng)接收
????????int?readLen?=?0;
????????byte[]?buf?=?new?byte[1024];
????????while?(true){
????????????//?讀取命令行輸入
????????????BufferedReader?bufReader?=?new?BufferedReader(new?InputStreamReader(System.in));
????????????String?iptLine?=?bufReader.readLine();
????????????if?("exit".equals(iptLine)){
????????????????break;
????????????}
????????????//?發(fā)送數(shù)據(jù)
????????????outStream.write(iptLine.getBytes());
????????????//?接收數(shù)據(jù)
????????????if?((readLen?=?inStream.read(buf))?!=?-1)?{
????????????????System.out.println(new?String(buf,?0,?readLen));
????????????}
????????}
????????//?4、資源關(guān)閉
????????inStream.close();
????????outStream.close();
????????socket.close();
????????System.out.println("socket-client，get?exit?command");
????}
}
測(cè)試結(jié)果：整個(gè)流程在沒有收到客戶端的exit退出指令前，會(huì)保持連接的狀態(tài)，并且可以基于字節(jié)流模式，進(jìn)行持續(xù)的數(shù)據(jù)傳輸；
4、字符流使用
基于上述的基礎(chǔ)案例，采用字符流的方式進(jìn)行數(shù)據(jù)傳輸，客戶端和服務(wù)端只進(jìn)行一次簡(jiǎn)單的交互；
--?1、客戶端
BufferedReader?bufReader?=?new?BufferedReader(new?InputStreamReader(inStream));
BufferedWriter?bufWriter?=?new?BufferedWriter(new?OutputStreamWriter(outStream));
//?客戶端發(fā)送數(shù)據(jù)
bufWriter.write("hello,server");
bufWriter.newLine();
bufWriter.flush();
//?客戶端接收數(shù)據(jù)
System.out.println("client-read："+bufReader.readLine());
--?2、服務(wù)端
BufferedReader?bufReader?=?new?BufferedReader(new?InputStreamReader(inStream));
BufferedWriter?bufWriter?=?new?BufferedWriter(new?OutputStreamWriter(outStream));
//?服務(wù)端接收數(shù)據(jù)
System.out.println("server-read："+bufReader.readLine());
//?服務(wù)端響應(yīng)數(shù)據(jù)
bufWriter.write("hello,client");
bufWriter.newLine();
bufWriter.flush();
5、文件傳輸
基于上述的基礎(chǔ)案例，客戶端向服務(wù)端發(fā)送圖片文件，服務(wù)端完成文件的讀取和保存網(wǎng)絡(luò)編程實(shí)現(xiàn)文件傳輸，在處理完成后給客戶端發(fā)送結(jié)果描述；
--?1、客戶端
//?客戶端發(fā)送圖片
FileInputStream?fileStream?=?new?FileInputStream("Local_File_Path/jvm.png");
byte[]?bytes?=?new?byte[1024];
int?i?=?0;
while?((i?=?fileStream.read(bytes))?!=?-1)?{
????outStream.write(bytes);
}
//?寫入結(jié)束標(biāo)記，禁用此套接字的輸出流，之后再使用輸出流會(huì)拋異常
socket.shutdownOutput();
//?接收服務(wù)端響應(yīng)結(jié)果
System.out.println("server-resp："+new?String(bytes,0,readLen));
--?2、服務(wù)端
//?接收客戶端圖片
FileOutputStream?fileOutputStream?=?new?FileOutputStream("Local_File_Path/new_jvm.png");
byte[]?bytes?=?new?byte[1024];
int?i?=?0;
while?((i?=?inStream.read(bytes))?!=?-1)?{
????fileOutputStream.write(bytes,?0,?i);
}
//?響應(yīng)客戶端文件處理結(jié)果
outStream.write("file-save-success".getBytes());
6、TCP協(xié)議
網(wǎng)絡(luò)編程是基于TCP協(xié)議的，TCP傳輸控制協(xié)議是一種面向連接的、可靠的、基于字節(jié)流的傳輸層通信協(xié)議，在上述案例中側(cè)重基于流的數(shù)據(jù)傳輸，其中關(guān)于連接還涉及兩個(gè)核心概念：
三次握手：建立連接的過程，在這個(gè)過程中進(jìn)行了三次網(wǎng)絡(luò)通信，當(dāng)連接處于建立的狀態(tài)，就可以進(jìn)行正常的通信，即數(shù)據(jù)傳輸；四次揮手：關(guān)閉連接的過程，調(diào)用close方法，即連接使用結(jié)束，在這個(gè)過程中進(jìn)行了四次網(wǎng)絡(luò)通信；