Java18:网络编程

一.对象序列化:

1.对象流:

ObjectInputStream 和 ObjectOutputStream

2.作用:

ObjectOutputSteam:内存中的对象-->存储中的文件,通过网络传输出去
ObjectInputStream:存储中的文件,通过网络传输出去-->内存中的对象

3.对象的序列化机制:

对象序列化机制允许把内存中的java对象转换成平台无关的二进制流,从而允许把这种二进制流持久地保存在磁盘上,或通过网络将这种二进制流传输到另外一个网络节点。//当其他程序获取了这种二进制流,就可以恢复成原来的java对象

4.序列化和反序列化过程:

代码实现:

public static void main(String[] args) throws IOException, ClassNotFoundException {//创建对象流ObjectOutputStream oos = new ObjectOutputStream( new FileOutputStream("object.txt"));//字符串序列化oos.writeObject("北京欢迎你!");oos.flush();System.out.println("***************************************");//对象序列化Person p  = new Person("tom",20);oos.writeObject(p);oos.flush();oos.close();System.out.println("***************************************");//反序列化:把对象从文件或数据库中读取到内存中ObjectInputStream ois = new ObjectInputStream(new FileInputStream("object.txt"));Object o = ois.readObject();System.out.println(o);Object o1 = ois.readObject();System.out.println(o1);ois.close();
}

5.实现序列化的对象所属的类需要满足:

1)需要实现接口:Serializable

2)当前类提供一个全局常量:SerialVersionUid

3)除了当前类需要实现Serializable接口之外,还需要保证其内部所有属性也必须是可序列化的

补充:ObjectOutputStream和ObjectInputStream不能序列化static和transient修饰的成员变量

二.随机存取文件流:

1.随机存取文件流:RandomAccessFile

2.使用说明:

1)RandomAccessFile直接继承于java.lang.Object类,实现了数据读取和输出

2)RandomAccessFile即可以是输入流又可以是输出流

3)RandomAccessFile作为输出流时,写出文件如果不存在,则在执行过程中自动创建,

如果写出的文件存在,则会对原文件内容进行覆盖

4)可以通过相关的操作,实现RandomAccessFile"插入"数据的效果。seek(int pos)

3.典型代码:

@Test
public void test() throws IOException {RandomAccessFile acf1 = new RandomAccessFile("cat.jpg", "r");RandomAccessFile acf2 = new RandomAccessFile("cat3.jpg", "rw");byte[] bute = new byte[1024];int len;while ((len = acf1.read(bute)) != -1) {acf2.write(bute, 0, len);}acf1.close();acf2.close();}@Test
public void test2() throws IOException {RandomAccessFile acf1 = new RandomAccessFile("hello1.txt", "rw");acf1.seek(3);acf1.write("xyz".getBytes());acf1.close();}@Test
public void test3() throws IOException {/*使用  RandomAccessFile 实现插入功能*/RandomAccessFile acf1 = new RandomAccessFile("h.txt", "rw");acf1.seek(3);StringBuilder sb  = new StringBuilder((int)new File("h.txt").length());//把剩余内容存到StringBuilder对象byte[] bute = new byte[1024];int len;while ((len = acf1.read(bute)) != -1) {sb.append(new String(bute,0,len));}//把指针从写指到3acf1.seek(3);acf1.write("xyz".getBytes());acf1.write(sb.toString().getBytes());acf1.close();}

三.网络传输:

1.实现网络通信需要解决的两个问题

1)如何准确地定位网络上一台或多台主机:定位主机上的特定应用

2)找到主机后如何可靠高效地进行数据传输

2.网络通信的两个要素:

1)对应问题一:ip和端口号

2)对应问题二:提供网络通信协议:TCP/IP参考模型(应用层,传输层,网络层,物理+数据链路层)

3.通信要素一:ip和端口号

1)ip的理解

》ip:唯一标识Internet上计算机(通信实体)

》在java 中使用InetAddress类代表ip

》ip分类:ipv4和ipv6 ;万维网和局域网

》域名:www.baidu.com  ,www.jd.com

2)InetAddress类:

2.1 实例化

getByName(String host),getLocalHost()

2.2 常用方法

getHostName() /getHostAddress()

3.端口号:正在计算机上运行的进程

要求:不同的进程不同的端口号

范围:被规定为一个正整数 0-65535

端口号与ip地址组合得出一个网络套接字:Socket

4.通信要素二:网络通信协议:

