我目前正在按以下方式開發事件驅動的 Java 軟件（這是我的主要方法的本質）：while(true) { Event event = eventListener.poll(); if(event != null) { // do something } else { // do nothing as usual, but burn CPU time. }}根據我正在構建的內容，eventListener可能會監聽外部 websocket、輪詢 Redis 通道以獲取更新，或者等待來自同一盒子上的另一個進程的消息（可能通過 UDP/TCP/shm）。eventListener我的想法是，這種繁忙的循環方法在返回 null 時（大多數情況下）會浪費大量 CPU 時間，因為它只是坐在那里旋轉。但是，除了每次迭代之外，我不知道如何實現此設計，Thread.sleep這不是一個很好的解決方案。理想情況下我想要一個方法：void run(Event event) { // do something}run每當事件發生時都會調用where eventListener。如果沒有這樣的事件可用，則理想情況下該過程應該只是閑置。現在，我知道有一些 websocket 庫實際上可以做到這一點，我想知道的是我如何為自己構建這樣的東西，并將我的 CPU 從坐在那里浪費自己無所事事的狀態中解放出來？
2 回答
慕姐4208626
TA貢獻1852條經驗 獲得超7個贊
您需要使用java非阻塞IO，并且可能是一些支持通過java NIO進行高級通信的庫（例如netty，它支持HTTP、websockets和redis等的NIO風格通信）。
以下是 NIO 工作原理的簡短描述。你正在尋找的東西是Selector.?它允許等待通道（這是文件或網絡連接等的抽象）上的數據可用。此 wait(Selector.select方法) 是阻塞的，當某些數據可供讀取或要寫入的輸出緩沖區可以獲得新數據時，操作系統會恢復該進程。
代碼大致如下所示：
Selector selector = createSelector();
Channel channel = createChannelForSocket();
SelectionKey key = channel.register(selector);
while(true) {
? int readyChannels = selector.select(TIMEOUT);
? if(readyChannels == 0) continue;
? Set<SelectionKey> selectedKeys = selector.selectedKeys();
? for(SelectionKey key : selectedKeys) {
? ? if (key.isReadable()) {
? ? ? ? readDataFromChannel(key.channel())
? ? } else if (key.isWritable()) {
? ? ? ? writeDataToChannel(key.channel())
? ? }
? }
}
使用netty，您可以擁有更高級別的代碼，您可以在其中定義一個Handlerwhich，它有一個類似于which的方法void channelRead(ChannelHandlerContext ctx, Object msg)，它是一種讀取事件偵聽器，您可以實現它來偵聽讀取事件。
netty 有一個內置循環，看起來與上面的示例類似，但對于許多事件偵聽器來說，它將這些事件傳播到特定的偵聽器。
aluckdog
TA貢獻1847條經驗 獲得超7個贊
如果您有興趣大規模使用事件驅動架構。您可能想要使用強大的“事件總線”，例如 Apache Kafka 或 AWS SNS+SQS。為了更簡單，您可以使用 kalium.alkal.io。這將無縫處理 POJO 或 protobuf 對象的反/序列化。
kalium.on(Event.class, event -> {
//doSomething with the event
});
添加回答
舉報
0/150
提交
取消