BIO、NIO、AIO

第一章 BIO、NIO、AIO课程介绍

1.1 课程说明

​ 在Java的软件设计开发中,通信架构是不可避免的,我们在进行不同系统或者不同进程之间的数据交互,或者在高并发下的通信场景下都需要用到网络通信相关的技术,对于一些经验丰富的程序员来说,Java早期的网络通信架构存在一些缺陷,其中最令人恼火的是基于性能低下的同步阻塞式的I/O通信(BIO),随着互联网开发下通信性能的高要求,Java在2002年开始支持了非阻塞式的I/O通信技术(NIO)。大多数读者在学习网络通信相关技术的时候,都只是接触到零碎的通信技术点,没有完整的技术体系架构,以至于对于Java的通信场景总是没有清晰的解决方案。本次课程将通过大量清晰直接的案例从最基础的BIO式通信开始介绍到NIO , AIO,读者可以清晰的了解到阻塞、同步、异步的现象、概念和特征以及优缺点。本课程结合了大量的案例让读者可以快速了解每种通信架构的使用。

1.2 本课程学习要求

  • 本课程不太适合完全0基础学员。
  • 至少需要掌握: Java SE基础编程,如Java多线程,Java IO流编程,Java网络基础知识(如:IP , 端口,协议),常用的Java设计模式要有一定的了解。
  • 能熟练掌握Java OOP编程,有一定的编程思维。

1.3 通信技术整体解决的问题

  • 局域网内的通信要求。
  • 多系统间的底层消息传递机制。
  • 高并发下,大数据量的通信场景需要。
  • 游戏行业。无论是手游服务端,还是大型的网络游戏,Java语言都得到越来越广泛的应用。

第二章 Java的I/O演进之路

2.1 I/O 模型基本说明

I/O 模型:就是用什么样的通道或者说是通信模式和架构进行数据的传输和接收,很大程度上决定了程序通信的性能,Java 共支持 3 种网络编程的/IO 模型:BIO、NIO、AIO
实际通信需求下,要根据不同的业务场景和性能需求决定选择不同的I/O模型

2.2 I/O模型

Java BIO

同步并阻塞(传统阻塞型),服务器实现模式为一个连接一个线程,即客户端有连接请求时服务器端就需要启动一个线程进行处理,如果这个连接不做任何事情会造成不必要的线程开销 【简单示意图

image-20200615181255063

Java NIO

Java NIO : 同步非阻塞,服务器实现模式为一个线程处理多个请求(连接),即客户端发送的连接请求都会注册到多路复用器上,多路复用器轮询到连接有 I/O 请求就进行处理 【简单示意图】

image-20200615180441015

Java AIO

Java AIO(NIO.2) : 异步非阻塞,服务器实现模式为一个有效请求一个线程,客户端的I/O请求都是由OS先完成了再通知服务器应用去启动线程进行处理,一般适用于连接数较多且连接时间较长的应用

2.3 BIO、NIO、AIO 适用场景分析

1、BIO 方式适用于连接数目比较小且固定的架构,这种方式对服务器资源要求比较高,并发局限于应用中,JDK1.4以前的唯一选择,但程序简单易理解。

2、NIO 方式适用于连接数目多且连接比较短(轻操作)的架构,比如聊天服务器,弹幕系统,服务器间通讯等。编程比较复杂,JDK1.4 开始支持。

3、AIO 方式使用于连接数目多且连接比较长(重操作)的架构,比如相册服务器,充分调用 OS 参与并发操作,编程比较复杂,JDK7 开始支持。

第三章 JAVA BIO深入剖析

3.1 Java BIO 基本介绍

  • Java BIO 就是传统的 java io 编程,其相关的类和接口在 java.io
  • BIO(blocking I/O) : 同步阻塞,服务器实现模式为一个连接一个线程,即客户端有连接请求时服务器端就需
    要启动一个线程进行处理,如果这个连接不做任何事情会造成不必要的线程开销,可以通过线程池机制改善(实现多个客户连接服务器).

