Netty学习——实战篇1 BIO、NIO入门demo 备注

news2024/11/25 23:33:08

 1 BIO 实战代码 

@Slf4j
public class BIOServer {
    public static void main(String[] args) throws IOException {
        //1 创建线程池
        ExecutorService threadPool = Executors.newCachedThreadPool();
        //2 创建ServerSocket
        ServerSocket serverSocket = new ServerSocket(8000);

        log.info("服务器已启动成功");
        //3 监听，等待客户端连接
        while(true){
            log.info("线程id:{}",Thread.currentThread().getId());
            log.info("等待连接...");
            //4 客户端连接后，创建一个线程，与客户端通信
            final Socket socket = serverSocket.accept();
            threadPool.execute(new Runnable() {
                @Override
                public void run() {
                    handler(socket);
                }
            });
        }

    }

    //编写一个handler方法，与客户端通信
    public static  void handler(Socket socket){
        try {
            log.info("线程id:{}",Thread.currentThread().getId());
            //创建一个byte[]数组
            byte[] bytes = new byte[1023];
            //通过socket获取输入流
            InputStream inputStream = socket.getInputStream();
            //循环读取客户端发送的消息
            while(true){
                int read = inputStream.read(bytes);
                if(read != -1){
                    System.out.println(new String(bytes,0,read));
                }else{
                    break;
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                log.info("关闭与客户端的连接");
                socket.close();
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }

    }
}

        运行结果

8621025cda1d47839eed300130b406cd.png

2 NIO实战

2.1 Buffer实战

@Slf4j
public class BasicBuffer {
    public static void main(String[] args) {
        //1 创建一个Buffer
        IntBuffer buffer = IntBuffer.allocate(10);
        //2 往Buffer存储数据
        for (int i = 0; i < buffer.capacity(); i++) {
            buffer.put(i * 2);
        }
        //3 Buffer读写切换
        buffer.flip();
        //4 Buffer 读数据
        while(buffer.hasRemaining()){
            log.info("{}",buffer.get());
        }
    }
}

 

2.2 FileChannel实战

        使用NIO的FileChannel和ByteBuffer，把一段文字写入到指定的文件中。

//把文字写入到指定文件中
public class FileChannelWrite{
    public static void main(String[] args) throws IOException {
        //1 指定文字
        String str = "hello,孔乙己";
        //2 创建一个输出流
        FileOutputStream fileOutputStream = new FileOutputStream("D:\\develop\\java-base\\test\\test01.txt");
        //3 通过输出流创建FileChannel
        java.nio.channels.FileChannel fileChannel = fileOutputStream.getChannel();
        //4 创建一个缓冲区
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        //5 把文字放入缓冲区buffer中
        buffer.put(str.getBytes());
        //6 对buffer进行翻转
        buffer.flip();
        //7 把buffer的数据写入到FileChannel
        fileChannel.write(buffer);
        //8 关闭流
        fileOutputStream.close();
    }
}

 

        使用NIO的FileChannel和Bytebuffer，读取指定文件中的内容，并打印到控制台

@Slf4j
public class FileChannelRead {
    public static void main(String[] args) throws IOException {
        //1 创建输入流
        File file = new File("D:\\develop\\java-base\\test\\test01.txt");
        FileInputStream fileInputStream = new FileInputStream(file);
        //2 通过输入流创建FileChannel
        FileChannel fileChannel = fileInputStream.getChannel();
        //3 创建缓冲区
        ByteBuffer buffer = ByteBuffer.allocate((int) file.length());
        //4 把通道的数据读取到缓冲区
        fileChannel.read(buffer);
        //5 把bytebuffer 转成 string
        log.info("文件的内容是: {}",new String(buffer.array()));
        //6 关闭输入流
        fileInputStream.close();
    }
}

 

        使用一个Buffer,FileChannel和read/write方法，完成文件的拷贝 .

public class FileChannelCopy {
    public static void main(String[] args) throws IOException {
        FileInputStream fileInputStream = new FileInputStream("D:\\develop\\java-base\\test\\source.txt");
        FileChannel inputChannel = fileInputStream.getChannel();

        FileOutputStream fileOutputStream = new FileOutputStream("D:\\develop\\java-base\\test\\target.txt");
        FileChannel outChannel = fileOutputStream.getChannel();

        ByteBuffer buffer = ByteBuffer.allocate(1024);

        while (true){
            buffer.clear();
            int read = inputChannel.read(buffer);
            if(read == -1){
                break;
            }
            buffer.flip();
            outChannel.write(buffer);
        }
        fileInputStream.close();
        fileOutputStream.close();

    }
}

        使用transferFrom方法拷贝文件 

public class FileChannelCopy01 {
    public static void main(String[] args) throws IOException {
        FileInputStream fileInputStream = new FileInputStream("D:\\develop\\java-base\\test\\source.png");
        FileOutputStream fileOutputStream = new FileOutputStream("D:\\develop\\java-base\\test\\dest.png");

        FileChannel inChannel = fileInputStream.getChannel();
        FileChannel outChannel = fileOutputStream.getChannel();

        outChannel.transferFrom(inChannel,0,inChannel.size());

        fileInputStream.close();
        fileOutputStream.close();
    }
}

2.3 MappedByteBufer

         MappedByteBufer 可以让文件直接在内存（堆外内存）修改，操作系统不需要再拷贝一次

//原来的内容是：hello,孔乙己
//修改后的内容是：HelLo,孔乙己
public class MappedByteBuffer {
    public static void main(String[] args) throws IOException {
        RandomAccessFile randomAccessFile = new RandomAccessFile("D:\\develop\\java-base\\test\\test01.txt", "rw");
        FileChannel channel = randomAccessFile.getChannel();
        java.nio.MappedByteBuffer map = channel.map(FileChannel.MapMode.READ_WRITE, 0, 5);
        map.put(0,(byte) 'H');
        map.put(3,(byte) 'L');
        randomAccessFile.close();
    }
}

2.4 ServerSocketChannel和SocketChannel

@Slf4j
public class ServerSocketChannelAndSocketChannel {
    public static void main(String[] args) throws IOException {
        //1 使用ServerSocketChannel和SocketChannel 网络
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        InetSocketAddress address = new InetSocketAddress(8000);

        //2 绑定端口到socket，并启动
        serverSocketChannel.socket().bind(address);
        //3 创建 ByteBuffer数组
        ByteBuffer[] buffers = new ByteBuffer[2];
        buffers[0] = ByteBuffer.allocate(5);
        buffers[1] = ByteBuffer.allocate(3);
        //4 等待客户端连接
        SocketChannel socketChannel = serverSocketChannel.accept();
        int messageLength = 8;//假定从客户端接收到8个字节
        //5 循环读取
        while(true){
            int byteRead = 0;
            while(byteRead < messageLength){
                long read = socketChannel.read(buffers);
                byteRead += read;
                log.info("byteRead = ,{}",byteRead);
                //使用流打印，查看当前的这个buffer的position和limit
                Arrays.asList(buffers).stream().
                        map(buffer -> "position = " +
                                buffer.position() +
                                ",limit = " + buffer.limit()
                        ).forEach(System.out::println);
            }
            // 6 将所有的buffer进行翻转
            Arrays.asList(buffers).forEach(buffer -> buffer.flip());
            // 将数据读取到客户端
            long byteWrite = 0;
            while(byteWrite < messageLength){
                long l = socketChannel.write(buffers);
                byteWrite += l;
            }
            //将所有的buffer进行翻转
            Arrays.asList(buffers).forEach(buffer ->{buffer.clear();
            });
            log.info("byteRead = ,{},byteWrite = {},messageLength = {}",byteRead,byteWrite,messageLength);
        }
        
    }
}

2.5 使用NIO开发服务端和客户端

        NIOServer.java 

 

@Slf4j
public class NIOServer {
    public static void main(String[] args) throws Exception{
        //1 创建ServerSocketChannel
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        //2 创建Selector对象
        Selector selector = Selector.open();
        //3 绑定端口 8000，在服务器监听
        serverSocketChannel.socket().bind(new InetSocketAddress(8000));
        //4 ServerSocketChannel设置为非阻塞
        serverSocketChannel.configureBlocking(false);
        //5 把ServerSocketChannel的OP_ACCEPT注册到selector
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
        log.info("ServerSocketChannel已注册到Selector上");
        // 6 循环，等待客户端连接
        while(true){
            //7 等待一秒，如果没有事件发生，就返回
            if(selector.select(1000) == 0){
                log.info("等待1秒，没有客户端连接");
                continue;
            }
            //8 如果有事件发生，就获取selectedKyes，返回关注事件的集合
            Set<SelectionKey> selectededKeys = selector.selectedKeys();
            Iterator<SelectionKey> keyIterator = selectededKeys.iterator();
            //9 遍历selectedKeys集合，获取事件类型
            while(keyIterator.hasNext()){

                SelectionKey key = keyIterator.next();
                if(key.isAcceptable()){
                    log.info("客户端连接成功");
                    //10_1 如果是OP_ACCEPT事件，证明有新的客户端连接，为该客户端创建一个SocketChannel
                    SocketChannel socketChannel = serverSocketChannel.accept();
                    socketChannel.configureBlocking(false);
                    //10_1_1 将SocketChannel注册到selector上，事件类型是OP_READ，并绑定一个缓冲区
                    socketChannel.register(selector,SelectionKey.OP_READ, ByteBuffer.allocate(1024));
                }
                if(key.isReadable()){
                    //10_2  如果是OP_READ事件，通过selectedKey 反向获取 SocketChannel
                    SocketChannel channel =(SocketChannel) key.channel();
                    //10_2_1  获取该channel绑定的buffer，并读取
                    ByteBuffer buffer = (ByteBuffer)key.attachment();
                    channel.read(buffer);
                    log.info("从客户端读取的数据是: {}",new String(buffer.array()));
                }
                //11 移除selectedKey,防止重复操作
                keyIterator.remove();

            }

        }

    }
}

        NIOClient.java

 

@Slf4j
public class NIOClient {
    public static void main(String[] args) throws Exception {
        //1 创建SocketChannel
        SocketChannel socketChannel = SocketChannel.open();
        //2 设置非阻塞模式
        socketChannel.configureBlocking(false);
        //3  提供服务器的ip和端口
        InetSocketAddress address = new InetSocketAddress("127.0.0.1", 8000);
        //4 连接服务器
        if(!socketChannel.connect(address)){
            // 4_1 连接失败
            while(!socketChannel.finishConnect()){
                log.info("连接需要时间，此时客户端不会阻塞，可以做其他工作。。。");
            }
        }
        //4_2 连接成功，发送数据
        String str = "hello ,孔乙己";
        ByteBuffer buffer = ByteBuffer.wrap(str.getBytes());
        socketChannel.write(buffer);
        System.in.read();
    }
}

        运行结果：

cac6746784044121871985398c1944f7.png

 

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

java下载网络上的文件、图片保存到本地 FileUtils

java下载网络上的文件、图片保存到本地 FileUtils

java下载网络上的文件、图片保存到本地 FileUtils 1. 引入FileUtils依赖2. 实现代码3. 输出结果 1. 引入FileUtils依赖 <!--FileUtils依赖--> <!-- https://mvnrepository.com/artifact/commons-io/commons-io --> <dependency><groupId>commons-io&l…
阅读更多...
（Java）数据结构——图（第九节）AOV网以及拓扑排序

（Java）数据结构——图（第九节）AOV网以及拓扑排序

前言 本博客是博主用于复习数据结构以及算法的博客&#xff0c;如果疏忽出现错误&#xff0c;还望各位指正。 AOV网 先前我们了解了有向无环图DAG的概念。 所有的工程或者某种流程可以分为若干个小的工程或者阶段&#xff0c;这些小的工程或者阶段就称为活动。若以图中的顶…
阅读更多...
IPV6的相关网络问题

IPV6的相关网络问题

问题 ​​​​​​​ 目录 问题 一.什么是NAT64转换 1.NAT64的工作原理 IPv6到IPv4转换 IPv4到IPv6的响应转换 2.NAT64的优点 3.NAT64的缺点 二.NAT64转换如何实现 1.工作原理 2.实现步骤 DNS查询转换&#xff08;DNS64&#xff09; 地址转换&#xff08;NAT64&a…
阅读更多...
ECharts的时间轴样式设置

ECharts的时间轴样式设置

timeline: {orient: vertical,axisType: category,autoPlay: false,inverse: true,right: 0,top: 5,bottom: 5,width: 100,realtime : true,symbolSize: 3,itemStyle: { // 轴默认样式color : #000000},checkpointStyle: { // 拖动按钮样式borderWidth: 0,width: 5,color: #7f8…
阅读更多...
如何正确使用数字化仪前端信号调理？（一）

如何正确使用数字化仪前端信号调理？（一）

一、前言 板卡式的数字转换器和类似测量仪器&#xff0c;比如图1所示的德思特TS-M4i系列&#xff0c;都需要为各种各样的特性信号与内部模数转换器&#xff08;ADC&#xff09;的固定输入范围做匹配。 图1&#xff1a;德思特TS-M4i系列高速数字化仪&#xff0c;包括2或4通道版…
阅读更多...
Nacos-默认token.secret.key-配置不当权限绕过漏洞复现

Nacos-默认token.secret.key-配置不当权限绕过漏洞复现

漏洞描述&#xff1a; Nacos 身份认证绕过漏洞(QVD-2023-6271)&#xff0c;开源服务管理平台 Nacos在默认配置下未对 token.secret.key 进行修改&#xff0c;导致远程攻击者可以绕过密钥认证进入后台&#xff0c;造成系统受控等后果。 漏洞信息 公开时间&#xff1a;2023-03…
阅读更多...
很难不爱啊！颠覆认知的13个Edge神级插件

很难不爱啊！颠覆认知的13个Edge神级插件

::: block-1 “时问桫椤”是一个致力于为本科生到研究生教育阶段提供帮助的不太正式的公众号。我们旨在在大家感到困惑、痛苦或面临困难时伸出援手。通过总结广大研究生的经验&#xff0c;帮助大家尽早适应研究生生活&#xff0c;尽快了解科研的本质。祝一切顺利&#xff01;—…
阅读更多...
[Algorithm][双指针][有效三角形的个数]详细解读 + 代码实现

[Algorithm][双指针][有效三角形的个数]详细解读 + 代码实现

题目链接优化&#xff1a;对整个数组排序&#xff0c;可以简化比较模型&#xff0c;减少比较次数在有序的情况下&#xff0c;只需较⼩的两条边之和⼤于第三边即可设最⻓边枚举到max位置&#xff0c;区间[left, right]是max位置左边的区间(也就是⽐它⼩的区间) if (nums[left] …
阅读更多...
前端React笔记（尚硅谷）

前端React笔记（尚硅谷）

react 尚硅谷react教程 jsx语法规则 1.定义虚拟dom时不加引号&#xff08;不是字符串&#xff09; 2.标签中混入js表达式时要用{} js表达式与js语句不同。 js语句是if&#xff08;&#xff09;&#xff0c;for&#xff08;&#xff09;&#xff0c;switch&#xff08;&#x…
阅读更多...
花趣短视频源码淘宝客系统全开源版带直播带货带自营商城流量主小游戏

花趣短视频源码淘宝客系统全开源版带直播带货带自营商城流量主小游戏

首页设计 仿抖音短视频&#xff1a;采用短视频流的形式展示内容&#xff0c;用户可浏览、点赞、评论和分享短视频。关注与我的&#xff1a;提供用户关注列表和个人中心入口&#xff0c;方便用户管理关注对象和查看个人信息。本地直播&#xff1a;集成直播功能&#xff0c;支持…
阅读更多...
小程序如何通过把动态数据值传入到css文件中控制样式

小程序如何通过把动态数据值传入到css文件中控制样式

场景&#xff1a;动态改变一个模块的高度 一、常用解决方法&#xff1a;行内样式绑值&#xff0c;或者动态class来传递 <viewclass"box":style"height: ${boxHeight}px">我是一个动态高度的box,我的高度是{{boxHeight}}px </view>二、高度传…
阅读更多...
CSS导读 （元素显示模式 下）

CSS导读 （元素显示模式 下）

&#xff08;大家好&#xff0c;今天我们将继续来学习CSS的相关知识&#xff0c;大家可以在评论区进行互动答疑哦~加油&#xff01;&#x1f495;&#xff09; 目录 3.6 元素显示模式转换 3.7 (一个小技巧)单行文字垂直居中的代码 3.8 单行文字垂直居中的原理 3.9 小案例…
阅读更多...
matlab conv2

matlab conv2

MATLAB卷积conv、conv2、convn详解-CSDN博客
阅读更多...
Java | Leetcode Java题解之第17题电话号码的字母组合

Java | Leetcode Java题解之第17题电话号码的字母组合

题目&#xff1a; 题解&#xff1a; class Solution {public List<String> letterCombinations(String digits) {List<String> combinations new ArrayList<String>();if (digits.length() 0) {return combinations;}Map<Character, String> phoneM…
阅读更多...
3月产品更新来袭，快来看有没你期待的功能

3月产品更新来袭，快来看有没你期待的功能

亮点更新一览 增强制作报表易用性&#xff0c;提升用户体验&#xff0c;如仪表盘图层锁定保持原有层级、即席查询支持批量选择表字段。 增强报表展示和分析能力&#xff0c;满足更多项目需求&#xff0c;如仪表盘表格支持配置是否显示分析菜单按钮、Web电子表格新增多选输入…
阅读更多...
Docker镜像，什么是Docker镜像，Docker基本常用命令

Docker镜像，什么是Docker镜像，Docker基本常用命令

docker镜像 1.1什么是镜像&#xff0c;镜像基础 1.1.1 镜像的简介 镜像是一种轻量级&#xff0c;可执行的独立软件包&#xff0c;也可以说是一个精简的操作系统。镜像中包含应用软件及应用软件的运行环境&#xff0c;具体来说镜像包含运行某个软件所需的所有内容&#xff0c;…
阅读更多...
【Linux】编写并运行Shell脚本程序操作实例

【Linux】编写并运行Shell脚本程序操作实例

关于Shell脚本的介绍&#xff1a; Shell脚本是一种用于自动化任务和简化常见操作的脚本语言&#xff0c;通常用于Linux和Unix环境中。Shell脚本允许用户通过编写一系列命令和逻辑语句来执行一系列任务&#xff0c;从而提高了工作效率和自动化水平。 以下是关于Shell脚本的详细…
阅读更多...
工业级POE交换机的测试标准

工业级POE交换机的测试标准

工业级POE交换机的测试标准通常包括以下方面&#xff1a; 1. IEEE 802.3标准&#xff1a;工业级POE交换机遵循IEEE 802.3标准&#xff0c;该标准规定了以太网设备的通信协议和物理层规范。 2. POE标准&#xff1a;工业级POE交换机支持POE&#xff08;Power over Ethernet&…
阅读更多...
【软件测试之因果图法】

【软件测试之因果图法】

【软件测试之判断表法】(蓝桥课学习笔记) 1、因果图法的概念 因果图法是一种利用图解法分析输入的各种组合情况&#xff0c;从而设计测试用例的方法&#xff0c;它适合于检查程序输入条件的各种情况的组合。因果图&#xff08;Cause-Effect-Graphing&#xff09;提供了把规则转…
阅读更多...
Rust语言

Rust语言

文章目录 Rust语言一&#xff0c;Rust语言是什么二&#xff0c;Rust语言能做什么&#xff1f;Rust语言的设计使其适用于许多不同的领域&#xff0c;包括但不限于以下几个方面&#xff1a;1. 传统命令行程序&#xff1a;2. Web 应用&#xff1a;3. 网络服务器&#xff1a;4. 嵌入…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023