Apache Ignite - 分布式内存数据库

# 基本概念

# 1.Ignite.NET是什么？

Ignite是：

一个以内存为中心的分布式数据库、缓存和处理平台，可以在PB级数据中，以内存级的速度进行事务性、分析性以及流式负载的处理。

# 1.1.固化内存

Ignite的固化内存组件不仅仅将内存作为一个缓存层，还视为一个全功能的存储层。这意味着可以按需将持久化打开或者关闭。如果持久化关闭，那么Ignite就可以作为一个分布式的内存数据库或者内存数据网格，这完全取决于使用SQL和键-值API的喜好。如果持久化打开，那么Ignite就成为一个分布式的，可水平扩展的数据库，它会保证完整的数据一致性以及集群故障的可恢复能力。

# 1.2.Ignite持久化

Ignite的原生持久化是一个分布式的、支持ACID以及兼容SQL的磁盘存储，它可以作为一个可选的磁盘层与Ignite的固化内存透明地集成，然后将数据和索引存储在SSD、闪存、3D XPoint以及其它类型的非易失性存储中。

打开Ignite的持久化之后，就不需要将所有的数据和索引保存在内存中，或者在节点或者集群重启后对数据进行预热，因为固化内存和持久化紧密耦合之后，会将其视为一个二级存储层，这意味着在内存中数据和索引的一个子集如果丢失了，固化内存会从磁盘上进行获取。

# 1.3.ACID兼容

存储在Ignite中的数据，在内存和磁盘上是同时支持ACID的，使Ignite成为一个强一致的系统，Ignite可以在整个拓扑的多台服务器上保持事务。

# 1.4.完整的SQL支持

Ignite提供了完整的SQL、DDL和DML的支持，可以使用纯SQL而不用写代码与Ignite进行交互，这意味着只使用SQL就可以创建表和索引，以及插入、更新和查询数据。有这个完整的SQL支持，Ignite就可以作为一种分布式SQL数据库。

# 1.5.键-值

Ignite的内存数据网格组件是一个完整的事务型分布式键值存储，它可以在有几百台服务器的集群上进行水平扩展。在打开持久化时，Ignite可以存储比内存容量更大的数据，并且在整个集群重启之后仍然可用。

# 1.6.并置处理

大多数传统数据库是以客户机-服务器的模式运行的，这意味着数据必须发给客户端进行处理，这个方式需要在客户端和服务端之间进行大量的数据移动，通常来说不可扩展。而Ignite使用了另外一种方式，可以将轻量级的计算发给数据，即数据的并置计算，从结果上来说，Ignite扩展性更好，并且使数据移动最小化。

# 1.7.可扩展性和持久性

Ignite是一个弹性的、可水平扩展的分布式系统，它支持按需地添加和删除节点，Ignite还可以存储数据的多个副本，这样可以使集群从部分故障中恢复。如果打开了持久化，那么Ignite中存储的数据可以在集群的完全故障中恢复。Ignite集群重启会非常快，因为数据从磁盘上获取，瞬间就具有了可操作性。从结果上来说，数据不需要在处理之前预加载到内存中，而Ignite会缓慢地恢复内存级的性能。

# 1.8.Ignite和Ignite.NET

Ignite.NET构建于Ignite之上：

  • .NET会在同一个进程中启动JVM，并通过JNI与之通信；
  • .NET、C++和Java节点会加入同一个集群，使用相同的缓存，并使用通用的二进制协议进行互操作；
  • Java计算作业可以在任意节点上执行（.NET、C++和Java）；
  • .NET计算作业只能运行在.NET节点上；

Ignite.NET还可以运行于瘦客户端模式，不需要Java/JVM，与服务端使用单一的TCP连接进行通信。

# 2.Ignite定位

Ignite是不是持久化或者纯内存存储？

都是，Ignite的原生持久化可以打开，也可以关闭。这使得Ignite可以存储比可用内存容量更大的数据集。也就是说，可以只在内存中存储较少的操作性数据集，然后将不适合存储在内存中的较大数据集存储在磁盘上，即为了提高性能将内存作为一个缓存层。

Ignite是不是内存数据库（IMDB）？

是，虽然Ignite的固化内存在内存和磁盘中都工作得很好，但是磁盘持久化是可以关闭的，使Ignite成为一个支持SQL以及分布式关联的内存数据库。

Ignite是不是内存数据网格（IMDG）？

是，Ignite是一个全功能的数据网格，它既可以用于纯内存模式，也可以带有Ignite的原生持久化，它也可以与任何第三方数据库集成，包括RDBMS和NoSQL。

Ignite是不是一个分布式缓存？

是，如果关闭原生持久化，Ignite就会成为一个分布式缓存，Ignite实现了JCache规范（JSR107），并且提供了比规范要求更多的功能，包括分区和复制模式、分布式ACID事务、SQL查询以及原生持久化等。

Ignite是不是分布式数据库？

是，在整个集群的多个节点中，Ignite中的数据要么是分区模式的，要么是复制模式的，这给系统带来了伸缩性，增加了系统的弹性。Ignite可以自动控制数据如何分区，同时，开发者也可以插入自定义的分布（关联）函数，以及为了提高效率将部分数据并置在一起。

Ignite是不是SQL数据库？

不完整，尽管Ignite的目标是和其它的关系型SQL数据库具有类似的行为，但是在处理约束和索引方面还是有不同的。Ignite支持一级和二级索引，但是只有一级索引支持唯一性，Ignite还不支持外键约束。

总体来说，Ignite作为约束不支持任何会导致集群广播消息的更新以及显著降低系统性能和可伸缩性的操作。

Ignite是不是一个NoSQL数据库?

不完全，和其它NoSQL数据库一样，Ignite支持高可用和水平扩展，但是，和其它的NoSQL数据库不同，Ignite支持SQL和ACID。

Ignite是不是事务型数据库？

不完整，ACID事务是支持的，但是仅仅在键-值API级别，Ignite还支持跨分区的事务，这意味着事务可以跨越不同服务器不同分区中的键。

Ignite在2.7版本中，通过MVCC技术，实现了包括SQL事务在内的全事务支持，不过目前还处于测试阶段。

Ignite是不是一个多模式数据库？

是，Ignite的数据建模和访问，同时支持键值和SQL，另外，Ignite还为在分布式数据上的计算处理，提供了强大的API。

Ignite是不是键-值存储？

是，Ignite提供了丰富的键-值API，兼容于JCache (JSR-107)，并且支持Java，C++和.NET。

固化内存是什么？

Ignite的固化内存架构使得Ignite可以将内存计算延伸至磁盘，它基于一个页面化的堆外内存分配器，它通过预写日志（WAL）的持久化来对数据进行固化，当持久化禁用之后，固化内存就会变成一个纯粹的内存存储。

并置处理是什么？

Ignite是一个分布式系统，因此，有能力将数据和数据以及数据和计算进行并置就变得非常重要，这会避免分布式数据噪声。当执行分布式SQL关联时数据的并置就变得非常的重要。Ignite还支持将用户的逻辑（函数，lambda等）直接发到数据所在的节点然后在本地进行数据的运算。

# 3.入门

# 3.1.环境要求

  • JDK：8+；
  • OS：Windows(7及以上)，Windows Server（2008 R2及以上），Linux（支持.NET Core的任何版本），macOS；
  • 网络：没有限制（建议10G）；
  • 硬件：无限制；
  • .NET框架：.NET 4.0+, .NET Core 2.0+；
  • IDE：.NET 4.0+, .NET Core 2.0+；

下面的内容基于Windows和Visual Studio，对于Linux和macOS平台的使用，请参见跨平台支持。

# 3.2.安装

NuGet

NuGet是将Ignite.NET包含到项目中最便捷的方法，具体可以在软件包管理器控制台中输入以下内容：Install-Package Apache.Ignite进行安装。

或者也可以在NuGet Gallery中搜索软件包：https://www.nuget.org/packages/Apache.Ignite/。

提示

安装NuGet软件包会更新项目的post-build事件，将Libs文件夹复制到输出目录，具体请参见部署章节的内容。

更新NuGet软件包

当要更新到新版本的Ignite.NET时，一定要清理bin文件夹并且重新构建，以更新Libs文件夹。

二进制包

二进制包包含了Ignite、Ignite.NET和Ignite.C++，可选的Java包，示例代码以及其他的内容。

  • 从如下地址下载二进制包；
  • 将压缩包解压到系统中某个安装文件夹中。

运行示例：

  • 打开platforms\dotnet\examples\Apache.Ignite.Examples.sln；
  • 打开Apache.Ignite.Examples项目属性文件，通过Startup object复选框选择一个示例；
  • 可选：通过Apache.Ignite.exe -configFileName=platforms\dotnet\examples\Apache.Ignite.Examples\App.config -assembly=[path_to_Apache.Ignite.ExamplesDll.dll]启动一个独立的节点；
  • 使用F5或者Ctrl-F5运行示例。

源代码包

Ignite.NET基于Ignite，需要首先构建Java源代码，具体请参见这里。

可以使用一个build.bat或者build.ps1脚本（位于modules\platforms\dotnet\文件夹）来构建Java源代码、.NET源代码和NuGet软件包。

rem Switch to Ignite.NET directory
cd modules\platforms\dotnet

build

# 3.3.从命令行启动

一个Ignite节点可以从命令行启动，可以使用默认的配置也可以传入一个配置文件。可以启动任意个节点，它们彼此之间会自动发现对方。假定当前位于Ignite的安装文件夹，可以在命令行中输入下面的命令：

