Clustering - Apache Ignite

优质

小牛编辑

139浏览

2023-12-01

翻译：Ranger Tsao，校对宋子豪、赵亮

IgniteClusterManager 是基于 Apache Ignite 实现。由于 Vert.x 集群管理的可插拔性，也可轻易切换至其它的集群管理器。

Vert.x 集群管理器包含以下几个功能：

发现并管理集群中的节点
管理集群端的主题订阅清单（这样就可以轻松得知集群中的那些节点订阅了那些 EventBus 地址）
分布式 Map 支持
分布式锁
分布式计数器

注意事项
Vert.x 集群器并不处理节点之间的通信，在 Vert.x 中节点中的通信是直接由 TCP 链接处理的。

使用 Ignite cluster manager

Vert.x 能够从 classpath 路径的 jar 自动检测并使用出 ClusterManager 的实现。不过需要确保在 classpath 没有其他的 ClusterManager 实现。

另外 Vert.x 可以通过设置 -Dvertx.clusterManagerFactory=io.vertx.spi.cluster.ignite.IgniteClusterManager 来使用指定的集群管理器实现。

通过命令行使用

确保 vertx-ignite-3.4.1.jar 在 Vert.x 的安装路径中的 lib 目录下。

通过 Maven 或 Gradle 构建工具使用

Maven(pom.xml)

<dependency>
  <groupId>io.vertx</groupId>
  <artifactId>vertx-ignite</artifactId>
  <version>3.4.1</version>
</dependency>

Gradle(gradle.xml)

compile 'io.vertx:vertx-ignite:3.4.1'

编程形式调用

通过编码的形式，设置集群管理器实现，例子：

ClusterManager clusterManager = new IgniteClusterManager();//创建 Ignite 集群管理器
VertxOptions options = new VertxOptions().setClusterManager(clusterManager);//设置集群管理器实现
Vertx.clusteredVertx(options, res -> {
  if (res.succeeded()) {
    Vertx vertx = res.result();
  } else {
    // failed!
  }
});

配置 Ignite cluster manager

使用配置文件

在 vertx-ignite jar 中内嵌了一个默认配置文件 default-ignite.xml。
如果需要覆盖此配置文件，需要在 classpath 路径中添加 ignite.xml

default-ignite.xml 与 ignite.xml 必须是一个 Apache Ignite 配置文件，在 Apache Ignite 的官方中文文档中，可以找到具体的配置描述。

编程配置

IgniteConfiguration cfg = new IgniteConfiguration();
// 配置 Ignite ，此处省略配置代码
ClusterManager clusterManager = new IgniteClusterManager(cfg);
VertxOptions options = new VertxOptions().setClusterManager(clusterManager);
Vertx.clusteredVertx(options, res -> {
  if (res.succeeded()) {
    Vertx vertx = res.result();
  } else {
    // failed!
  }
});

自动发现及网络传输配置

在默认配置中使用 TcpDiscoveryMulticastIpFinder 实现，这网络发现实现，需要开启组播。如果组播被禁用，可以采用 TcpDiscoveryVmIpFinder 替代，前提是在 ignite.xml 事先配置好 IP 地址列表。具体 Ignite 集群配置，可以参考文档 Apache Ignite。

故障排除

组播未正常开启

MacOS 默认禁用组播。Google一下启用组播。

使用错误的网络接口

如果机器上有多个网络接口（也有可能是在运行 VPN 的情况下），那幺 Ignite 很有可能是使用了错误的网络接口。

为了确保 Ignite 使用正确的网络接口，在配置文件中将 IgniteConfiguration 设置为指定IP地址。例如：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
  <property name="localHost" value="192.168.1.20"/>
</bean>

当运行集群模式时，需要确保 Vert.x 使用正确的网络接口。当通过命令行模式时，可以设置 cluster-host 参数：

vertx run myverticle.js -cluster -cluster-host your-ip-address

其中 your-ip-address 必须与 Ignite 中的配置保持一致。

当通过编程模式使用 Vert.x 时，可以调用方法 setClusterHost 来设置参数

使用VPN

VPN 软件通常通过创建不支持组播的虚拟网络接口来进行工作。在 VPN 环境中，如果 Ignite 与 Vert.x 不正确配置的话，VPN 接口将被选择，而不是正确的接口。

所以，如果你的软件运行在 VPN 环境中，参考上述章节，设置正确的网络接口。

组播被禁用

在一些情况下，运行环境中，无法开启组播。在这种情况下，需要配置合适的 IP finder。TCP sockets 发现器 TcpDiscoveryVmIpFinder ，或者 Amazon S3 发现器 TcpDiscoveryS3IpFinder 。

具体 Ignite 集群配置，可以参考文档 Apache Ignite。

开启日志

在排除故障时，开启 Ignite 日志，将会给予很大的帮助。在 classpath 中添加 vertx-default-jul-logging.properties 文件（默认的JUL记录时），这是一个标准 java.util.loging（JUL）配置文件。具体配置如下：

org.apache.ignite.level=INFO
java.util.logging.ConsoleHandler.level=INFO
java.util.logging.FileHandler.level=INFO