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

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

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

瀏覽:104日期: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
相關文章:
主站蜘蛛池模板: 转向助力泵/水泵/发电机皮带轮生产厂家-锦州华一精工有限公司 | 开锐教育-学历提升-职称评定-职业资格培训-积分入户 | 帽子厂家_帽子工厂_帽子定做_义乌帽厂_帽厂_制帽厂 | 十字轴_十字轴万向节_十字轴总成-南京万传机械有限公司 | 吹田功率计-长创耐压测试仪-深圳市新朗普电子科技有限公司 | PCB设计,PCB抄板,电路板打样,PCBA加工-深圳市宏力捷电子有限公司 | LZ-373测厚仪-华瑞VOC气体检测仪-个人有毒气体检测仪-厂家-深圳市深博瑞仪器仪表有限公司 | 冷却塔改造厂家_不锈钢冷却塔_玻璃钢冷却塔改造维修-广东特菱节能空调设备有限公司 | 水冷式工业冷水机组_风冷式工业冷水机_水冷螺杆冷冻机组-深圳市普威机械设备有限公司 | ZHZ8耐压测试仪-上海胜绪电气有限公司 | 安平县鑫川金属丝网制品有限公司,声屏障,高速声屏障,百叶孔声屏障,大弧形声屏障,凹凸穿孔声屏障,铁路声屏障,顶部弧形声屏障,玻璃钢吸音板 | 网站优化公司_北京网站优化_抖音短视频代运营_抖音关键词seo优化排名-通则达网络 | 行吊_电动单梁起重机_双梁起重机_合肥起重机_厂家_合肥市神雕起重机械有限公司 | SMN-1/SMN-A ABB抽屉开关柜触头夹紧力检测仪-SMN-B/SMN-C-上海徐吉 | 自动化改造_智虎机器人_灌装机_贴标机-上海圣起包装机械 | 铁艺,仿竹,竹节,护栏,围栏,篱笆,栅栏,栏杆,护栏网,网围栏,厂家 - 河北稳重金属丝网制品有限公司 山东太阳能路灯厂家-庭院灯生产厂家-济南晟启灯饰有限公司 | 电脑知识|软件|系统|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网 | 地埋式垃圾站厂家【佳星环保】小区压缩垃圾中转站转运站 | 宝元数控系统|对刀仪厂家|东莞机器人控制系统|东莞安川伺服-【鑫天驰智能科技】 | 翅片管散热器价格_钢制暖气片报价_钢制板式散热器厂家「河北冀春暖气片有限公司」 | 洛阳防爆合格证办理-洛阳防爆认证机构-洛阳申请国家防爆合格证-洛阳本安防爆认证代办-洛阳沪南抚防爆电气技术服务有限公司 | PSI渗透压仪,TPS酸度计,美国CHAI PCR仪,渗透压仪厂家_价格,微生物快速检测仪-华泰和合(北京)商贸有限公司 | 智能汉显全自动量热仪_微机全自动胶质层指数测定仪-鹤壁市科达仪器仪表有限公司 | 纸张环压仪-纸张平滑度仪-杭州纸邦自动化技术有限公司 | 高低温试验箱-模拟高低温试验箱订制-北京普桑达仪器科技有限公司【官网】 | 深圳律师咨询_深圳律师事务所_华荣【免费在线法律咨询】网 | 防爆电机生产厂家,YBK3电动机,YBX3系列防爆电机,YBX4节防爆电机--河南省南洋防爆电机有限公司 | 恒温恒湿试验箱_高低温试验箱_恒温恒湿箱-东莞市高天试验设备有限公司 | 南京泽朗生物科技有限公司 | 诸城网站建设-网络推广-网站优化-阿里巴巴托管-诸城恒泰互联 | 物流公司电话|附近物流公司电话上门取货 | ETFE膜结构_PTFE膜结构_空间钢结构_膜结构_张拉膜_浙江萬豪空间结构集团有限公司 | 河南正规膏药生产厂家-膏药贴牌-膏药代加工-修康药业集团官网 | 成都软件开发_OA|ERP|CRM|管理系统定制开发_成都码邻蜀科技 | 电缆接头_防水接头_电缆防水接头_防水电缆接头_上海闵彬 | 医院专用门厂家报价-医用病房门尺寸大全-抗菌木门品牌推荐 | 集装箱标准养护室-集装箱移动式养护室-广州璟业试验仪器有限公司 | 奇酷教育-Python培训|UI培训|WEB大前端培训|Unity3D培训|HTML5培训|人工智能培训|JAVA开发的教育品牌 | 除尘布袋_液体过滤袋_针刺毡滤料-杭州辉龙过滤技术有限公司 | 海水晶,海水素,海水晶价格-潍坊滨海经济开发区强隆海水晶厂 | 北京企业宣传片拍摄_公司宣传片制作-广告短视频制作_北京宣传片拍摄公司 |