platforms\dotnet\bin\Apache.Ignite.exe

可以看到下面的信息：

[02:49:12] Ignite node started OK (id=ab5d18a6)
[02:49:12] Topology snapshot [ver=1, nodes=1, CPUs=8, heap=1.0GB]

提示

关于如何生成独立的Ignite.NET节点以及使用各种配置参数的更多信息，可以参见独立节点。

# 3.4.第一个Ignite计算应用

下面是第一个网格应用，该应用将计算句子中的非空白字符数。例如将一个句子拆分为多个单词，并将统计每个单词中的字符数作为一个计算作业，最后将各个作业获得的结果相加即可得出总数。

  • 创建一个新的控制台应用项目；
  • 使用NuGet时：安装Apache Ignite.NET NuGet软件包；
  • 使用完整二进制包时：添加对platform\dotnet\bin\Apache.Ignite.Core.dll的引用。
static void Compute()
{
    using (var ignite = Ignition.Start())
    {
        var funcs = "Count characters using callable".Split(' ')
          .Select(word => new ComputeFunc { Word = word });

        ICollection<int> res = ignite.GetCompute().Call(funcs);

        var sum = res.Sum();

        Console.WriteLine(">>> Total number of characters in the phrase is '{0}'.", sum);
    }
}

class ComputeFunc : IComputeFunc<int>
{
    public string Word { get; set; }

    public int Invoke()
    {
        return Word.Length;
    }
}

# 3.5.第一个Ignite数据网格应用

下面是一组简单的应用，它们会简单地进行一些分布式缓存的读写，然后执行基本的事务操作：

写和读：

using (var ignite = Ignition.Start())
{
    var cache = ignite.GetOrCreateCache<int, string>("myCache");

    // Store keys in cache (values will end up on different cache nodes).
    for (int i = 0; i < 10; i++)
        cache.Put(i, i.ToString());

    for (int i = 0; i < 10; i++)
        Console.WriteLine("Got [key={0}, val={1}]", i, cache.Get(i));
}

原子化操作：

// Put-if-absent which returns previous value.
CacheResult<string> oldVal = cache.GetAndPutIfAbsent(11, "Hello");

// Put-if-absent which returns boolean success flag.
bool success = cache.PutIfAbsent(22, "World");

// Replace-if-exists operation (opposite of getAndPutIfAbsent), returns previous value.
oldVal = cache.GetAndReplace(11, "Hello");

// Replace-if-exists operation (opposite of putIfAbsent), returns boolean success flag.
success = cache.Replace(22, "World");

// Replace-if-matches operation.
success = cache.Replace(22, "World", "World!");

// Remove-if-matches operation.
success = cache.Remove(1, "Hello");

事务：

using (var tx = ignite.GetTransactions().TxStart())
{
    var hello = cache.Get(1);

    if (hello == "1")
        cache.Put(1, "Hello");

    cache.Put(22, "World");

    tx.Commit();
}

分布式锁：

// Lock cache key "11".
using (var cacheLock = cache.Lock(11))
{
    cacheLock.Enter();

    try
    {
        cache.Put(11, "Hello");
        cache.Put(22, "World");
    }
    finally
    {
        cacheLock.Exit();
    }
}

# 3.6.Ignite Visor管理控制台

要确认数据网格的内容以及执行一些其它的管理和监视操作，最简单的方法是使用Ignite的Visor命令行工具。

通过下面的命令可以启动Visor：

bin\ignitevisorcmd.bat

# 3.7.LINQPad入门

LINQPad非常适合快速入门。

Apache Ignite.NET NuGet软件包包括LINQPad示例。

  • 参考NuGet软件包：F4->添加NuGet ...；
  • 转到Samples选项卡 ⇒ nuget ⇒ Apache.Ignite；

更多的信息可以参见：在LINQPad中使用Apache Ignite.NET。

# 4.跨平台支持

从2.4版本开始，同Windows平台一样，也可以在Linux和macOS平台上运行.NET节点以及开发Ignite.NET应用，.NET Core和Mono平台都是支持的。

# 4.1..NET Core

环境要求

使用NuGet

  • dotnet new console；
  • dotnet add package Apache.Ignite；

编辑Program.cs文件：

using System;
using Apache.Ignite.Core;

namespace IgniteTest
{
    class Program
    {
        static void Main(string[] args)
        {
            Ignition.Start();
        }
    }
}
  • dotnet run

运行示例

二进制包中包含了.NET Core的示例：

  • 从这里下载二进制包然后解压；
  • cd platforms/dotnet/examples/dotnetcore；
  • dotnet run。

# 4.2.Mono

环境要求

  • Mono；
  • Java 8+（macOS需要JDK，否则JRE也可以）。

使用NuGet

请参见入门章节中的相关内容。

一个额外的步骤是配置IGNITE_HOME环境变量或者IgniteConfiguration.IgniteHome，指向NuGet的包路径（通常是packages/Apache.Ignite.2.4.0）。

运行示例

Mono可以直接在.NET 4环境中构建和运行。

  • cd platforms/dotnet/examples；
  • nuget restore；
  • msbuild；
  • mono Apache.Ignite.Examples/bin/Debug/Apache.Ignite.Examples.exe。

# 4.3.Java检测

Ignite.NET会在如下路径中查找Java运行环境：

  • HKLM\Software\JavaSoft\Java Runtime Environment（Windows）；
  • /usr/bin/java（Linux）；
  • /Library/Java/JavaVirtualMachines（macOS）；

如果在其它位置自行安装Java环境，则需配置下面的任一配置项：

  • IgniteConfiguration.JvmDllPath属性；
  • JAVA_HOME环境变量。

# 4.4.已知问题

NU1701

warning NU1701: Package 'Apache.Ignite 2.4.0' was restored using '.NETFramework,Version=v4.6.1' instead of the project target framework '.NETCoreApp,Version=v2.0'. This package may not be fully compatible with your project.。

Ignite.NET完全支持.NET Core，但NuGet程序集针对的是.NET 4.0。通过在csproj文件中添加<PropertyGroup><NoWarn>NU1701</NoWarn></PropertyGroup>，可以安全地忽略此警告。

No Java runtime present, requesting install

在macOS上Java的8u151版本存在一个问题：JDK-7131356，一定要安装8u152及其以后的版本。

Serializing delegates is not supported on this platform

.NET Core不支持序列化委托，执行System.MulticastDelegate.GetObjectData会抛出异常，因此Ignite.NET无法对委托或包含委托的对象进行序列化。

Could not load file or assembly 'System.Configuration.ConfigurationManager'

已知的.NET问题(506)，有时需要额外的包引用：

  • dotnet add package System.Configuration.ConfigurationManager

# 5.配置

Ignite.NET节点可以通过多种方法来配置，具体表现为一组Ignition.Start*方法。

# 5.1.C#代码

在C#代码中，完全可以通过Ignition.Start(IgniteConfiguration)配置Ignite.NET。

Ignition.Start(new IgniteConfiguration
{
    DiscoverySpi = new TcpDiscoverySpi
    {
        IpFinder = new TcpDiscoveryStaticIpFinder
        {
            Endpoints = new[] {"127.0.0.1:47500..47509"}
        },
        SocketTimeout = TimeSpan.FromSeconds(0.3)
    },
    IncludedEventTypes = EventType.CacheAll,
    JvmOptions = new[] { "-Xms1024m", "-Xmx1024m" }
});

# 5.2.app.config和web.config

Ignition.StartFromApplicationConfiguration方法会从app.config或web.config文件的Apache.Ignite.Core.IgniteConfigurationSection中读取配置。

在二进制包的Apache.Ignite.Core.dll旁边，以及Apache.Ignite.SchemaNuGet包中，可以找到IgniteConfigurationSection.xsd架构文件。在配置文件中编辑IgniteConfigurationSection时，将其包含在项目中并且构建动作为None，可以在Visual Studio中启用IntelliSense。

提示

要将IgniteConfigurationSection.xsd架构文件添加到Visual Studio项目中，可以转到Projects菜单，然后单击Add Existing Item...菜单项，之后找到IgniteConfigurationSection.xsd并且选中。

或者，安装NuGet软件包：Install-Package Apache.Ignite.Schema，这将自动将xsd文件添加到项目中。

为了改善编辑体验，确保在工具-选项-文本编辑器-XML中启用了语句完成选项。

app.config

<?xml version="1.0" encoding="utf-8"?>

<configuration>
    <configSections>
        <section name="igniteConfiguration" type="Apache.Ignite.Core.IgniteConfigurationSection, Apache.Ignite.Core" />
    </configSections>

    <runtime>
        <gcServer enabled="true"/>
    </runtime>

    <igniteConfiguration xmlns="http://ignite.apache.org/schema/dotnet/IgniteConfigurationSection" gridName="myGrid1">
        <discoverySpi type="TcpDiscoverySpi">
            <ipFinder type="TcpDiscoveryStaticIpFinder">
                <endpoints>
                    <string>127.0.0.1:47500..47509</string>
                </endpoints>
            </ipFinder>
        </discoverySpi>

        <cacheConfiguration>
            <cacheConfiguration cacheMode='Replicated' readThrough='true' writeThrough='true' />
            <cacheConfiguration name='secondCache' />
        </cacheConfiguration>

        <includedEventTypes>
            <int>42</int>
            <int>TaskFailed</int>
            <int>JobFinished</int>
        </includedEventTypes>

        <userAttributes>
            <pair key='myNode' value='true' />
        </userAttributes>

        <JvmOptions>
          <string>-Xms1024m</string>
          <string>-Xmx1024m</string>
        </JvmOptions>
    </igniteConfiguration>
