распределенного кэша с WSO2 Cep двигателя

Question

Общая информация:

Использование server7.0 с кот JDK1.7

У меня есть два сервера, и я использую Hazlecat версии 3.0 для кэширования.

Моя проблема с двигателем CEP. Использование WSO2 двигатель

Я добавил следующее к моей pom.xml:

<dependency> 
     <groupId>org.wso2.siddhi</groupId> 
     <artifactId>siddhi-api</artifactId> 
     <version>2.1.0-wso2v1</version> 
    </dependency> 
    <dependency> 
     <groupId>org.wso2.siddhi</groupId> 
     <artifactId>siddhi-core</artifactId> 
     <version>2.1.0-wso2v1</version> 
    </dependency> 
    <dependency> 
     <groupId>org.wso2.siddhi</groupId> 
     <artifactId>siddhi-query</artifactId> 
     <version>2.1.0-wso2v1</version> 
    </dependency> 

Я поставил siddhiConfig в DistributedProcessing (истина) + установить instanceIdentifier иметь тот же идентификатор моего HazelcastInstance.

Каждый сервер имеет один экземпляр siddihiManager.

Вопрос в том, 2 сервер читает/записывает в тот же кеш?

В других местах я видел, что существует необходимость синхронизации между двумя серверами. Любая идея как?

Благодаря

Answer 1

При включении distributed processing в WSO2 СЕР (не Сиддхи) 310 будет использовать встроенные экземпляры Hazelcast разделить события между экземплярами и иметь общее состояние. Но из-за серьезных проблем с производительностью этот подход не поощряется и прекращается в новом выпуске WSO2 CEP.

В новом CEP 4.0.0, Apache Storm используется для обработки распределенной обработки. Вы можете сослаться на это sample и guide о том, как это делается.

Надеюсь, что эта помощь поможет, хотя я напрямую не обратился к вашей первоначальной проблеме.