在 Java 应用程序中嵌入数据仓库

流程

• 将 Red Hat GA 存储库添加到您的 Maven 设置文件中，通常为 ~/.m2/settings.xml，或者直接在项目的 pom.xml 文件中添加。

  <repositories>
    <repository>
      <id>redhat-ga-repository</id>
      <name>Red Hat GA Repository</name>
      <url>https://maven.repository.redhat.com/ga/</url>
    </repository>
  </repositories>
  <pluginRepositories>
    <pluginRepository>
      <id>redhat-ga-repository</id>
      <name>Red Hat GA Repository</name>
      <url>https://maven.repository.redhat.com/ga/</url>
    </pluginRepository>
  </pluginRepositories>

  Copy to Clipboard Toggle word wrap

参考

• Red Hat Enterprise Maven 软件仓库

先决条件

• 配置您的项目，以从 Maven 存储库获取 Data Grid 工件。

流程

• 将 infinispan-core 工件作为依赖项添加到 pom.xml 中，如下所示：

先决条件

• 将 infinispan-core 工件作为依赖项添加到 pom.xml 中。

• gauges 提供值，如写入操作或 JVM 运行时间的平均纳秒数。
• 直方图提供有关操作执行时间的详细信息，如读取、写入和删除时间。

• 在大多数网络上工作且不依赖于外部服务的通用发现协议。
• 发现协议，它依赖于外部服务来为 Data Grid 集群存储和检索拓扑信息。
  例如，DNS_PING 协议通过 DNS 服务器记录执行发现。

• 使用 infinispan.xml 文件中的 stack 属性。

  <infinispan>
    <cache-container default-cache="replicatedCache">
      <!-- Use the default UDP stack for cluster transport. -->
      <transport cluster="${infinispan.cluster.name}"
                 stack="udp"
                 node-name="${infinispan.node.name:}"/>
    </cache-container>
  </infinispan>

  Copy to Clipboard Toggle word wrap

• 使用 addProperty （） 方法设置 JGroups 堆栈文件：

  GlobalConfiguration globalConfig = new GlobalConfigurationBuilder().transport()
          .defaultTransport()
          .clusterName("qa-cluster")
          //Uses the default-jgroups-udp.xml stack for cluster transport.
          .addProperty("configurationFile", "default-jgroups-udp.xml")
          .build();

  Copy to Clipboard Toggle word wrap

参考

• Data Grid 8.x 的 JGroups 集群传输配置 （红帽知识库文章）

流程

• 根据需要使用 -D<property-name>=<property-value > 参数来设置 JGroups 系统属性。

流程

• 在 infinispan.xml 文件中嵌入自定义 JGroups 堆栈声明。

  <infinispan>
    <!-- Contains one or more JGroups stack definitions. -->
    <jgroups>
      <!-- Defines a custom JGroups stack named "prod". -->
      <stack name="prod">
        <TCP bind_port="7800" port_range="30" recv_buf_size="20000000" send_buf_size="640000"/>
        <MPING break_on_coord_rsp="true"
               mcast_addr="${jgroups.mping.mcast_addr:228.2.4.6}"
               mcast_port="${jgroups.mping.mcast_port:43366}"
               num_discovery_runs="3"
               ip_ttl="${jgroups.udp.ip_ttl:2}"/>
        <MERGE3 />
        <FD_SOCK />
        <FD_ALL timeout="3000" interval="1000" timeout_check_interval="1000" />
        <VERIFY_SUSPECT timeout="1000" />
        <pbcast.NAKACK2 use_mcast_xmit="false" xmit_interval="200" xmit_table_num_rows="50"
                        xmit_table_msgs_per_row="1024" xmit_table_max_compaction_time="30000" />
        <UNICAST3 conn_close_timeout="5000" xmit_interval="200" xmit_table_num_rows="50"
                  xmit_table_msgs_per_row="1024" xmit_table_max_compaction_time="30000" />
        <pbcast.STABLE desired_avg_gossip="2000" max_bytes="1M" />
        <pbcast.GMS print_local_addr="false" join_timeout="${jgroups.join_timeout:2000}" />
        <UFC max_credits="4m" min_threshold="0.40" />
        <MFC max_credits="4m" min_threshold="0.40" />
        <FRAG3 />
      </stack>
    </jgroups>
    <cache-container default-cache="replicatedCache">
      <!-- Uses "prod" for cluster transport. -->
      <transport cluster="${infinispan.cluster.name}"
             stack="prod"
             node-name="${infinispan.node.name:}"/>
    </cache-container>
  </infinispan>

  Copy to Clipboard Toggle word wrap