day11【网络编程】-综合案例

news2024/11/15 17:52:24

day11【网络编程】

第三章 综合案例

3.1 文件上传案例

文件上传分析图解

  1. 【客户端】输入流，从硬盘读取文件数据到程序中。
  2. 【客户端】输出流，写出文件数据到服务端。
  3. 【服务端】输入流，读取文件数据到服务端程序。
  4. 【服务端】输出流，写出文件数据到服务器硬盘中。

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

基本实现

服务端实现：

public class FileUpload_Server {
    public static void main(String[] args) throws IOException {
        System.out.println("服务器 启动.....  ");
        // 1. 创建服务端ServerSocket
      	ServerSocket serverSocket = new ServerSocket(6666);
  		// 2. 建立连接 
        Socket accept = serverSocket.accept();
      	// 3. 创建流对象
      	// 3.1 获取输入流,读取文件数据
        BufferedInputStream bis = new BufferedInputStream(accept.getInputStream());
        // 3.2 创建输出流,保存到本地 .
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("copy.jpg"));
		// 4. 读写数据
        byte[] b = new byte[1024 * 8];
        int len;
        while ((len = bis.read(b)) != -1) {
            bos.write(b, 0, len);
        }
        //5. 关闭 资源
        bos.close();
        bis.close();
        accept.close();
        System.out.println("文件上传已保存");
    }
}

客户端实现：

public class FileUPload_Client {
	public static void main(String[] args) throws IOException {
        // 1.创建流对象
        // 1.1 创建输入流,读取本地文件  
        BufferedInputStream bis  = new BufferedInputStream(new FileInputStream("test.jpg"));
        // 1.2 创建输出流,写到服务端 
        Socket socket = new Socket("localhost", 6666);
        BufferedOutputStream   bos   = new BufferedOutputStream(socket.getOutputStream());

        //2.写出数据. 
        byte[] b  = new byte[1024 * 8 ];
        int len ; 
        while (( len  = bis.read(b))!=-1) {
            bos.write(b, 0, len);
            bos.flush();
        }
        System.out.println("文件发送完毕");
        // 3.释放资源

        bos.close(); 
        socket.close();
        bis.close(); 
        System.out.println("文件上传完毕 ");
	}
}

文件上传优化分析

  1. 文件名称写死的问题

    服务端，保存文件的名称如果写死，那么最终导致服务器硬盘，只会保留一个文件，建议使用系统时间优化，保证文件名称唯一，代码如下：

FileOutputStream fis = new FileOutputStream(System.currentTimeMillis()+".jpg") // 文件名称
BufferedOutputStream bos = new BufferedOutputStream(fis);

  1. 循环接收的问题

    服务端，指保存一个文件就关闭了，之后的用户无法再上传，这是不符合实际的，使用循环改进，可以不断的接收不同用户的文件，代码如下：

// 每次接收新的连接,创建一个Socket
while（true）{
    Socket accept = serverSocket.accept();
    ......
}

  1. 效率问题

    服务端，在接收大文件时，可能耗费几秒钟的时间，此时不能接收其他用户上传，所以，使用多线程技术优化，代码如下：