</configuration>

C#

var ignite = Ignition.StartFromApplicationConfiguration("igniteConfiguration");

Ignite配置段的语法

Ignite的配置段直接映射到IgniteConfiguration类。

  • 简单属性（字符串、基础类型、枚举）映射到XML属性（属性名为驼峰式的C#属性名）；
  • 复杂属性映射到嵌套的XML元素（元素名为驼峰式的C#属性名）；
  • 当复杂属性是接口或抽象类时，type属性将用于指定类型，需要使用程序集限定名。对于内置类型（例如上面代码示例中的TcpDiscoverySpi），可以省略程序集名和命名空间；
  • 如有疑问，可以查询IgniteConfigurationSection.xsd。

# 5.3.Spring XML

Spring的XML文件可以使用原生的基于Java的Ignite配置，Spring的配置文件可以通过Ignition.Start(string)方法以及IgniteConfiguration.SpringConfigUrl属性传入。

使用IgniteConfiguration.SpringConfigUrl属性时，Spring的配置会首先加载，在其之上才会应用其他的IgniteConfiguration属性，这样在Ignite.NET不直接支持某些Java属性时，此功能会有用。

Spring XML：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:util="http://www.springframework.org/schema/util"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/util
                           http://www.springframework.org/schema/util/spring-util.xsd">
    <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
        <property name="localHost" value="127.0.0.1"/>
        <property name="gridName" value="grid1"/>
        <property name="userAttributes">
            <map>
                <entry key="my_attr" value="value1"/>
            </map>
        </property>

        <property name="cacheConfiguration">
            <list>
                <bean class="org.apache.ignite.configuration.CacheConfiguration">
                    <property name="name" value="cache1"/>
                    <property name="startSize" value="10"/>
                </bean>
            </list>
        </property>

        <property name="discoverySpi">
            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
                <property name="ipFinder">
                    <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
                        <property name="addresses">
                            <list>
                                <value>127.0.0.1:47500..47509</value>
                            </list>
                        </property>
                    </bean>
                </property>
                <property name="socketTimeout" value="300" />
            </bean>
        </property>
    </bean>
</beans>

C#：

var ignite = Ignition.Start("spring-config.xml");

# 6.独立节点

Ignite.NET节点可以在.NET应用的代码中通过使用Ignition.Start()启动，也可以使用可执行的Apache.Ignite.exe（位于{apache_ignite_release}\platforms\dotnet\bin文件夹下）作为单独的进程启动。像通常一样，在内部Apache.Ignite.exe引用Apache.Ignite.Core.dll和使用Ignition.Start()，并且可以使用下面列出的命令行参数进行配置，方法是将它们作为命令行选项传递或直接在Apache.Ignite.exe.config文件中进行设置。

# 6.1.通过命令行配置独立节点

下面是基本的Ignite参数，当使用Apache.Ignite.exe程序启动节点时，这些参数可以作为命令行参数传入：

命令行参数 含义
-IgniteHome Ignite安装目录路径（如果未提供会使用IGNITE_HOME环境变量）
-ConfigFileName app.config文件路径（如果未提供会使用Apache.Ignite.exe.config）
-ConfigFileName 配置文件中IgniteConfigurationSection的名字
-SpringConfigUrl Spring配置文件路径
-JvmDllPath JVM库jvm.dll的路径（如果未提供会使用JAVA_HOME环境变量）
-JvmClasspath 传递给JVM的类路径（在这里注册其它的jar文件）
-SuppressWarnings 是否输出警告信息
-J<javaOption> JVM参数
-Assembly 要加载的其它.NET程序集
-JvmInitialMemoryMB 初始Java堆大小（MB），对应于-XmsJava参数
-JvmMaxMemoryMB 最大Java堆大小（MB），对应于-XmxJava参数
/install 根据指定的参数将Ignite安装为Windows服务
/uninstall 卸载Ignite Windows服务

示例：

Apache.Ignite.exe -ConfigFileName=c:\ignite\my-config.xml -ConfigSectionName=igniteConfiguration -Assembly=c:\ignite\my-code.dll -J-Xms1024m -J-Xmx2048m

# 6.2.通过XML文件配置独立节点

通过app.configXML文件或/和Spring配置文件，也可以配置独立节点。上面列出的每个命令行参数，也可以用于Apache.Ignite.exe.config的appSettings段。

<configuration>
  <configSections>
    <section name="igniteConfiguration" type="Apache.Ignite.Core.IgniteConfigurationSection, Apache.Ignite.Core" />
  </configSections>

  <igniteConfiguration springConfigUrl="c:\ignite\spring.xml">
    <cacheConfiguration name="myCache" cacheMode="Replicated" />
  </igniteConfiguration>

  <appSettings>
    <add key="Ignite.Assembly.1" value="my-assembly.dll"/>
    <add key="Ignite.Assembly.2" value="my-assembly2.dll"/>
    <add key="Ignite.ConfigSectionName" value="igniteConfiguration" />
  </appSettings>
</configuration>

这个示例定义了igniteConfiguration段，并通过Ignite.ConfigSectionName配置用其启动Ignite，它还引用了一个Spring配置文件，两者最终会组合在一起。

# 6.3.加载用户程序集

某些Ignite的API涉及了远程代码执行，因此需要将代码和程序集一起加载到Apache.Ignite.exe，这可以通过-Assembly命令行参数或者Ignite.Assembly应用配置来实现。

以下功能要求在所有节点上加载相应的程序集：

  • ICompute（支持自动加载，具体可以参见远程程序集加载）。
  • 带过滤器的扫描查询；
  • 带过滤器的持续查询；
  • 远程程序集加载方法；
  • 带过滤器的ICache.LoadCache；
  • IServices；
  • IMessaging.RemoteListen；
  • IEvents.RemoteQuery。

缺失用户程序集

如果一个用户程序集无法加载，会抛出Could not load file or assembly 'MyAssembly' or one of its dependencies异常。

注意任何程序集的依赖也是必须要加入该列表的。

# 6.4.Ignite.NET作为Windows服务

Apache.Ignite.exe可以安装为Windows的服务，因此可以通过/install命令行参数自动启动。每次服务启动时，所有其它命令行参数将被保留和使用。使用/uninstall可以卸载服务。

Apache.Ignite.exe /install -J-Xms513m -J-Xmx555m -ConfigSectionName=igniteConfiguration

# 7.Ignite.NET生命周期

Ignite.NET是基于进程的，单个进程代表一个或多个逻辑Ignite.NET节点（多数情况下单个进程仅运行一个Ignite.NET节点）。在整个Ignite文档中，几乎可以交替使用术语Ignite运行时和Ignite节点，例如当说要求“在该主机上运行5个节点”时，从技术上讲，大多数情况下在该主机上启动5个Ignite.NET进程即可，每个进程都运行一个Ignite节点。当然Ignite.NET也可以在单​​个进程中支持多个节点，比如大多数Ignite.NET自身内部测试即是这样的运行方式。

提示

Ignite.NET运行时 == Ignite.NET进程 == Ignite.NET节点（多数情况下）

# 7.1.Ignition类

Ignition类可以在网络拓扑中启动一个独立的Ignite.NET节点，注意一台物理服务器（例如网络上的一台计算机），可以同时运行多个Ignite.NET节点。

下面是在本地使用默认值启动一个节点的方法：

IIgnite ignite = Ignition.Start();

也可以传递一个配置文件：

IIgnite ignite = Ignition.Start("examples/config/example-cache.xml");

配置文件的路径可以是绝对路径，也可以相对于IGNITE_HOME（Ignite安装文件夹）或者当前目录。

# 7.2.ILifecycleHandler

有时在启动或者停止Ignite节点时需要执行特定的事件，这可以通过实现ILifecycleHandler接口实现，然后在IgniteConfiguration的LifecycleHandlers属性中指定。

var cfg = new IgniteConfiguration
{
    LifecycleHandlers = new [] { new LifecycleExampleHandler() }
};

using (var ignite = Ignition.Start(cfg))
{
  ...
}

ILifecycleHandler的实现大致如下：

class LifecycleExampleHandler : ILifecycleHandler
{
    public void OnLifecycleEvent(LifecycleEventType evt)
    {
        if (evt == LifecycleEventType.AfterNodeStart)
            Started = true;
        else if (evt == LifecycleEventType.AfterNodeStop)
            Started = false;
    }

    public bool Started { get; private set; }
}

# 7.3.生命周期事件类型

Ignite.NET支持如下的生命周期事件类型：

事件类型 描述
BeforeNodeStart 启动节点启动过程之前调用
AfterNodeStart 节点启动之后调用
BeforeNodeStop 启动节点停止过程之前调用
AfterNodeStop 节点停止之后调用

# 8.异步支持

Ignite.NET API的所有分布式方法都可以以同步或者异步的方式执行，这些方法以DoSomething/DoSomethingAsync的方式成对表示。异步方法遵循基于任务的异步模式：它们返回System.Threading.Task，可以使用C# 5的await关键字来等待。

支持取消的异步方法具有CancellationToken参数重载。

计算网格示例

下面的示例说明了同步计算和异步计算之间的区别。

同步：

ICompute compute = ignite.GetCompute();

// Execute a job and wait for the result.
string res = compute.Call(new ComputeFunc());

Console.WriteLine(res);

下面是将上面的代码异步化：

// Start asynchronous operation and obtain a Task that represents it
Task<string> asyncRes = compute.CallAsync(new ComputeFunc());

// Synchronously wait for the task to complete and obtain result
Console.WriteLine(asyncRes.Result);

