1. 网络编程的常识

(1) 七层网络模型

image.png

(2) 相关的协议(笔试题)

1. 协议的概念

  • 协议让计算机之间进行通讯的一套规则

image.png

2. TCP协议

image.png
image.png
image.png

3. UDP协议

image.png

(3) IP地址相关（重点）

image.png

(4) （重点）端口号

image.png

2. 基于TCP协议的编程模型(重点)

（1） C/S架构的简介

image.png

（2） 编程模型

image.png

（3）相关类和方法的解析

1. ServerSocket类

image.png

2. Socket类

image.png 

  1. package com.lagou.task19;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintStream;
  7. import java.net.Socket;
  8. import java.util.Scanner;
  10. /**
  11.  * @author 西风月
  12.  * @date 2020/8/29
  13.  * @description
  14.  */
  15. public class ClientStringTest {
  16.     public static void main(String[] args) {
  17.         Socket s = null;
  18.         PrintStream ps = null;
  19.         Scanner sc = null;
  20.         BufferedReader br = null;
  21.         try {
  22.             //1. 创建Socket类型的对象并提供服务器的通信地址
  23.             s = new Socket("127.0.0.1", 6666);
  24.             System.out.println("连接服务器成功！");
  25.             //2. 使用输入输出流进行通信
  26.             ps = new PrintStream(s.getOutputStream());
  27.             br = new BufferedReader(new InputStreamReader(s.getInputStream()));
  28.             while(true) {
  29.                 System.out.println("请输入要发送的数据：");
  30.                 sc = new Scanner(System.in);
  31.                 String s1 = sc.next();
  32.                 //实现客户端向服务器发送字符串"hello"
  33.                 ps.println(s1);
  34.                 //实现接受服务器发来的字符串内容并打印
  35.                 String s2 = br.readLine();
  36.                 System.out.println("服务器回发的消息是：" + s2);
  37.                 if("bye".equalsIgnoreCase(s1)) {
  38.                     System.out.println("聊天结束！");
  39.                     break;
  40.                 }
  41.             }
  42.         } catch (IOException e) {
  43.             e.printStackTrace();
  44.         } finally {
  45.             //3. 关闭Socket并释放资源
  46.             if(br != null) {
  47.                 try {
  48.                     br.close();
  49.                 } catch (IOException e) {
  50.                     e.printStackTrace();
  51.                 }
  52.             }
  53.             if(sc != null) {
  54.                 sc.close();
  55.             }
  56.             if(null != s) {
  57.                 try {
  58.                     s.close();
  59.                 } catch (IOException e) {
  60.                     e.printStackTrace();
  61.                 }
  62.             }
  63.             if(null != ps) {
  64.                 ps.close();
  65.             }
  66.         }
  67.     }
  68. }
  1. package com.lagou.task19;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintStream;
  7. import java.net.ServerSocket;
  8. import java.net.Socket;
  10. /**
  11.  * @author 西风月
  12.  * @date 2020/8/29
  13.  * @description
  14.  */
  15. public class ServerStringTest {
  16.     public static void main(String[] args) {
  17.         ServerSocket ss = null;
  18.         Socket s = null;
  20.         try {
  21.             //1. 创建ServerSocket类型的对象并提供端口号
  22.             ss = new ServerSocket(6666);
  23.             //2. 等待客户端的连接请求，调用accept方法
  24.             while(true) {
  25.                 System.out.println("等待客户端的连接请求！");
  26.                 s = ss.accept();    //当没有客户端连接时，则服务器阻塞在accept方法的调用这里
  27.                 System.out.println("客户端" +s.getInetAddress() + "连接成功~");
  28.                 //每当有一个客户端连接成功,则需要启动一个新的线程为之提供服务
  29.                 new ServerThread(s).start();
  30.             }
  31.         } catch (IOException e) {
  32.             e.printStackTrace();
  33.         } finally {
  34.             //4. 关闭Socket并释放有关的资源
  35.             if(null != ss) {
  36.                 try {
  37.                     ss.close();
  38.                 } catch (IOException e) {
  39.                     e.printStackTrace();
  40.                 }
  41.             }
  42.         }
  45.     }
  46. }
  1. package com.lagou.task19;
  3. import java.io.BufferedReader;
  4. import java.io.IOException;
  5. import java.io.InputStreamReader;
  6. import java.io.PrintStream;
  7. import java.net.Socket;
  8. import java.util.SortedMap;
  10. /**
  11.  * @author 西风月
  12.  * @date 2020/8/30
  13.  * @description
  14.  */
  15. public class ServerThread extends Thread {
  16.     private Socket s;
  18.     public ServerThread(Socket s) {
  19.         this.s = s;
  20.     }
  22.     @Override
  23.     public void run() {
  24.         BufferedReader br = null;
  25.         PrintStream ps = null;
  26.         try {
  27.             br = new BufferedReader(new InputStreamReader(s.getInputStream()));
  28.             ps = new PrintStream(s.getOutputStream());
  29.             while(true) {
  30.                 //3. 使用输入输出流进行通信
  31.                 //实现对客户端发来字符内容的接受并且打印
  32.                 String s1 = br.readLine();
  33.                 System.out.println("客户端" +s.getInetAddress() + "发来的字符串是：" + s1);
  34.                 if("bye".equalsIgnoreCase(s1)) {
  35.                     System.out.println("客户端" +s.getInetAddress() + "下线了!");
  36.                     break;
  37.                 }
  38.                 ps.println("I Recevice!");
  39.                 System.out.println("服务器发送数据成功！");
  40.             }
  41.         } catch (IOException e) {
  42.             e.printStackTrace();
  43.         } finally {
  44.             if(null != s) {
  45.                 try {
  46.                     s.close();
  47.                 } catch (IOException e) {
  48.                     e.printStackTrace();
  49.                 }
  50.             }
  51.             if(ps != null) {
  52.                 ps.close();
  53.             }
  54.             if(null != br) {
  55.                 try {
  56.                     br.close();
  57.                 } catch (IOException e) {
  58.                     e.printStackTrace();
  59.                 }
  60.             }
  61.         }
  62.     }
  63. }

