Как построить и очистить кэш справочных данных с помощью Sgingleton EJB, Ehcache и MBeans

	@PostConstruct
	public void initialize(){		
		
		cacheManager = CacheManager.create();

		CacheConfiguration cacheConfiguration = new CacheConfiguration("referenceDataCache", 1000);
		cacheConfiguration.setTimeToLiveSeconds(CACHE_MINUTES_TO_LIVE * 60);
		
		refDataEHCache = new Cache(cacheConfiguration );
		cacheManager.addCache(refDataEHCache);
	}

Примечание. С помощью этой аннотации можно аннотировать только один метод.

Все случаи использования Ehcache начинаются с создания a CacheManager, который является контейнером для Ehcaches, который поддерживает все аспекты их жизненного цикла. Я использую  CacheManager.create()метод, который является фабричным методом для создания одноэлементного CacheManager с конфигурацией по умолчанию, или возвращаю его, если он существует:

cacheManager = CacheManager.create();

Затем я построил  CacheConfigurationобъект, указав имя кэша («referenceDataCache») и количество максимального количества элементов в памяти ( maxEntriesLocalHeap), до того, как они будут выселены (0 == без ограничений), и, наконец, я установил значение по умолчанию. количество времени жизни для элемента с даты его создания:

CacheConfiguration cacheConfiguration = new CacheConfiguration("referenceDataCache", 1000);
cacheConfiguration.setTimeToLiveSeconds(CACHE_MINUTES_TO_LIVE * 60);

Теперь с помощью объекта CacheConfiguration я  программно  создаю свой кеш справочных данных и добавляю его в CacheManager. Обратите внимание, что кеши нельзя использовать, пока они не добавлены в CacheManager:

refDataEHCache = new Cache(cacheConfiguration );
cacheManager.addCache(refDataEHCache);

Примечание.   Вы также можете создавать кэши декларативным способом: при создании CacheManager создаются кэши, найденные в конфигурации. Вы можете создать CacheManager, указав путь к файлу конфигурации, из конфигурации в classpath, из конфигурации в InputStream или путем использования файла ehcache.xml по умолчанию в вашем classpath. Взгляните на примеры кода Ehcache  для получения дополнительной информации.

1.2.2. Получить данные из кеша

@Override
@Lock(LockType.READ)
public ReferenceData getReferenceData() {
	Element element = refDataEHCache.get(ALL_REFERENCE_DATA_KEY);
	
	if(element != null){	
		return (ReferenceData) element.getObjectValue();
	} else {
		ReferenceData referenceData = referenceDataLogic.getReferenceData();
		
		refDataEHCache.put(new Element(ALL_REFERENCE_DATA_KEY, referenceData));
		
		return referenceData;
	}		
}

Сначала я пытаюсь получить элемент из кэша, основываясь на его ключе, и, если он присутствует в cache ( ==null), то если он будет получен из класса обслуживания и помещен в кэш для будущих запросов.

Примечание 
.  @Lock(LockType.READ) Указывает тип блокировки параллелизма для одноэлементных компонентов с управляемым контейнером параллелизмом. Когда установлено значение  LockType.READ, он применяет метод для разрешения полного одновременного доступа к нему (при условии, что блокировки записи не удерживаются). Это именно то, что я хотел, так как мне нужно только выполнять операции чтения. Другой более консервативный вариант  @Lock(LockType.WRITE), который, кстати, является DEFAULT, обеспечивает исключительный доступ к экземпляру компонента. Это должно замедлить метод в среде с высокой степенью параллелизма …

1.2.3. Очистить кеш

@Override
public void evictAll() {
	cacheManager.clearAll();
}

clearAll()Метод CacheManager очищает содержимое всех кэшей в CacheManager, но без удаления каких — либо тайников. Я просто использовал это здесь для простоты, и потому что у меня есть только один кеш, мне нужно обновить.

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

@Singleton
@Startup
public class CacheReset implements CacheResetMXBean {
    
	private MBeanServer platformMBeanServer;
    private ObjectName objectName = null;
    	
	@EJB
	ReferenceDataCache referenceDataCache;
	
    @PostConstruct
    public void registerInJMX() {
        try {
        	objectName = new ObjectName("org.codingpedia.simplecacheexample:type=CacheReset");
            platformMBeanServer = ManagementFactory.getPlatformMBeanServer();

            //unregister the mbean before registerting again
            Set<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);
        }
    }	
	
	@Override
	public void resetReferenceDataCache() {
		referenceDataCache.evictAll();

	}
	
}

@Path("/reference-data")
public class ReferenceDataResource {
	
	@EJB
	ReferenceDataCache 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();				
		}
	}	
}