第13篇-JAVA 網(wǎng)絡編程

2022-03-11 11:29 更新
  • 每篇一句 ：比我強大的人都在努力我還有什么理由不拼命
  • 初學心得： 不去追逐你所渴求，你將永遠不會擁有
  • (筆者：JEEP/711)[JAVA筆記 | 時間:2017-04-22| JAVA 網(wǎng)絡編程 ]

1.網(wǎng)絡編程基本概念

1.什么是計算機網(wǎng)絡
計算機網(wǎng)絡，是指將地理位置不同的具有獨立功能的多臺計算機及其外部設備，通過通信線路連接起來，在網(wǎng)絡操作系統(tǒng)，網(wǎng)絡管理軟件及網(wǎng)絡通訊協(xié)議的管理和協(xié)調(diào)下，實現(xiàn)資源共享和信息傳遞的計算機系統(tǒng)
把分布在不同地理區(qū)域的計算機與專門的外部設備用通訊線路互連成一個規(guī)模大
功能強的網(wǎng)絡系統(tǒng)，從而使眾多的計算機可以方便地相互傳遞信息，共享硬件，軟件、數(shù)據(jù)信息等資源
2.計算機網(wǎng)絡的主要功能
資源共享，信息傳輸與集中處理，均衡負荷與分布處理，綜合信息服務(www/綜合業(yè)務數(shù)字網(wǎng)絡ISDN)等
3.網(wǎng)絡通訊協(xié)議
要使計算機連成網(wǎng)絡能夠互相通信，需要對數(shù)據(jù)傳輸速率，傳輸代碼，代碼結構，傳輸控制步驟，出錯
控制等制定一組標準，這一組共同遵守的通訊標準就是網(wǎng)絡通訊協(xié)議
4.網(wǎng)絡通訊接口
為了是這兩個結點之間進行對話，必須在它們之間建立通訊工具(既接口)
使彼此之間能進行信息交換，接口包括兩部分：
1.硬件裝置：實現(xiàn)結點之間的信息傳遞
2.軟件裝置：規(guī)定雙方進行通訊的約定協(xié)議
4.TCP/IP
5.程序開發(fā)結構

5.IP協(xié)議
IP協(xié)議是Internet上使用的一個關鍵協(xié)議，它的全稱是Internet Protocol，即Internet協(xié)議，通常簡稱IP協(xié)議
通過使用IP協(xié)議，從而使Internet成為一個允許連接不同類型的計算機和不同操作系統(tǒng)的網(wǎng)絡。
IP協(xié)議只保證計算機能發(fā)送和接收分組數(shù)據(jù)。IP協(xié)議負責將消息從一個主機傳送到另一個主機，消息在傳送的過程中被分割成一個個的小包

6.Java對TCP/IP協(xié)議的支持
- TCP/IP通信協(xié)議是一種可靠的網(wǎng)絡協(xié)議，它在通信的兩端各建立一個Socket，從而在通信的兩端之間形成網(wǎng)絡虛擬鏈路
- 一旦建立了虛擬的網(wǎng)絡鏈路，兩端的程序就可以通過虛擬鏈路進行通信
- Java對基于TCP協(xié)議的網(wǎng)絡通信提供了良好的封裝，Java使用Socket對象來代表兩端的通信接口，并通過Socket產(chǎn)生IO流來進行網(wǎng)絡通信

2.網(wǎng)絡通訊協(xié)議（TCP/IP UDP）

IP的概念
IP是互聯(lián)網(wǎng)上的每一臺計算機都有得一個唯一表示自己的標記
IP地址使用4個8位的二進制數(shù)據(jù)表示,每8位之間使用圓點隔開，每個8位整數(shù)可以轉(zhuǎn)換成一個0~255的十進制整數(shù)
因此一般看到的IP地址類似：192.168.1.1

IP地址分類：
- IPv4：32位，分4段，0~255之間的十進制表示
- IPv6：128位，分8段，0000~FFFF的十六進制數(shù)值，冒號分割
如：1080:0:0:0:8:800:200C:417A
- IP地址 = 網(wǎng)絡地址 + 主機地址
- 網(wǎng)絡號：用于識別主機所在的網(wǎng)絡
- 主機號：用于識別該網(wǎng)絡的主機

什么是端口？
如果把IP地址比作一間房子 ，端口就是出入這間房子的門。真正的房子只有幾個門，但是一個IP地址的端口 可以有65536（即：2^16）個之多！端口是通過端口號來標記的，端口號只有整數(shù)，范圍是從0 到65535（2^16-1）
同一臺機器上不能有兩個程序使用同一個端口；