3. 基于udp协议的编程模型(熟悉)

（1）编程模型

image.png

（2） 相关类和方法的解析

1. DatagramSocket类

image.png

2. DatagramPacket类

image.png

3. InetAddress类

image.png

package com.lagou.task19;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

/**
 * @author 西风月
 * @date 2020/8/30
 * @description
 */
public class ReceiveTest {
    public static void main(String[] args) {
        DatagramSocket ds = null;
        try {
            //1. 创建DatagramSocket类型的对象并提供端口号
            ds = new DatagramSocket(8888);
            //2. 创建DatagramPackage类型的对象并提供缓冲区接数据
            byte[] bArr = new byte[20];
            DatagramPacket dp = new DatagramPacket(bArr, bArr.length);
            //3. 通过Socket接收数据内容并放到Packet里面,调用receive方法
            System.out.println("等待数据中.....");
            ds.receive(dp);
            System.out.println("接收的数据是：" + new String(bArr) + "!");
            //回发消息
            byte[] bArr2 = "I Receive!".getBytes();
            DatagramPacket dp2 = new DatagramPacket(bArr2, bArr2.length, dp.getAddress(), dp.getPort());
            ds.send(dp2);
            System.out.println("回发消息成功！");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //4. 关闭Socket并释放有关资源
            if(ds != null) {
                ds.close();
            }
        }
    }
}

package com.lagou.task19;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/**
 * @author 西风月
 * @date 2020/8/30
 * @description
 */
public class SendTest {
    public static void main(String[] args) {
        DatagramSocket ds = null;
        try {
            //1. 创建DatagramSocket类型的对象
            ds = new DatagramSocket();
            //2. 创建DatagramSocket类型对象并提供接收方的通信地址和端口
            byte[] bArr = "hello".getBytes();
            DatagramPacket dp = new DatagramPacket(bArr, bArr.length, InetAddress.getLocalHost(), 8888);
            //3. 通过 Socket发送Packet，调用send方法
            ds.send(dp);
            System.out.println("发送数据成功！");
            //4. 接受回发消息
            byte[] bArr2 = new byte[20];
            DatagramPacket dp2 = new DatagramPacket(bArr2, bArr2.length);
            ds.receive(dp2);
            System.out.println("接收到的回发消息内容是：" + new String(bArr2, 0, dp2.getLength()));

        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //4. 关闭Socket并释放有关的资源
            if(ds != null) {
                ds.close();
            }
        }
    }
}

4. URL类（熟悉）

（1） 基本概念

image.png

（2）常用的方法

image.png

（3）URLConnection类

image.png

package com.lagou.task19;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;

/**
 * @author 西风月
 * @date 2020/8/30
 * @description
 */
public class URLTest {
    public static void main(String[] args) {
        URL url = null;
        try {
            url = new URL("https://www.lagou.com");
            System.out.println("获取到的协议名称是："+ url.getProtocol());
            System.out.println("获取到的主机名称是：" + url.getHost());
            System.out.println("获取到的端口号是：" + url.getPort());
            //获取URLConnection类的实例
            HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
            InputStream i = urlConnection.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(i));
            String str = null;
            while((str = br.readLine()) != null) System.out.println(str);
            br.close();
            //断开连接
            urlConnection.disconnect();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //省略不写....
        }
    }
}

5. 总结

  • 网络编程
    • 网络编程的常识
    • tcp协议的编程模型
      • image.png
    • udp协议的编程模型
  • URL类的概念