Package nablarch.integration.redisstore.lettuce

Class LettuceClusterRedisClient

java.lang.Object
nablarch.integration.redisstore.lettuce.AbstractLettuceRedisClient
nablarch.integration.redisstore.lettuce.LettuceClusterRedisClient
All Implemented Interfaces:
Disposable, Initializable, LettuceRedisClient
public class LettuceClusterRedisClient extends AbstractLettuceRedisClient implements Initializable
Cluster 構成の Redis に接続するための LettuceRedisClient 実装クラス。

このクラスの AbstractLettuceRedisClient.getType() は、識別子 "cluster" を返す。

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected List<String>
    uriList
    接続するRedisクラスタの、各ノードURIのリスト。

  • Constructor Summary

    Constructors
    Constructor
    Description
    LettuceClusterRedisClient()
    コンストラクタ。

  • Method Summary

    Modifier and Type
    Method
    Description
    protected io.lettuce.core.cluster.RedisClusterClient
    createClient()
    RedisClusterClient のインスタンスを生成する。
    protected io.lettuce.core.cluster.api.StatefulRedisClusterConnection<byte[],byte[]>
    createConnection(io.lettuce.core.cluster.RedisClusterClient client)
    StatefulRedisClusterConnection のインスタンスを生成する。
    void
    del(String key)
    値を削除する。
    void
    dispose()
    Redisサーバーとの接続を閉じる。
    boolean
    exists(String key)
    指定したキーが存在するか確認する。
    byte[]
    get(String key)
    値を取得する。
    void
    initialize()
    初期化処理を行う。
    void
    pexpire(String key, long milliseconds)
    キーの有効期限を設定する。
    void
    pexpireat(String key, long milliseconds)
    キーの有効期限をUTC時間で設定する
    long
    pttl(String key)
    キーの残りの生存期間を取得する。
    void
    set(String key, byte[] value)
    値を保存する。
    void
    setUriList(List<String> uriList)
    接続するRedisクラスタの、各ノードのURIをリストで設定する。

    Methods inherited from class nablarch.integration.redisstore.lettuce.AbstractLettuceRedisClient

    encodeKey, getType

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • uriList

      protected List<String> uriList
      接続するRedisクラスタの、各ノードURIのリスト。

  • Constructor Details

    • LettuceClusterRedisClient

      public LettuceClusterRedisClient()
      コンストラクタ。

  • Method Details

    • set

      public void set(String key, byte[] value)
      Description copied from interface: LettuceRedisClient
      値を保存する。
      Specified by:
      set in interface LettuceRedisClient
      Parameters:
      key - キー
      value - 値

    • pexpire

      public void pexpire(String key, long milliseconds)
      Description copied from interface: LettuceRedisClient
      キーの有効期限を設定する。
      Specified by:
      pexpire in interface LettuceRedisClient
      Parameters:
      key - キー
      milliseconds - 有効期限（ミリ秒）

    • pexpireat

      public void pexpireat(String key, long milliseconds)
      Description copied from interface: LettuceRedisClient
      キーの有効期限をUTC時間で設定する
      Specified by:
      pexpireat in interface LettuceRedisClient
      Parameters:
      key - キー
      milliseconds - UTC時間で指定された有効期限（ミリ秒）

    • pttl

      public long pttl(String key)
      Description copied from interface: LettuceRedisClient
      キーの残りの生存期間を取得する。

      キーに有効期限が設定されていない場合は -1 を返し、 キーが存在しない場合は -2 を返す。

      Specified by:
      pttl in interface LettuceRedisClient
      Parameters:
      key - キー
      Returns:
      残りの生存期間（ミリ秒）

    • get

      public byte[] get(String key)
      Description copied from interface: LettuceRedisClient
      値を取得する。

      該当するキーが存在しない場合は null を返す。

      Specified by:
      get in interface LettuceRedisClient
      Parameters:
      key - キー
      Returns:
      値

    • del

      public void del(String key)
      Description copied from interface: LettuceRedisClient
      値を削除する。
      Specified by:
      del in interface LettuceRedisClient
      Parameters:
      key - キー

    • exists

      public boolean exists(String key)
      Description copied from interface: LettuceRedisClient
      指定したキーが存在するか確認する。
      Specified by:
      exists in interface LettuceRedisClient
      Parameters:
      key - キー
      Returns:
      キーが存在する場合は true

    • setUriList

      public void setUriList(List<String> uriList)
      接続するRedisクラスタの、各ノードのURIをリストで設定する。

      URIの書式については、Lettuceのドキュメントを参照。

      Parameters:
      uriList - 各ノードのURIのリスト

    • initialize

      public void initialize()
      初期化処理を行う。

      このメソッドは、 createClient() と createConnection(RedisClusterClient) メソッドを使って RedisClusterClient と StatefulRedisClusterConnection のインスタンスを生成している。
      これらのインスタンスの設定を任意にカスタマイズしたい場合は、このクラスを継承したサブクラスを作り、 それぞれの create メソッドをオーバーライドすること。

      Specified by:
      initialize in interface Initializable

    • createClient

      protected io.lettuce.core.cluster.RedisClusterClient createClient()
      RedisClusterClient のインスタンスを生成する。
      Returns:
      生成された RedisClusterClient

    • createConnection

      protected io.lettuce.core.cluster.api.StatefulRedisClusterConnection<byte[],byte[]> createConnection(io.lettuce.core.cluster.RedisClusterClient client)
      StatefulRedisClusterConnection のインスタンスを生成する。
      Parameters:
      client - createClient() で生成された RedisClusterClient インスタンス
      Returns:
      生成された StatefulRedisClusterConnection

    • dispose

      public void dispose()
      Description copied from interface: LettuceRedisClient
      Redisサーバーとの接続を閉じる。
      Specified by:
      dispose in interface Disposable
      Specified by:
      dispose in interface LettuceRedisClient