while（true）{
    Socket accept = serverSocket.accept();
    // accept 交给子线程处理.
    new Thread(() -> {
      	......
        InputStream bis = accept.getInputStream();
      	......
    }).start();
}
优化实现
public class FileUpload_Server {
    public static void main(String[] args) throws IOException {
        System.out.println("服务器 启动.....  ");
        // 1. 创建服务端ServerSocket
        ServerSocket serverSocket = new ServerSocket(6666);
      	// 2. 循环接收,建立连接
        while (true) {
            Socket accept = serverSocket.accept();
          	/* 
          	3. socket对象交给子线程处理,进行读写操作
               Runnable接口中,只有一个run方法,使用lambda表达式简化格式
            */
            new Thread(() -> {
                try (
                    //3.1 获取输入流对象
                    BufferedInputStream bis = new BufferedInputStream(accept.getInputStream());
                    //3.2 创建输出流对象, 保存到本地 .
                    FileOutputStream fis = new FileOutputStream(System.currentTimeMillis() + ".jpg");
                    BufferedOutputStream bos = new BufferedOutputStream(fis);) {
                    // 3.3 读写数据
                    byte[] b = new byte[1024 * 8];
                    int len;
                    while ((len = bis.read(b)) != -1) {
                      bos.write(b, 0, len);
                    }
                    //4. 关闭 资源
                    bos.close();
                    bis.close();
                    accept.close();
                    System.out.println("文件上传已保存");
                } catch (IOException e) {
                  	e.printStackTrace();
                }
            }).start();
        }
    }
}

信息回写分析图解

前四步与基本文件上传一致.

  1. 【服务端】获取输出流，回写数据。
  2. 【客户端】获取输入流，解析回写数据。

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