3.2 Java BIO 工作机制

image-20200618222916021

对 对 BIO 编程流程的梳理

  1. 服务器端启动一个 ServerSocket,注册端口,调用accpet方法监听客户端的Socket连接。
  2. 客户端启动 Socket 对服务器进行通信,默认情况下服务器端需要对每个客户 建立一个线程与之通讯

3.3 传统的BIO编程实例回顾

​ 网络编程的基本模型是Client/Server模型,也就是两个进程之间进行相互通信,其中服务端提供位置信(绑定IP地址和端口),客户端通过连接操作向服务端监听的端口地址发起连接请求,基于TCP协议下进行三次握手连接,连接成功后,双方通过网络套接字(Socket)进行通信。

​ 传统的同步阻塞模型开发中,服务端ServerSocket负责绑定IP地址,启动监听端口;客户端Socket负责发起连接操作。连接成功后,双方通过输入和输出流进行同步阻塞式通信。
​ 基于BIO模式下的通信,客户端 - 服务端是完全同步,完全耦合的。

客户端案例如下

package com.itheima._02bio01;import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
/**目标: Socket网络编程。Java提供了一个包:java.net下的类都是用于网络通信。Java提供了基于套接字(端口)Socket的网络通信模式,我们基于这种模式就可以直接实现TCP通信。只要用Socket通信,那么就是基于TCP可靠传输通信。功能1:客户端发送一个消息,服务端接口一个消息,通信结束!!创建客户端对象:(1)创建一个Socket的通信管道,请求与服务端的端口连接。(2)从Socket管道中得到一个字节输出流。(3)把字节流改装成自己需要的流进行数据的发送创建服务端对象:(1)注册端口(2)开始等待接收客户端的连接,得到一个端到端的Socket管道(3)从Socket管道中得到一个字节输入流。(4)把字节输入流包装成自己需要的流进行数据的读取。Socket的使用:构造器:public Socket(String host, int port)方法:  public OutputStream getOutputStream():获取字节输出流public InputStream getInputStream() :获取字节输入流ServerSocket的使用:构造器:public ServerSocket(int port)小结:通信是很严格的,对方怎么发你就怎么收,对方发多少你就只能收多少!!*/
public class ClientDemo {public static void main(String[] args) throws Exception {System.out.println("==客户端的启动==");// (1)创建一个Socket的通信管道,请求与服务端的端口连接。Socket socket = new Socket("127.0.0.1",8888);// (2)从Socket通信管道中得到一个字节输出流。OutputStream os = socket.getOutputStream();// (3)把字节流改装成自己需要的流进行数据的发送PrintStream ps = new PrintStream(os);// (4)开始发送消息ps.println("我是客户端,我想约你吃小龙虾!!!");ps.flush();}
}

服务端案例如下

package com.itheima._02bio01;import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;/*** 服务端*/
public class ServerDemo {public static void main(String[] args) throws Exception {System.out.println("==服务器的启动==");// (1)注册端口ServerSocket serverSocket = new ServerSocket(8888);//(2)开始在这里暂停等待接收客户端的连接,得到一个端到端的Socket管道Socket socket = serverSocket.accept();//(3)从Socket管道中得到一个字节输入流。InputStream is = socket.getInputStream();//(4)把字节输入流包装成自己需要的流进行数据的读取。BufferedReader br = new BufferedReader(new InputStreamReader(is));//(5)读取数据String line ;while((line = br.readLine())!=null){System.out.println("服务端收到:"+line);}}
}

小结