// OR use C# 5 await keyword
Console.WriteLine(await asyncRes);

// OR use continuation
asyncRes.ContinueWith(task => Console.WriteLine(task.Result));

数据网格示例

下面是同步和异步调用的数据网格示例。

同步：

ICache<int, string> cache = ignite.GetCache<int, string>("myCache");

CacheResult<string> val = cache.GetAndPut(1, "1");

下面是上面调用的异步形式：

// Start asynchronous operation and obtain a Task that represents it
Task<CacheResult<string>> asyncVal = cache.GetAndPutAsync(1, "1");

// Synchronously wait for the task to complete and obtain result
Console.WriteLine(asyncVal.Result.Success);

// Use C# 5 await keyword
Console.WriteLine((await asyncVal).Success);

// Use continuation
asyncVal.ContinueWith(task => Console.WriteLine(task.Result.Success));

# 8.1.异步延续

Ignite中的异步操作是通过特殊的系统线程完成的，这些线程具有以下限制：

  • 不应使用Ignite API；
  • 不应执行繁重的操作。

当ConfigureAwait(false)与async关键字一起使用时，代码可能最终在Ignite系统线程中：

var cache = ignite.GetCache<int, int>("ints");

await cache.PutAsync(1, 1).ConfigureAwait(false);
// All the code below executes in Ignite system thread.
// Do not access Ignite APIs from here.

如果需要执行多个等待的操作，请不要使用ConfigureAwait(false)。

对于控制台、ASP.NET Core和某些其他类型的应用，System.Threading.SynchronizationContext未设置默认值，因此一个自定义的SynchronizationContext是必要的，以避免在Ignite系统线程上运行延续。最简单的方法是从这样的SynchronizationContext类派生：

class Program
{
    public static async Task<int> Main()
    {
        // Run async continuations on .NET Thread Pool threads.
        SynchronizationContext.SetSynchronizationContext(
             new ThreadPoolSynchronizationContext());

        using (var ignite = Ignition.Start())
        {
            var cache = ignite.GetOrCreateCache<int, string>("my-cache");
            await cache.PutAsync(1, "Test1");
            await cache.PutAsync(2, "Test2");
            await cache.PutAsync(3, "Test3");
        }

        return 0;
    }
}

class ThreadPoolSynchronizationContext : SynchronizationContext
{
    // No-op.
    // Don't use SynchronizationContext class directly because optimization
    // in the Task class treats that the same way as null context.
}

# 9.客户端和服务端

# 9.1.概述

Ignite.NET有客户端和服务端节点的概念。服务端节点参与缓存、计算执行、流处理等，而原生客户端节点可以远程接入服务端，可以使用完整的Ignite API，包括客户端近缓存、事务、计算、流处理、服务网格等。

所有Ignite节点默认均以服务端模式启动，客户端模式是需要显式指定的。

另一个Ignite模式是瘦客户端，它与原生客户端有很大不同。瘦客户端非常轻量，不参与集群拓扑。每个瘦客户端都通过套接字接入特定的Ignite节点，并通过该节点执行所有操作。瘦客户端API与完整的Ignite API相似，但功能较少。

# 9.2.配置客户端和服务端

通过IgniteConfiguration.clientMode属性，可以将一个节点配置为客户端或者服务端。

或者为了方便，也可以在Ignition类本身上启用或禁用客户端模式，这样可以使客户端和服务端有同样的配置。

Ignition.ClientMode = true;

// Start Ignite in client mode.
IIgnite ignite = Ignition.Start();

# 9.3.创建分布式缓存

当创建缓存时，不管是通过XML文件，还是通过IIgnite.CreateCache(...)或者IIgnite.GetOrCreateCache(...)方法，Ignite都会自动在所有服务端节点上部署分布式缓存。

提示

一个分布式缓存创建之后，它会自动部署到所有的现有和未来的服务端节点上。

// Enable client mode locally.
Ignition.ClientMode = true;

// Start Ignite in client mode.
IIgnite ignite = Ignition.Start();

// Create cache on all the existing and future server nodes.
// Note that since the local node is a client, it will not
// be caching any data.
var cache = ignite.GetOrCreateCache<object, object>("cacheName");

# 9.4.客户端或者服务端上的计算

IgniteCompute默认会在所有的服务端节点上执行计算作业，不过通过创建对应的集群组，也可以选择只在服务端节点或者只在客户端节点上执行。

服务端上的计算：

ICompute compute = ignite.GetCompute();

// Execute computation on the server nodes (default behavior).
compute.Broadcast(new MyComputeAction());

客户端上的计算：

IClusterGroup clientGroup = ignite.GetCluster().ForClientNodes(null);

ICompute clientCompute = clientGroup.GetCompute();

// Execute computation on the client nodes.
clientCompute.Broadcast(new MyComputeAction());

# 9.5.客户端重连

在以下几种情况下，客户端节点可能会与集群断开连接：

  • 当客户端节点由于网络问题而无法与服务端节点重建连接时；
  • 与服务端节点的连接断开了一段时间，客户端节点能够重建与服务端的连接，但是服务端因为未收到客户端心跳，仍然删除了客户端节点；
  • 速度慢的客户端可能会被服务器节点踢出。

当客户端确定它与集群断开时，它会被分配一个新的节点id，并尝试重新接入集群。不过要注意这有副作用，即如果客户端重新连接，则本地ClusterNode的id属性将更改，这意味着任何依赖于id值的应用逻辑都可能受到影响。

当客户端处于断开状态并且正在进行重连尝试时，Ignite API会抛出一个特定的异常： IgniteClientDisconnectedException，此异常提供了一个ClientReconnectTask属性，该任务在重连完成后将会完成（IgniteCacheAPI会抛出CacheException，其将IgniteClientDisconnectedException作为InnerException），该任务也可以通过IIgnite.ClientReconnectTask获得。

客户端重连也有对应的Ignite事件（这些事件是本地事件，即它们仅在客户端节点上触发），包括：EventType.ClientNodeDisconnected和EventType.ClientNodeReconnected。

IIgnite中当然也有ClientDisconnected和ClientReconnected事件：

计算：

var compute = ignite.GetCompute();

while (true)
{
    try
    {
        compute.Run(job);
    }
    catch (ClientDisconnectedException e)
    {
        e.ClientReconnectTask.Wait(); // Wait for reconnection.

        // Can proceed and use the same ICompute instance.
    }
}

缓存：

var cache = ignite.GetOrCreateCache("myCache");

while (true)
{
  try
  {
    cache.Put(key, val);
  }
  catch (CacheException e)
  {
    var discEx = e.InnerException as ClientDisconnectedException;

    if (discEx != null)
    {
      discEx.ClientReconnectTask.Wait();

      // Can proceed and use the same ICache instance.
    }
  }
}

使用TcpDiscoverySpi中的ClientReconnectDisabled属性，也可以禁用客户端的自动重连。如果重连被禁用，客户端节点会被停止。

C#：

var cfg = new IgniteConfiguration
{
    DiscoverySpi = new TcpDiscoverySpi
    {
        ClientReconnectDisabled = true
    }
};

app.config：

<discoverySpi type="TcpDiscoverySpi" clientReconnectDisabled="true" />

# 9.6.管理慢客户端

在许多环境中，客户端节点是在主集群之外、网络较差、速度较慢的主机上启动的，这时服务端可能会生成客户端无法处理的负载（例如持续查询通知等），从而导致服务端上出站消息队列的增加。如果启用了背压控制，最终可能会导致服务端内存不足或阻塞整个集群。

要管理这些情况，可以配置面向客户端节点的最大允许出站消息数。如果出站队列的大小超过此值，则此类客户端节点将与集群断开，从而阻止整体变慢。

下面显示了如何配置慢客户端队列限制：

C#：

var cfg = new IgniteConfiguration
{
    CommunicationSpi = new TcpCommunicationSpi
    {
        SlowClientQueueLimit = 1000
    }
};

app.config：

<igniteConfiguration>
    <communicationSpi type="TcpCommunicationSpi" slowClientQueueLimit="1000" />
</igniteConfiguration>

Spring XML：

<bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
  <property name="communicationSpi">
    <bean class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi">
      <property name="slowClientQueueLimit" value="1000"/>
    </bean>
  </property>
</bean>

# 10.性能优化技巧

Ignite.NET内存数据网格的性能和吞吐量很大程度上依赖于使用的功能以及配置，在几乎所有的场景中都可以通过简单地调整缓存的配置来优化缓存的性能。

# 10.1.禁用内部事件通知

Ignite有丰富的事件系统来向用户通知各种各样的事件，包括缓存的修改、退出、压缩、拓扑的变化等。因为每秒钟可能产生上千的事件，它会对系统产生额外的负载，这会导致显著地性能下降。因此，强烈建议只有应用逻辑必要时才启用这些事件。事件通知默认是禁用的：

C#：

var cfg = new IgniteConfiguration
{
    IncludedEventTypes =
    {
        EventType.TaskStarted,
        EventType.TaskFinished,
        EventType.TaskFailed
    }
};

app.config：

<igniteConfiguration>
    <includedEventTypes>
        <int>TaskStarted</int>
        <int>TaskFinished</int>
        <int>TaskFailed</int>
    </includedEventTypes>
</igniteConfiguration>

Spring XML：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    ...
    <!-- Enable only some events and leave other ones disabled. -->
    <property name="includeEventTypes">
        <list>
            <util:constant static-field="org.apache.ignite.events.EventType.EVT_TASK_STARTED"/>
            <util:constant static-field="org.apache.ignite.events.EventType.EVT_TASK_FINISHED"/>
            <util:constant static-field="org.apache.ignite.events.EventType.EVT_TASK_FAILED"/>
        </list>
    </property>
    ...
