• 网络编程实战（二）

    目录

    一、TCP文件上传实现

    二、UDP消息发送

    2.1 DatagramPacket

    2.2 DatagramSocket

    2.3 实现消息通信

    三、UDP聊天实现

    四、UDP多线程在线咨询

    五、URL下载网络资源

    一、TCP文件上传实现

    准备工作：准备一张图片放于根目录下

    客户端：1）创建一个socket连接

                   2）创建一个输出流

                   3）需要拿到文件 --->  需要文件流

                   4）将文件写出 （需要用到IO流知识点，这一块都是固定写法）

                   5）通知服务器传输完毕

                   6）确认服务器接收完毕，断开连接

                   7）关闭资源

    1. import java.io.ByteArrayOutputStream;
    2. import java.io.FileInputStream;
    3. import java.io.InputStream;
    4. import java.io.OutputStream;
    5. import java.net.InetAddress;
    6. import java.net.Socket;
    7.  
    8. public class TcpClientDemo02 {
    9.     public static void main(String[] args) throws Exception {
    10.         //1.创建一个socket连接
    11.         Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 9000);
    12.         //2.创建一个输出流
    13.         OutputStream os = socket.getOutputStream();
    14.         //3.文件流（拿到文件）
    15.         FileInputStream fis = new FileInputStream("tx.PNG");
    16.         //4.写出文件
    17.         byte[] buffer = new byte[1024];//缓冲区
    18.         int len;
    19.         while((len=fis.read(buffer))!=-1){
    20.             os.write(buffer,0,len);
    21.         }
    22.  
    23.         //通知服务器传输完毕
    24.         socket.shutdownOutput();
    25.  
    26.         //确定服务器接收完毕，才断开连接
    27.         InputStream inputStream = socket.getInputStream();
    28.         ByteArrayOutputStream baos = new ByteArrayOutputStream();
    29.         byte[] buffer2 = new byte[2014];
    30.         int len2;
    31.         while((len2=inputStream.read(buffer2))!=-1){
    32.             baos.write(buffer2,0,len2);
    33.         }
    34.  
    35.         System.out.println(baos.toString());
    36.  
    37.         //关闭资源
    38.         baos.close();
    39.         inputStream.close();
    40.         fis.close();
    41.         os.close();
    42.         socket.close();
    43.     }
    44. }

    服务器：1）创建服务 （两边端口号需一致）

                   2）监听客户端的连接

                   3）获取输入流

                   4）文件输出 ---> 利用管道输出流 （固定写法）

                   5）通知客户端接收完毕

                   6）关闭资源

    1. import java.io.File;
    2. import java.io.FileOutputStream;
    3. import java.io.InputStream;
    4. import java.io.OutputStream;
    5. import java.net.ServerSocket;
    6. import java.net.Socket;
    7.  
    8. public class TcpServerDemo02 {
    9.     public static void main(String[] args) throws Exception {
    10.         //1.创建服务
    11.         ServerSocket serverSocket = new ServerSocket(9000);
    12.         //2.监听客户端的连接
    13.         Socket socket = serverSocket.accept();//阻塞式监听，会一直等待客户端的连接
    14.         //3.获取输入流
    15.         InputStream is = socket.getInputStream();
    16.         //4.文件输出(利用管道输出流)
    17.         FileOutputStream fos = new FileOutputStream(new File("receive.PNG"));
    18.         byte[] buffer = new byte[1024];
    19.         int len;
    20.         while((len=is.read(buffer))!=-1){
    21.             fos.write(buffer,0,len);
    22.         }
    23.  
    24.         //通知客户端接收完毕
    25.         OutputStream os = socket.getOutputStream();
    26.         os.write("可以断开了".getBytes());
    27.  
    28.         //5.关闭资源
    29.         fos.close();
    30.         is.close();
    31.         socket.close();
    32.         serverSocket.close();
    33.     }
    34. }

    运行结果：

    tx.PNG是事先准备的资源文件         receive.PNG是接收到的资源文件

    二、UDP消息发送

    2.1 DatagramPacket

    在码头发送和接收货物时都需要使用集装箱来装载货物，UDP通信也是一样，发送和接收的数据也需要使用“集装箱”进行打包，为此JDK中提供了一个DatagramPacket类，该类的实例对象就相当于一个集装箱，用于封装UDP通信中发送或者接收的数据。

    2.2 DatagramSocket

    DatagramPacket数据包的作用就如同是“集装箱”，可以将发送端或者接收端的数据封装起来。然而运输货物只有“集装箱”是不够的，还需要有码头。在程序中需要实现通信只有DatagramPacket数据包也同样不行，为此JDK中提供的一个DatagramSocket类。DatagramSocket类的作用就类似于码头，使用这个类的实例对象就可以发送和接收DatagramPacket数据包，发送数据的过程如下图所示。

    2.3 实现消息通信

    实际UDP通信中并不存在客服端和服务器一说法

    发送端：  1）需要一个socket

                     2）建个包

                     3）确定发送对象

                     4）发送包

                     5）关闭流

    1. import java.net.DatagramPacket;
    2. import java.net.DatagramSocket;
    3. import java.net.InetAddress;
    4.  
    5. //不需要连接服务器
    6. public class UDPClientDemo01 {
    7.     public static void main(String[] args) throws Exception {
    8.         //1.建立一个socket
    9.         DatagramSocket socket = new DatagramSocket();
    10.         //2.建个包
    11.         String msg="hello";
    12.         //发送给谁
    13.         InetAddress localhost = InetAddress.getByName("localhost");
    14.         int port=9090;
    15.         //getBytes() 是Java编程语言中将一个字符串转化为一个字节数组byte[]的方法
    16.         //参数：数据    数据的长度  发送给谁
    17.         DatagramPacket packet = new DatagramPacket(msg.getBytes(), 0, msg.getBytes().length, localhost, port);
    18.         //3.发送包
    19.         socket.send(packet);
    20.         //4.关闭流
    21.         socket.close();
    22.     }
    23. }

    接收端： 1）开放端口

                   2）接收数据包

                   3）读取内容

                   4）关闭流

    1. //需要等待客户端的连接
    2. public class UDPServerDemo01 {
    3.     public static void main(String[] args) throws Exception {
    4.         //开放端口
    5.         DatagramSocket socket = new DatagramSocket(9090);
    6.         //接收数据包
    7.         byte[] buffer = new byte[1024];
    8.         DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);//接收
    9.         socket.receive(packet);//阻塞接受
    10.         //读取内容
    11.         System.out.println(packet.getAddress().getHostAddress());
    12.         System.out.println(new String(packet.getData(),0,packet.getLength()));
    13.         //关闭流
    14.         socket.close();
    15.     }
    16. }

    运行结果：

    三、UDP聊天实现

    发送方：

    1. import java.io.BufferedReader;
    2. import java.io.InputStreamReader;
    3. import java.net.DatagramPacket;
    4. import java.net.DatagramSocket;
    5. import java.net.InetSocketAddress;
    6.  
    7. public class UDPSendDemo01 {
    8.     public static void main(String[] args) throws Exception {
    9.         DatagramSocket socket = new DatagramSocket(8888);
    10.         //准备数据：控制台读取 System.in
    11.         BufferedReader reader=   new BufferedReader(new InputStreamReader(System.in));
    12.         while (true){
    13.             String data= reader.readLine();
    14.             byte[] datas=data.getBytes();
    15.             DatagramPacket packet=new DatagramPacket(datas,0,datas.length,new InetSocketAddress("localhost",6666));
    16.             socket.send(packet);
    17.             if (data.equals("bye")){
    18.                 break;
    19.             }
    20.         }
    21.         socket.close();
    22.     }
    23. }

    接收方：

    1. import java.net.DatagramPacket;
    2. import java.net.DatagramSocket;
    3.  
    4. public class UDPReceiveDemo01 {
    5.     public static void main(String[] args) throws Exception {
    6.         DatagramSocket socket = new DatagramSocket(6666);
    7.  
    8.         //循环接收
    9.         while (true){
    10.             //准备接收包裹
    11.             byte[] container = new byte[1024];
    12.             DatagramPacket packet = new DatagramPacket(container,0,container.length);
    13.             socket.receive(packet);//阻塞式接收包裹
    14.             //断开连接
    15.             byte[] data=packet.getData();
    16.             String receiveData = new String(data, 0, packet.getLength());
    17.             System.out.println(receiveData);
    18.  
    19.             if(receiveData.equals("bye")) {
    20.                 break;
    21.             }
    22.         }
    23.         socket.close();
    24.     }
    25. }

    运行结果：

    四、UDP多线程在线咨询

    双方互为发送方与接收方

    案例：模拟教师-学生间互发消息

    发送端：

    1. import java.io.BufferedReader;
    2. import java.io.IOException;
    3. import java.io.InputStreamReader;
    4. import java.net.DatagramPacket;
    5. import java.net.DatagramSocket;
    6. import java.net.InetSocketAddress;
    7. import java.net.SocketException;
    8.  
    9. public class TalkSend implements Runnable{
    10.     private int fromPort;
    11.     private String toIP;
    12.     private int toPort;
    13.     DatagramSocket socket = null;
    14.     BufferedReader reader = null;
    15.  
    16.     public TalkSend(int fromPort, String toIP,int toPort) {
    17.         this.fromPort = fromPort;
    18.         this.toIP = toIP;
    19.         this.toPort = toPort;
    20.  
    21.         try {
    22.             //初始化建立连接
    23.             socket = new DatagramSocket(fromPort);
    24.             //控制台获取输入的文字信息
    25.             reader = new BufferedReader(new InputStreamReader(System.in));
    26.         } catch (SocketException e) {
    27.             e.printStackTrace();
    28.         }
    29.     }
    30.  
    31.     @Override
    32.     public void run() {
    33.         while(true){
    34.             try {
    35.                 //读取数据
    36.                 String data = reader.readLine();
    37.                 //新建数据包
    38.                 byte[] datas = data.getBytes();
    39.                 DatagramPacket  packet = new DatagramPacket (datas, 0, datas.length,new InetSocketAddress(this.toIP,this.toPort));
    40.                 //发送包
    41.                 socket.send(packet);
    42.                 if(data.startsWith("bye"))
    43.                     break;
    44.             } catch (IOException e) {
    45.                 e.printStackTrace();
    46.             }
    47.         }
    48.     }
    49. }

    接收端：

    1. import java.net.DatagramPacket;
    2. import java.net.DatagramSocket;
    3.  
    4. public class TalkReceive implements  Runnable{
    5.  
    6.     DatagramSocket socket = null;
    7.     private int port;
    8.     private String msgFrom;
    9.  
    10.     public TalkReceive(int port, String msgFrom) {
    11.         this.port = port;
    12.         this.msgFrom = msgFrom;
    13.  
    14.         try {
    15.             //初始化建立连接
    16.             socket = new DatagramSocket(port);
    17.         } catch (Exception e) {
    18.             e.printStackTrace();
    19.         }
    20.     }
    21.  
    22.     @Override
    23.     public void run() {
    24.         //无限循环获取消息
    25.         while (true){
    26.             try {
    27.                 byte[] container = new byte[1024];
    28.                 //新建包用于存储等下要接收的信息
    29.                 DatagramPacket packet = new DatagramPacket(container, 0, container.length);
    30.                 //存储到packet里面
    31.                 socket.receive(packet);
    32.  
    33.  
    34.                 //转换
    35.                 byte[] data = packet.getData();
    36.                 String receiveData = new String(data, 0, packet.getLength());
    37.  
    38.                 System.out.println(msgFrom + ":" + receiveData);
    39.  
    40.                 if(receiveData.startsWith("bye")){
    41.                     break;
    42.                 }
    43.             } catch (Exception e) {
    44.                 e.printStackTrace();
    45.             }
    46.         }
    47.         socket.close();
    48.     }
    49. }

    学生：

    1. public class TalkStudent{
    2.     public static void main(String[] args) {
    3.         //开启两个线程
    4.         new Thread(new TalkSend(7777,"localhost",9999)).start();
    5.         new Thread(new TalkReceive(8888,"老师")).start();
    6.     }
    7. }

    老师：

    1. public class TalkTeacher {
    2.     public static void main(String[] args) {
    3.         new Thread(new TalkSend(5555,"localhost",8888)).start();
    4.         new Thread(new TalkReceive(9999,"学生")).start();
    5.     }
    6. }

    运行结果：

    学生收到的信息：

    老师收到的信息：

    五、URL下载网络资源

    URL：统一资源定位符，定位资源，即定位互联网上的某一个资源

    DNS：域名解析

    案例：测试URL

    1. import java.net.MalformedURLException;
    2. import java.net.URL;
    3.  
    4. public class URLDemo01 {
    5.     public static void main(String[] args) throws MalformedURLException {
    6.         URL url = new URL("http://localhost:8080/helloworld/index.jsp?username=biubiu$password=123");
    7.         System.out.println(url.getProtocol());//协议名
    8.         System.out.println(url.getHost());//主机(IP)
    9.         System.out.println(url.getPort());//端口号
    10.         System.out.println(url.getPath());//文件地址
    11.         System.out.println(url.getFile());//文件全路径
    12.         System.out.println(url.getQuery());//参数
    13.     }
    14. }

    案例：下载网络资源，这里以下载图片为例

    1. import java.io.FileOutputStream;
    2. import java.io.InputStream;
    3. import java.net.HttpURLConnection;
    4. import java.net.URL;
    5.  
    6. public class urlDown {
    7.     public static void main(String[] args) throws Exception {
    8.         //1.下载地址
    9.         URL url = new URL("https://img-blog.csdnimg.cn/018fc854848e4a92b9b4e2db976aa779.png");
    10.         //2。连接到这个地址
    11.         HttpURLConnection urlConnection=(HttpURLConnection) url.openConnection();
    12.         InputStream inputStream = urlConnection.getInputStream();
    13.         FileOutputStream fos = new FileOutputStream("test.png");
    14.  
    15.         byte[] buffer = new byte[1024];
    16.         int len;
    17.         while((len=inputStream.read(buffer))!=-1){
    18.             fos.write(buffer,0,len);
    19.         }
    20.         fos.close();
    21.         inputStream.close();
    22.         urlConnection.disconnect();
    23.     }
    24. }

    运行结果：图片被成功下载

  • 相关阅读:
    docker部署Vaultwarden密码共享管理系统
    redis面试基础
    vue生成动态表单
    大数据之LibrA数据库系统告警处理（ALM-12030 无合法license存在）
    【字符串】【字符串和字符数组的相互转化】Leetcode 541 反转字符串 II
    Vue3中组件数据的传递以及更改
    EFDC模型教程
    请问swat输出的是有机氮、 有机磷、 硝态氮等，但目前只有总磷、总氮和氨氮的数据，该怎么率定呢？
    linux安装Jdk
    OBS-Studio-27.2.4-Full-Installer-x64.exe 下载
  • 原文地址：https://blog.csdn.net/qq_61727355/article/details/126166307