Распределенный кеш с движком WSO2 cep

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

Использование tomcat 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(true) + установил для instanceIdentifier тот же идентификатор, что и у моего HazelcastInstance.

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

Мой вопрос: читает ли сервер 2 из/записывает в один и тот же кеш?

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

Спасибо


hazelcast wso2 siddhi wso2cep
person naama    schedule 21.10.2015    source источник

Ответы (1)


arrow_upward
0
arrow_downward

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

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

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

person Tishan    schedule 27.11.2015