电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

小白也可以學會的Java NIO的Write事件

瀏覽:105日期:2022-08-11 13:55:05
目錄一、NIO Server端1.1 多路復用開發一般步驟1.2 解惑寫事件二、不使用事件三、使用事件四、NIO Client端一、NIO Server端1.1 多路復用開發一般步驟

//打開選擇器Selector selector = Selector.open();//打開通到ServerSocketChannel socketChannel = ServerSocketChannel.open();//配置非阻塞模型socketChannel.configureBlocking(false);//綁定端口socketChannel.bind(new InetSocketAddress(8080));//注冊事件,OP_ACCEPT只適用于ServerSocketChannel socketChannel.register(selector, SelectionKey.OP_ACCEPT);while (true) { selector.select(); Set<SelectionKey> selectionKeys = selector.selectedKeys(); Iterator<SelectionKey> iter = selectionKeys.iterator(); while(iter.hasNext()) {SelectionKey key = iter.next();if(key.isAcceptable()) { SocketChannel channel = ((ServerSocketChannel)key.channel()).accept(); channel.configureBlocking(false); channel.register(selector,SelectionKey.OP_READ);}if(key.isWritable()) {}if(key.isReadable()) { SocketChannel channel = (SocketChannel) key.channel(); ByteBuffer readBuffer = ByteBuffer.allocate(1024); channel.read(readBuffer); readBuffer.flip(); // handler Buffer // 一般是響應客戶端的數據 // 直接是write寫不就完事了嘛,為啥需要write事件? // channel.write(...)}iter.remove(); }}1.2 解惑寫事件

對NIO的寫操作:

為什么要注冊寫事件 何時注冊寫事件 為什么寫完之后要取消注冊寫事件

如果有channel在Selector上注冊了SelectionKey.OP_WRITE,在調用selector.select();時,系統會檢查內核寫緩沖區是否可寫:

如果可寫,selector.select();立即返回,進入key.isWritable() 何時不可寫?比如緩沖區已滿,channel調用了shutdownOutPut等

當然除了注冊寫事件,你也可以在channel直接調用write(…),也可以將數據發出去,但這樣不夠靈活,而且可能浪費CPU。

比如服務端需要發送一個200M的Buffer,看看是否使用OP_WRITE事件的區別。

二、不使用事件

程序運行到這會等到200M文件發送完成后才繼續往下執行,不符合異步事件模型的思想。若緩沖區一直處不可寫狀態,則該過程一直在這里死循環,浪費CPU。

// 200M的BufferByteBuffer buffer = .... while(buffer.hasRemaining()) { // 該方法只會寫入小于socket’s output buffer空閑區域的任何字節數 // 并返回寫入的字節數,可能是0字節 channel.write(buffer);}三、使用事件

