在我的一個項目中，我需要使用EclipseLink作為ORM框架從Java EE 6 WebLogic環境中的多個源中加載參考數據。 由于我在Java EE世界中找不到與Spring YET的@Cacheable相當的注釋，因此我不得不編寫自己的緩存解決方案。 盡管參考數據幾乎不會隨時間變化，但一項額外的要求是能夠從外部清除緩存。 所以就這樣...

1.快取

這應該是只讀緩存，可以從外部刷新它。 我希望將緩存作為服務的一種包裝，為應用程序提供實際的參考數據–帶代碼的AOP樣式！

接口

簡單的緩存界面，用于參考數據

@Local public interface ReferenceDataCache {/*** Returns all reference data required in the application */ReferenceData getReferenceData();/*** evict/flush all data from cache */void evictAll(); }

緩存功能定義了兩種簡單的方法：

• getReferenceData() –緩存所有不同來源在后臺收集的參考數據
• evictAll() –調用方法以完全清除緩存

實作

使用@Singleton的簡單參考數據緩存實現

@ConcurrencyManagement(ConcurrencyManagementType.CONTAINER) @Singleton public class ReferenceDataCacheBean implements ReferenceDataCache {private static final String ALL_REFERENCE_DATA_KEY = "ALL_REFERENCE_DATA";private ConcurrentHashMap<String, Object> refDataCache = null;@EJBReferenceDataService referenceDataService;@PostConstructpublic void initialize(){this.refDataCache = new ConcurrentHashMap<>(); }@Override@Lock(LockType.READ)public ReferenceData getReferenceData() {if(refDataCache.containsKey(ALL_REFERENCE_DATA_KEY)){ return refDataCache.get(ALL_REFERENCE_DATA_KEY);} else {ReferenceData referenceData = referenceDataService.getReferenceData();refDataCache.put(ALL_REFERENCE_DATA_KEY, referenceData);return referenceData;} }@Overridepublic void evictAll() {refDataCache.clear(); } .......... }

注意：

• @Singleton –可能是此類中最重要的代碼行。 此注釋指定在應用程序中將僅存在一個這種類型的bean的單例。 該bean可以由多個線程同時調用。 它還帶有@PostConstruct批注。 此注釋用于需要依賴注入完成后才能執行任何初始化的方法，在本例中，該方法用于初始化“緩存”（哈希映射）
• @ConcurrencyManagement(ConcurrencyManagementType.CONTAINER)聲明單例會話bean的并發管理類型。 默認情況下，它設置為Container 。 我在這里使用它只是為了強調它的存在。 另一個選項ConcurrencyManagementType.BEAN指定Bean開發人員負責管理對Bean實例的并發訪問。
• 實際的“緩存”是ConcurrentHashMap ，它具有基于String的鍵并存儲Object 。 由于bean的單例性質，它被保留在內存中
• 注入的ReferenceDataService是@Stateless @EJB ，它在后臺收集來自不同來源的參考數據
• getReferenceData（）方法的實現非常簡單–它檢查ConcurrentHashMap是否具有將String鍵指定為常量“ ALL_REFERENCE_DATA ”的條目。 如果是這樣，它將從內存中檢索，否則將由服務Bean加載。
• @Lock(LockType.READ)指定具有容器管理的并發性的單例bean的并發鎖定類型。 當設置為LockType.READ ，它將強制執行該方法以允許對其進行完全并發訪問（假定未持有任何寫鎖）。 這正是我想要的，因為我只需要執行讀取操作。 另一個更保守的選項@Lock(LockType.WRITE)順便說一下是DEFAULT，它強制對bean實例的獨占訪問。 這應該在高度并發的環境中使方法變慢。
• evictAll()方法，只是從哈希圖中刪除所有元素。

2.刷新緩存

這篇文章的第二部分將討論清除緩存的可能性。 由于緩存實現是企業Java Bean，因此我們可以從MBean或從Web服務中調用它。

MBean

