【Netty】IO 模型简介 ( Netty 特点 | Netty 应用场景 | Java 三种 IO 模型 | BIO 模型 )(二)

简介: 【Netty】IO 模型简介 ( Netty 特点 | Netty 应用场景 | Java 三种 IO 模型 | BIO 模型 )(二)

VI . BIO 实例


1 . BIO 示例 :


① 服务器端 : 编写服务器端 , 监听 8888 端口 , 阻塞等待客户端连接 , 连接成功后 , 创建线程 , 线程中阻塞等待客户端发送请求数据 ;


② 客户端 : 编写一个客户端 , 请求服务器的 8888 端口号 , 客户端发送 “Hello World” 字符串给服务器端 ;


③ Telnet 客户端 : 使用 Telnet 客户端向上述服务器端 8888 端口 发送 “Hello World” 字符串请求 ;



2 . 服务器代码示例 :


package kim.hsl.bio;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class TCPServer {
    public static void main(String[] args) {
        try {
            //创建线程池
            ExecutorService threadPool = Executors.newCachedThreadPool();
            //创建服务器套接字
            ServerSocket serverSocket = new ServerSocket(8888);
            System.out.println("服务器启动,监听 8888 端口");
            while (true){
                //阻塞, 等待客户端连接请求 ( 此处是第一个阻塞点 )
                Socket socket = serverSocket.accept();
                System.out.println("客户端连接成功");
                //线程池启动线程
                threadPool.execute(new ClientRquest(socket));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    /**
     * 与客户端交互类
     */
    static class ClientRquest implements Runnable {
        private Socket socket;
        public ClientRquest(Socket socket) {
            this.socket = socket;
        }
        @Override
        public void run() {
            try {
                clientRequest();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                //最终要将 Socket 关闭, 如果出异常继续捕获
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        public void clientRequest() throws IOException {
            //获取输入流, 读取客户端写入的信息
            byte[] buffer = new byte[1024];
            InputStream is = socket.getInputStream();
            System.out.println("等到客户端请求");
            //此处会阻塞等待客户端的请求 ( 此处是第二个阻塞点 )
            int count = is.read(buffer);
            String request = new String(buffer, 0, count);
            System.out.println("客户端请求到达 : " + request);
        }
    }
}





3 . 客户端代码示例 :


package kim.hsl.bio;


import java.io.IOException;

import java.net.Inet4Address;

import java.net.InetSocketAddress;

import java.net.Socket;


public class TCPClient {

   public static void main(String[] args) {

       try {

           Socket socket = new Socket();

           InetSocketAddress inetSocketAddress =

                   new InetSocketAddress(

                           Inet4Address.getLocalHost(),   //本机IP地址

                           8888                      //端口号

                   );

           System.out.println("客户端开始连接 ...");

           //此处会阻塞等待连接成功

           socket.connect(inetSocketAddress);

           System.out.println("客户端连接成功");

           //连接成功后, 开始执行后续操作

           socket.getOutputStream().write("Hello World".getBytes());

           System.out.println("客户端写出 Hello World 成功");

       } catch (IOException e) {

           e.printStackTrace();

       }

   }

}


1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

4 . 执行结果 :


① 启动服务器 :

image.png



② 启动客户端 :



image.png




③ 使用 Telnet 客户端测试 localhost 8888 端口 :


建立连接 : 在命令行工具中 , 使用 telnet localhost 8888 连接本机的 8888 端口 ;



连接成功后 , 按下 Ctrl + ] 快捷键 , 进入 Telnet 命令行 , 输入 send Hello World 命令 , 向本机的 8888 端口发送 Hello World 字符串 ;



服务器端显示 :


image.png





VII . BIO 模型实例分析


BIO 模型实例分析 : 针对上述 BIO 实例 , 从性能 , 线程个数 , 阻塞 等角度分析 BIO 模型 ;



① 线程维护个数 : 在服务器端 , 需要针对每个客户端连接都创建一个线程 , 有多少连接 , 就需要有多少线程 ;


② 性能分析 : 如果客户端数量很多 , 那么大量客户端同时连接 , 其并发数量很大 , 对系统的资源占用较高 ;


③ 阻塞分析 : BIO 模型中 , 服务器端有两处阻塞 , 一个是等待客户端连接 , 一个是连接后 , 等待客户端发出请求数据 , 后者的阻塞等待完全就是对资源的浪费 , 没有数据交互 , 一直占用资源 ;


目录
相关文章
|
5天前
|
存储 缓存 算法
JVM简介—1.Java内存区域
本文详细介绍了Java虚拟机运行时数据区的各个方面,包括其定义、类型(如程序计数器、Java虚拟机栈、本地方法栈、Java堆、方法区和直接内存)及其作用。文中还探讨了各版本内存区域的变化、直接内存的使用、从线程角度分析Java内存区域、堆与栈的区别、对象创建步骤、对象内存布局及访问定位,并通过实例说明了常见内存溢出问题的原因和表现形式。这些内容帮助开发者深入理解Java内存管理机制,优化应用程序性能并解决潜在的内存问题。
JVM简介—1.Java内存区域
|
10天前
|
Java Linux API
课时3:Java简介(Java主要特点)
本文介绍了Java的主要特点及其运行机制。Java结合了编译型和解释型语言的优点,通过Java虚拟机(JVM)实现跨平台移植,简化了不同操作系统间的开发流程。Java的特点包括可移植性、简单易用、支持多线程编程、自动垃圾收集和面向对象编程。随着硬件技术的发展,Java的性能问题已大大改善,成为行业标准之一,广泛应用于各种商用平台开发。
|
10天前
|
开发框架 移动开发 Java
课时2:Java简介(Java发展概述)
课时2:Java简介(Java发展概述) 摘要: 1. Java基础知识:介绍Java作为编程语言及其思想。 2. Java的发展历史:从1991年GREEN项目到1995年正式推出,历经网景公司、HotJava浏览器等关键节点。 3. Java的版本信息:涵盖从JDK 1.0到JDK 1.8的主要版本及特性,如Lambda表达式和模块化支持。
|
10天前
|
存储 Java C语言
课时11:Java数据类型简介
本文介绍了Java中的数据类型划分,主要分为基本数据类型和引用数据类型。基本数据类型包括数值型(整型、浮点型)、布尔型和字符型,每种类型有固定的默认值和存储范围。引用数据类型涉及内存使用,如数组、类和接口,默认值为Null。文中还提供了不同类型的选择原则,帮助开发者在实际编程中合理选用数据类型。
|
10天前
|
Oracle Java Unix
课时1:认识Java(Java发展简介)
课时1:认识Java(Java发展简介)。主讲人李兴华介绍了Java的起源、发展历程及其广泛应用。Java由Sun公司开发,最初为嵌入式系统设计,后演变为三大方向:Java SE、Java ME和Java EE。尽管面临版权争议等挑战,Java仍是最流行的编程语言之一,广泛应用于大型企业及互联网平台开发。
|
23天前
|
缓存 网络协议 Java
JAVA网络IO之NIO/BIO
本文介绍了Java网络编程的基础与历史演进,重点阐述了IO和Socket的概念。Java的IO分为设备和接口两部分,通过流、字节、字符等方式实现与外部的交互。
|
2月前
|
人工智能 搜索推荐 算法
【潜意识Java】人工智能与Java的有关应用场景
本文介绍了如何使用Java和Apache Mahout实现一个基于协同过滤的推荐系统。
40 1
|
2月前
|
自然语言处理 Java 关系型数据库
Java mysql根据很长的富文本如何自动获取简介
通过使用Jsoup解析富文本并提取纯文本,然后根据需要生成简介,可以有效地处理和展示长文本内容。该方法简单高效,适用于各种应用场景。希望本文对您在Java中处理富文本并生成简介的需求提供实用的指导和帮助。
67 14
|
2月前
|
自然语言处理 Java 关系型数据库
Java mysql根据很长的富文本如何自动获取简介
通过使用Jsoup解析富文本并提取纯文本,然后根据需要生成简介,可以有效地处理和展示长文本内容。该方法简单高效,适用于各种应用场景。希望本文对您在Java中处理富文本并生成简介的需求提供实用的指导和帮助。
58 9
|
3月前
|
监控 Java API
探索Java NIO:究竟在哪些领域能大显身手?揭秘原理、应用场景与官方示例代码
Java NIO(New IO)自Java SE 1.4引入,提供比传统IO更高效、灵活的操作,支持非阻塞IO和选择器特性,适用于高并发、高吞吐量场景。NIO的核心概念包括通道(Channel)、缓冲区(Buffer)和选择器(Selector),能实现多路复用和异步操作。其应用场景涵盖网络通信、文件操作、进程间通信及数据库操作等。NIO的优势在于提高并发性和性能,简化编程;但学习成本较高,且与传统IO存在不兼容性。尽管如此,NIO在构建高性能框架如Netty、Mina和Jetty中仍广泛应用。
74 3