if(key.isReadable()) {// 200M Buffer ByteBuffer buffer = .... // 注冊寫事件 key.interestOps(key.interestOps() | SelectionKey.OP_WRITE); // 綁定Buffer key.attach(buffer);}// 可寫分支if(key.isWritable()) { ByteBuffer buffer = (ByteBuffer) key.attachment(); SocketChannel channel = (SocketChannel) key.channel(); if (buffer.hasRemaining()) {channel.write(buffer) } else {// 發送完了就取消寫事件,否則下次還會進入寫事件分支(因為只要還可寫,就會進入)key.interestOps(key.interestOps() & ~SelectionKey.OP_WRITE); }}

要觸發寫事件,需要先向 selector 注冊該通道的寫事件,跟注冊讀事件一樣,當底層寫緩沖區有空閑就會觸發寫事件了,而一般來說底層的寫緩沖區大部分都是空閑的。所以一般只要注冊了寫事件,就會立馬觸發了,為了避免 cpu 空轉,在寫操作完成后需要把寫事件取消掉,然后下次再有寫操作時重新注冊寫事件。

四、NIO Client端

開發的一般步驟

// 打開選擇器Selector selector = Selector.open();// 打開通道SocketChannel socketChannel = SocketChannel.open();// 配置非阻塞模型socketChannel.configureBlocking(false);// 連接ServersocketChannel.connect(new InetSocketAddress('127.0.0.1',8080));// 注冊事件socketChannel.register(selector, SelectionKey.OP_CONNECT | SelectionKey.OP_READ);// 循環處理while (true) { selector.select(); Set<SelectionKey> keys = selector.selectedKeys(); Iterator<SelectionKey> iter = keys.iterator(); while(iter.hasNext()) {SelectionKey key = iter.next();if(key.isConnectable()) { // 連接建立或者連接建立不成功 SocketChannel channel = (SocketChannel) key.channel(); // 完成連接建立 if(channel.finishConnect()) { }}if(key.isReadable()) { SocketChannel channel = (SocketChannel) key.channel(); ByteBuffer buffer = ByteBuffer.allocate(500 * 1024 * 1024); buffer.clear(); channel.read(buffer); // buffer Handler}iter.remove(); }}

起初對OP_CONNECT事件還有finishConnect不理解,OP_CONNECT事件何時觸發,特別是為什么要在key.isConnectable()分支里調用finishConnect方法后才能進行讀寫操作。

首先,在non-blocking模式下調用socketChannel.connect(new InetSocketAddress(“127.0.0.1”,8080));連接遠程主機,如果連接能立即建立就像本地連接一樣,該方法會立即返回true,否則該方法會立即返回false,然后系統底層進行三次握手建立連接。連接有兩種結果,一種是成功連接,第二種是異常,但是connect方法已經返回,無法通過該方法的返回值或者是異常來通知用戶程序建立連接的情況,所以由OP_CONNECT事件和finishConnect方法來通知用戶程序。不管系統底層三次連接是否成功,selector都會被喚醒繼而觸發OP_CONNECT事件,如果握手成功,并且該連接未被其他線程關閉,finishConnect會返回true,然后就可以順利的進行channle讀寫。如果網絡故障,或者遠程主機故障,握手不成功,用戶程序可以通過finishConnect方法獲得底層的異常通知,進而處理異常。

到此這篇關于小白也可以學會的Java NIO的Write事件的文章就介紹到這了,更多相關Java NIO的Write事件內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Java
相關文章:
主站蜘蛛池模板: 烽火安全网_加密软件、神盾软件官网 | 车件|铜件|车削件|车床加工|五金冲压件-PIN针,精密车件定制专业厂商【东莞品晔】 | KBX-220倾斜开关|KBW-220P/L跑偏开关|拉绳开关|DHJY-I隔爆打滑开关|溜槽堵塞开关|欠速开关|声光报警器-山东卓信有限公司 | 水厂自动化-水厂控制系统-泵站自动化|控制系统-闸门自动化控制-济南华通中控科技有限公司 | 卡诺亚轻高定官网_卧室系统_整家定制_定制家居_高端定制_全屋定制加盟_定制家具加盟_定制衣柜加盟 | 高低温试验箱-模拟高低温试验箱订制-北京普桑达仪器科技有限公司【官网】 | 镀锌钢格栅_热镀锌格栅板_钢格栅板_热镀锌钢格板-安平县昊泽丝网制品有限公司 | 气力输送设备_料封泵_仓泵_散装机_气化板_压力释放阀-河南锐驰机械设备有限公司 | 脉冲除尘器,除尘器厂家-淄博机械 | Boden齿轮油泵-ketai齿轮泵-yuken油研-无锡新立液压有限公司 | 北京发电机出租_发电机租赁_北京发电机维修 - 河北腾伦发电机出租 | 国资灵活用工平台_全国灵活用工平台前十名-灵活用工结算小帮手 | YJLV22铝芯铠装电缆-MYPTJ矿用高压橡套电缆-天津市电缆总厂 | 彭世修脚_修脚加盟_彭世修脚加盟_彭世足疗加盟_足疗加盟连锁_彭世修脚技术培训_彭世足疗 | 共享雨伞_共享童车_共享轮椅_共享陪护床-共享产品的领先者_有伞科技 | Trimos测长机_测高仪_TESA_mahr,WYLER水平仪,PWB对刀仪-德瑞华测量技术(苏州)有限公司 | 塑料撕碎机_编织袋撕碎机_废纸撕碎机_生活垃圾撕碎机_废铁破碎机_河南鑫世昌机械制造有限公司 | 蒸汽热收缩机_蒸汽发生器_塑封机_包膜机_封切收缩机_热收缩包装机_真空机_全自动打包机_捆扎机_封箱机-东莞市中堡智能科技有限公司 | 档案密集架,移动密集架,手摇式密集架,吉林档案密集架-厂家直销★价格公道★质量保证 | 电动手术床,医用护理床,led手术无影灯-曲阜明辉医疗设备有限公司 | 骨密度仪-骨密度测定仪-超声骨密度仪-骨龄测定仪-天津开发区圣鸿医疗器械有限公司 | 电脑刺绣_绣花厂家_绣花章仔_织唛厂家-[源欣刺绣]潮牌刺绣打版定制绣花加工厂家 | 除尘器布袋骨架,除尘器滤袋,除尘器骨架,电磁脉冲阀膜片,卸灰阀,螺旋输送机-泊头市天润环保机械设备有限公司 | 数年网路-免费在线工具您的在线工具箱-shuyear.com | 开平机_纵剪机厂家_开平机生产厂家|诚信互赢-泰安瑞烨精工机械制造有限公司 | EPK超声波测厚仪,德国EPK测厚仪维修-上海树信仪器仪表有限公司 | 附着力促进剂-尼龙处理剂-PP处理剂-金属附着力处理剂-东莞市炅盛塑胶科技有限公司 | LINK FASHION 童装·青少年装展 河南卓美创业科技有限公司-河南卓美防雷公司-防雷接地-防雷工程-重庆避雷针-避雷器-防雷检测-避雷带-避雷针-避雷塔、机房防雷、古建筑防雷等-山西防雷公司 | 砂磨机_立式纳米砂磨机_实验室砂磨机-广州儒佳化工设备厂家 | 车载加油机品牌_ 柴油加油机厂家 | PCB厂|线路板厂|深圳线路板厂|软硬结合板厂|电路板生产厂家|线路板|深圳电路板厂家|铝基板厂家|深联电路-专业生产PCB研发制造 | PAS糖原染色-CBA流式多因子-明胶酶谱MMP-上海研谨生物科技有限公司 | 检验科改造施工_DSA手术室净化_导管室装修_成都特殊科室建设厂家_医疗净化工程公司_四川华锐 | 罗氏牛血清白蛋白,罗氏己糖激酶-上海嵘崴达实业有限公司 | CTAB,表面活性剂1631溴型(十六烷基三甲基溴化铵)-上海升纬化工原料有限公司 | 信阳市建筑勘察设计研究院有限公司 | PU树脂_水性聚氨酯树脂_聚氨酯固化剂_聚氨酯树脂厂家_宝景化工 | LED灯杆屏_LED广告机_户外LED广告机_智慧灯杆_智慧路灯-太龙智显科技(深圳)有限公司 | 天助网 - 中小企业全网推广平台_生态整合营销知名服务商_天助网采购优选 | 武汉高温老化房,恒温恒湿试验箱,冷热冲击试验箱-武汉安德信检测设备有限公司 | 合肥注册公司|合肥代办营业执照、2024注册公司流程 |