Java BIO 模型演示

我就是我 2023-10-01 16:08 20阅读 0赞

#### Java BIO 模型演示 ####

*  一、演示
 *   *  1. BIO 服务代码
     *  2.调用
     *   *  1.利用CMD的Telnet实现客户端请求（Telnet为WIN自带服务，若未启用自行百度开启方法）
         *  2.结果

## 一、演示 ##

### 1. BIO 服务代码 ###

package com.example.netty.io.bio;
    
    import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.Executor;
    import java.util.concurrent.ThreadPoolExecutor;
    
    /**
     * Description: BIO 阻塞通讯
     *
     * @Author: zhx & moon hongxu_1234@163.com
     * @Date: 2022-01-22 23:43
     * @version: V1.0.0
     */
    public class BIOServer {
        
    
        private static int BIO_PORT=8888;
    
        /**
         * 1.创建线程池
         * 2.如果有客户端连接，则创建一个线程，与之通信
         *
         * @param args
         */
        public static void main(String[] args) throws IOException {
        
    
            Executor executor = getThreadPool();
    
            ServerSocket server = new ServerSocket(BIO_PORT);
    
            System.out.println("Socket 服务启动完成...");
    
            /**
             * 监听
             */
            while (true){
        
    			//当没有连接时，主线程会阻塞在此处
                final Socket socket = server.accept();
    
                executor.execute(()->{
        
                    System.out.println("获取了一个连接：" + Thread.currentThread().getName());
                    handler(socket);
                });
            }
        }
    
        /**
         * 创建线程池
         * @return
         */
        public static Executor getThreadPool() {
        
            ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
            //线程池维护线程的最少数量，核心线程数
            executor.setCorePoolSize(5);
            //线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
            executor.setMaxPoolSize(10);
            //缓存队列
            executor.setQueueCapacity(20);
            //允许的空闲时间,当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
            executor.setKeepAliveSeconds(200);
            //线程名称前缀
            executor.setThreadNamePrefix("zhx-moon-thread-");
            // 线程池对拒绝任务（无线程可用）的处理策略，目前只支持AbortPolicy、CallerRunsPolicy；默认为后者
            executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
            // 调度器shutdown被调用时等待当前被调度的任务完成
            executor.setWaitForTasksToCompleteOnShutdown(true);
            // 等待时长
            executor.setAwaitTerminationSeconds(60);
            executor.initialize();
            return executor;
        }
    
        /**
         * 通信方法
         * @param socket
         */
        public static void handler(Socket socket){
        
    
            byte[] bytes = new byte[1024];
    
            try {
        
                InputStream inputStream = socket.getInputStream();
                int read;
                //循环读取信息,通道内无数据时，会阻塞在此处
                while (-1!=(read = inputStream.read(bytes))){
        
                    System.out.println("Client Info : " + new String(bytes,0,read));
                }
    
            } catch (IOException e) {
        
                e.printStackTrace();
            } finally {
        
                //关闭通道
                try {
        
                    socket.close();
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
            }
        }
    }

### 2.调用 ###

#### 1.利用CMD的Telnet实现客户端请求（Telnet为WIN自带服务，若未启用自行百度开启方法） ####

启动CMD窗口，输入命令：telnet 127.0.0.1 8888
    按组合键【CTRL + ]】打开Client
    输入命令【SEND】命令，加当发送信息，并回车即可发送数据

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA54yq5oKf6YGT_size_20_color_FFFFFF_t_70_g_se_x_16]

#### 2.结果 ####