端口的分類：
- 公認端口：0~1023，他們緊密綁定一些服務
- 注冊端口：1024~49151，松散綁定一些服務
- 動態(tài)端口：49152~65535，動態(tài)使用的端口，程序一般不會使用這些端口；

TCP協(xié)議
- TCP協(xié)議被稱作一種端對端協(xié)議
- 這是因為它為兩臺計算機之間的連接起了重要作用：當一臺計算機需要與另一臺遠程計算機連接時，TCP協(xié)議會讓它們建立一個連接：用于發(fā)送和接收數(shù)據(jù)的虛擬鏈路。
- TCP協(xié)議負責收集這些信息包，并將其按適當?shù)拇涡蚍藕脗魉?，在接收端收到后再將其正確地還原
- TCP協(xié)議保證了數(shù)據(jù)包在傳送中準確無誤。TCP協(xié)議使用重發(fā)機制：當一個通信實體發(fā)送一個消息給另一個通信實體后，需要收到另一個通信實體確認信息，如果沒有收到另一個通信實體的確認信息，則會再次重發(fā)剛才發(fā)送的信息
- 通過這種重發(fā)機制，TCP協(xié)議向應用程序提供可靠的通信連接，使它能夠自動適應網(wǎng)上的各種變化。即使在 Internet 暫時出現(xiàn)堵塞的情況下，TCP也能夠保證通信的可靠

UDP協(xié)議
- UDP協(xié)議是一種不可靠的網(wǎng)絡協(xié)議
- 它在通信實例的兩端各建立一個Socket，但這兩個Socket之間并沒有虛擬鏈路，這兩個Socket只是發(fā)送、接收數(shù)據(jù)報的對象，Java提供了DatagramSocket對象作為基于UDP協(xié)議的Socket，使用DatagramPacket代表DatagramSocket發(fā)送、接收的數(shù)據(jù)報

發(fā)送端：在發(fā)送端，要在數(shù)據(jù)包對象中明確目的地IP及端口

DatagramSocket ds = new DatagramSocket();
byte[] by = “hello,udp”.getBytes();
DatagramPacket dp = new DatagramPacket(by,0,by.length,
InetAddress.getByName(“127.0.0.1”),10000);
ds.send(dp);
ds.close();

接收端：在接收端，要指定監(jiān)聽的端口

DatagramSocket ds = new DatagramSocket(10000);
byte[] by = new byte[1024];
DatagramPacket dp = new DatagramPacket(by,by.length);
ds.receive(dp);
String str = new String(dp.getData() );
System.out.println(str+"--"+dp.getAddress());
ds.close();

3.UDP和TCP的對比

  • TCP協(xié)議：可靠，傳輸大小無限制，但是需要連接建立時間，差錯控制開銷大
    - UDP協(xié)議：不可靠，差錯控制開銷較小，傳輸大小限制在64K以下，不需要建立連接

4.QSI七層模型

物理，比特流 網(wǎng)卡
數(shù)據(jù)鏈路，數(shù)據(jù)幀 交換機
網(wǎng)絡，IP TCP上層?數(shù)據(jù) 數(shù)據(jù)包 路由器
傳輸，TCP上頭上層數(shù)據(jù) 數(shù)據(jù)段 防火墻
會話，
表示，
應用 上層數(shù)據(jù) 48位2進制 計算機

TCP/IP4 TCP/IP5 TCP/IP7
物理層 0,1 比特流
數(shù)據(jù)鏈路層
網(wǎng)絡層 數(shù)據(jù)包封裝結構
傳輸層
會話層建立會話關系

TCP/
ARP轉(zhuǎn)為Mark地址
ICMP傳輸用戶協(xié)議

TCP需要同步才能傳輸數(shù)據(jù)，安全性高/傳輸控制協(xié)議 三次握手 四次結束
HTTP傳輸協(xié)議
FTP文件傳輸協(xié)議
SMTP郵件傳輸協(xié)議
DNS將域名轉(zhuǎn)化為地址
UDP效率更快，但不安全/用戶數(shù)據(jù)協(xié)議

ARP將IP解析成Mark地址的過程
arp -a 為了防止欺騙，實行綁定地址
實現(xiàn)字節(jié)流和字符流分別實現(xiàn)客戶端，服務器返回

5.ServerSocket和Socket

