hazelcast

    0熱度

    1回答

    我試圖創建一個Hazelcast客戶端的實例,但我無法從Spring覆蓋緩存管理器實現。我不想使用hazelcast.xml(所以,我正在使用spring引導應用程序)。有辦法做到這一點? 按照我的測試: @Bean CacheManager cacheManager() { return new HazelcastCacheManager(); } 我讀過很多教程談論這種實現的

    1熱度

    1回答

    我在Hazelcast集羣中創建了一個映射。我可以在我的地圖上看到Hazelcast管理中心用戶界面上的條目數量增加。在控制檯上,我還可以使用m.size命令獲取大小。 我知道像Integer和String這樣的基本包裝類,我可以使用m.get命令來查看任何鍵的值。我使用自定義對象作爲map的鍵和值,所以我無法在控制檯上使用m.keys或m.values命令。 它給HazelcastSeriali

    0熱度

    1回答

    我想測試榛廣告。 <map name="testMap"> <!-- <in-memory-format>BINARY</in-memory-format> --> <in-memory-format>NATIVE</in-memory-format> <backup-count>1</backup-count> <async-backup-count>0<

    1熱度

    1回答

    我正在嘗試使用託管在本地服務器上的VM使用orientdb-enterprise-2.2.3來組建orientDB羣集。 VM具有Fedora OS 18的配置。我已經連接了orientdb-server-config.xml和hazelcast.xml文件。 orientdb服務器-config.xml中 <?xml version="1.0" encoding="UTF-8" standalo

    0熱度

    1回答

    與Hazelcast,我想象一個常見的情況是,消費者想知道世界的當前狀態(當前在地圖中的什麼),然後在沒有丟失任何東西的情況下進行更新。 想象一下,Hazelcast地圖持有一些消費者想要流式傳輸(可能通過Rx)當前狀態的數據,然後是來自監聽器的任何更新。 API建議我們爲更新添加一個Listener並將Map視爲正常的ConcurrentMap。但是,當我枚舉Map時,更新可能通過監聽器進入,因

    0熱度

    1回答

    使用版本3.6.1,爲什麼我們對put和putTransient在地圖監聽器方面有不同的行爲(添加了.putTransient觸發器,並更新了.put觸發器)? public void testNoDelta() { String str = "world"; String key = "hello"; map.putTransient(key, str, 1000,

    0熱度

    1回答

    我們如何強制所有值在啓動時加載,並且這是通過單個數據庫調用完成的?配置一個急切加載的maploader似乎並沒有這樣做?相反,單個值被加載,這意味着很多往返數據庫。 的MapLoader實現片斷如下: public V load(K key) { // issues a SQL query return databaseService.findByPrimaryKey(key)

    0熱度

    1回答

    使用3.8.1。即使放置了相同的鍵和值,更新的事件也會被觸發?爲什麼? map.addEntryListener(new EntryUpdatedListener() { @Override public void entryUpdated(EntryEvent event) { System.out.println("Updated listener fir

    0熱度

    1回答

    我有一個Spring Boot服務,其中啓動了HazelCast實例。 @Bean public Config config(){ return new Config(); } @Bean public HazelcastInstance hazelcastInstance(Config config){ return Hazelcast.newHazelcastI

    1熱度

    1回答

    我想獲取一組存儲在Hazelcast地圖中的對象字段的不同值。 此行的Java代碼: instructions.aggregate(Supplier.all(value -> value.getWorkArea()), Aggregations.distinctValues()); 具有以下堆棧跟蹤: java.util.concurrent.ExecutionException: com.h