"C:\Program Files\Java\jdk-17.0.1\bin\java.exe" -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:65361,suspend=y,server=n -javaagent:C:\Users\Administrator\AppData\Local\JetBrains\IntelliJIdea2021.2\captureAgent\debugger-agent.jar -Dfile.encoding=UTF-8 -classpath "E:\IdeaProjects\netty\target\classes;D:\apache-maven-space\org\springframework\boot\spring-boot-starter-web\2.5.6\spring-boot-starter-web-2.5.6.jar;D:\apache-maven-space\org\springframework\boot\spring-boot-starter\2.5.6\spring-boot-starter-2.5.6.jar;D:\apache-maven-space\org\springframework\boot\spring-boot\2.5.6\spring-boot-2.5.6.jar;D:\apache-maven-space\org\springframework\boot\spring-boot-autoconfigure\2.5.6\spring-boot-autoconfigure-2.5.6.jar;D:\apache-maven-space\jakarta\annotation\jakarta.annotation-api\1.3.5\jakarta.annotation-api-1.3.5.jar;D:\apache-maven-space\org\yaml\snakeyaml\1.28\snakeyaml-1.28.jar;D:\apache-maven-space\org\springframework\boot\spring-boot-starter-json\2.5.6\spring-boot-starter-json-2.5.6.jar;D:\apache-maven-space\com\fasterxml\jackson\core\jackson-databind\2.12.5\jackson-databind-2.12.5.jar;D:\apache-maven-space\com\fasterxml\jackson\core\jackson-annotations\2.12.5\jackson-annotations-2.12.5.jar;D:\apache-maven-space\com\fasterxml\jackson\core\jackson-core\2.12.5\jackson-core-2.12.5.jar;D:\apache-maven-space\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.12.5\jackson-datatype-jdk8-2.12.5.jar;D:\apache-maven-space\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.12.5\jackson-datatype-jsr310-2.12.5.jar;D:\apache-maven-space\com\fasterxml\jackson\module\jackson-module-parameter-names\2.12.5\jackson-module-parameter-names-2.12.5.jar;D:\apache-maven-space\org\springframework\spring-web\5.3.12\spring-web-5.3.12.jar;D:\apache-maven-space\org\springframework\spring-beans\5.3.12\spring-beans-5.3.12.jar;D:\apache-maven-space\org\springframework\spring-webmvc\5.3.12\spring-webmvc-5.3.12.jar;D:\apache-maven-space\org\springframework\spring-aop\5.3.12\spring-aop-5.3.12.jar;D:\apache-maven-space\org\springframework\spring-context\5.3.12\spring-context-5.3.12.jar;D:\apache-maven-space\org\springframework\spring-expression\5.3.12\spring-expression-5.3.12.jar;D:\apache-maven-space\org\springframework\boot\spring-boot-starter-log4j2\2.5.6\spring-boot-starter-log4j2-2.5.6.jar;D:\apache-maven-space\org\apache\logging\log4j\log4j-slf4j-impl\2.14.1\log4j-slf4j-impl-2.14.1.jar;D:\apache-maven-space\org\slf4j\slf4j-api\1.7.32\slf4j-api-1.7.32.jar;D:\apache-maven-space\org\apache\logging\log4j\log4j-api\2.14.1\log4j-api-2.14.1.jar;D:\apache-maven-space\org\apache\logging\log4j\log4j-core\2.14.1\log4j-core-2.14.1.jar;D:\apache-maven-space\org\apache\logging\log4j\log4j-jul\2.14.1\log4j-jul-2.14.1.jar;D:\apache-maven-space\org\slf4j\jul-to-slf4j\1.7.32\jul-to-slf4j-1.7.32.jar;D:\apache-maven-space\io\netty\netty-all\4.1.50.Final\netty-all-4.1.50.Final.jar;D:\apache-maven-space\org\projectlombok\lombok\1.18.22\lombok-1.18.22.jar;D:\apache-maven-space\org\springframework\spring-core\5.3.12\spring-core-5.3.12.jar;D:\apache-maven-space\org\springframework\spring-jcl\5.3.12\spring-jcl-5.3.12.jar;D:\Program Files\JetBrains\IntelliJ IDEA 2020.2.3\lib\idea_rt.jar" com.example.netty.io.bio.BIOServer
    Connected to the target VM, address: '127.0.0.1:65361', transport: 'socket'
    Java HotSpot(TM) 64-Bit Server VM warning: Sharing is only supported for boot loader classes because bootstrap classpath has been appended
    Socket 服务启动完成...
    获取了一个连接：zhx-moon-thread-1
    Client Info : I am Client_1
    获取了一个连接：zhx-moon-thread-2
    Client Info : I am Client_2

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA54yq5oKf6YGT_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/f3eda94349864270ae449ae2b82fb0be.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA54yq5oKf6YGT,size_20,color_FFFFFF,t_70,g_se,x_16