1.ServerSocket(服務端)
- ServerSocket對象用于監(jiān)聽來自客戶端的Socket連接，如果沒有連接，它將一直處于等待狀態(tài)
- ServerSocket包含一個監(jiān)聽來自客戶端連接請求的方法：
- Socket accept()：如果接收到一個客戶端Socket的連接請求，該方法將返回一個與連客戶端Socket對應的Socket，否則該方法將一直處于等待狀態(tài)，線程也被阻塞
- 為了創(chuàng)建ServerSocket對象，ServerSocket類提供了如下幾個構造器：
- ServerSocket(int port)：用指定的端口port來創(chuàng)建一個ServerSocket
- 該端口應該是有一個有效的端口整數(shù)值：0～65535
- ServerSocket(int port,int backlog)：增加一個用來改變連接隊列長度的參數(shù)backlog
- ServerSocket(int port,int backlog,InetAddress localAddr)：在機器存在多個 IP地址的情況下，允許通過localAddr這個參數(shù)來指定將ServerSocket綁定到指定的IP地址
- 服務端：建立服務端需要監(jiān)聽一個端口

ServerSocket ss = new ServerSocket(9999);
Socket s = ss.accept ();
InputStream in = s.getInputStream();
byte[] buf = new byte[1024];
int num = in.read(buf);
String str = new String(buf,0,num);
System.out.println(s.getInetAddress().toString()+”:”+str);
s.close();
ss.close();


2.Socket(客戶端)
- 客戶端通?？墒褂肧ocket的構造器來連接到指定服務器，Socket通?？墒褂萌缦聝蓚€構造器：
- Socket(InetAddress/String remoteAddress, int port)：創(chuàng)建連接到指定遠程主機、遠程端口的Socket，該構造器沒有指定本地地址、本地端口，默認使用本地主機的默認IP地址，默認使用系統(tǒng)動態(tài)指定的IP地址
- Socket(InetAddress/String remoteAddress, int port, InetAddress localAddr, int localPort)：創(chuàng)建連接到指定遠程主機、遠程端口的Socket，并指定本地IP地址和本地端口號，適用于本地主機有多個IP地址的情形
- 客戶端：通過Socket建立對象并指定要連接的服務端主機以及端口

Socket s = new Socket(“192.168.1.1”,9999);
OutputStream out = s.getOutputStream();
out.write(“hello”.getBytes());
s.close();

6.網(wǎng)絡通信

  • 當客戶端、服務器端產(chǎn)生了對應的Socket之后，程序無需再區(qū)分服務器、客戶端，而是通過各自的Socket進行通信，Socket提供如下兩個方法來獲取輸入流和輸出流：
    - InputStream getInputStream()：返回該Socket對象對應的輸入流，讓程序通過該輸入流從Socket中取出數(shù)據(jù)
    - OutputStream getOutputStream()：返回該Socket對象對應的輸出流，讓程序通過該輸出流向Socket中輸出數(shù)據(jù)

7.網(wǎng)絡HTTP互聯(lián)實例

實例一：下載網(wǎng)絡圖片保存到此項目目錄

