nablarch.integration.redisstore.lettuce

Class LettuceMasterReplicaRedisClient

java.lang.Object

nablarch.integration.redisstore.lettuce.AbstractLettuceRedisClient

nablarch.integration.redisstore.lettuce.LettuceMasterReplicaRedisClient

All Implemented Interfaces:

Disposable, Initializable, LettuceRedisClient

@Published(tag="architect")
public class LettuceMasterReplicaRedisClient
extends AbstractLettuceRedisClient
implements Initializable

Master/Replica 構成の Redis に接続するための LettuceRedisClient 実装。

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

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	uri 接続するRedisサーバーのURI。

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected io.lettuce.core.RedisClient	createClient() RedisClient のインスタンスを生成する。
protected io.lettuce.core.masterreplica.StatefulRedisMasterReplicaConnection<byte[],byte[]>	createConnection(io.lettuce.core.RedisClient client) StatefulRedisMasterReplicaConnection のインスタンスを生成する。
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	setUri(java.lang.String uri) 接続する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

uri

protected java.lang.String uri

接続するRedisサーバーのURI。

Constructor Detail

LettuceMasterReplicaRedisClient

public LettuceMasterReplicaRedisClient()

コンストラクタ。

Method Detail

setUri

public void setUri(java.lang.String uri)

接続するRedisサーバーのURIを設定する。

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

Parameters:

uri - 接続するRedisサーバーのURI

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

initialize

public void initialize()

初期化処理を行う。

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

Specified by:

initialize in interface Initializable

createClient

protected io.lettuce.core.RedisClient createClient()

RedisClient のインスタンスを生成する。

Returns:

生成された RedisClient

createConnection

protected io.lettuce.core.masterreplica.StatefulRedisMasterReplicaConnection<byte[],byte[]> createConnection(io.lettuce.core.RedisClient client)

StatefulRedisMasterReplicaConnection のインスタンスを生成する。

Parameters:

client - createClient() で生成された RedisClient インスタンス

Returns:

生成された StatefulRedisMasterReplicaConnection

dispose

public void dispose()

Description copied from interface: LettuceRedisClient

Redisサーバーとの接続を閉じる。

Specified by:

dispose in interface Disposable

Specified by:

dispose in interface LettuceRedisClient