對標蘋果的靈動島 華為帶來實況窗功能
繼蘋果的靈動島之后，華為也在今天正式推出了“實況窗”功能。據(jù)今天鴻蒙OS 4.0的現(xiàn)場演示顯示，華為的實況窗可以更高效的展現(xiàn)出實時通知，比如鎖屏上就能看到外賣、打車、銀行
Java的NIO庫提供了基于選擇器的多路復(fù)用機制，它可以同時監(jiān)視多個通道，并且在通道有數(shù)據(jù)可讀或可寫時通知程序進行讀寫操作，從而提高了系統(tǒng)的I/O吞吐量。本文將對Java的NIO多路復(fù)用機制進行詳細介紹和演示。
在傳統(tǒng)的I/O模型中，每個連接都需要一個線程來處理讀寫操作。這種模型會導致線程數(shù)量增多，從而增加了系統(tǒng)開銷。為了解決這個問題，Java的NIO庫提供了基于選擇器的多路復(fù)用機制。
多路復(fù)用機制可以同時監(jiān)視多個通道，并且在通道有數(shù)據(jù)可讀或可寫時通知程序進行讀寫操作。這種機制可以大大減少線程的數(shù)量，從而提高了系統(tǒng)的I/O吞吐量。
在Java中，多路復(fù)用機制主要由Selector和SelectionKey兩個類來實現(xiàn)。
在使用多路復(fù)用機制時，通常需要按照以下步驟進行操作：
首先，需要創(chuàng)建一個Selector對象來進行多路復(fù)用。我們可以使用Selector的靜態(tài)方法open()來創(chuàng)建一個Selector對象：
Selector selector = Selector.open();接下來，需要將通道注冊到Selector中，以便Selector可以監(jiān)視這些通道。我們可以使用通道的register()方法來實現(xiàn)這一步驟：
SelectableChannel channel = ...; // 獲取一個通道channel.configureBlocking(false); // 非阻塞模式SelectionKey key = channel.register(selector, SelectionKey.OP_READ);在上面的代碼中，我們首先獲取了一個通道，并將通道設(shè)置為非阻塞模式。然后，我們調(diào)用通道的register()方法，將通道注冊到Selector中，并指定了SelectionKey.OP_READ參數(shù)，表示我們希望Selector監(jiān)視通道的讀事件。
注冊完通道后，我們可以開始處理事件了。我們可以使用Selector的select()方法來等待事件的發(fā)生：
selector.select();在上面的代碼中，select()方法會一直阻塞，直到有事件發(fā)生或者調(diào)用了Selector的wakeup()方法。
當有事件發(fā)生時，我們可以使用Selector的selectedKeys()方法來獲取所有發(fā)生事件的SelectionKey對象。然后，我們可以遍歷這些SelectionKey對象，并根據(jù)其對應(yīng)的通道進行讀寫操作：
Set<SelectionKey> keys = selector.selectedKeys();for (SelectionKey key : keys) { if (key.isReadable()) { // 讀取數(shù)據(jù) } else if (key.isWritable()) { // 寫入數(shù)據(jù) } // 處理完事件后需要將該SelectionKey對象從Selector的key集合中刪除 keys.remove(key);}在上面的代碼中，我們首先使用selectedKeys()方法獲取所有發(fā)生事件的SelectionKey對象。然后，我們遍歷這些SelectionKey對象，并根據(jù)其對應(yīng)的通道進行讀寫操作。處理完事件后，我們需要將該SelectionKey對象從Selector的key集合中刪除，以便下次可以再次監(jiān)聽該通道的事件。
最后，我們需要在程序退出時關(guān)閉Selector對象：
selector.close();多路復(fù)用機制可以大大減少線程的數(shù)量，從而提高了系統(tǒng)的I/O吞吐量。然而，多路復(fù)用機制也有一些缺點，需要注意：
以下是一個完整的Java代碼示例，演示了如何使用Java NIO庫的多路復(fù)用機制：
import java.io.IOException;import java.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.SelectionKey;import java.nio.channels.Selector;import java.nio.channels.ServerSocketChannel;import java.nio.channels.SocketChannel;import java.util.Iterator;import java.util.Set;public class NioMultiplexerExample { public static void main(String[] args) throws IOException { // 創(chuàng)建Selector對象 Selector selector = Selector.open(); // 創(chuàng)建ServerSocketChannel對象，并將其注冊到Selector中 ServerSocketChannel serverChannel = ServerSocketChannel.open(); serverChannel.socket().bind(new InetSocketAddress(8080)); serverChannel.configureBlocking(false); serverChannel.register(selector, SelectionKey.OP_ACCEPT); while (true) { // 等待事件的發(fā)生 selector.select(); // 獲取所有事件的SelectionKey對象 Set<SelectionKey> keys = selector.selectedKeys(); Iterator<SelectionKey> iterator = keys.iterator(); while (iterator.hasNext()) { SelectionKey key = iterator.next(); if (key.isAcceptable()) { // 處理連接事件 ServerSocketChannel server = (ServerSocketChannel) key.channel(); SocketChannel client = server.accept(); client.configureBlocking(false); client.register(selector, SelectionKey.OP_READ); } else if (key.isReadable()) { // 處理讀取事件 SocketChannel client = (SocketChannel) key.channel(); ByteBuffer buffer = ByteBuffer.allocate(1024); int bytesRead = client.read(buffer); if (bytesRead > 0) { buffer.flip(); byte[] data = new byte[buffer.limit()]; buffer.get(data); System.out.println(new String(data)); buffer.clear(); } else if (bytesRead < 0) { // 客戶端連接斷開，關(guān)閉通道 client.close(); } } // 處理完事件后，需要將該SelectionKey對象從Selector的key集合中刪除 iterator.remove(); } } }}在上面的代碼中，我們首先創(chuàng)建了一個Selector對象，并將ServerSocketChannel對象注冊到Selector中，以便Selector可以監(jiān)視客戶端的連接事件。然后，我們使用一個while循環(huán)來等待事件的發(fā)生，并使用Selector的select()方法來獲取所有發(fā)生事件的SelectionKey對象。
在處理事件時，我們首先判斷事件類型，如果是連接事件，則使用ServerSocketChannel對象來接受客戶端連接，并將SocketChannel對象注冊到Selector中，以便Selector可以監(jiān)視該客戶端的讀取事件。如果是讀取事件，則使用SocketChannel對象來讀取客戶端發(fā)送的數(shù)據(jù)，并進行相關(guān)處理。
需要注意的是，在處理完事件后，我們需要將該SelectionKey對象從Selector的key集合中刪除，以便下次可以再次監(jiān)聽該事件。
需要注意的是，這里的代碼只是演示了Selector的基本用法，實際應(yīng)用中還需要處理更多的異常情況和錯誤情況，以保證程序的穩(wěn)定性和正確性。
本文介紹了Java NIO庫中的多路復(fù)用機制，包括如何創(chuàng)建Selector對象和SelectionKey對象，并如何使用Selector對象來進行多路復(fù)用。盡管多路復(fù)用機制有一些缺點，但它仍然是一種高效的I/O模型，可以大大減少線程的數(shù)量，從而提高系統(tǒng)的I/O吞吐量。
本文鏈接：http://www.tebozhan.com/showinfo-26-5192-0.html你的Java程序還在使用阻塞式I/O嗎？試試NIO多路復(fù)用提高性能！
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： Vue組件的Prop命名約定
下一篇： 聊聊 RocketMQ 名字服務(wù)
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號