  • 在以上通信中,服务端会一致等待客户端的消息,如果客户端没有进行消息的发送,服务端将一直进入阻塞状态。
  • 同时服务端是按照行获取消息的,这意味着客户端也必须按照行进行消息的发送,否则服务端将进入等待消息的阻塞状态!

3.4 BIO模式下多发和多收消息

​ 在1.3的案例中,只能实现客户端发送消息,服务端接收消息,并不能实现反复的收消息和反复的发消息,我们只需要在客户端案例中,加上反复按照行发送消息的逻辑即可!案例代码如下:

客户端代码如下

package com.itheima._03bio02;import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;/**目标: Socket网络编程。功能1:客户端可以反复发消息,服务端可以反复收消息小结:通信是很严格的,对方怎么发你就怎么收,对方发多少你就只能收多少!!*/
public class ClientDemo {public static void main(String[] args) throws Exception {System.out.println("==客户端的启动==");// (1)创建一个Socket的通信管道,请求与服务端的端口连接。Socket socket = new Socket("127.0.0.1",8888);// (2)从Socket通信管道中得到一个字节输出流。OutputStream os = socket.getOutputStream();// (3)把字节流改装成自己需要的流进行数据的发送PrintStream ps = new PrintStream(os);// (4)开始发送消息Scanner sc = new Scanner(System.in);while(true){System.out.print("请说:");String msg = sc.nextLine();ps.println(msg);ps.flush();}}
}

服务端代码如下

package com.itheima._03bio02;import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;/*** 服务端*/
public class ServerDemo {public static void main(String[] args) throws Exception {String s = "886";System.out.println("886".equals(s));System.out.println("==服务器的启动==");//(1)注册端口ServerSocket serverSocket = new ServerSocket(8888);//(2)开始在这里暂停等待接收客户端的连接,得到一个端到端的Socket管道Socket socket = serverSocket.accept();//(3)从Socket管道中得到一个字节输入流。InputStream is = socket.getInputStream();//(4)把字节输入流包装成  自己需要的流进行数据的读取。BufferedReader br = new BufferedReader(new InputStreamReader(is));//(5)读取数据String line ;while((line = br.readLine())!=null){System.out.println("服务端收到:"+line);}}
}

小结

