1.網絡編程三要素

1.IP地址：網絡中設備的唯一標識IPv4: 由4個字節組成，點分十進制表示法IPv6: 由16個字節組成，冒分十六進制表示法"127.0.0.1"本地主機網絡地址【用于測試】相關命令：ipconfig: 查看本機在當前網絡環境下的ip地址ping: 查看當前主機和指定的ip地址是否連通2.端口號：在網絡設備中應用程序的標識，用一個整數表示。范圍：[0~65535]，[0-1023]可能被操作系統占用,建議使用1024以后的端口號80: 瀏覽器中訪問服務器的默認端口號8080: Tomcat服務器默認的端口號3306: MySQL數據庫的端口號3.網絡協議：網絡中數據傳輸的規則UDP: 面向無連接的，不可靠的協議，一次只能傳輸64K的數據TCP: 面向有鏈接的，可靠的協議，對數據大小沒有限制 對當前網絡通訊質量要求不高的時候，要求網絡通訊速度盡量的快，這時就使用UDP1.QQ語音 2.QQ視頻 3.TFTP當對網絡通信質量有要求時，比如：整個數據要準確無誤的傳遞給對方，這往往對于一些要求可靠的應用1.瀏覽器使用的：HTTP 2.FlashFXP:FTP3.Outlook:POP，SMTP 4.QQ文件傳輸

2.InetAddress類【ip相關】

//InetAddress類 public class Demo1 {public static void main(String[] args) throws UnknownHostException {//確定主機名稱的IP地址。主機名稱可以是機器名稱，也可以是IP地址//static InetAddress getByName (string host)InetAddress inetAddress = InetAddress.getByName("192.168.83.152");//獲取此IP地址的主機名//string getHostName ()如果主機名[安全問題]隱藏,則返回ip地址System.out.println("主機名為 "+inetAddress.getHostName());//string getHostAddress ()返回文本顯示中的IP地址字符串System.out.println("ip為 "+inetAddress.getHostAddress());//局域網為192.168.83.113//外網為10.254.3.213} }打印結果： ------------------------------------------------------------------------ 主機名為 192.168.83.152 ip為 192.168.83.152

3.UDP通信【協議】

【過程與碼頭送包裹類似】

//發送端 public class ClientDemo {public static void main(String[] args) throws IOException {//創建碼頭DatagramSocket ds = new DatagramSocket();//打包數據Scanner sc = new Scanner(System.in);String s = sc.nextLine();byte[] bytes = s.getBytes();InetAddress address = InetAddress.getByName("127.0.0.1");DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,10001);//發送包裹【sent方法發送，并將包裹傳入】ds.send(dp);//釋放資源ds.close();} }打印結果： ---------------------------------------------------------------------------------------------------- 你好

【注：需要先打開接收端，再打開發送端才可測試】

//接收端[碼頭需要釋放資源] //注意點： //1.要先運行接收端,再運行發送端 //2.如果接收端再啟動之后,沒有接收到數據,那么會死等(阻塞). //3.在接收數據的時候,需要調用一個getLength方法,表示接收到了多少字節 public class ServerDemo {public static void main(String[] args) throws IOException {//找到碼頭DatagramSocket ds = new DatagramSocket(10001);//創建新包//DatagramPacket (byte[] buf, int length)byte[] bytes = new byte[1024];DatagramPacket dp = new DatagramPacket(bytes,bytes.length);//將客戶端發送的包裹放進新包里ds.receive(dp);//拆包展示//DatagramPacket getData(獲取字節數組) getLength(獲取數據的長度)byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data, 0, length));//釋放資源ds.close();} }打印結果： ---------------------------------------------------------------------------------------------------- /127.0.0.1 來信息 你好

4.UDP中的組播和廣播

組播代碼實現
組播地址:224.0.0.0~239.255.255.255
其中224.0.0.0~224.0.0.255為預留的組播地址

//UDP組播 //發送端 public class ClientDemo {public static void main(String[] args) throws IOException {//1.創建碼頭DatagramSocket ds = new DatagramSocket();//2.打包byte[] bytes = "hello組播".getBytes();//netsh interface ipv4 show joins查看組播地址InetAddress address = InetAddress.getByName("224.0.0.1");//int ip =10000;DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,10000);//發送ds.send(dp);//釋放資源ds.close();} } 打印結果： ---------------- 你好組播public class ServerDemo {public static void main(String[] args) throws IOException {//找碼頭的組MulticastSocket ms = new MulticastSocket(10000);//準備新箱子DatagramPacket dp = new DatagramPacket(new byte[1024],1024);//放包：把當前計算機綁定一個組播地址，表示添加到這一組中ms.joinGroup(InetAddress.getByName("224.0.0.1"));ms.receive(dp);//拆包System.out.println(new String(dp.getData(), 0, dp.getLength()));ms.close();} }

廣播代碼實現
廣播地址：255.255.255.255