</bean>

# 10.2.调整缓存初始大小

在大小和容量方面，Ignite的内部缓存映射的行为与普通的.NET Hashtable或Dictionary完全相同：它有初始容量（默认情况下很小），当没有空余时容量会增加一倍。内部缓存映射调整大小的过程会占用大量CPU且非常耗时，并且如果将巨大的数据集加载到缓存中（这是常规使用场景），则映射将不得不调整很多次。为避免这种情况，建议指定初始缓存映射容量，与数据集的预期大小相当。在加载期间这将节省大量CPU资源，因为不必调整映射的大小。例如如果希望将1亿数据加载到缓存中，则可以使用以下配置：

C#：

var cfg = new IgniteConfiguration
{
    CacheConfiguration = new[]
    {
        new CacheConfiguration
        {
            StartSize = 100 * 1024 * 1024
        }
    }
};

app.config：

<igniteConfiguration>
    <cacheConfiguration>
        <cacheConfiguration startSize="104857600" />
    </cacheConfiguration>
</igniteConfiguration>

Spring XML：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    ...
    <property name="cacheConfiguration">
        <bean class="org.apache.ignite.configuration.CacheConfiguration">
            ...
            <!-- Set initial cache capacity to ~ 100M. -->
            <property name="startSize" value="#{100 * 1024 * 1024}"/>
            ...
        </bean>
    </property>
</bean>

上面的配置将节省log₂(10⁸) − log₂(1024) ≈ 16次缓存映射大小调整（初始映射容量默认为1024）。注意每次后续大小调整平均将比前一次多2倍的时间。

# 10.3.关闭备份

如果使用了分区缓存，而且数据丢失并不是关键（比如，当有一个备份缓存存储时），可以考虑禁用分区缓存的备份。当备份启用时，缓存引擎会为每个条目维护一个远程拷贝，这需要网络交换，因此是耗时的。要禁用备份，可以使用如下的配置：

C#：

var cfg = new IgniteConfiguration
{
    CacheConfiguration = new[]
    {
        new CacheConfiguration
        {
            CacheMode = CacheMode.Partitioned,
            Backups = 0
        }
    }
};

app.config：

<igniteConfiguration>
    <cacheConfiguration>
        <cacheConfiguration cacheMode="Partitioned" backups="0" />
    </cacheConfiguration>
</igniteConfiguration>

Spring XML：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    ...
    <property name="cacheConfiguration">
        <bean class="org.apache.ignite.configuration.CacheConfiguration">
            ...
            <!-- Set cache mode. -->
            <property name="cacheMode" value="PARTITIONED"/>
            <!-- Set number of backups to 0-->
            <property name="backups" value="0"/>
            ...
        </bean>
    </property>
</bean>

可能的数据丢失

如果没有启用分区缓存的备份，会丢失缓存在故障节点的所有数据，这对于缓存临时数据或者数据可以通过某种方式重建可能是可以接受的。禁用备份之前一定要确认对于应用来说丢失数据不是严重问题。

# 10.4.调整退出策略

退出默认是禁用的，为了确保缓存中的数据不会增长到超过限值，需要使用退出机制并选择合适的退出策略，下面的示例是配置LRU退出策略，最大值为100000条数据：

C#：

var cfg = new IgniteConfiguration
{
    CacheConfiguration = new[]
    {
        new CacheConfiguration
        {
            EvictionPolicy = new LruEvictionPolicy { MaxSize = 1000000 }
        }
    }
};

app.config：

<igniteConfiguration>
    <cacheConfiguration>
        <cacheConfiguration>
          	<evictionPolicy type='LruEvictionPolicy' maxSize='1000000' />
        </cacheConfiguration>
    </cacheConfiguration>
</igniteConfiguration>

Spring XML：

<bean class="org.apache.ignite.cache.CacheConfiguration">
    ...
    <property name="evictionPolicy">
        <!-- LRU eviction policy. -->
        <bean class="org.apache.ignite.cache.eviction.lru.LruEvictionPolicy">
            <!-- Set the maximum cache size to 1 million (default is 100,000). -->
            <property name="maxSize" value="1000000"/>
        </bean>
    </property>
    ...
</bean>

不管使用了哪个退出策略，缓存的性能取决于缓存中退出策略允许的最大数据量，即如果缓存大小超过了限值，就会发生退出。

# 10.5.调整缓存数据再平衡

当新节点加入拓扑时，现有节点会放弃某些键的主备数据所有权，并转给新的节点，以使数据在整个网格中始终保持均衡。这可能需要额外的资源并影响缓存性能，要解决此可能的问题，需要考虑调整以下参数：

  • 配置适合自己网络的再平衡批次大小。默认值为512KB，这意味着默认的再平衡消息约为512KB，不过可以根据网络性能将此值设置为更高或更低；
  • 配置再平衡限流以释放CPU。如果数据集很大并且有很多消息要发送，则CPU或网络可能会被过度消耗，这可能会持续降低应用的性能。这时应该启用数据再平衡限流，这有助于调整再平衡消息之间的等待时间，以确保再平衡过程不会对性能造成任何负面影响。注意在再平衡过程中，应用将继续正常运行；
  • 配置再平衡线程池大小。与上一点相反，有时可能需要通过使用更多的CPU内核来加快再平衡，这可以通过增加再平衡线程池中的线程数来实现（池中默认只有2个线程）。

以下是在缓存配置中配置所有上述参数的示例：

C#：

var cfg = new IgniteConfiguration
{
    CacheConfiguration = new[]
    {
        new CacheConfiguration
        {
            RebalanceBatchSize = 1024 * 1024,
            RebalanceThrottle = TimeSpan.Zero  // disable throttling
        }
    }
};

app.config：

<igniteConfiguration>
    <cacheConfiguration>
        <cacheConfiguration rebalanceBatchSize="1048576" rebalanceThrottle="0:0:0" />
    </cacheConfiguration>
</igniteConfiguration>

Spring XML：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    ...
    <property name="cacheConfiguration">
        <bean class="org.apache.ignite.configuration.CacheConfiguration">
            <!-- Set rebalance batch size to 1 MB. -->
            <property name="rebalanceBatchSize" value="#{1024 * 1024}"/>

            <!-- Explicitly disable rebalance throttling. -->
            <property name="rebalanceThrottle" value="0"/>
            ...
        </bean
    </property>
</bean>

# 10.6.配置线程池

Ignite的主线程池大小默认为可用CPU核数的2倍。在大多数情况下，每个内核持有2个线程可以提高应用的性能，因为上下文切换会更少，CPU缓存也会更好地工作。不过如果预期作业会因I/O或任何其他原因而阻塞，则增加线程池大小可能是有意义的。以下是如何配置线程池的示例：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    ...
    <!-- Configure internal thread pool. -->
    <property name="publicThreadPoolSize" value="64"/>

    <!-- Configure system thread pool. -->
    <property name="systemThreadPoolSize" value="32"/>
    ...
</bean>

# 10.7.尽可能地使用IBinarizable

通过网络传输的每个对象都实现Apache.Ignite.Core.Binary.IBinarizable是一个最佳实践。这些可能是缓存键或值、作业、作业的参数或将通过网络发送到其他节点的任何内容。实现IBinarizable有时性能可能比标准序列化提高10倍以上。

# 10.8.使用并置计算

Ignite可以在内存中执行MapReduce计算，不过大多数计算通常需要处理缓存在远程节点上的某些数据。从远程节点加载该数据通常非常昂贵，但是将计算发送到数据所在的节点要廉价得多。最简单的方法是使用ICompute.AffinityRun()方法，还有其他方法，包括ICacheAffinity.MapKeysToNodes()方法。并置计算概念的更多信息和代码示例，请参见关联并置。

# 10.9.使用数据流处理器

如果需要将大量数据加载到缓存中，可以使用IDataStreamer。数据流处理器在将更新发送到远程节点之前，会将更新恰当地批量化，还会适当地控制每个节点上并行操作的数量，以避免故障。通常它的性能比一堆单线程更新高10倍。更详细的说明和示例，请参见数据加载章节。

# 10.10.批量处理消息

如果能发送10个比较大的作业而不是100个小些的作业，那么应该选择发送大些的作业，这会降低网络上传输作业的数量以及显著地提升性能。类似的对于缓存条目也是一样，应该尽可能使用持有键值集合的API方法，而不是一个一个地传递。

# 10.11.调整垃圾收集

如果由于垃圾收集（GC）导致吞吐量大幅波动，则应调整JVM参数。以下的JVM设置已经被证明可提供相当平稳的吞吐量，而不会出现大的波动：

-XX:+UseParNewGC
-XX:+UseConcMarkSweepGC
-XX:+UseTLAB
-XX:NewSize=128m
-XX:MaxNewSize=128m
-XX:MaxTenuringThreshold=0
-XX:SurvivorRatio=1024
-XX:+UseCMSInitiatingOccupancyOnly
-XX:CMSInitiatingOccupancyFraction=60

# 11.序列化

大多数用户定义的类都会使用Ignite.NET API通过网络传递给其他节点，这些类包括：

  • 缓存键和值；
  • 缓存处理器和过滤器（ICacheEntryProcessor、ICacheEntryFilter、ICacheEntryEventFilter、ICacheEntryEventListener）；
  • 计算函数（IComputeFunc）、操作（IComputeAction）和作业（IComputeJob）；
  • 服务（IService）；
  • 事件和消息处理器（IEventListener，IEventFilter，IMessageListener）。