  • 本案例中确实可以实现客户端多发多收
  • 但是服务端只能处理一个客户端的请求,因为服务端是单线程的。一次只能与一个客户端进行消息通信。

3.5 BIO模式下接收多个客户端

概述

​ 在上述的案例中,一个服务端只能接收一个客户端的通信请求,那么如果服务端需要处理很多个客户端的消息通信请求应该如何处理呢,此时我们就需要在服务端引入线程了,也就是说客户端每发起一个请求,服务端就创建一个新的线程来处理这个客户端的请求,这样就实现了一个客户端一个线程的模型,图解模式如下:

image-20200615181141593

客户端案例代码如下

/**目标: Socket网络编程。功能1:客户端可以反复发,一个服务端可以接收无数个客户端的消息!!小结:服务器如果想要接收多个客户端,那么必须引入线程,一个客户端一个线程处理!!*/
public class ClientDemo {public static void main(String[] args) throws Exception {System.out.println("==客户端的启动==");// (1)创建一个Socket的通信管道,请求与服务端的端口连接。Socket socket = new Socket("127.0.0.1",7777);// (2)从Socket通信管道中得到一个字节输出流。OutputStream os = socket.getOutputStream();// (3)把字节流改装成自己需要的流进行数据的发送PrintStream ps = new PrintStream(os);// (4)开始发送消息Scanner sc = new Scanner(System.in);while(true){System.out.print("请说:");String msg = sc.nextLine();ps.println(msg);ps.flush();}}
}

服务端案例代码如下

/**服务端*/
public class ServerDemo {public static void main(String[] args) throws Exception {System.out.println("==服务器的启动==");// (1)注册端口ServerSocket serverSocket = new ServerSocket(7777);while(true){//(2)开始在这里暂停等待接收客户端的连接,得到一个端到端的Socket管道Socket socket = serverSocket.accept();new ServerReadThread(socket).start();System.out.println(socket.getRemoteSocketAddress()+"上线了!");}}
}class ServerReadThread extends Thread{private Socket socket;public ServerReadThread(Socket socket){this.socket = socket;}@Overridepublic void run() {try{//(3)从Socket管道中得到一个字节输入流。InputStream is = socket.getInputStream();//(4)把字节输入流包装成自己需要的流进行数据的读取。BufferedReader br = new BufferedReader(new InputStreamReader(is));//(5)读取数据String line ;while((line = br.readLine())!=null){System.out.println("服务端收到:"+socket.getRemoteSocketAddress()+":"+line);}}catch (Exception e){System.out.println(socket.getRemoteSocketAddress()+"下线了!");}}
}

小结

  • 1.每个Socket接收到,都会创建一个线程,线程的竞争、切换上下文影响性能;
  • 2.每个线程都会占用栈空间和CPU资源;
  • 3.并不是每个socket都进行IO操作,无意义的线程处理;
  • 4.客户端的并发访问增加时。服务端将呈现1:1的线程开销,访问量越大,系统将发生线程栈溢出,线程创建失败,最终导致进程宕机或者僵死,从而不能对外提供服务。

3.6 伪异步I/O编程

概述

​ 在上述案例中:客户端的并发访问增加时。服务端将呈现1:1的线程开销,访问量越大,系统将发生线程栈溢出,线程创建失败,最终导致进程宕机或者僵死,从而不能对外提供服务。

​ 接下来我们采用一个伪异步I/O的通信框架,采用线程池和任务队列实现,当客户端接入时,将客户端的Socket封装成一个Task(该任务实现java.lang.Runnable线程任务接口)交给后端的线程池中进行处理。JDK的线程池维护一个消息队列和N个活跃的线程,对消息队列中Socket任务进行处理,由于线程池可以设置消息队列的大小和最大线程数,因此,它的资源占用是可控的,无论多少个客户端并发访问,都不会导致资源的耗尽和宕机。

​ 图示如下:

image-20200619085953166

客户端源码分析

public class Client {public static void main(String[] args) {try {// 1.简历一个与服务端的Socket对象:套接字Socket socket = new Socket("127.0.0.1", 9999);// 2.从socket管道中获取一个输出流,写数据给服务端 OutputStream os = socket.getOutputStream() ;// 3.把输出流包装成一个打印流 PrintWriter pw = new PrintWriter(os);// 4.反复接收用户的输入 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));String line = null ;while((line = br.readLine()) != null){pw.println(line);pw.flush();}} catch (Exception e) {e.printStackTrace();}}
}

线程池处理类

// 线程池处理类
public class HandlerSocketThreadPool {// 1.创建一个线程池的成员变量用于存储一个线程池对象private ExecutorService executor;//2.创建这个类的对象的时候就需要初始化线程池对象public HandlerSocketThreadPool(int maxPoolSize, int queueSize){this.executor = new ThreadPoolExecutor(3, // 8maxPoolSize,  120L, TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(queueSize) );}/***3、提供一个方法来提交任务给线程池的任务队列来暂存,等着线程池来处理**/public void execute(Runnable task){this.executor.execute(task);}
}

服务端源码分析

public class Server {public static void main(String[] args) {try {System.out.println("----------服务端启动成功------------");//1. 注册端口ServerSocket ss = new ServerSocket(9999);// 2. 初始化线程池对象, 一个服务端只需要对应一个线程池HandlerSocketThreadPool handlerSocketThreadPool =new HandlerSocketThreadPool(3, 1000);// 客户端可能有很多个while(true){Socket socket = ss.accept() ; // 阻塞式的!// 3. 把socket对象交给一个线程池进行处理,System.out.println("有人上线了!!");// 每次收到一个客户端的socket请求,都需要为这个客户端分配一个// 独立的线程 专门负责对这个客户端的通信!!handlerSocketThreadPool.execute(new ReaderClientRunnable(socket));}} catch (Exception e) {e.printStackTrace();}}}
class ReaderClientRunnable implements Runnable{private Socket socket ;public ReaderClientRunnable(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {// 读取一行数据InputStream is = socket.getInputStream() ;// 转成一个缓冲字符流Reader fr = new InputStreamReader(is);BufferedReader br = new BufferedReader(fr);// 一行一行的读取数据String line = null ;while((line = br.readLine())!=null){ // 阻塞式的!!System.out.println("服务端收到了数据:"+line);}} catch (Exception e) {System.out.println("有人下线了");}}
}

小结

  • 伪异步io采用了线程池实现,因此避免了为每个请求创建一个独立线程造成线程资源耗尽的问题,但由于底层依然是采用的同步阻塞模型,因此无法从根本上解决问题。
  • 如果单个消息处理的缓慢,或者服务器线程池中的全部线程都被阻塞,那么后续socket的i/o消息都将在队列中排队。新的Socket请求将被拒绝,客户端会发生大量连接超时。

3.7 基于BIO形式下的文件上传

目标

支持任意类型文件形式的上传。

客户端开发

package com.itheima.file;import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import java.net.Socket;/**目标:实现客户端上传任意类型的文件数据给服务端保存起来。*/
public class Client {public static void main(String[] args) {try(InputStream is = new FileInputStream("C:\\Users\\dlei\\Desktop\\BIO,NIO,AIO\\文件\\java.png");){//  1、请求与服务端的Socket链接Socket socket = new Socket("127.0.0.1" , 8888);//  2、把字节输出流包装成一个数据输出流DataOutputStream dos = new DataOutputStream(socket.getOutputStream());//  3、先发送上传文件的后缀给服务端dos.writeUTF(".png");//  4、把文件数据发送给服务端进行接收byte[] buffer = new byte[1024];int len;while((len = is.read(buffer)) > 0 ){dos.write(buffer , 0 , len);}dos.flush();socket.shutdownOutput();//通知服务端这边的数据发送完毕了Thread.sleep(10000);}catch (Exception e){e.printStackTrace();}}
}

服务端开发

package com.itheima.file;import java.net.ServerSocket;
import java.net.Socket;/**目标:服务端开发,可以实现接收客户端的任意类型文件,并保存到服务端磁盘。*/
public class Server {public static void main(String[] args) {try{ServerSocket ss = new ServerSocket(8888);while (true){//accept方法会阻塞,直到接收到客户端请求Socket socket = ss.accept();// 交给一个独立的线程来处理与这个客户端的文件通信需求。new ServerReaderThread(socket).start();}}catch (Exception e){e.printStackTrace();}}
}
package com.itheima.file;import java.io.DataInputStream;
import java.io.FileOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.UUID;public class ServerReaderThread extends Thread {private Socket socket;public ServerReaderThread(Socket socket){this.socket = socket;}@Overridepublic void run() {try{// 1、得到一个数据输入流读取客户端发送过来的数据DataInputStream dis = new DataInputStream(socket.getInputStream());// 2、读取客户端发送过来的文件类型String suffix = dis.readUTF();System.out.println("服务端已经成功接收到了文件类型:" + suffix);// 3、定义一个字节输出管道负责把客户端发来的文件数据写出去OutputStream os = new FileOutputStream("C:\\Users\\dlei\\Desktop\\BIO,NIO,AIO\\文件\\server\\"+UUID.randomUUID().toString()+suffix);// 4、从数据输入流中读取文件数据,写出到字节输出流中去byte[] buffer = new byte[1024];int len;while((len = dis.read(buffer)) > 0){//服务端收到客户端的shutdownOutput()后将不再等待,跳出循环,继续向下执行.os.write(buffer,0, len);}os.close();System.out.println("服务端接收文件保存成功!");}catch (Exception e){e.printStackTrace();}}
}

小结

客户端怎么发,服务端就怎么接收

3.9 Java BIO模式下的端口转发思想

需求:需要实现一个客户端的消息可以发送给所有的客户端去接收。(群聊实现)

image-20200619123304241

客户端开发

package com.itheima.file;import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.InputStream;
import java.net.Socket;/**目标:实现客户端上传任意类型的文件数据给服务端保存起来。*/
public class Client {public static void main(String[] args) {try(InputStream is = 

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

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

相关文章

VUE学习笔记4__安装开发者工具

https://chrome.zzzmh.cn/index 安装后需要关闭所有浏览器并重启 再次打开检查会看到vue标签&#xff0c;方便调试修改 如果安装后找不到vue标签&#xff0c;请尝试下载历史版本&#xff0c;这里用的是6.4.5 <!doctype html> <html lang"en"> <head&…

GitLab集成Jira

GitLab与Jira集成的两种方式 GitLab 提供了两种 Jira 集成&#xff0c;即Jira议题集成和Jira开发面板集成&#xff0c;可以配置一个或者两个都配置。 具体集成步骤可以参考官方文档Jira 议题集成&#xff08;极狐GitLab文档&#xff09;和Jira 开发面板集成&#xff08;极狐G…

深入理解计算机系统阅读笔记-第十二章

第12章 网络编程 12.1 客户端-服务器编程模型 每个网络应用都是基于客户端-服务器模型的。根据这个模型&#xff0c;一个应用时由一个服务器进程和一个或者多个客户端进程组成。服务器管理某种资源&#xff0c;并且通过操作这种资源来为它的客户端提供某种服务。例如&#xf…

用css和html制作太极图

目录 css相关参数介绍 边距 边框 伪元素选择器 太极图案例实现、 代码 效果 css相关参数介绍 边距 <!DOCTYPE html> <html><head><meta charset"utf-8"><title></title><style>*{margin: 0;padding: 0;}div{width: …

C++算法第十六天

本篇文章我们继续学习动态规划 第一题 题目链接 978. 最长湍流子数组 - 力扣&#xff08;LeetCode&#xff09; 题目解析 从上图可见其实有三个状态 代码原理 注意&#xff1a;我们在分析题目的时候分析出来的是三个状态&#xff0c;分别是上升、下降、平坦&#xff0c;但是…

基于YOLOv8与CGNet的鸟类智能识别系统 深度学习图像分类 鸟类目标检测与分类 图像特征提取 模型优化与应用 数据可视化(源码+指导+定制)

博主介绍&#xff1a; ✌我是阿龙&#xff0c;一名专注于Java技术领域的程序员&#xff0c;全网拥有10W粉丝。作为CSDN特邀作者、博客专家、新星计划导师&#xff0c;我在计算机毕业设计开发方面积累了丰富的经验。同时&#xff0c;我也是掘金、华为云、阿里云、InfoQ等平台…

qml LevelAdjust详解

1、概述 LevelAdjust 是 QML&#xff08;Qt Modeling Language&#xff09;中的一个类型&#xff0c;用于调整源组件的每个色彩通道的颜色级别。通过 LevelAdjust&#xff0c;可以实现对源项目对比度的调节和色彩平衡的改变。LevelAdjust 类型继承自 Item&#xff0c;并提供了…

springMVC实现文件上传

目录 一、创建项目 二、引入依赖 三、web.xml 四、编写上传文件的jsp页面 五、spring-mvc.xml 六、controller 七、运行 一、创建项目 二、引入依赖 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.o…

opencv进行人脸识别环境搭建

1. 构建人脸识别环境 1) 下载安装opencv 下载地址&#xff1a;Releases - OpenCV 参考博文&#xff1a;OpenCV下载安装教程&#xff08;Windows&#xff09;-CSDN博客 下载对应系统的opencv&#xff0c;如windows版&#xff0c;opencv-4.5.5-vc14_vc15.exe 2) 然后解压缩到…

[SAP ABAP] 批量导入(BDC)练习案例

业务目的&#xff1a;对采购订单做批量修改&#xff0c;同时需要用报表显示导入结果&#xff0c;Excel上传凭证后&#xff0c;录制BDC&#xff0c;调用BDC对采购订单进行修改 批量修改以下3个采购订单的短文本以及采购订单数量 提示Tips&#xff1a;上述提供的3个采购订单涉及…

《自动驾驶与机器人中的SLAM技术》ch4:预积分学

目录 1 预积分的定义 2 预积分的测量模型 ( 预积分的测量值可由 IMU 的测量值积分得到 ) 2.1 旋转部分 2.2 速度部分 2.3 平移部分 2.4 将预积分测量和误差式代回最初的定义式 3 预积分的噪声模型和协方差矩阵 3.1 旋转部分 3.2 速度部分 3.3 平移部分 3.4 噪声项合并 4 零偏的…

2Spark Core

2Spark Core 1.RDD 详解1) 为什么要有 RDD?2) RDD 是什么?3) RDD 主要属性 2.RDD-API1) RDD 的创建方式2) RDD 的算子分类3) Transformation 转换算子4) Action 动作算子 3. RDD 的持久化/缓存4. RDD 容错机制 Checkpoint5. RDD 依赖关系1) 宽窄依赖2) 为什么要设计宽窄依赖 …

归子莫的科技周刊#2:白天搬砖,夜里读诗

归子莫的科技周刊#2&#xff1a;白天搬砖&#xff0c;夜里读诗 本周刊开源&#xff0c;欢迎投稿。 刊期&#xff1a;2025.1.5 - 2025.1.11。原文地址。 封面图 下班在深圳看到的夕阳&#xff0c;能遇到是一种偶然的机会&#xff0c;能拍下更是一种幸运。 白天搬砖&#xff0c;…

机器学习第一道菜(一):线性回归的理论模型

机器学习第一道菜&#xff08;一&#xff09;&#xff1a;线性回归的理论模型 一、问题&#xff1a;千金买笑1.1 散点图1.2 机器学习能搞啥 二、模型的建立2.1 线性回归2.2 回归模型 前面讲了机器学习的“四大绝技”&#xff0c;今天&#xff0c;开始研究第一绝技“回归”&…

http转化为https生成自签名证书

背景 项目开发阶段前后交互采用http协议&#xff0c;演示环境采用htttps协议 &#xff0c;此处为个人demo案例 组件 后端&#xff1a;springBoot 前端&#xff1a;vue web 服务&#xff1a;tomcat 部署环境&#xff1a;linux 生成自签名证书 创建目录 存储证书位置 # mkdir -p…

【安卓开发】【Android】总结:安卓技能树

【持续更新】 对笔者在安卓开发的实践中认为必要的知识点和遇到的问题进行总结。 一、基础知识部分 1、Android Studio软件使用 软件界面 最新的版本是瓢虫&#xff08;Ladybug&#xff09;&#xff0c;bug的确挺多。笔者更习惯使用电鳗&#xff08;Electric Eel&#xff0…

PT8M2302 触控 A/D 型 8-Bit MCU

1. 产品概述 PT8M2302 是一款可多次编程&#xff08; MTP &#xff09; A/D 型 8 位 MCU &#xff0c;其包括 2K*16bit MTP ROM 、 256*8bit SRAM、 ADC 、 PWM 、 Touch 等功能&#xff0c;具有高性能精简指令集、低工作电压、低功耗特性且完全集 成触控按键功能。为…

HunyuanVideo 文生视频模型实践

HunyuanVideo 文生视频模型实践 flyfish 运行 HunyuanVideo 模型使用文本生成视频的推荐配置&#xff08;batch size 1&#xff09;&#xff1a; 模型分辨率(height/width/frame)峰值显存HunyuanVideo720px1280px129f60GHunyuanVideo544px960px129f45G 本项目适用于使用 N…

【网络 MAC 学习专栏 -- 如何理解 PHY 的 Link Up】

请阅读【嵌入式开发学习必备专栏 Cache | MMU | AMBA BUS | CoreSight | Trace32 | CoreLink | ARM GCC | CSH】 文章目录 OverviewClause 22/Clause 45Clause 22Clause 45 PHY Link 状态的软件实现 转自&#xff1a; 开心果 Need Car 2022年10月20日 09:50 上海 Overview PHY…

npm发布组件(vue3+webpack)

1.初始化Vue项目 vue create my-app 2.本地运行 npm run serve 3.新增目录和文件 1. src/package/index.js 2. src/package/wlz-btn/index.vue 3. src/package/wlz-input/index.vue // src\package\index.js import WlzBtn from "./wlz-btn"; import WlzInput …