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 and Description
protected java.util.List<java.lang.String>	uriList 接続するRedisクラスタの、各ノードURIのリスト。

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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(java.lang.String key) 値を削除する。
void	dispose() Redisサーバーとの接続を閉じる。
boolean	exists(java.lang.String key) 指定したキーが存在するか確認する。
byte[]	get(java.lang.String key) 値を取得する。
void	initialize() 初期化処理を行う。
void	pexpire(java.lang.String key, long milliseconds) キーの有効期限を設定する。
void	pexpireat(java.lang.String key, long milliseconds) キーの有効期限をUTC時間で設定する
long	pttl(java.lang.String key) キーの残りの生存期間を取得する。
void	set(java.lang.String key, byte[] value) 値を保存する。
void	setUriList(java.util.List<java.lang.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 Detail

uriList

protected java.util.List<java.lang.String> uriList

接続するRedisクラスタの、各ノードURIのリスト。

Constructor Detail

LettuceClusterRedisClient

public LettuceClusterRedisClient()

コンストラクタ。

Method Detail

set

public void set(java.lang.String key,
                byte[] value)

Description copied from interface: LettuceRedisClient

値を保存する。

Specified by:

set in interface LettuceRedisClient

Parameters:

key - キー

value - 値

pexpire

public void pexpire(java.lang.String key,
                    long milliseconds)

Description copied from interface: LettuceRedisClient

キーの有効期限を設定する。

Specified by:

pexpire in interface LettuceRedisClient

Parameters:

key - キー

milliseconds - 有効期限（ミリ秒）

pexpireat

public void pexpireat(java.lang.String key,
                      long milliseconds)

Description copied from interface: LettuceRedisClient

キーの有効期限をUTC時間で設定する

Specified by:

pexpireat in interface LettuceRedisClient

Parameters:

key - キー

milliseconds - UTC時間で指定された有効期限（ミリ秒）

pttl

public long pttl(java.lang.String key)

Description copied from interface: LettuceRedisClient

キーの残りの生存期間を取得する。

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

Specified by:

pttl in interface LettuceRedisClient

Parameters:

key - キー

Returns:

残りの生存期間（ミリ秒）

get

public byte[] get(java.lang.String key)

Description copied from interface: LettuceRedisClient

値を取得する。

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

Specified by:

get in interface LettuceRedisClient

Parameters:

key - キー

Returns:

値

del

public void del(java.lang.String key)

Description copied from interface: LettuceRedisClient

値を削除する。

Specified by:

del in interface LettuceRedisClient

Parameters:

key - キー

exists

public boolean exists(java.lang.String key)

Description copied from interface: LettuceRedisClient

指定したキーが存在するか確認する。

Specified by:

exists in interface LettuceRedisClient

Parameters:

key - キー

Returns:

キーが存在する場合は true

setUriList

public void setUriList(java.util.List<java.lang.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