package cn.http;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
public class HttpPhoto {
@SuppressWarnings("resource")
public static void main(String[] args) {
//打開url網(wǎng)址
String url = "http://t1.27270.com/uploads/150609/7-1506091506401R.jpg";
try {
URL uu = new URL(url);//創(chuàng)建URL對象
URLConnection uc = uu.openConnection();//返回URLConnection
uc.connect();//發(fā)起請求連接
InputStream in = uc.getInputStream();//輸入
byte[] bytes = new byte[1024];//字節(jié)儲存
int len = 0;
File f = new File("美女圖片.jpg");//將圖片保存跟目錄
FileOutputStream fos = new FileOutputStream(f);//輸出
//循環(huán)讀取
while((len = in.read(bytes))!=-1){
fos.write(bytes,0,len);
}
System.out.println("圖片下載成功!");
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}


實例二：與網(wǎng)絡機器人聊天功能

package cn.http;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.util.Scanner;
/**
* 連接接口實現(xiàn)聊天功能
* JSON數(shù)據(jù)格式
* @author JEEP-711
*/
public class HttpCalling {
@SuppressWarnings({ "unused", "resource" })
public static void main(String[] args) {
String name = "咨詢助理";
Scanner sc = new Scanner(System.in);//接收進控制鍵盤輸入
System.out.println("Hi，現(xiàn)在我們已經(jīng)是好友啦,開始我們的聊天吧!");//提示
//循環(huán)輸入
while(true){
System.out.println("請輸入...");//提示
String user = sc.next();//用戶輸入內(nèi)容
//打開url接口網(wǎng)址
String url = "http://www.tuling123.com/openapi/api?key=4c767f02ca7b44378156821ab35856df&info="+user;
try {
URL uu = new URL(url);//創(chuàng)建URL對象
URLConnection uc = uu.openConnection();//返回URLConnection
uc.connect();//發(fā)起請求連接
//讀取原文件
BufferedReader br = new BufferedReader(new InputStreamReader(uc.getInputStream()));
StringBuffer sb = new StringBuffer();
String s = "";
s = br.readLine();
String[] str = s.split(":");//分隔字符串
String[] strs = str[2].split("\"");
//for數(shù)組
for(String sr : strs){
System.out.println(name +"發(fā)來消息:"+strs[1]);
}
//JSONObject jc = new JSONObject(s);
//System.out.println(name +"發(fā)來消息:"+br.readLine());
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}



實例三：網(wǎng)絡編程傳輸文件

package cn.socket;
import java.io.DataInputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服務端
* @author JEEP-711
*
*/
public class Servers extends ServerSocket{
private static final int PORT = 8000;//定義靜態(tài)整形常量端口號
private ServerSocket ss;//定義服務端
private Socket sk;//定義客戶端
private DataInputStream d;//定義
private FileOutputStream fp;//定義文件傳輸
//定義構造方法并拋出異常
public Servers()throws Exception{
try {
try {
ss = new ServerSocket(PORT);//傳值-端口號
while(true){
sk = ss.accept();
d = new DataInputStream(sk.getInputStream());
//文件名和長度
String fileName = d.readUTF();
long fileLeng = d.readLong();
fp =new FileOutputStream(new File("src\\" + fileName));
byte[] bytes = new byte[1024];//定義為1024個字節(jié)
int len = 0;//定義為0
//文件傳輸提示
System.out.println("----正在開始接收文件<" + fileName +"&,文件大小為<" + fileLeng +"&----");
while(true){
int read =0;
read = d.read(bytes);
if(read == -1)
break;
len += read;
System.out.println("接收文件進度" +100 * len/fileLeng +"%...");//文件接收提示
fp.write(bytes,0, read);//
fp.flush();//刷新
}
System.out.println("----接收文件<" + fileName +"&成功-------");
sk.close();//關閉流客戶端
}
}catch (Exception e) {
e.printStackTrace();
//統(tǒng)一出口
}finally {
//如果傳輸不等于空
if(d !=null)
d.close();//則關閉傳輸流
//如果文件傳輸不等于空
if(fp !=null)
fp.close();//則關閉傳輸文件流
ss.close();//關閉服務器流
}
}catch (Exception e) {
e.printStackTrace();
}
}
@SuppressWarnings("resource")
public static void main(String[] args) throws Exception{
new Servers();//調(diào)用Servers方法
}
}


package cn.socket;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.net.Socket;
/**
* 客戶端
* @author JEEP-711
*
*/
public class Cilens extends Socket{
private static final String server_ip = "192.168.199.109";//定義靜態(tài)字符串常量IP地址
private static final int duankou = 8000;//定義靜態(tài)整形常量端口號
private Socket s;//定義服務器
private FileInputStream f;//定義文件
private DataOutputStream d;//定義傳輸
//構造方法
public Cilens(){
try {
try {
s = new Socket(server_ip,duankou);//傳參數(shù)
//向服務端傳送文件
File file =new File("src\\test.doc");//文件在src目錄下
f = new FileInputStream(file);//傳文件
d = new DataOutputStream(s.getOutputStream());
//文件名和長度
d.writeUTF(file.getName());//文件名稱
d.flush();//刷新
d.writeLong(file.length());//文件長度
d.flush();//傳輸刷新
//傳輸文件
byte[] Bytes =new byte[1024];//定義byte1024的字節(jié)
int len = 0;//定義len為0
//循環(huán)
while((len = f.read(Bytes,0,Bytes.length)) &0){
d.write(Bytes,0, len);//字節(jié)從0到len
d.flush();//傳輸刷新
}
}catch (Exception e) {
e.printStackTrace();
}finally{
//如果文件不等于空
if(f !=null)
f.close();//則關閉流
//如果傳輸不等于空
if(d !=null)
d.close();//則關閉流
s.close();//關閉流
}
}catch (Exception e) {
e.printStackTrace();
}
}
@SuppressWarnings("resource")
public static void main(String[] args) throws Exception {
new Cilens();//調(diào)用方法
}
}

初學(JAVA 網(wǎng)絡編程 高級階段) 難點: ★★★★★

希望每一篇文章都能夠?qū)ψx者們提供幫助與提升，這乃是每一位筆者的初衷

感謝您的閱讀 歡迎您的留言與建議

以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號