Apache IgniteでバックエンドにH2 Databaseを利用して永続化する

概要

Apache Igniteはインメモリデータグリッドを実現するミドルウェアであるがデータを永続化したいことがある。
永続化の方法としてディスク領域に保存するNative Parsistenceと外部のデータベース等に保存する3rd Party Persistence機能があり、 この記事では後者の3rd Party Persistence機能試してみる。

apacheignite.readme.io

環境

• Apache Ignite Node (Server Mode)
  • Scala 2.12.6
  • ignite-core 2.4.0
  • ignite-spring 2.4.0
  • ignite-indexing 2.4.0
• H2 database 1.4.194

構成

手順

H2 Database

All Platformsのzipファイルをダウンロードして、解凍する。

www.h2database.com

binディレクトリのh2.batを起動するとWeb管理画面が開く
Apache Igniteからも接続したいので設定済みファイルをServerにして接続する

build.sbt

ignite関連のlibraryを追加

libraryDependencies ++= {
  val igniteVersion = "2.4.0"
  Seq(
    "org.apache.ignite" % "ignite-core" % igniteVersion,
    "org.apache.ignite" % "ignite-spring" % igniteVersion,
    "org.apache.ignite" % "ignite-indexing" % igniteVersion
  )
}

config(xml)

Apache Igniteは設定をxmlファイルで保持する。
xmlファイルはsrc/main/resources/META-INFディレクトリに配置した。

H2 Databaseへの接続設定

先程のH2 DatabaseのWeb管理画面に指定した接続先設定と同じものを指定する。

<bean id= "simpleDataSource" class="org.h2.jdbcx.JdbcDataSource">
    <property name="user" value = "sa" />
    <property name="url" value="jdbc:h2:tcp://localhost/~/test" />
</bean>

キャッシュの設定

• CacheJdbcBlobStoreFactoryを利用してBLOB形式でデータベースに保存
• write, readスルー機能を有効化

<property name="cacheConfiguration">
    <list>
        <bean class="org.apache.ignite.configuration.CacheConfiguration">
            <constructor-arg name="name" value="testCache"></constructor-arg>
            <property name="cacheStoreFactory">
                <bean class="org.apache.ignite.cache.store.jdbc.CacheJdbcBlobStoreFactory">
                    <property name="user" value = "sa" />
                    <property name="dataSourceBean" value = "simpleDataSource" />
                </bean>
            </property>
            <property name="writeThrough" value="true"/>
            <property name="readThrough" value="true"/>
        </bean>
    </list>
</property>

Scalaプログラム

データをputしてgetするだけの単純なプログラムを書いた。

import org.apache.ignite.Ignition

object Main extends App {
  using(Ignition.start("example-ignite.xml")) { ignite =>
    using (ignite.getOrCreateCache[String, String]("testCache")) { cache =>
      cache.put("test1", "test1Value")
      cache.put("test2", "test2Value")

      println(s"test1 = ${cache.get("test1")}")
      println(s"test2 = ${cache.get("test2")}")
    }
  }

  def using[T <: AutoCloseable, A](resource: T)(proc: T => A): Unit = {
    try {
      proc(resource)
    } catch {
      case e: Throwable => e.printStackTrace()
    } finally {
      resource.close()
    }
  }
}

実行した

上記のScalaプログラムを実行した。igniteのログが表示され、getしたデータが取得できた

[22:58:03]    __________  ________________
[22:58:03]   /  _/ ___/ |/ /  _/_  __/ __/
[22:58:03]  _/ // (7 7    // /  / / / _/
[22:58:03] /___/\___/_/|_/___/ /_/ /___/
[22:58:03]
[22:58:03] ver. 2.4.0#20180305-sha1:aa342270
[22:58:03] 2018 Copyright(C) Apache Software Foundation
[22:58:03]
[22:58:03] Ignite documentation: http://ignite.apache.org
・・・・

永続化されたか確認する

H2 DatabaseのWeb管理画面から確認したところ、ENTRIESテーブルが新たに追加されていた。
内容を確認したところ先程putしたデータが保存されているようだ。

SELECT UTF8TOSTRING(akey), UTF8TOSTRING(val) FROM ENTRIES;