0

基本信息:

使用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 具有相同的 ID。

每台服务器都有一个 siddihiManager 实例。

我的问题是,2 服务器是否读取/写入相同的缓存?

我在其他地方看到需要在两台服务器之间进行同步。知道怎么做吗?

谢谢

4

1 回答 1

0

当您在 WSO2 CEP(不是 Siddhi)310 中启用分布式处理时,它将使用嵌入式 Hazelcast 实例在实例之间共享事件并具有共享状态。但是由于严重的性能问题,这种方法不鼓励并且在新的WSO2 CEP版本中停止使用。

在新的 CEP 4.0.0 中,Apache Storm用于处理分布式处理。您可以参考此示例指导它是如何完成的。

即使我没有直接解决您最初的问题,也希望这能有所帮助。

于 2015-11-27T10:00:52.523 回答