Как получить доступ к Apache Camel Eh-кеше вне контекста верблюдов?
Я хочу использовать данные из веб-сервиса и поместить их в верблюжий eh-cache. позже я хочу использовать этот кеш вне контекста верблюда через CacheManager. Я не нахожу никакого способа сделать это.
В приведенном ниже коде я пропустил использование веб-службы и использовал данные из Map и предоставил их в eh-кеш, но я не могу получить доступ к этому кешу с помощью CacheManager.
Класс CamelRouter
package com.camel;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.ehcache.EhcacheConstants;
import org.apache.camel.main.Main;
import org.ehcache.Cache;
import org.ehcache.CacheManager;
import org.ehcache.config.Configuration;
import org.ehcache.config.builders.CacheManagerBuilder;
import org.ehcache.xml.XmlConfiguration;
public class Test {
private static Main main;
public static void main(String[] args) throws Exception {
main = new Main();
main.addRouteBuilder(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("timer:foo?period=5s&repeatCount=1")
.process(exchange ->{
Map<String, String> inputMap = new HashMap<>();
inputMap.put("name", "murli");
inputMap.put("lastname", "hiware");
inputMap.put("city", "pune");
exchange.getIn().setBody(inputMap);
exchange.getIn().setHeader("CamelEhcacheAction", EhcacheConstants.ACTION_PUT_ALL);
})
.to("ehcache://testCache?configUri=ehcache.xml&keyType=java.lang.String&valueType=java.lang.String")
.process(exchange -> {
URL myUrl = getClass().getResource("/ehcache.xml");
Configuration xmlConfig = new XmlConfiguration(myUrl);
CacheManager myCacheManager = CacheManagerBuilder.newCacheManager(xmlConfig);
myCacheManager.init();
//here I want to access already created testCache component but it is creating new one.
Cache<String, String> cache = myCacheManager.getCache("testCache", String.class, String.class);
System.out.println("Cache Element:"+cache.get("name"));
System.out.println("Exchange Message:"+exchange.getIn().getBody());
});
}
});
main.run();
}
}
Конфигурационный файл ehcache
<config
xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance'
xmlns='http://www.ehcache.org/v3'
xsi:schemaLocation="http://www.ehcache.org/v3 http://www.ehcache.org/schema/ehcache-core.xsd">
<cache alias="testCache">
<key-type>java.lang.String</key-type>
<value-type>java.lang.String</value-type>
<resources>
<heap unit="entries">2000</heap>
<offheap unit="MB">100</offheap>
</resources>
</cache>
<cache-template name="myDefaults">
<key-type>java.lang.Long</key-type>
<value-type>java.lang.String</value-type>
<heap unit="entries">200</heap>
</cache-template>
<cache alias="bar" uses-template="myDefaults">
<key-type>java.lang.Number</key-type>
</cache>
<cache alias="simpleCache" uses-template="myDefaults" />
</config>
пожалуйста, дайте мне знать, вариант использования, которого я пытаюсь достичь, возможен с верблюжьим кэшем или нет?
3 ответа
Обычно вы можете получить значение с помощью from("ehcache://...),
Однако я предполагаю, что вы действительно хотите получить доступ к кешу или кеш-менеджеру.
Это способ сделать это:
public static void main(String[] args) throws Exception {
URL url = App.class.getResource("/ehcache.xml");
Configuration xmlConfig = new XmlConfiguration(url);
CacheManager cacheManager = CacheManagerBuilder.newCacheManager(xmlConfig);
cacheManager.init();
Main main = new Main();
main.bind("cacheManager", cacheManager);
main.addRouteBuilder(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("timer:foo?period=5s&repeatCount=1")
.process(exchange ->{
Map<String, String> inputMap = new HashMap<>();
inputMap.put("name", "murli");
inputMap.put("lastname", "hiware");
inputMap.put("city", "pune");
exchange.getIn().setBody(inputMap);
exchange.getIn().setHeader("CamelEhcacheAction", EhcacheConstants.ACTION_PUT_ALL);
})
.to("ehcache://testCache?cacheManager=#cacheManager&keyType=java.lang.String&valueType=java.lang.String")
.process(exchange -> {
//here I want to access already created testCache component but it is creating new one.
Cache<String, String> cache = cacheManager.getCache("testCache", String.class, String.class);
System.out.println("Cache Element:"+cache.get("name"));
System.out.println("Exchange Message:"+exchange.getIn().getBody());
});
}
});
main.run();
}
То, что вы ищете, это:
- либо хранилище
CacheManagerчто вы можете получить доступ из любого места, в том числе из контекста Camel - или вам нужно найти способ разоблачить
Cacheили жеCacheManagerвне контекста.
Первый был по умолчанию для Ehcache 2.x, он был убран из Ehcache 3.x. К сожалению, я не знаю верблюда достаточно хорошо, чтобы рекомендовать в любом случае лучший подход.
Вы можете установить менеджер кеша используя uri как:
to("ehcache:myCache?cacheManager=#myCacheManager")
Где myCacheManager - это ссылка на bean-компонент, который вы в реестре верблюдов смотрите для примера:
Я хотел бы поделиться подходом, когда кеш Camel-context был достигнут из Spring Boot
@Service. В результате REST API позволяет получить последнее значение, передаваемое по маршруту:
Прежде всего, мы добавляем кеш как дополнительную точку назначения маршрута, однако мы преобразуем входящие данные, чтобы явно сделать их объектом String, что выполняется в части процесса перед последним
to():
from(
getMqttRouteConfiguration(
sourceId, mqttHost, mqttTopic, mqttPort, mqttProtocol, authenticated,
username, password, mqttVersion, maxReadRate, qualityOfService
)
)
.to("log:camel.proxy?level=INFO&groupInterval=500000")
.to(String.format("kafka:%s?brokers=%s", sourceId, kafkaBrokerUrls))
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
exchange.getIn().setBody(exchange.getIn().getBody(String.class));
exchange.getIn().setHeader("CamelCacheKey",sourceId);
exchange.getIn().setHeader("CamelCacheOperation","Update");
}
})
.to(String.format("cache://%s?maxElementsInMemory=10&eternal=true", sourceId))
.routeId(sourceId);
На
@Service мы вызываем camelContext и затем получаем необходимый компонент со значением "cache":
public Optional<String> cachedLastValue(String key) {
CacheManager cacheManager = ((CacheComponent) camelContext.getComponent("cache")).getCacheManagerFactory().getInstance();
Cache cache = cacheManager.getCache(key);
if (cache != null) {
Element valueElement = cache.
get(key);
if (valueElement != null) {
String value = (String) (valueElement.
getObjectValue());
return Optional.of(value);
} else {
logger.warn("Cached value for {} topic was requested, but can not be retrieved from the cache: {} with key: {}", key, key, key);
}
} else {
logger.info("Cached value for {} topic was requested, but not yet recorded from the source", key);
}
return Optional.empty();
}
Таким образом, мы достигаем объектов CacheManager и Cache, которые позволяют нам заглянуть в необходимое имя кеша и получить последнее оставшееся здесь значение.
После этого решения все еще не ясно, можем ли мы использовать тот же подход для хранения примерно 10 значений в кеше и извлечения их всех. Также было непонятно, почему без явного вызова
exchange.getIn().setBody(exchange.getIn().getBody(String.class));
exchange.getIn().setHeader("CamelCacheKey",sourceId);
exchange.getIn().setHeader("CamelCacheOperation","Update");
где я вручную помещаю объект String для обмена телом перед помещением его в кеш и явный набор заголовков (я считаю, что они должны быть добавлены Apache Camel Ehcache по умолчанию, но мне пришлось добавить их явно).