//UDP廣播[廣播地址不一定全部寫成255,可以網段+255] //發送端 public class ClientDemo {public static void main(String[] args) throws IOException {//1.創建碼頭DatagramSocket ds = new DatagramSocket();//2.打包byte[] bytes = "hello廣播".getBytes();//255.255.255.255或者自己的網段+255InetAddress address = InetAddress.getByName("192.168.83.255");//int ip =10000;DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,10000);//發送ds.send(dp);//釋放資源ds.close();} } 打印結果： ---------------------------- 你好，廣播//接收端 public class ServerDemo {public static void main(String[] args) throws IOException {//找碼頭的組DatagramSocket ds = new DatagramSocket(10000);//準備新箱子DatagramPacket dp = new DatagramPacket(new byte[1024],1024);//放包：把當前計算機綁定一個組播地址，表示添加到這一組中ds.receive(dp);//拆包System.out.println(new String(dp.getData(), 0, dp.getLength()));ds.close();} }

5.TCP通信【協議】

【使用Socket和ServerSocket發送一張圖片】
測試也是先開啟服務端，再開啟客戶端發送

客戶端

public class ClientDemo {public static void main(String[] args) throws IOException {//1.創建客戶端Socket對象Socket socket = new Socket("192.168.83.113", 10002);//2.本地輸入流讀取文件BufferedInputStream bis = new BufferedInputStream(new FileInputStream("C:\\Users\\Inuyasha\\Desktop\\2.jpg"));//網絡輸出流輸出文件BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());//邊讀邊寫byte[] bytes = new byte[1024];int len = bis.read(bytes);while (len != -1) {bos.write(bytes, 0, len);len = bis.read(bytes);}//給服務端讀取結束符號socket.shutdownOutput();//關閉本地流bis.close();//3.等待服務器響應并讀取//使用網絡輸入流對取并打印BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String s = br.readLine();System.out.println(s);//4.釋放資源socket.close();} }

服務端

public class ServerDemo {public static void main(String[] args) throws IOException {//1.創建客戶端ServerSocket對象ServerSocket serverSocket = new ServerSocket(10002);//2.監視客戶端，等待請求Socket socket = serverSocket.accept();//3.網絡輸入流讀取客戶端信息BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());//本地輸出流將文件寫入硬盤BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("day15_mySocket\\a.jpg"));//邊讀邊寫byte[] bytes = new byte[1024];int len = bis.read(bytes);while (len != -1) {bos.write(bytes, 0, len);len = bis.read(bytes);}//關閉本地流bos.close();//4.讀寫完畢，傳遞客戶端//網絡輸出流BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上傳成功");bw.newLine();bw.flush();//釋放資源serverSocket.close();socket.close();} }

服務端改進【服務端的對客戶端傳輸的信息的操作可以寫成線程任務，從而創建多線程】

public class ServerDemo {public static void main(String[] args) throws IOException {//1.創建客戶端ServerSocket對象ServerSocket serverSocket = new ServerSocket(10002);//2.監視客戶端，等待請求while (true) {Socket socket = serverSocket.accept();//socket有參構造，得到一個socket的線程任務ThreadSocket threadSocket = new ThreadSocket(socket);Executors.newFixedThreadPool(10).submit(threadSocket);//也可自定義線程池new ThreadPoolExecutor(5,//核心線程數8,//最大線程數1,//臨時線程存在時間TimeUnit.MINUTES,//時間單位new ArrayBlockingQueue<>(8),//阻塞隊列Executors.defaultThreadFactory(),//線程工程new ThreadPoolExecutor.AbortPolicy()//拒絕策略).submit(threadSocket);}} }//線程任務實現類 public class ThreadSocket implements Runnable {private Socket socket;public ThreadSocket(Socket socket) {this.socket = socket;}@Overridepublic void run() {BufferedOutputStream bos = null;try {//3.網絡輸入流讀取客戶端信息BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());//本地輸出流將文件寫入硬盤String s = UUID.randomUUID().toString();bos = new BufferedOutputStream(new FileOutputStream("day15_mySocket\\src\\com\\A\\" + s + ".jpg"));//邊讀邊寫byte[] bytes = new byte[1024];int len = bis.read(bytes);while (len != -1) {bos.write(bytes, 0, len);len = bis.read(bytes);}//4.讀寫完畢，傳遞客戶端//網絡輸出流BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上傳成功");bw.newLine();bw.flush();} catch (IOException e) {e.printStackTrace();} finally {//關閉本地流if (bos != null) {try {bos.close();} catch (IOException e) {e.printStackTrace();}}if (socket != null) {//釋放資源try {socket.close();} catch (IOException e) {e.printStackTrace();}}}} }

6.TCP代碼實現注意點

<1>阻塞方法

a.使用accept()【ServerSocket對象調用】來監聽客戶端，并返回一個Socket對象【阻塞，等待客戶端請求】
——解決客戶端ip地址和端口號與服務端一致，即可發送請求
b.read()【輸入流讀取】阻塞，等待客戶端輸入【結束標記】
——關閉流，或者調用socket.shutdownOutput()方法給與一個結束標記，但不會影響socket流的繼續使用

<2>三次握手【建立連接】

<3>四次揮手【取消連接】

總結

以上是生活随笔為你收集整理的网络编程实现的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。