BIO学习笔记

article/2025/3/17 18:52:43

视频地址:https://www.bilibili.com/video/BV1gz4y1C7RK?from=search&seid=15021234423448500976

2. JAVA BIO深入剖析

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

img

对 BIO 编程流程的梳理

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

传统的BIO编程实例回顾

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

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

BIO模式下多发和多收消息

客户端案例如下

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.print("客户端");  //此时客户端发送的数据并不是按行进行发送的//ps.println("客户端");  //此时客户端发送的数据是按行进行发送的ps.flush();}
}

服务端案例如下

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表示一直等待客户端发送的数据,并且数据是按行进行读取while((line = br.readLine())!=null){System.out.println("服务端收到:"+line);}/*//if表示只读取一次客户端发送的数据,并且数据是按行进行读取if((line = br.readLine())!=null){System.out.println("服务端收到:"+line);}*/}
}

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

BIO模式下多发和多收消息

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

客户端代码如下

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();}}
}

服务端代码如下

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);}}
}

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

BIO模式下接收多个客户端

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

在这里插å¥å›¾ç‰‡æè¿°

客户端案例代码如下

/**目标: 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();// 创建一个独立的线程对socket进行处理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()+"下线了!");}}
}

缺点:

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

伪异步I/O编程

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

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

在这里插å¥å›¾ç‰‡æè¿°

客户端源码分析

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 {// 线程池 private ExecutorService executor;public HandlerSocketThreadPool(int maxPoolSize, int queueSize){this.executor = new ThreadPoolExecutor(3, // 8maxPoolSize,  120L, TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(queueSize) );}//提交一个任务public void execute(Runnable task){this.executor.execute(task);}
}

服务端源码分析

public class Server {public static void main(String[] args) {try {System.out.println("----------服务端启动成功------------");ServerSocket ss = new ServerSocket(9999);// 一个服务端只需要对应一个线程池HandlerSocketThreadPool handlerSocketThreadPool =new HandlerSocketThreadPool(3, 1000);// 客户端可能有很多个while(true){Socket socket = ss.accept() ; // 阻塞式的!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请求将被拒绝,客户端会发生大量连接超时。

BIO文件传输

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();Thread.sleep(10000);}catch (Exception e){e.printStackTrace();}}
}

服务端开发

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){Socket socket = ss.accept();// 交给一个独立的线程来处理与这个客户端的文件通信需求。new ServerReaderThread(socket).start();}}catch (Exception e){e.printStackTrace();}}
}
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){os.write(buffer,0, len);}os.close();System.out.println("服务端接收文件保存成功!");}catch (Exception e){e.printStackTrace();}}
}

http://chatgpt.dhexx.cn/article/0sOpgZxP.shtml

相关文章

BIO实例

使用 BIO 模型编写一个服务器端&#xff0c;监听 6666 端口&#xff0c;当有客户端连接时&#xff0c;就启动一个线程与之通讯。要求使用线程池机制改善&#xff0c;可以连接多个客户端.服务器端可以接收客户端发送的数据(telnet 方式即可)。 图 代码演示&#xff1a; package…

利用 bioconda 管理生物信息软件

利用 bioconda 管理生物信息软件 如需视频讲解&#xff0c;请移步&#xff1a;一只小蛮要 【要知道 bioinfo】利用 bioconda 管理生物信息软件 1 了解 conda&#xff0c;anaconda&#xff0c;miniconda&#xff0c;bioconda 1.1 conda conda是一个软件模块管理工具&#xff…

IMex和IntAct数据库简介

欢迎关注微信公众号《生信修炼手册》! 蛋白质相互作用的数据库非常的多&#xff0c;比如DIP, MINT, IntAct, BioGRID等&#xff0c;不同数据库中的信息存在了大量的冗余&#xff0c;而且在不同数据库之间进行检索也非常的费力&#xff0c;为了减少不同数据库的冗余&#xff0c…

【Bio】基础生物学 - 基因 gene

文章目录 1. DNA 脱氧核糖核酸、RNA 核糖核酸1.1 核苷酸1.2 脱氧核糖核酸1.3 核糖核酸 2. 基因2.1 基因组2.2 染色体2.3 基因与脱氧核苷酸的牵连2.4 基因与DNA的牵连2.5 基因与染色体的牵连 Ref 1. DNA 脱氧核糖核酸、RNA 核糖核酸 1.1 核苷酸 核苷酸 (Nucleotide) \blue{\tex…

Bioedit 使用

1. 下载&#xff1a; 地址一搜就有&#xff0c;软件界面如下 BioEdit Download - Research software utility for creating and editing biological sequences 2. 酶切位点分析 构建过表达质粒、双荧光素酶质粒必用功能。以人的MYOD1基因为例 &#xff0c;分析酶切位点。 &…

BIO~~

BIO~~ 第一章 Java的I/O演进之路2.1 I/O 模型基本说明2.2 I/O模型Java BIOJava NIOJava AIO 2.3 BIO、NIO、AIO 适用场景分析 第三章 JAVA BIO深入剖析3.1 Java BIO 基本介绍3.2 Java BIO 工作机制3.3 传统的BIO编程实例回顾客户端案例如下服务端案例如下小结 3.4 BIO模式下多发…

python处理数据的一些代码

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 一、如何读取txt文件&#xff0c;将其转化为DataFrame格式二、给DataFrame添加列名三、删除指定行四、读取csv文件&#xff0c;不让第一行成为列名五、读取DataFram…

BioGRID:蛋白质相互作用数据库

欢迎关注微信公众号《生信修炼手册》! BioGRID数据库是一个老牌经典的蛋白质相互作用数据库&#xff0c;在今年9月份刚刚分布了最新版本3.5.165&#xff0c;该版本从66,164篇文献中整理出了1,607,037个蛋白质相互作用&#xff0c;28,093个嵌合体信息以及726,378个转录后修饰PTM…

(NCRE网络技术)中小型网络系统总体规划与设计方法-知识点

欢迎您阅读此系列文章&#xff0c;文章参考自《全国计算机等级考试三级教程.网络技术》。内容为NCRE三级网络技术主要知识点以及常考点&#xff0c;此知识点总结参照《三级网络技术考试大纲(2018年版)》。阅读此系列文章可以帮助您快速、轻松考取相应证书&#xff01;祝您阅读愉…

Linux系统如何查看服务器带宽及网络使用情况

文章目录 前言  linux查看服务器带宽具体方法  一、使用speedtest-cli命令查看下载和上传最大流量值  二、查看网卡、网络的详情   1.查看服务器网络端口   2.ethtool命令查看宽带大小 三、nload命令实时统计网卡带宽使用率  四、dstat -n命令实时监测网络的状态…

计算机网络的组成及其逻辑结构

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 目录 前言 一、计算机网络的组成 计算机系统&#xff1a; 数据通信系统 网络软件及网络协议 二、计算机网络的逻辑结构 资源子网 通信子网 总结 前言 计算机网络是在20世纪6…

Linux中centos修改系统时间并写到硬件,Linux中centos设置定时自动同步网络时间

文章目录 前言一、centos修改系统时间并写到硬件1.1查看当前的系统时间1.2修改系统时间1.3查看硬件时间1.4同步系统时间和硬件时间1.5本地时间写入硬件时间 二、centos设置定时自动同步网络时间2.1安装ntpdate工具2.2CentOS安装/操纵crontab2.3启动crontab并查看状态2.4写一个c…

计算机网络的发展简史

目录 前言一、互联网发展历史1. 第一阶段&#xff1a;ARPANET2. 第二阶段&#xff1a;三级结构互联网3. 第三阶段&#xff1a;多层次ISP互联网 二、中国互联网的发展简史1. 发展阶段2. 公共网络 总结 前言 时间是2022年的6月&#xff0c;当真正的注意到现在的时间时不禁感叹时…

浅谈网络舆情监测系统中爬虫的设计及系统架构

前言 说到网络舆情监测想必很多人都不陌生。可以跟大家这么说吧。爬虫所能带来的商业价值适用并深存于所有小-中-大企业中,尤其做网络舆情的大数据公司所有的业务基本都必须依托于爬虫来开展它的战略布局,毕竟有了米才能做饭嘛~ 不信的话我简单的来采访一下做舆情项目的相关…

基于java的网络在线考试管理系统的设计与实现--毕业开题报告

基于java的网络在线考试管理系 统的设计与实现开题报告–毕业设计 最近grace刚完成毕业设计 通过了赶紧来给宝贝们分享我的成果哈哈 设计题目&#xff1a;基于java的网络在线考试管理系统的设计与实现 一、选题依据&#xff1a; 1.国内外有关的研究动态 在线考试系统在国内…

校园网系统集成方案设计

校园网系统集成方案设计 第一篇的文章献给我的网络系统集成大作业&#xff0c;这篇文章是关于校园网系统集成方案的设计&#xff0c;文章有很多不足仅限于我目前的水平。 第一章 前言 随着经济的发展&#xff0c;信息起着越来越重要的作用。计算机、网络和多媒体等信息技术的…

VM虚拟机上的网络设置

1. 前言 一般Linux编程时,经常都会使用虚拟机跑Linux系统,VMware Workstation Pro 虚拟机里的系统不管是Linux、还是windows、还是其他系统想要上网就必须配置好虚拟网络连接方式。VMware Workstation 支持共享、桥接,选择网卡的方法自定义上网方式。 如果虚拟机里的系统想…

Cisco Packet Tracer 网络系统工程实训大作业【附网络拓扑图】

文章目录 前言网络拓扑图资源项目基本要求项目一项目二项目三 实验原理静态路由基本原理VLAN基本原理OSPF的基本原理 项目的实现项目一的设计与实现网络拓扑图接口信息配置流程连通性测试 项目二的设计与实现网络拓扑图接口信息配置流程连通性测试 项目三的设计与实现网络拓扑图…

零信任网络

“前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到网站。” 前言 - 床长人工智能教程 零信任&#xff1a; 零信任概念是由网络去边界化发展改进而来。之前网络的建设理念中&#xff0c;将网络分…

Linux系统中网络管理命令和查看网络配置的命令

前言 这是我听老师讲课做的笔记,考试要看的。 这是视频地址 作者&#xff1a;RodmaChen 关注我的csdn博客&#xff0c;更多Linux笔记知识还在更新 说明&#xff1a;本人只在csdn写博客&#xff0c;如果在其他网站上看到&#xff0c;请不要信 网络管理命令和查看网络配置的命令 …