通过网络传输的这些类对象需要序列化，Ignite.NET支持以下序列化用户数据的方式：

  • Apache.Ignite.Core.Binary.IBinarizable接口；
  • Apache.Ignite.Core.Binary.IBinarySerializer接口；
  • System.Runtime.Serialization.ISerializable接口；
  • Ignite反射式序列化（当以上都不适用时）。

Ignite.NET 2.0不需要在BinaryConfigurations中注册类型

Ignite.NET的早期版本（1.9和更早版本）要求在IgniteConfiguration.BinaryConfiguration中注册所有的类型（除了Serializable），而在Ignite.NET 2.0和更高版本不再有此限制。

Ignite.NET 2.0允许在Serializable类型上使用SQL

从2.0版本开始，所有序列化都以Ignite二进制格式执行，从而启用了所有的Ignite功能，例如SQL和二进制模式，这包括带有和不带有ISerializable接口的Serializable类型。

自动化GetHashCode和Equals实现

如果对象可以序列化为二进制形式，则Ignite将在序列化时计算其哈希值，并将其写入二进制数组。此外，Ignite还提供了equals方法的自定义实现，用于二进制对象的比较。这意味着无需覆盖自定义键和值的GetHashCode和Equals方法即可在Ignite中使用它们。

# 11.1.IBinarizable

IBinarizable方式提供了对序列化的细粒度控制，这是高性能生产代码的首选方法。

首先，在自己的类中实现IBinarizable接口：

public class Address : IBinarizable
{
    public string Street { get; set; }

    public int Zip { get; set; }

    public void WriteBinary(IBinaryWriter writer)
    {
        // Alphabetic field order is required for SQL DML to work.
        // Even if DML is not used, alphabetic order is recommended.
        writer.WriteString("street", Street);
        writer.WriteInt("zip", Zip);
    }

    public void ReadBinary(IBinaryReader reader)
    {
      	// Read order does not matter, however, reading in the same order
        // as writing improves performance.
        Street = reader.ReadString("street");
        Zip = reader.ReadInt("zip");
    }
}

IBinarizable也可以在没有字段名的原始模式下实现，这提供了最快和最紧凑的序列化，但是SQL查询不可用：

public class Address : IBinarizable
{
    public string Street { get; set; }

    public int Zip { get; set; }

    public void WriteBinary(IBinaryWriter writer)
    {
        var rawWriter = writer.GetRawWriter();

        rawWriter.WriteString(Street);
        rawWriter.WriteInt(Zip);
    }

    public void ReadBinary(IBinaryReader reader)
    {
        // Read order must be the same as write order
        var rawReader = reader.GetRawReader();

        Street = rawReader.ReadString();
        Zip = rawReader.ReadInt();
    }
}

# 11.2.IBinarySerializer

IBinarySerializer与IBinarizable类似，但是将序列化逻辑与类实现分开。当无法修改类代码，并且在多个类之间共享序列化逻辑等场景时，这可能很有用。以下代码产生与上面的Address示例完全相同的序列化：

public class Address : IBinarizable
{
    public string Street { get; set; }

    public int Zip { get; set; }
}

public class AddressSerializer : IBinarySerializer
{
    public void WriteBinary(object obj, IBinaryWriter writer)
    {
      	var addr = (Address) obj;

        writer.WriteString("street", addr.Street);
        writer.WriteInt("zip", addr.Zip);
    }

    public void ReadBinary(object obj, IBinaryReader reader)
    {
      	var addr = (Address) obj;

        addr.Street = reader.ReadString("street");
        addr.Zip = reader.ReadInt("zip");
    }
}

序列化器应在配置中指定，如下：

var cfg = new IgniteConfiguration
{
    BinaryConfiguration = new BinaryConfiguration
    {
        TypeConfigurations = new[]
        {
            new BinaryTypeConfiguration(typeof (Address))
            {
                Serializer = new AddressSerializer()
            }
        }
    }
};

using (var ignite = Ignition.Start(cfg))
{
  ...
}

# 11.3.ISerializable

实现System.Runtime.Serialization.ISerializable接口的类型将相应地进行序列化（通过调用GetObjectData和序列化构造函数）。所有的系统功能都支持：包括IObjectReference、IDeserializationCallback、OnSerializingAttribute、OnSerializedAttribute、OnDeserializingAttribute、OnDeserializedAttribute。

GetObjectData的结果以Ignite二进制格式写入，以下三个类提供相同的序列化表示形式：

class Reflective
{
	public int Id { get; set; }
	public string Name { get; set; }
}

class Binarizable : IBinarizable
{
	public int Id { get; set; }
	public string Name { get; set; }

	public void WriteBinary(IBinaryWriter writer)
	{
		writer.WriteInt("Id", Id);
		writer.WriteString("Name", Name);
	}

	public void ReadBinary(IBinaryReader reader)
	{
		Id = reader.ReadInt("Id");
		Name = reader.ReadString("Name");
	}
}

class Serializable : ISerializable
{
	public int Id { get; set; }
	public string Name { get; set; }

	public Serializable() {}

	protected Serializable(SerializationInfo info, StreamingContext context)
	{
		Id = info.GetInt32("Id");
		Name = info.GetString("Name");
	}

	public void GetObjectData(SerializationInfo info, StreamingContext context)
	{
		info.AddValue("Id", Id);
		info.AddValue("Name", Name);
	}
}

# 11.4.Ignite反射式序列化

Ignite反射式序列化本质上是一种IBinarizable方式，其是通过反射所有字段并发出读/写调用自动实现的。

该机制没有条件，任何类或结构都可以序列化（包括所有系统类型、委托、表达式树、匿名类型等）。

可以使用NonSerialized属性排除不需要的字段。

可以通过BinaryReflectiveSerializer显式启用原始模式：

var binaryConfiguration = new BinaryConfiguration
{
    TypeConfigurations = new[]
    {
        new BinaryTypeConfiguration(typeof(MyClass))
        {
            Serializer = new BinaryReflectiveSerializer {RawMode = true}
        }
    }
};

app.config：

<igniteConfiguration>
	<binaryConfiguration>
		<typeConfigurations>
			<binaryTypeConfiguration typeName='Apache.Ignite.ExamplesDll.Binary.Address'>
				<serializer type='Apache.Ignite.Core.Binary.BinaryReflectiveSerializer, Apache.Ignite.Core' rawMode='true' />
			</binaryTypeConfiguration>
		</typeConfigurations>
	</binaryConfiguration>
</igniteConfiguration>

如果没有这个配置，BinaryConfiguration是不需要的。

性能与手工实现IBinarizable相同，反射只在启动阶段使用，用于遍历所有的字段并发出有效的IL代码。

带有Serializable属性但没有ISerializable接口的类型使用Ignite反射式序列化器写入。

# 11.5.使用Entity Framework POCOs

Ignite中可以直接使用Entity Framework POCOs。

但是，Ignite无法直接序列化或反序列化POCO代理https://msdn.microsoft.com/zh-cn/data/jj592886.aspx，因为代理类型是动态类型。

将EF对象与Ignite结合使用时，要确认禁用创建代理：

Entity Framework 6：

ctx.Configuration.ProxyCreationEnabled = false;

Entity Framework 5：

ctx.ContextOptions.ProxyCreationEnabled = false;

# 12.二进制模式

上一章节序列化讲解了Ignite.NET如何将用户定义类型（类和结构）的实例转换为序列化形式，反之亦然。

Ignite还提供了一种直接以二进制（序列化）形式处理数据的方法，而无需在节点或整个集群中持有该类型，可能的场景是：

  • 部分节点已加载类型并且可以处理反序列化形式的数据，但是部分节点因无法访问持有该类型的程序集，而无法处理二进制格式的数据（服务端节点）；
  • 类型在编译时未知，是动态构造的；
  • 当只需要处理大对象中的一小部分数据时，以二进制方式处理数据要比反序列化整个对象更快。

# 12.1.启用二进制模式

部分Ignite.NET API具有以下WithKeepBinary()方法：

  • ICache<TK, TV>.WithKeepBinary<TK1, TV1>()；
  • ICompute.WithKeepBinary()；
  • IServices.WithKeepBinary()和IServices.WithServerKeepBinary()；
  • IDataStreamer<TK, TV>.WithKeepBinary<TK1, TV1>；

启用二进制模式后，这些方法会返回该API的新实例（当前实例不受影响），这意味着其会返回IBinaryObject实例，而不是用户定义的类型实例。

基本类型

注意并非所有类型都可以表示为IBinaryObject，基本类型、string、Guid、DateTime以及这些类型的集合和数组总是返回原始对象。

在下面的示例中，键类型int不变，因为它是基本类型：

ICache<int, Person> cache = ignite.GetCache<int, Person>("persons");
cache[1] = new Person { Name = "Joe" };

ICache<int, IBinaryObject> binaryCache = cache.WithKeepBinary<int, IBinaryObject>();
IBinaryObject binaryPerson = binaryCache[1];

string name = binaryPerson.GetField<string>("Name");

对于泛型API，要由用户提供适当的泛型类型参数。如果缓存中有多个键或值类型并且部分是基本类型，需要使用.WithKeepBinary<object, object>，然后将其安全地强制转换为IBinaryObject。

# 12.2.修改二进制对象

IBinaryObject是不可变的，调用IBinaryObject.ToBuilder()方法可以获得IBinaryObjectBuilder的一个实例，其持有所有二进制对象内容的副本，然后通过各种.Set*方法修改数据，并调用Build()方法来构造持有所有变更的IBinaryObject新实例：

