Java之UDP,TCP的详细解析

练习四：文件名重复

public class UUIDTest { public static void main(String[] args) { String str = UUID.randomUUID().toString().replace("-", ""); System.out.println(str);//9f15b8c356c54f55bfcb0ee3023fce8a } } ```public class Client {public static void main(String[] args) throws IOException {//客户端：将本地文件上传到服务器。接收服务器的反馈。//服务器：接收客户端上传的文件，上传完毕之后给出反馈。
​
​//1. 创建Socket对象，并连接服务器Socket socket = new Socket("127.0.0.1",10000);
​//2.读取本地文件中的数据，并写到服务器当中BufferedInputStream bis = new BufferedInputStream(new FileInputStream("mysocketnet\\clientdir\\a.jpg"));BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());byte[] bytes = new byte[1024];int len;while ((len = bis.read(bytes)) != -1){bos.write(bytes,0,len);}
​//往服务器写出结束标记socket.shutdownOutput();
​
​//3.接收服务器的回写数据BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line = br.readLine();System.out.println(line);
​
​//4.释放资源socket.close();
​}
}
public class Server {public static void main(String[] args) throws IOException {//客户端：将本地文件上传到服务器。接收服务器的反馈。//服务器：接收客户端上传的文件，上传完毕之后给出反馈。
​
​//1.创建对象并绑定端口ServerSocket ss = new ServerSocket(10000);
​//2.等待客户端来连接Socket socket = ss.accept();
​//3.读取数据并保存到本地文件中BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());String name = UUID.randomUUID().toString().replace("-", "");BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("mysocketnet\\serverdir\\" + name + ".jpg"));int len;byte[] bytes = new byte[1024];while ((len = bis.read(bytes)) != -1) {bos.write(bytes, 0, len);}bos.close();//4.回写数据BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();
​//5.释放资源socket.close();ss.close();}
}

练习五：服务器改写为多线程

服务器只能处理一个客户端请求，接收完一个图片之后，服务器就关闭了。

优化方案一：

使用循环

弊端：

第一个用户正在上传数据，第二个用户就来访问了，此时第二个用户是无法成功上传的。

所以，使用多线程改进

优化方案二：

每来一个用户，就开启多线程处理

public class Client {public static void main(String[] args) throws IOException {//客户端：将本地文件上传到服务器。接收服务器的反馈。//服务器：接收客户端上传的文件，上传完毕之后给出反馈。
​
​//1. 创建Socket对象，并连接服务器Socket socket = new Socket("127.0.0.1",10000);
​//2.读取本地文件中的数据，并写到服务器当中BufferedInputStream bis = new BufferedInputStream(new FileInputStream("mysocketnet\\clientdir\\a.jpg"));BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());byte[] bytes = new byte[1024];int len;while ((len = bis.read(bytes)) != -1){bos.write(bytes,0,len);}
​//往服务器写出结束标记socket.shutdownOutput();
​
​//3.接收服务器的回写数据BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line = br.readLine();System.out.println(line);
​
​//4.释放资源socket.close();
​}
}
public class Server {public static void main(String[] args) throws IOException {//客户端：将本地文件上传到服务器。接收服务器的反馈。//服务器：接收客户端上传的文件，上传完毕之后给出反馈。
​
​//1.创建对象并绑定端口ServerSocket ss = new ServerSocket(10000);
​while (true) {//2.等待客户端来连接Socket socket = ss.accept();
​//开启一条线程//一个用户就对应服务端的一条线程new Thread(new MyRunnable(socket)).start();}
​}
}
​
​
public class MyRunnable implements Runnable{
​Socket socket;
​public MyRunnable(Socket socket){this.socket = socket;}
​@Overridepublic void run() {try {//3.读取数据并保存到本地文件中BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());String name = UUID.randomUUID().toString().replace("-", "");BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("mysocketnet\\serverdir\\" + name + ".jpg"));int len;byte[] bytes = new byte[1024];while ((len = bis.read(bytes)) != -1) {bos.write(bytes, 0, len);}bos.close();//4.回写数据BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();} catch (IOException e) {e.printStackTrace();} finally {//5.释放资源if(socket != null){try {socket.close();} catch (IOException e) {e.printStackTrace();}}}}
}

练习六：线程池改进

public class Client {public static void main(String[] args) throws IOException {//客户端：将本地文件上传到服务器。接收服务器的反馈。//服务器：接收客户端上传的文件，上传完毕之后给出反馈。
​
​//1. 创建Socket对象，并连接服务器Socket socket = new Socket("127.0.0.1",10000);
​//2.读取本地文件中的数据，并写到服务器当中BufferedInputStream bis = new BufferedInputStream(new FileInputStream("mysocketnet\\clientdir\\a.jpg"));BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());byte[] bytes = new byte[1024];int len;while ((len = bis.read(bytes)) != -1){bos.write(bytes,0,len);}
​//往服务器写出结束标记socket.shutdownOutput();
​
​//3.接收服务器的回写数据BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line = br.readLine();System.out.println(line);
​
​//4.释放资源socket.close();
​}
}
public class Server {public static void main(String[] args) throws IOException {//客户端：将本地文件上传到服务器。接收服务器的反馈。//服务器：接收客户端上传的文件，上传完毕之后给出反馈。
​
​//创建线程池对象ThreadPoolExecutor pool = new ThreadPoolExecutor(3,//核心线程数量16,//线程池总大小60,//空闲时间TimeUnit.SECONDS,//空闲时间（单位）new ArrayBlockingQueue<>(2),//队列Executors.defaultThreadFactory(),//线程工厂，让线程池如何创建线程对象new ThreadPoolExecutor.AbortPolicy()//阻塞队列);
​
​
​//1.创建对象并绑定端口ServerSocket ss = new ServerSocket(10000);
​while (true) {//2.等待客户端来连接Socket socket = ss.accept();
​//开启一条线程//一个用户就对应服务端的一条线程//new Thread(new MyRunnable(socket)).start();pool.submit(new MyRunnable(socket));}
​}
}
public class MyRunnable implements Runnable{
​Socket socket;
​public MyRunnable(Socket socket){this.socket = socket;}
​@Overridepublic void run() {try {//3.读取数据并保存到本地文件中BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());String name = UUID.randomUUID().toString().replace("-", "");BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("mysocketnet\\serverdir\\" + name + ".jpg"));int len;byte[] bytes = new byte[1024];while ((len = bis.read(bytes)) != -1) {bos.write(bytes, 0, len);}bos.close();//4.回写数据BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();} catch (IOException e) {e.printStackTrace();} finally {//5.释放资源if(socket != null){try {socket.close();} catch (IOException e) {e.printStackTrace();}}}}
}

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

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

相关文章

【K8S系列】深入解析k8s 网络插件—kube-router

【K8S系列】深入解析k8s 网络插件—kube-router

序言 做一件事并不难&#xff0c;难的是在于坚持。坚持一下也不难&#xff0c;难的是坚持到底。 文章标记颜色说明&#xff1a; 黄色&#xff1a;重要标题红色&#xff1a;用来标记结论绿色&#xff1a;用来标记论点蓝色&#xff1a;用来标记论点 在现代容器化应用程序的世界中…
阅读更多...
java最优建树算法

java最优建树算法

建树算法 树的数据结构 {"code": "1111","name": "","parentcode": "0000","children": null }, {"code": "2222","name": "","parentcode": &q…
阅读更多...
面试算法19：最多删除一个字符得到回文

面试算法19：最多删除一个字符得到回文

题目 给定一个字符串&#xff0c;请判断如果最多从字符串中删除一个字符能不能得到一个回文字符串。例如&#xff0c;如果输入字符串"abca"&#xff0c;由于删除字符’b’或’c’就能得到一个回文字符串&#xff0c;因此输出为true。 分析 本题还是从字符串的两端…
阅读更多...
Tomcat隔离web原理和热加载热部署

Tomcat隔离web原理和热加载热部署

Tomcat 如何打破双亲委派机制 Tomcat 的自定义类加载器 WebAppClassLoader 打破了双亲委派机制&#xff0c;它首先自己尝试去加载某个类&#xff0c;如果找不到再代理给父类加载器&#xff0c;其目的是优先加载 Web 应用自己定义的类。具体实现就是重写 ClassLoader 的两个方法…
阅读更多...
SpringBoot全局异常处理 | Java

SpringBoot全局异常处理 | Java

⭐简单说两句⭐ 作者&#xff1a;后端小知识 CSDN个人主页&#xff1a;后端小知识 &#x1f50e;GZH&#xff1a;后端小知识 &#x1f389;欢迎关注&#x1f50e;点赞&#x1f44d;收藏⭐️留言&#x1f4dd; 文章目录 ✨SpringBoot全局异常处理 | Java&#x1f3a8;什么是全局…
阅读更多...
CAXA汇总尺寸避免混乱

CAXA汇总尺寸避免混乱

把单图的尺寸名称全部重命名
阅读更多...
Android 13 骁龙相机点击拍照流程分析（二）——点击拍照到存入相册

Android 13 骁龙相机点击拍照流程分析（二）——点击拍照到存入相册

一.前言 本篇是在Android 13 骁龙相机点击拍照流程分析（一）——点击拍照到更新到左下角缩略图文章的基础上进行延申的，前面的预览、点击拍照的过程参考第一篇：Android 13 骁龙相机点击拍照流程分析（一）——点击拍照到更新到左下角缩略图-CSDN博客 二.生成图片并保存 从第…
阅读更多...
KUKA机器人通过直接输入法设定负载数据和附加负载数据的具体操作

KUKA机器人通过直接输入法设定负载数据和附加负载数据的具体操作

KUKA机器人通过直接输入法设定负载数据和附加负载数据的具体操作 设置背景色： 工具负载数据 工具负载的定义： 工具负载数据是指所有装在机器人法兰上的负载。它是另外装在机器人上并由机器人一起移动的质量。需要输入的值有质量、重心位置、质量转动惯量以及所属的主惯性轴。…
阅读更多...
爱尔眼科角膜塑形镜验配超百万，全力做好“角塑镜把关人”

爱尔眼科角膜塑形镜验配超百万，全力做好“角塑镜把关人”

你知道吗?过去的2022年&#xff0c;我国儿童青少年总体近视率为53.6%&#xff0c;其中6岁儿童为14.5%&#xff0c;小学生为36%&#xff0c;初中生为71.6%&#xff0c;高中生为81%①。儿童青少年眼健康问题俨然成为全社会关心的热点与痛点&#xff0c;牵动着每一个人的神经。 好…
阅读更多...
给手机上液冷？谈谈华为Mate 60系列手机专属黑科技—— “微泵液冷”手机壳

给手机上液冷？谈谈华为Mate 60系列手机专属黑科技—— “微泵液冷”手机壳

最近&#xff0c;有一个手机配件吸引了我的注意——华为的微泵液冷壳。 简单来说&#xff0c;就是在手机壳里装了无线充电微泵&#xff0c;为手机实现外置水冷的能力。让手机壳在“外观装饰”和“防摔保护”的功能性上额外加了一个“降温提性能”的作用。 接下来&#xff0c;本…
阅读更多...
深度学习DAY3:神经网络训练常见算法概述

深度学习DAY3:神经网络训练常见算法概述

梯度下降法&#xff08;Gradient Descent&#xff09;&#xff1a; 这是最常见的神经网络训练方法之一。它通过计算损失函数对权重的梯度&#xff0c;并沿着梯度的反方向更新权重&#xff0c;从而逐步减小损失函数的值。梯度下降有多个变种&#xff0c;包括随机梯度下降&#…
阅读更多...
软考-高级系统架构师复习知识点总结

软考-高级系统架构师复习知识点总结

软件架构概念 软件架构定义 系统的一个或多个结构。结构中包含软件的构件、构件的外部可见属性、构件之间的相互关系。 软件架构设计与生命周期 需求分析阶段：问题空间，根据需求模型构件SA模型、保证模型转换的可追踪性 设计阶段 SA模型的描述： SA的基本概念：构件、…
阅读更多...
MySQL之MHA集群

MySQL之MHA集群

MHA概述 什么是 MHA MHA&#xff08;MasterHigh Availability&#xff09;是一套优秀的MySQL高可用环境下故障切换和主从复制的软件。 MHA 的出现就是解决MySQL 单点故障的问题。 MySQL故障切换过程中&#xff0c;MHA能做到0-30秒内自动完成故障切换操作。 MHA能在故障切换…
阅读更多...
iPhone手机上使用的定时提醒APP是哪个

iPhone手机上使用的定时提醒APP是哪个

在日常喧闹的生活和工作中&#xff0c;琐碎的任务会像喷泉一样突涌而至&#xff0c;如不及时规划&#xff0c;我们将陷入手足无措的境地。而想要让各项工作任务按时完成&#xff0c;我们可以借助一些比较好用的时间提醒软件来督促各项任务。 就拿常用的iPhone手机来讲&#xf…
阅读更多...
Flutter的Platform介绍-跨平台开发，如何根据不同平台创建不同UI和行为

Flutter的Platform介绍-跨平台开发，如何根据不同平台创建不同UI和行为

文章目录 Flutter跨平台概念介绍跨平台开发平台相关性Platform ChannelPlatform-specific UIPlatform Widgets 如何判断当前是什么平台实例 Platform 类介绍获取当前平台的名称检查当前平台其他属性 利用flutter设计跨Android和IOS平台应用的技巧1. 遵循平台的设计准则2. 使用平…
阅读更多...
回归算法全解析！一文读懂机器学习中的回归模型

回归算法全解析！一文读懂机器学习中的回归模型

目录 一、引言回归问题的重要性文章目的和结构概览 二、回归基础什么是回归问题例子&#xff1a; 回归与分类的区别例子&#xff1a; 回归问题的应用场景例子&#xff1a; 三、常见回归算法3.1 线性回归数学原理代码实现输出例子&#xff1a; 3.2 多项式回归数学原理代码实现输…
阅读更多...
Ubuntu磁盘满了，导致黑屏

Ubuntu磁盘满了，导致黑屏

前言 &#xff08;1&#xff09;最近要玩Milk-V Duo&#xff0c;配置环境过程中&#xff0c;发现磁盘小了。于是退出虚拟机&#xff0c;扩大Ubuntu大小&#xff0c;重新开机&#xff0c;发现无法进入Ubuntu界面。 &#xff08;2&#xff09;查了很久&#xff0c;后面发现是磁盘…
阅读更多...
javascript二维数组(19)不要键名只保留值的算法

javascript二维数组(19)不要键名只保留值的算法

在数组var a[ {pre1_day_off:1}, {pre2_day_off:2}, {pre3_day_off:3} ]中&#xff0c;如果去除键名只保留值&#xff0c;形成[1,2,3]这样的数组格式 在JavaScript中&#xff0c;你可以通过使用Array.prototype.map函数来实现这个目标。map函数遍历数组的每个元素&#xff0c;然…
阅读更多...
这短短 6 行代码你能数出几个bug？

这短短 6 行代码你能数出几个bug？

前言&#xff1a;本文仅仅只是分享笔者一年前见到的诡异代码&#xff0c;大家可以看看乐子&#xff0c;随便数一数一共有多少个bug&#xff0c;这数bug多少还是要点水平的 在初学编程的时候&#xff0c;写的第一个代码大多都是 hello world&#xff0c;可是就算是 hello world…
阅读更多...
Windows安装Node.js

Windows安装Node.js

1、Node.js介绍 ①、Node.js简介 Node.js是一个开源的、跨平台的JavaScript运行环境&#xff0c;它允许开发者使用JavaScript语言来构建高性能的网络应用程序和服务器端应用。Node.js的核心特点包括&#xff1a; 1. 事件驱动: Node.js采用了事件驱动的编程模型&#xff0c;通…
阅读更多...
最新文章

Copyright @ 2022~2023