如果您不熟悉Java管理擴展（JMX）， 這是一種Java技術，它提供用于管理和監視應用程序，系統對象，設備（例如打印機）和面向服務的網絡的工具。 這些資源由稱為MBeans（用于Managed Bean）的對象表示 ，我強烈建議您從本教程的起點開始：Java管理擴展（JMX）

2.1.1。 接口

公開的方法僅允許通過JMX重置緩存：

CacheRest MBean

@MXBean public interface CacheResetMXBean {void resetReferenceDataCache(); }

“ MXBean是一種MBean，僅引用一組預定義的數據類型。 這樣，您可以確保您的MBean可被任何客戶端（包括遠程客戶端）使用，而無需客戶端有權訪問代表MBean類型的特定于模型的類。 MXBean提供了一種方便的方式將相關值捆綁在一起，而無需將客戶端進行特殊配置以處理捆綁。” [4]

2.1.2。 實作

MBean的CacheReset實現

@Singleton @Startup public class CacheReset implements CacheResetMXBean {private MBeanServer platformMBeanServer;private ObjectName objectName = null;@EJBReferenceDataCache referenceDataCache;@PostConstructpublic void registerInJMX() {try {objectName = new ObjectName("org.codingpedia.simplecacheexample:type=CacheReset");platformMBeanServer = ManagementFactory.getPlatformMBeanServer();//unregister the mbean before registerting againSet<ObjectName> existing = platformMBeanServer.queryNames(objectName, null);if(existing.size() > 0){platformMBeanServer.unregisterMBean(objectName);}platformMBeanServer.registerMBean(this, objectName);} catch (Exception e) {throw new IllegalStateException("Problem during registration of Monitoring into JMX:" + e);}} @Overridepublic void resetReferenceDataCache() {referenceDataCache.evictAll();}}

注意：

• 如前所述，該實現僅調用上一節中介紹的注入的單例bean的evictAll()方法
• 該bean也被定義為@Singleton
• @Startup批注導致在應用程序啟動時由容器實例化@Startup 渴望初始化
• 我再次使用@PostConstruct功能。 在這里， 此 bean已在JMX中注冊，如果是，則檢查是否使用ObjectName將其刪除。

休息服務電話

我還內置了通過調用REST資源清除緩存的可能性。 在（rest-context）/ reference-data / flush-cache上執行HTTP POST時會發生這種情況：

在參考數據緩存上進行剩余調用

@Path("/reference-data") public class ReferenceDataResource {@EJBReferenceDataCache referenceDataCache;@POST@Path("flush-cache")public Response flushReferenceDataCache() {referenceDataCache.evictAll();return Response.status(Status.OK).entity("Cache successfully flushed").build();} @GET@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })public Response getReferenceData(@QueryParam("version") String version) {ReferenceData referenceData = referenceDataCache.getReferenceData(); if(version!=null && version.equals(referenceData.getVersion())){return Response.status(Status.NOT_MODIFIED).entity("Reference data was not modified").build(); } else {return Response.status(Status.OK).entity(referenceData).build(); }} }

注意@GET getReferenceData(...)方法中存在版本查詢參數。 這表示參考數據上的哈希，如果尚未修改，則客戶端將收到304未修改HTTP狀態 。 這是節省一些帶寬的好方法，尤其是在您擁有移動客戶端的情況下。 有關REST服務設計和實現的詳細討論，請參閱我的教程“使用Jersey和Spring的Java REST API設計和實現”。

注意：

在集群環境中，當參考數據更改時，需要在部署了應用程序的每個JVM上調用resetCache（…）。

好吧，就是這樣。 在本文中，我們學習了如何使用Java EE注釋構建簡單的緩存。 當然，您可以輕松擴展緩存功能，以提供對緩存對象的更精細的訪問/清除。 在這種情況下，請不要忘記使用LockType.WRITE作為清除方法……

翻譯自: https://www.javacodegeeks.com/2014/09/how-to-build-and-clear-a-reference-data-cache-with-singleton-ejbs-and-mbeans.html

總結

以上是生活随笔為你收集整理的如何使用单例EJB和MBean构建和清除参考数据缓存的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。