我谨代表 Spring Integration 社区宣布 Spring Integration Extension for Hazelcast 的第二个里程碑版本，其工件为 spring-integration-hazelcast.1.0.0.M2，可在 里程碑存储库中找到。

该项目已经存在一段时间了，自上一个 里程碑 1 以来，没有太多的活动，直到最近才获得足够的社区吸引力来保证发布。所以，首先，非常感谢您，社区，感谢您的贡献！

此里程碑中包含的一些功能亮点

Hazelcast 领导者选举

如果您需要选举领导者（例如，对于高可用性消息使用者，只有一台节点应接收消息），您只需要创建一个 LeaderInitiator

@Bean
public HazelcastInstance hazelcastInstance() {
    return Hazelcast.newHazelcastInstance();
}

@Bean
public LeaderInitiator initiator() {
    return new LeaderInitiator(hazelcastInstance());
}

然后，当节点被选为领导者时，它会将 OnGrantedEvent 发送到所有应用程序侦听器。 有关如何使用这些事件控制消息传递端点的更多信息，请参见 Spring Integration 参考手册。

Hazelcast 写入 MessageHandler

现在，HazelcastCacheWritingMessageHandler 可以通过 cacheExpression 属性在运行时针对传入的 Message 解析 DistributedObject。 支持的类型为 IMap、MultiMap、ITopic、ISet 或 IList

@Bean
public IMap<Integer, HazelcastIntegrationTestUser> distMap() {
    return testHzInstance().getMap("Distributed_Map1");
}

@Bean
@ServiceActivator(inputChannel = "distMapChannel")
public HazelcastCacheWritingMessageHandler hazelcastMessageHandler() {
    HazelcastCacheWritingMessageHandler handler =
                   new HazelcastCacheWritingMessageHandler();
    handler.setDistributedObject(distMap());
    handler.setKeyExpression(PARSER.parseExpression("payload.id"));
    handler.setExtractPayload(true);
    return handler;
}

Hazelcast 集群监视器入站通道适配器

HazelcastClusterMonitorMessageProducer 允许侦听对集群执行的修改。 这是一个事件驱动的通道适配器，它侦听相关的成员资格、分布式对象、迁移、生命周期和客户端事件

<int-hazelcast:cm-inbound-channel-adapter
                 channel="monitorChannel"
                 hazelcast-instance="instance"
                 monitor-types="MEMBERSHIP, DISTRIBUTED_OBJECT" />

<bean id="instance" class="com.hazelcast.core.Hazelcast"
            factory-method="newHazelcastInstance">
    <constructor-arg>
        <bean class="com.hazelcast.config.Config" />
    </constructor-arg>
</bean>

我们希望在直接发布 1.0.0.RELEASE 之前听到社区的任何反馈，因此，请随时通过任何可用的沟通渠道与我们联系！

项目页面 | 问题 | 帮助 | 聊天