1)分类模型

2)TCP和UDP的区别

TCP协议:使用协议前建立TCP连接,形成传输通道,传输前使用三次握手方式,点对点通信,是可靠的;在连接中可进行大数据量的传输;传输完毕,需释放已建立的连接,效率低

UDP协议:将数据,源,目的封装成数据包,不需要建立连接,每个数据报的大小限制在64k内;

发送不管对方是否准备好,接收方收到也不确认,故是不可靠的;可以广播发送;发送数据结束时,无需释放资源,开销小,速度快

5.代码实例:

1)IP地址代码实例:

public class InetAddressTest {public static void main(String[] args) throws UnknownHostException {//根据ip地址创建ip地址对象InetAddress ina1 =InetAddress.getByName("192.168.1.1");System.out.println(ina1);//根据域名创建ip地址对象InetAddress ina2= InetAddress.getByName("www.baidu.com");System.out.println(ina2);byte[] address = ina1.getAddress();System.out.println(ina1.getHostName());System.out.println(ina1.getHostAddress());System.out.println(ina2.getHostName());System.out.println(ina2.getHostAddress());}
}

2)TCP代码实例:

public class Tcp1Test {
//发送信息@Testpublic void test() throws IOException {Socket  clent = new Socket(InetAddress.getByName("127.0.0.1"),8899);OutputStream outputStream = clent.getOutputStream();outputStream.write("我是客户端".getBytes());outputStream.close();clent.close();}@Testpublic void test2() throws IOException {ServerSocket  server  =new ServerSocket(8899);Socket accept = server.accept();InputStream inputStream = accept.getInputStream();ByteArrayOutputStream byteout =new ByteArrayOutputStream();byte[] buffer =new byte[20];int len;while((len=inputStream.read(buffer))!=-1){byteout.write(buffer,0,len);System.out.println(byteout.toString());}server.close();inputStream.close();byteout.close();}}
public class Tcp2Test {//发送文件@Testpublic void test1() throws IOException {InetAddress  inet= InetAddress.getByName("127.0.0.1");Socket clent =new Socket(inet,8851);OutputStream outputStream = clent.getOutputStream();FileInputStream fis= new FileInputStream("leaf.jpg");byte[] buffer= new byte[10];int len;while((len=fis.read(buffer))!=-1){outputStream.write(buffer,0,len);}fis.close();outputStream.close();clent.close();}@Testpublic  void  test2() throws IOException {ServerSocket server =new ServerSocket(8851);Socket accept = server.accept();InputStream inputStream = accept.getInputStream();FileOutputStream fos=new FileOutputStream("leaf2.jpg");byte[] bufferr = new byte[10];int len;while((len=inputStream.read(bufferr))!=-1){fos.write(bufferr,0,len);}fos.close();inputStream.close();server.close();}}
public class Tcp3Test {//发送文件,服务器返回信息@Testpublic void test() throws IOException {InetAddress   inet = InetAddress.getByName("127.0.0.1");Socket  client  =new Socket(inet,7788);OutputStream outputStream = client.getOutputStream();//从本地读取文件并发送到服务器FileInputStream fis =new FileInputStream("leaf.jpg");byte[] buffer =new byte[20];int len;while((len=fis.read(buffer))!=-1){outputStream.write(buffer,0,len);}//关闭数据输出client.shutdownOutput();//接受服务器发送的信息,并输出到控制台InputStream inputStream = client.getInputStream();ByteArrayOutputStream bos =new ByteArrayOutputStream();byte[] bu =new byte[20];int len1;while((len1=inputStream.read(bu))!=-1){bos.write(bu,0,len1);}System.out.println(bos.toString());fis.close();outputStream.close();client.close();}@Testpublic void test2() throws IOException {ServerSocket server = new ServerSocket(7788);Socket accept = server.accept();InputStream inputStream = accept.getInputStream();//接受客户端发送文件并存到本地FileOutputStream  fos= new FileOutputStream("leaf3.jpg");byte[] buff =new byte[20];int len;while((len=inputStream.read(buff))!=-1){fos.write(buff,0,len);}//给客户端发送已接收消息OutputStream outputStream = accept.getOutputStream();outputStream.write("图片已收到,谢谢".getBytes());fos.close();inputStream.close();server.close();outputStream.close();}}

3)UDP代码实例:

public class UdpTest {@Testpublic  void test() throws IOException {//发送端DatagramSocket socket =new DatagramSocket();InetAddress inet =InetAddress.getLocalHost();String str="我是udp方式发送的数据";byte[] buff = str.getBytes();DatagramPacket  packet =new DatagramPacket(buff,0,buff.length,inet,8890);socket.send(packet);socket.close();}@Testpublic void test2() throws IOException {//接收者DatagramSocket  socket =new DatagramSocket(8890);byte[] buffer =new byte[100];DatagramPacket packet =new DatagramPacket(buffer,0,buffer.length);socket.receive(packet);System.out.println(new String(packet.getData(),0,packet.getLength()));}
}

4)URL代码实例:

public class UrlTest {@Testpublic void test() throws MalformedURLException {//获取url对象URL url =new URL("http://localhost:8080/examples/leaf.jpg");//url 主要方法System.out.println(url.getProtocol());//获取协议System.out.println(url.getHost());//获取主机System.out.println(url.getPort());//获取端口System.out.println(url.getQuery());//获取查询内容}@Testpublic void test2() throws IOException {//服务器下载图片
URL url =new URL("http://localhost:8080/examples/leaf.jpg");HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();urlConnection.connect();InputStream inputStream = urlConnection.getInputStream();byte[] buffer =new byte[20];int len;FileOutputStream fos =new FileOutputStream("leafdown.jpg");while((len=inputStream.read(buffer))!=-1){fos.write(buffer,0,len);}inputStream.close();fos.close();urlConnection.disconnect();}
}

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

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

相关文章

【漏洞复现】ActiveMQ文件上传漏洞(CVE-2016-3088)

Nx01 产品简介 Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件。ActiveMQ是消息队列服务,是面向消息中间件(MOM)的最终实现,它为企业消息传递提供高可用、出色性能、可扩展、稳定和安全保障。 Nx02 漏洞描述 Ap…

vercel部署twikoo后评论收不到通知邮件问题解决方法

📌 前言:本文主要是总结一下在vercel部署twikoo后收不到评论邮件通知问题的解决方法,本人在各种查资料无果后最终去twioo的git官方项目的issue中找到某位大佬给出的原因以及解决方案,故做此记录,希望对遇到此问题的同学…

重学JavaScript高级(八):ES6-ES12新增特性学习

ES6-ES12新增特性学习 ES6–对象字面量增强 属性的简写方法的简写计算属性名 let name "zhangcheng" //我想让sum作为obj的key值 let objKey "sum" let obj {//属性名的简写name//等同于name:name//方法的简写running(){}//等同于running:function()…

ERD助力研发资产沉淀研发提效

一、从痛点中思考答案 痛点一:复杂系统的设计和逻辑碎片化散落,缺少沉淀导致系统后期维护、迭代以及架构升级都非常困难。 痛点二:由于新需求或新项目导致的系统的老旧逻辑梳理往往耗费大量人力,甚至造成人才的流失。 痛点三&a…

React 入门 - 05(响应式与事件绑定)

本章内容 目录 一、响应式设计思想二、React 中的事件绑定 继上一节我们简单实现一个 TodoList来更加了解编写组件的一些细节。本节继续这个案例功能的完成。 一、响应式设计思想 1、在原生的 JS中,如果要实现点击”提交“按钮就将输入框的内容添加至页面列表中&…

什么是协议和什么是OSI模型,以及两者之间的关系

目录 协议 1.协议 2.OSI模型 (1)什么是OSI模型 (2)OSI模型和协议之间的关系 总结 (3)示意图 协议 1.协议 就是双方通过协商,需要共同遵守的约定 协议就是规则,是约定 http…

数字战场上的坚固屏障:雷池社区版(WAF)

黑客的挑战 智能语义分析算法: 黑客们常利用复杂技术进行攻击,但雷池社区版的智能语义分析算法能深入解析攻击本质,即使是最复杂的攻击手法也难以逃脱。 0day攻击防御: 传统防火墙难以防御未知攻击,但雷池社区版能有效…

Spark八:Spark性能优化

Spark性能调优 Spark调优的方法,包括RDD使用、文件读取,partition 学习资料:https://mp.weixin.qq.com/s/caCk3mM5iXy0FaXCLkDwYQ 一、Spark调优之RDD算子调优 1.1 RDD复用 在对RDD进行计算时,要避免相同的算子和计算逻辑下对…

计算机科学速成课【学习笔记】(3)——布尔逻辑和逻辑门

本集课程的B站链接 3. 布尔逻辑 和 逻辑门-Boolean Logic & Logic Gates_哔哩哔哩_bilibili3. 布尔逻辑 和 逻辑门-Boolean Logic & Logic Gates是【计算机科学速成课】[40集全/精校] - Crash Course Computer Science的第3集视频,该合集共计40集&#xff…

当需要视频监控技术升级时,应该如何操作呢?

在当今社会,信息技术的飞速发展为我们提供了前所未有的安全和管理工具,其中视频监控系统无疑是其中一项引人注目的成果。 视频监控系统不仅提高了安全性和生产效率,同时也为社会的可持续发展提供了有力支持。 客户案例 工业生产管理优化 广…

将dumpbin从Visual Studio中抠出来,并使用dumpbin查看exe和dll库的依赖关系

目录 1、初步说明 2、在开发的机器上使用dumpbin工具查看dll库的依赖关系 3、将dumpbin.exe从Visual Studio中抠出来 3.1、找到dumpbin.exe文件及其依赖的dll文件 3.2、在cmd中运行dumpbin,提示找不到link.exe文件 3.3、再次运行dumpbin.exe提示找不到mspdb10…

了解DC电源模块的基本参数及选择方法

BOSHIDA 了解DC电源模块的基本参数及选择方法 DC电源模块是一种用来提供稳定直流电源的设备,常被应用在电子产品测试、实验室设备等领域。了解DC电源模块的基本参数和选择方法有助于正确选择和使用合适的模块。 1. 输出电压范围:DC电源模块通常有固定的…

mybatisplus快速入门-个人理解版

mybatisplus快速入门 1.快速入门1.1准备开发环境-idea2019.2.1版第一步:新建工程第二步:导入依赖 1.2创建数据库和表创建库表添加数据 1.3编写代码进行测试第一步:配置application.yml第二步:添加实体类第三步:添加map…

【算法】链表-20240109

这里写目录标题 一、141. 环形链表二、876. 链表的中间结点三、面试题 02.01. 移除重复节点 一、141. 环形链表 简单 给你一个链表的头节点 head ,判断链表中是否有环。 如果链表中有某个节点,可以通过连续跟踪 next 指针再次到达,则链表中…

Excel如何插入行?4个简单方法轻松完成!

“我在使用Excel表格工作时,需要插入一些行来填写数据。但是我不知道应该如何操作,有没有朋友可以支支招呀?” Excel是办公室工作中不可或缺的工具,它强大的数据处理能力使得工作变得高效。因此很多用户在使用电脑时或许都会用到E…

vue倒计时60秒改变按钮状态效果demo(整理)

你可以使用Vue的计时器和绑定状态的方法来实现这个功能。 首先&#xff0c;在data中添加一个计时器countdown&#xff0c;初始值为0。 data() {return {countdown: 0} }<template><div><button click"startCountdown" :disabled"countdown > …

基于Jackson封装的JSON、Properties、XML、YAML 相互转换的通用方法

文章目录 一、概述二、思路三、实现四、测试 一、概述 我们在 yaml转换成JSON、MAP、Properties 通过引入 实现了JSON、Properties、XML、YAML文件的相互转换&#xff0c;具体封装的类、方法如下&#xff1a; 上面的实现&#xff0c;定义了多个类、多个方法&#xff0c;使用…

FineBI实战项目一(2):案例架构说明及数据准备

1 系统架构 基于MySQL搭建数据仓库基于Kettle进行数据处理帆软FineBI基于MySQL搭建的数据仓库进行数据分析 2 数据流程图 通过Kettle将MySQL业务系统数据库中&#xff0c;将数据抽取出来&#xff0c;然后装载到MySQL数据仓库中。编写SQL脚本&#xff0c;对MySQL数据仓库中的数…

Qt之有趣的数字钟

一.效果 基于网络代码修改,支持时、分、秒;支持滑动、翻页和旋转。 二.实现 #include <QtCore> #include <QPainter> #include <QAction> #include <QWidget> #include <QMainWindow> #include <QTimer> #include <QKeyEvent> #…

MySQL性能调优---BKA

1.BKA原理介绍 MySQL 5.6版本开始增加了提高表join性能的Batched Key Access (BKA)算法。BKA是对于多表join语句&#xff0c;当MySQL使用索引访问第二个join表的时候&#xff0c;使用一个join buffer来收集第一个操作对象生成的相关列值。BKA构建好key后&#xff0c;批量传给引…