回写实现
public class FileUpload_Server {
    public static void main(String[] args) throws IOException {
        System.out.println("服务器 启动.....  ");
        // 1. 创建服务端ServerSocket
        ServerSocket serverSocket = new ServerSocket(6666);
        // 2. 循环接收,建立连接
        while (true) {
            Socket accept = serverSocket.accept();
          	/*
          	3. socket对象交给子线程处理,进行读写操作
               Runnable接口中,只有一个run方法,使用lambda表达式简化格式
            */
            new Thread(() -> {
                try (
                    //3.1 获取输入流对象
                    BufferedInputStream bis = new BufferedInputStream(accept.getInputStream());
                    //3.2 创建输出流对象, 保存到本地 .
                    FileOutputStream fis = new FileOutputStream(System.currentTimeMillis() + ".jpg");
                    BufferedOutputStream bos = new BufferedOutputStream(fis);
                ) {
                    // 3.3 读写数据
                    byte[] b = new byte[1024 * 8];
                    int len;
                    while ((len = bis.read(b)) != -1) {
                        bos.write(b, 0, len);
                    }

                    // 4.=======信息回写===========================
                    System.out.println("back ........");
                    OutputStream out = accept.getOutputStream();
                    out.write("上传成功".getBytes());
                    out.close();
                    //================================

                    //5. 关闭 资源
                    bos.close();
                    bis.close();
                    accept.close();
                    System.out.println("文件上传已保存");
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

客户端实现：

public class FileUpload_Client {
    public static void main(String[] args) throws IOException {
        // 1.创建流对象
        // 1.1 创建输入流,读取本地文件
        BufferedInputStream bis = new BufferedInputStream(new FileInputStream("test.jpg"));
        // 1.2 创建输出流,写到服务端
        Socket socket = new Socket("localhost", 6666);
        BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());

        //2.写出数据.
        byte[] b  = new byte[1024 * 8 ];
        int len ;
        while (( len  = bis.read(b))!=-1) {
            bos.write(b, 0, len);
        }
      	// 关闭输出流,通知服务端,写出数据完毕
        socket.shutdownOutput();
        System.out.println("文件发送完毕");
        // 3. =====解析回写============
        InputStream in = socket.getInputStream();
        byte[] back = new byte[20];
        in.read(back);
        System.out.println(new String(back));
        in.close();
        // ============================

        // 4.释放资源
        socket.close();
        bis.close();
    }
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1539010.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

scDEA一键汇总12种单细胞差异分析方法 DESeq2、edgeR、MAST、monocle、scDD、Wilcoxon

scDEA一键汇总12种单细胞差异分析方法 DESeq2、edgeR、MAST、monocle、scDD、Wilcoxon

问题来源 单细胞可以做差异分析，但是究竟选择哪种差异分析方法最靠谱呢？ 解决办法 于是我去检索文献，是否有相关研究呢？ https://academic.oup.com/bib/article/23/1/bbab402/6375516 文章指出，现有的差异分析方法…
阅读更多...
Linux基础-Makefile

Linux基础-Makefile

目录 一、Make简介 二、Makefile基本结构 示例： 补充(Makefile)： 伪目标： 三、创建和使用变量 变量定义的方式： 简单方式： 递归方式： 用?定义变量 为变量添加值 预定义变量 例 自动变量 例 …
阅读更多...
数据结构从入门到精通——快速排序

数据结构从入门到精通——快速排序

快速排序 前言一、快速排序的基本思想常见方式通用模块 二、快速排序的特性总结三、三种快速排序的动画展示四、hoare版本快速排序的代码展示普通版本优化版本为什么要优化快速排序代码三数取中法优化代码 五、挖坑法快速排序的代码展示六、前后指针快速排序的代码展示七、非递…
阅读更多...
Sentry(Android)源码解析

Sentry(Android)源码解析

本文字数：16030字 预计阅读时间：40分钟 01 前言 Sentry是一个日志记录、错误上报、性能监控的开源框架，支持众多平台： 其使用方式在本文不进行说明了，大家可参照官方文档：https://docs.sentry.io/platforms…
阅读更多...
【网络基础】VRRP虚拟路由冗余协议介绍与配置

【网络基础】VRRP虚拟路由冗余协议介绍与配置

目录 一、VRRP的概述 1.1 VRRP的由来 1.2 作用 1.3 基本结构 1.4 状态机流程 1.5 设备类型 二、 实例演示 一、VRRP的概述 1.1 VRRP的由来 局域网中的用户终端通常采用配置一个默认网关的形式访问外部网络，如果此时默认网关设备发生故障，将中断…
阅读更多...
算法设计与分析-分支限界——沐雨先生

算法设计与分析-分支限界——沐雨先生

（1）抓奶牛问题描述： 农夫约翰被告知逃跑的奶牛的位置，并且要求立即去抓住它。约翰开始的位置在数轴上位置 N （ 0 ≤ N ≤ 100) ，而奶牛的位置在同样一个数轴上的 K (0 ≤ K ≤ 100) 。约翰有两种移动方式&…
阅读更多...
普洛斯怀来数据中心获Uptime MO认证，以高品质服务持续提升客户体验

普洛斯怀来数据中心获Uptime MO认证，以高品质服务持续提升客户体验

近日，普洛斯怀来数据中心顺利通过Uptime M&O（运维与管理）认证，获得Uptime Institute颁发的认证证书。普洛斯数据中心致力于为客户提供高品质、高可靠的运维服务，此项认证，标志着普洛斯数据中心运营及管…
阅读更多...
Mac上玩《赛博朋克2077》mac电脑怎么玩这个游戏

Mac上玩《赛博朋克2077》mac电脑怎么玩这个游戏

X用户crushovitz_b最近发现，在《赛博朋克2077》游戏主菜单页面，将鼠标停在版本号选项卡上面足够长时间，就会发现游戏当前的版本号由2.12变为了2.0.77，这是对游戏标题2077的致敬彩蛋。 《赛博朋克2077》的叙事总监兼续集副总监Pawe…
阅读更多...
Flutter 事件传递简单概述、事件冒泡、事件穿透

Flutter 事件传递简单概述、事件冒泡、事件穿透

前言 当前案例 Flutter SDK版本：3.13.2 本文对 事件传递只做 简单概述，主要讲解，事件传递过程中可能遇到的问题解决，比如 事件冒泡、事件穿透； 不是我偷懒，是自认为没有这几位写的详细、仔细&#xff0c…
阅读更多...
FPGA学习_时序分析

FPGA学习_时序分析

文章目录 前言一、组合逻辑与时序逻辑二、建立时间和保持时间三、建立时间和保持时间 前言 心中有电路，下笔自然神！！！ 一、组合逻辑与时序逻辑 组合逻辑：没有时钟控制的数字电路，代码里的判断逻辑都是组…
阅读更多...
颠覆传统：Web3如何塑造未来的数字经济

颠覆传统：Web3如何塑造未来的数字经济

引言 近年来，随着数字化时代的到来，互联网已经成为人们生活中不可或缺的一部分。然而，随着技术的不断发展和社会的不断变迁，传统的Web2模式逐渐显露出一些弊端，如数据垄断、隐私泄露等问题，这促使人们寻求…
阅读更多...
简历指导与模板获取

简历指导与模板获取

简历是应聘过程当中最重要的材料，是我们在求职市场的一张名片，一份好的简历能够吸引招聘者的注意，使你在竞争激烈的求职市场中脱颖而出。 1.简历指导 以下是一份典型简历的主要部分和常见内容： 联系信息： 包括你的全…
阅读更多...
设计模式 适配器模式

设计模式 适配器模式

1.背景 适配器模式，这个模式也很简单，你笔记本上的那个拖在外面的黑盒子就是个适配器，一般你在中国能用，在日本也能用，虽然两个国家的的电源电压不同，中国是 220V，日本是 110V，但是这…
阅读更多...
操作系统面经-什么是操作系统？

操作系统面经-什么是操作系统？

通过以下四点可以概括操作系统到底是什么： 操作系统（Operating System，简称 OS）是管理计算机硬件与软件资源的程序，是计算机的基石。操作系统本质上是一个运行在计算机上的软件程序 ，主要用于管理计算机硬…
阅读更多...
DP：路径规划模型

DP：路径规划模型

创作不易，感谢三连支持！ 路径规划主要是让目标对象在规定范围内的区域内找到一条从起点到终点的无碰撞安全路径。大多需要用二维dp数组去实现 一、不同路径 . - 力扣（LeetCode）不同路径 class Solution { public:int uniquePath…
阅读更多...
自动驾驶---Motion Planning之轨迹Path优化

自动驾驶---Motion Planning之轨迹Path优化

1 背景 在之前的几篇文章中，不管是通过构建SL图《自动驾驶---Motion Planning之Path Boundary》，ST图《自动驾驶---Motion Planning之Speed Boundary》，又或者是构建SLT图《自动驾驶---Motion Planning之构建SLT Driving Corridor》，最终我们都是为了得到boundary的信息。 …
阅读更多...
基于springboot的4S店车辆管理系统

基于springboot的4S店车辆管理系统

基于springboot的4S店车辆管理系统 的设计和实现 开发语言：Java 框架：springboot JDK版本：JDK1.8 服务器：tomcat7 数据库：mysql 5.7（一定要5.7版本） 数据库工具：Navicat11 开…
阅读更多...
算法－最短路径

算法－最短路径

图的最短路径问题是一个经典的计算机科学和运筹学问题，旨在找到图中两个顶点之间的最短路径。这种问题在多种场景中都有应用，如网络路由、地图导航等。 解决图的最短路径问题有多种算法，其中最著名的包括： 1.迪杰斯特拉算法 (1).…
阅读更多...
抖音小店怎么定类目？分享几个爆单几率大，适合新手的细分类目！

抖音小店怎么定类目？分享几个爆单几率大，适合新手的细分类目！

大家好，我是电商糖果 做电商的应该经常听过这么一句话，类目大于一切！ 好的类目可以让商家减少很多竞争和难题。 糖果做电商有很多年了，我一直认为做店前期最难的定类目，中期是选品，后期是维护店铺。 如…
阅读更多...
物联网数据报表分析

物联网数据报表分析

随着物联网技术的迅猛发展，越来越多的企业开始将物联网解决方案应用于各个领域，从提高生产效率到优化用户体验，物联网都发挥着至关重要的作用。然而，如何有效地分析和管理物联网产生的海量数据，成为企业面临的挑战之一…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023