disruptor-pattern

1熱度

1回答

LMX干擾器的屏障是如何工作的？我確實懂得如何使用DSL進行干擾。但我無法找到一個很好的參考如何障礙或序列壁壘工作。例如我發現下面的鏈接，但不知道如何使用Barrier數據結構。 http://mechanitis.blogspot.com/2011/08/dissecting-disruptor-why-its-so-fast.html 例如，新的BatchEventProcessor（）接受

3熱度

2回答

ByteBuffer.putLong〜與非本地ByteOrder相比更快2倍

儘管我們廣泛閱讀了JDK源代碼以及內部例程的檢查，但仍然無法通過頭部進行包裝。我正在測試清除ByteBuffer，使用ByteBuffer.putLong(int index, long value)分配allocateDirect。基於JDK代碼，如果緩衝區處於「本地字節順序」或字節交換，則會導致單個8字節寫入，如果不是，則會執行相同的操作。所以我希望本地字節順序（對我而言，小端）至少和非本

0熱度

1回答

在Java Servlet中使用干擾程序並處理多個事件

我在我的Web應用程序中使用了LMAX干擾程序，它接受http請求參數並將它們處理到環緩衝區。 3個事件處理程序處理和處理數據，最後一個將其保存到數據庫中。當實例化servlet時，初始化一次環形緩衝區。這是正確的嗎？ public void init() throws ServletException { Disruptor<CampaignCode> disruptor = ne

2熱度

1回答

構建干擾器給出的autoconf

錯誤我下載了破壞者的來源從這裏開始： https://github.com/fsaintjacques/disruptor-- 我再嘗試，但得到給定的錯誤。有什麼，我失蹤？ autoconf configure.ac > configure configure.ac:9: error: possibly undefined macro: AM_INIT_AUTOMAKE If t

0熱度

1回答

如果在Disruptor中的next（）和publish（）之間拋出異常，會發生什麼情況？

如果在next()和publish()之間使用Disruptor或publish()因爲某些其他原因或在可接受的時間內未被調用而引發異常，會發生什麼情況？什麼是恢復/超時技術來處理這種情況？

1熱度

1回答

如何在Disruptor中創建自定義EventProcessors？

我正在尋找在Disruptor中創建自定義EventProcessors，但文檔非常小。（https://code.google.com/p/disruptor/wiki/DisruptorWizard）這是如何完成的。它背後的概念是什麼？有哪些問題和缺陷？

3熱度

2回答

干擾模式 - 主節點和從節點如何保持同步？

在LMAX Disruptor模式中，使用複製器將輸入事件從主節點複製到從節點。因此，設置可能會看起來如下：主節點的複製事件寫入到數據庫（所有雖然我們能想到更好的機制比寫入到DB-它不是很重要問題陳述）。從節點的接收器從DB讀取並將事件放到從節點的環形緩衝區中。忽略從節點的輸出事件。現在有可能主節點的業務邏輯處理器比從節點的業務邏輯處理器慢。例如，主節點的示例BL可以位於槽102，其中從屬節

0熱度

1回答

爲什麼Java lmax disruptor在通過EventProcessors傳遞事件時有很大的延遲？

我在我的項目中有一個環形緩衝區，其中很多發佈者將發佈事件（例如500個發佈者），並且我有3個EventProcessors應該按順序處理事件。所有事件都應該通過這種方式： {很多出版商} - > {UpStreamProcessor} - > {DownStreamProcessor} - > {LogProcessor中} 的問題是，我失去了很多時間在傳遞活動在UpStreamProcessor

1熱度

1回答

哪些jar包含com.google.common.event.disuptor.EventDisruptor？

我收到了一個com.google.common.event.disuptor.EventDisruptor的項目源，但是我找不到這個東西。這是來自disuptor的嗎？ import com.google.common.domain.message.DomainEventHandler; import com.google.common.event.disuptor.EventDisruptor

2熱度

1回答

使用多個LMAX擾動器

我是LMAX擾動器的新手，我正在探索將它用於需要處理巨大流量的多層異步項目中。將請求發送到平臺以發送SMS，請求被清理/檢查以查找簡單錯誤並記錄下來。獲取和分析與發送SMS的客戶端相關的各種其他信息，並將其他參數添加到SMS信息中。分析並選擇正確的路由路由。然後從SMS-info中設置平臺特定的協議參數並將其提交給路由器。像這樣，接收和處理短信傳送到日誌，賬單，重試和許多其他流程將有流量。