ICache<int, IBinaryObject> binaryCache = cache.WithKeepBinary<int, IBinaryObject>();
IBinaryObject binaryPerson = binaryCache[1];
string name = binaryPerson.GetField<string>("Name");

IBinaryObjectBuilder builder = binaryPerson.ToBuilder();
builder.SetField("Name", name + " - Copy");

IBinaryObject binaryPerson2 = builder.Build();
binaryCache[2] = binaryPerson2;

# 12.3.创建二进制对象

可以从头开始创建任意类型的二进制对象，而无需通过IBinary.GetBuilder()方法持有任何类/结构。具体请参见BinaryModeExample.cs。

IIgnite ignite = Ignition.Start();

IBinaryObjectBuilder builder = ignite.GetBinary().GetBuilder("Book");

IBinaryObject book = builder
  .SetField("ISBN", "xyz")
  .SetField("Title", "War and Peace")
  .Build();

还可以使用IBinary.GetBuilder(Type)重载来构造已知类型的实例。

# 12.4.二进制类型元数据

IBinaryObject的元数据（类型名，字段名和类型）可以通过IBinaryObject.GetBinaryType()方法获得，其会返回IBinaryType的实例。

例如，以下代码会打印任意二进制对象的内容：

IBinaryObject binaryObj = binaryCache.Get(1);
IBinaryType binaryType = binaryObj.GetBinaryType();

Console.WriteLine("Object of type {0}:", binaryType.TypeName);

foreach (string field in binaryType.Fields)
{
  object fieldVal = binaryObj.GetField<object>(field);
  Console.WriteLine("{0} = {1}", field, fieldVal);
}

# 13.平台互操作性

Ignite允许不同的平台（例如.NET、Java和C++）彼此互操作，不同平台上定义的类之间可以相互转换。

# 13.1.标识符

为了实现互操作性，Ignite使用通用二进制格式写入对象，此格式使用整数标识符对对象类型和字段进行编码。

Ignite通过两个阶段，将对象的类型和字段名转换为整数值：

  • 名称转换：将完整的类型名和字段名传递给IBinaryNameMapper接口，并转换为某种通用形式；
  • ID转换：将生成的字符串传递给IBinaryIdMapper以生成字段ID或者类型ID。

可以在BinaryConfiguration中配置全局映射器，也可以在BinaryTypeConfiguration中为具体类型配置映射器。

Java有相同的接口BinaryNameMapper和BinaryIdMapper，它们也是配置在BinaryConfiguration或BinaryTypeConfiguration上。

.NET和Java类型必须映射到相同的类型ID，并且相关字段必须映射到相同的字段ID。

# 13.2.默认行为

Ignite.NET的.NET部分默认会应用以下转换：

  • 名称转换：System.Type.FullName面向非泛型类型的属性，字段或属性名称不变；
  • ID转换：将名称转换为小写，然后以与Java中的java.lang.String.hashCode()方法相同的方式计算ID。

Ignite.NET的Java部分默认会应用以下转换：

  • 名称转换：Class.getName()方法用于获取类名称，字段名称保持不变；
  • ID转换：将名称转换为小写，然后用java.lang.String.hashCode()计算ID。

例如，如果以下两种类型在.NET命名空间和Java包外部，则它们将自动彼此映射：

class Person
{
    public int Id { get; set; }
    public string Name { get; set; }
    public byte[] Data { get; set; }
}

class Person
{
    public int id;
    public String name;
    public byte[] data;
}

不过类型通常在某些命名空间或包中，包和命名空间的命名约定在Java和.NET中有所不同，.NET命名空间与Java包相同可能会出现问题。

简单名称映射器（忽略命名空间）可以避免此问题，其应该在.NET端和Java端中同时配置：

Java Spring XML：

<bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
    ...
    <property name="binaryConfiguration">
        <bean class="org.apache.ignite.configuration.BinaryConfiguration">
            <property name="nameMapper">
                <bean class="org.apache.ignite.binary.BinaryBasicNameMapper">
                    <property name="simpleName" value="true"/>
                </bean>
            </property>
        </bean>
    </property>
    ...
</bean>

C#：

var cfg = new IgniteConfiguration
{
  BinaryConfiguration = new BinaryConfiguration
  {
    NameMapper = new BinaryBasicNameMapper {IsSimpleName = true}
  }
}

app.config：

<igniteConfiguration>
  <binaryConfiguration>
    <nameMapper type="Apache.Ignite.Core.Binary.BinaryBasicNameMapper, Apache.Ignite.Core" isSimpleName="true" />
  </binaryConfiguration>
</igniteConfiguration>

# 13.3.类型兼容性

C# Java
bool boolean
byte(*)，sbyte byte
short，ushort(*) short
int, uint(*) int
long,ulong(*) long
char char
float float
double double
decimal java.math.BigDecimal(**)
decimal java.lang.String
Guid java.util.UUID
DateTime java.util.Date,java.sql.Timestamp
  • byte，ushort，uint，ulong没有对应的Java类型，将直接按字节映射（无范围检查），例如在C#中byte值为200，对应在Java中为有符号的byte值-56。

** Java中BigDecimal可以有任意的大小和精度，而C#中数值型固定为16个字节和28-29位精度，如果反序列化时一个BigDecimal无法匹配decimal，则Ignite.NET会抛出BinaryObjectException。

枚举，在Ignite中，Java的writeEnum只会写入序数值，但是在.NET中，可以为enumValue分配任何数字，因此要注意，不会考虑任何自定义的枚举到原始值的绑定。

DateTime序列化

DateTime可以是Local和UTC，Java中Timestamp只能是UTC。因此Ignite.NET可以通过两种方式对DateTime进行序列化：.NET风格（可以与非UTC值一起使用，在SQL中不可用）和作为Timestamp（对非UTC值抛出异常，可用在SQL中）。

反射式序列化：使用QuerySqlField标记字段以强制执行时间戳序列化。

IBinarizable：使用IBinaryWriter.WriteTimestamp方法。

如果无法通过QuerySqlField修改类来标记字段或无法实现IBinarizable，可以使用IBinarySerializer方式。具体请参见序列化。

# 13.4.集合兼容性

简单类型数组（上表所示）和对象数组都是可互操作的，所有其他集合和数组的默认行为（使用反射式序列化或IBinaryWriter.WriteObject）将使用BinaryFormatter，Java代码是无法读取的（为了正确支持泛型）。如果要将集合写为可互操作的格式，需要实现IBinarizable接口，并使用IBinaryWriter.WriteCollection或IBinaryWriter.WriteDictionary或IBinaryReader.ReadCollection或IBinaryReader.ReadDictionary方法。

# 13.5.混合平台集群

Ignite、Ignite.NET和Ignite.C++节点可以加入同一个集群。

所有平台都是基于Java构建的，因此任何节点都可以执行Java计算。但是.NET和C++计算只能由相对应的节点执行。

如果集群中至少有一个非.NET节点，则不支持以下Ignite.NET功能：

  • 带过滤器的扫描查询；
  • 带过滤器的持续查询；
  • ICache.Invoke方法；
  • 带过滤器的ICache.LoadCache；
  • 服务；
  • IMessaging.RemoteListen；
  • IEvents.RemoteQuery；

有关多平台搭建的实战文章：构建多平台的Ignite集群：Java+.NET。

# 13.6.混合平台集群中的计算

ICompute.ExecuteJavaTask方法在任何集群上的执行都没有限制。

其他ICompute方法将仅在.NET节点上执行闭包，如果集群中没有服务端模式的.NET节点，就会抛出ClusterGroupEmptyException异常。

# 14.部署

Ignite.NET由.NET程序集和Java jar文件组成。

.NET程序集由具体的项目引用，并在构建过程中自动复制到输出文件夹。

Jar文件需要手工复制，Ignite.NET通过IgniteHome或JvmClasspath配置发现它们。

# 14.1.完整的二进制包部署

  • 复制从https://ignite.apache.org下载的整个二进制包内容以及自己的应用；
  • 配置IGNITE_HOME环境变量或IgniteConfiguration.IgniteHome以指向该文件夹。

# 14.2.NuGet部署

在Ignite.NET NuGet软件包安装过程中，将自动更新构建后事件，以将jar文件复制到输出目录中的Libs文件夹中（具体参见入门），分发二进制文件时，要确保包括该Libs文件夹。

确认未全局配置IGNITE_HOME，除了ASP.NET环境（参见下文）外，通常不需要使用NuGet配置IGNITE_HOME。

构建后事件：

if not exist "$(TargetDir)Libs" md "$(TargetDir)Libs"
xcopy /s /y "$(SolutionDir)packages\Apache.Ignite.1.6.0\Libs\*.*" "$(TargetDir)Libs"

# 14.3.自定义部署

Jar文件位于二进制包的libs文件夹和NuGet包中。

Ignite.NET必需的最小Jar集合是：

  • ignite-core-{VER}.jar；
  • cache-api-1.0.0.jar；
  • ignite-indexing文件夹（如果使用缓存查询）；
  • ignite-spring文件夹（如果使用基于spring的配置）。

将jar部署到默认位置：

  • 将jar文件复制到Apache.Ignite.Core.dll旁边的Libs文件夹中；
  • 不要配置IgniteConfiguration.JvmClasspath、IgniteConfiguration.IgniteHome属性和IGNITE_HOME环境变量。

将jar文件部署到任意位置：

  • 将jar文件复制到某处；
  • 将IgniteConfiguration.JvmClasspath属性配置为指向每个jar文件路径的字符串，多个用分号分割；
  • 不要设置IGNITE_HOME环境变量和IgniteConfiguration.IgniteHome属性。

IgniteConfiguration.JvmClasspath示例：

c:\ignite-jars\ignite-core-1.5.0.final.jar;c:\ignite-jars\cache-api-1.0.0.jar

# 14.4.ASP.NET部署

在Web环境（IIS和IIS Express）中使用Ignite时，JvmClasspath或IgniteHome必须显式配置，因为dll文件复制到了临时文件夹，而Ignite无法自动定位这些jar文件。

在ASP.NET环境中可以像下面这样配置IgniteHome：

Ignition.Start(new IgniteConfiguration
{
    IgniteHome = HttpContext.Current.Server.MapPath(@"~\bin\")
});

或者，可以全局配置IGNITE_HOME，将下面这行代码添加到Global.asax.cs中Application_Start方法的顶部：

Environment.SetEnvironmentVariable("IGNITE_HOME", HttpContext.Current.Server.MapPath(@"~\bin\"));

或者，可以使用以下方法填充JvmClasspath：

static string GetDefaultWebClasspath()
{
    var dir = HttpContext.Current.Server.MapPath(@"~\bin\libs");

    return string.Join(";", Directory.GetFiles(dir, "*.jar"));
}

# 14.5.IIS程序池生命周期、AppDomains和Ignite.NET

IIS有一个已知的问题：当重启Web应用时（由于代码更改或手动重启），程序池进程仍然在线，而AppDomain被回收。

卸载AppDomain后，Ignite.NET会自动停止。不过在旧域卸载过程中，可能会启动新域，因此，旧域中的节点可能与新域中的节点发生IgniteConfiguration.IgniteInstanceName冲突。

要解决此问题，需要确保为IgniteInstanceName分配唯一值或将IgniteConfiguration.AutoGenerateIgniteInstanceName属性设置为true：

C#：

var cfg = new IgniteConfiguration { AutoGenerateIgniteInstanceName = true };

web.config：

<igniteConfiguration autoGenerateIgniteInstanceName="true">
  ...
</igniteConfiguration>

这样就不会发生GridName冲突，并且来自旧AppDomain的节点最终会停止。

# 15.瘦客户端

瘦客户端是一种轻量级的Ignite连接模式，它不会在JVM进程中启动（根本不需要Java），不参与集群，从不持有任何数据或执行计算。

它只是建立与单个Ignite节点的套接字连接，然后通过该节点执行所有操作。

瘦客户端模式非常适合周期短且资源受限的应用，内存和CPU使用率极低。

# 15.1.安装

瘦客户端API位于同一个Apache.Ignite.Core程序集中（Apache.IgniteNuGet程序包），然后与完整的Ignite.NET API共享许多类和接口，因此可以轻松地从一种API切换到另一种。基本安装步骤与入门中的描述相同。

# 15.2.环境要求

即使程序集和NuGet包相同，要求也不同：

  • 不需要Java；
  • 支持的运行时：.NET 4.0 + 、. NET Core 2.0+；
  • 支持的操作系统：Windows、Linux、macOS（.NET Core 2.0+支持的任何操作系统）

将多个线程与瘦客户端连接池一起使用可提高性能

目前.NET瘦客户端没有创建多个线程来提高吞吐量的功能，不过可以通过从应用维护的池中获取瘦客户端连接来创建多个线程，以提高吞吐量。

# 15.3.配置服务端节点

Ignite服务端节点默认是启用了瘦客户端连接器的。该功能可以通过在.NET中将IgniteConfiguration.ClientConnectorConfigurationEnabled配置为false，或在Java或Spring的XML将IgniteConfiguration.clientConnectorConfiguration配置为null禁用。

连接器可以做出如下调整：

C#：

var cfg =  new IgniteConfiguration
{
    ClientConnectorConfiguration = new ClientConnectorConfiguration
    {
      Host = "myHost",
      MaxOpenCursorsPerConnection = 64,
      Port = 10900,
      PortRange = 50
    }
};

app.config：

<igniteConfiguration>
  <clientConnectorConfiguration host='myHost' port='10900' portRange='50' maxOpenCursorsPerConnection='50' />
</igniteConfiguration>

Spring XML：

<bean  class="org.apache.ignite.configuration.IgniteConfiguration">
    <property name="clientConnectorConfiguration">
        <bean class="org.apache.ignite.configuration.ClientConnectorConfiguration">
            <property name="host" value="myHost"/>
            <property name="port" value="11110"/>
            <property name="portRange" value="30"/>
        </bean>
    </property>
</bean>

# 15.4.接入集群

瘦客户端API的入口点就是Ignition.StartClient(IgniteClientConfiguration)方法，其中IgniteClientConfiguration.Host属性是必需的，它应指向运行Ignite服务端节点的主机，其他属性应对应于服务端节点中ClientConnectorConfiguration的属性。

假定服务端节点在本地运行，并且ClientConnectorConfiguration是默认的配置：

var cfg = new IgniteClientConfiguration
{
  Host = "127.0.0.1"
};

using (IIgniteClient client = Ignition.StartClient(cfg))
{
  ICacheClient<int, string> cache = client.GetCache<int, string>("cache");
  cache.Put(1, "Hello, World!");
}

认证

如果服务端启用了认证，则必须提供用户的凭据：

var cfg = new IgniteClientConfiguration
{
  Host = "127.0.0.1",
  Port = 10900,
  UserName = "ignite",
  Password = "kg1mmcoXZU"
};

using (IIgniteClient client = Ignition.StartClient(cfg))
{
  ICacheClient<int, string> cache = client.GetCache<int, string>("cache");
  cache.Put(1, "Hello, World!");
}

# 15.5.瘦客户端API

瘦客户端提供了完整Ignite.NET API的一个子集，并且还在不断发展，后续计划在胖客户端和瘦客户端中都支持大多数API。

当前版本支持Cache APIICacheClient，包括支持谓词的ScanQuery。

# 16.故障解决

# 16.1.使用控制台

Ignite会产生控制台输出（stdout）：信息、指标、警告、错误详细信息等，如果应用未打开控制台，则可以将控制台输出重定向到字符串或文件：

var sw = new StringWriter();
Console.SetOut(sw);

// Examine output:
sw.ToString();

# 16.2.获取有关异常的更多信息

当拿到IgniteException时，一定要检查其中的InnerException属性，该属性通常包含有关错误的更多详细信息，具体可以在Visual Studio的调试器中或通过在异常对象上调用ToString()方法看到：

try {
    IQueryCursor<List> cursor = cache.QueryFields(query);
}
catch (IgniteException e) {
    // Printing out the whole exception meesage.
    Console.WriteLine(e.ToString());
}

# 16.3.无法加载jvm.dll

确认已安装JDK，配置好了JAVA_HOME环境变量并指向JDK安装目录。最新的JDK可以在这里找到：http://www.oracle.com/technetwork/java/javase/downloads/index.html。

errorCode=193是ERROR_BAD_EXE_FORMAT，通常是由x64/x86不匹配引起的。确认已安装的JDK和应用具有相同的x64/x86平台架构。当未设置JAVA_HOME时，Ignite会自动检测到合适的JDK，因此即使同时安装了x86和x64的JDK，也没有问题。

# 16.4.无法找到Java类

检查IGNITE_HOME环境变量、IgniteConfiguration.IgniteHome和IgniteConfiguration.JvmClasspath属性，具体请参见部署章节，ASP.NET/IIS场景还需要其他的步骤。

# 16.5.Ignition.Start阻塞

检查控制台输出。

最常见的原因是拓扑连接失败：

# 16.6.启动管理器失败: GridManagerAdapter

检查控制台输出。

通常这是由无效或不兼容的配置引起的：

  • 某些配置属性值无效（超出范围等）；
  • 某些配置属性与其他集群节点中的值不兼容。尤其是BinaryConfiguration中的属性，例如CompactFooter、IdMapper和NameMapper应在所有节点上是相同的。

当搭建混合集群（Java + .NET节点）时，通常会出现后一个问题，因为这些平台上的默认配置是不同的。.NET仅支持BinaryBasicIdMapper和BinaryBasicNameMapper，因此必须通过以下方式调整Java配置以启用.NET节点的接入：

<property name="binaryConfiguration">
    <bean class="org.apache.ignite.configuration.BinaryConfiguration">
        <property name="compactFooter" value="true"/>
        <property name="idMapper">
            <bean class="org.apache.ignite.binary.BinaryBasicIdMapper">
                <constructor-arg value="true"/>
            </bean>
        </property>
        <property name="nameMapper">
            <bean class="org.apache.ignite.binary.BinaryBasicNameMapper">
                <constructor-arg value="true"/>
            </bean>
        </property>
    </bean>
</property>

# 16.7.无法加载文件或程序集'MyAssembly'或其依赖，系统无法找到指定文件

远程节点缺失某程序集时会抛出该异常，具体请参见加载用户程序集。

# 16.8.堆栈溢出错误，.NET终止

在Linux平台的.NET Core环境下，当用户代码抛出NullReferenceException异常时，就会发生这种情况。其原因是，.NET和Java都使用SIGSEGV来处理某些异常，包括NullPointerException和NullReferenceException，当JVM与.NET运行在同一进程中时，它将覆盖该处理器，破坏.NET异常处理（具体参见1，2）。

.NET Core 3.0解决了该问题（#25972：将COMPlus_EnableAlternateStackCheck环境变量设置为1）。

最后更新时间：: 11/25/2023, 3:51:28 PM

集群化 →