60.6. Usage
また、利用可能な 単体テスト も参照してください。
Redis producer
from(“direct:start”)
.setHeader("CamelRedis.Key", constant(key))
.setHeader("CamelRedis.Value", constant(value))
.to("spring-redis://host:port?command=SET&redisTemplate=#redisTemplate");
from(“direct:start”)
.setHeader("CamelRedis.Key", constant(key))
.setHeader("CamelRedis.Value", constant(value))
.to("spring-redis://host:port?command=SET&redisTemplate=#redisTemplate");
Redis consumer
from("spring-redis://host:port?command=SUBSCRIBE&channels=myChannel")
.log("Received message: ${body}");
from("spring-redis://host:port?command=SUBSCRIBE&channels=myChannel")
.log("Received message: ${body}");
'//host:port' は、実行中の Redis サーバーの URL アドレスです。
60.6.1. Redis producer によって評価されるメッセージヘッダー リンクのコピーリンクがクリップボードにコピーされました!
producer はサーバーにコマンドを発行し、各コマンドには特定のタイプの異なるパラメーターセットがあります。コマンド実行の結果は、メッセージボディーで返されます。
| ハッシュコマンド | 説明 | パラメーター | 結果 |
|---|---|---|---|
|
| ハッシュフィールドの文字列値を設定します。 |
| Void |
|
| ハッシュフィールドの値を取得します。 |
| 文字列 |
|
| フィールドが存在しない場合にのみ、ハッシュフィールドの値を設定します。 |
| Void |
|
| 複数のハッシュフィールドを複数の値に設定します。 |
| Void |
|
| 指定されたすべてのハッシュフィールドの値を取得します。 |
| Collection<Object> |
|
| 指定された数だけハッシュフィールドの整数値をインクリメントします。 |
| ロング |
|
| ハッシュフィールドが存在するかどうかを判断します。 |
| ブール値 |
|
| 1 つ以上のハッシュフィールドを削除します。 |
| Void |
|
| ハッシュ内のフィールド数を取得します。 |
| ロング |
|
| ハッシュ内のすべてのフィールドを取得します。 |
| Set<String> |
|
| ハッシュ内のすべての値を取得します。 |
| Collection<Object> |
|
| ハッシュ内のすべてのフィールドと値を取得します。 |
| Map<String, Object> |
| リストコマンド | 説明 | パラメーター | 結果 |
|---|---|---|---|
| RPUSH | 1 つまたは複数の値をリストに追加します。 |
| ロング |
| RPUSHX | リストが存在する場合にのみ、リストに値を追加します。 |
| ロング |
| LPUSH | リストの先頭に 1 つまたは複数の値を追加します。 |
| ロング |
| LLEN | リストの長さを取得します。 |
| ロング |
| LRANGE | リストから要素の範囲を取得します。 |
| List<Object> |
| LTRIM | リストを指定された範囲にトリミングします。 |
| Void |
| LINDEX | インデックスでリストから要素を取得します。 |
| 文字列 |
| LINSERT | リスト内の別の要素の前後に要素を挿入します。 |
| ロング |
| LSET | リスト内の要素の値をそのインデックスで設定します。 |
| Void |
| LREM | リストから要素を削除します。 |
| ロング |
| LPOP | リストの最初の要素を削除して取得します。 |
| オブジェクト |
| RPOP | リストの最後の要素を削除して取得します。 |
| 文字列 |
| RPOPLPUSH | リストの最後の要素を削除し、それを別のリストに追加して返します。 |
| オブジェクト |
| BRPOPLPUSH | リストから値をポップし、それを別のリストにプッシュして返します。または利用可能になるまでブロックします。 |
| オブジェクト |
| BLPOP | リストの最初の要素を削除して取得するか、使用可能になるまでブロックします。 |
| オブジェクト |
| BRPOP | リストの最後の要素を削除して取得するか、使用可能になるまでブロックします。 |
| 文字列 |
| コマンドの設定 | 説明 | パラメーター | 結果 |
|---|---|---|---|
| SADD | 1 つまたは複数のメンバーをセットに追加します。 |
| ブール値 |
| SMEMBERS | セット内のすべてのメンバーを取得します。 |
| Set<Object> |
| SREM | セットから 1 つまたは複数のメンバーを削除します。 |
| ブール値 |
| SPOP | セットからランダムなメンバーを削除して返します。 |
| 文字列 |
| SMOVE | メンバーをあるセットから別のセットに移動します。 |
| ブール値 |
| SCARD | セット内のメンバーの数を取得します。 |
| ロング |
| SISMEMBER | 指定された値がセットのメンバーであるかどうかを判別します。 |
| ブール値 |
| SINTER | 複数のセットを交差します。 |
| Set<Object> |
| SINTERSTORE | 複数のセットを交差させ、結果のセットをキーに格納します。 |
| Void |
| SUNION | 複数のセットを追加します。 |
| Set<Object> |
| SUNIONSTORE | 複数のセットを追加し、結果のセットをキーに保存します。 |
| Void |
| SDIFF | 複数のセットを減算します。 |
| Set<Object> |
| SDIFFSTORE | 複数のセットを減算し、結果のセットをキーに格納します。 |
| Void |
| SRANDMEMBER | セットから 1 つまたは複数のランダムメンバーを取得します。 |
| 文字列 |
| 順序集合コマンド | 説明 | パラメーター | 結果 |
|---|---|---|---|
| ZADD | 並べ替えられたセットに 1 つ以上のメンバーを追加するか、すでに存在する場合はそのスコアを更新します。 |
| ブール値 |
| ZRANGE | 並べ替えられたセット内のメンバーの範囲をインデックスで返します。 |
| オブジェクト |
| ZREM | ソート済みセットから 1 つ以上のメンバーを削除します。 |
| ブール値 |
| ZINCRBY | ソート済みセットのメンバーのスコアをインクリメントします。 |
| double |
| ZRANK | 並べ替えられたセット内のメンバーのインデックスを決定します。 |
| ロング |
| ZREVRANK | スコアが高いものから低いものに並べられた、並べ替えられたセット内のメンバーのインデックスを決定します。 |
| ロング |
| ZREVRANGE | 並べ替えられたセット内のメンバーの範囲をインデックス別に返します。スコアは高いものから低いものへと並べられます。 |
| オブジェクト |
| ZCARD | ソート済みセットのメンバー数を取得します。 |
| ロング |
| ZCOUNT | 指定された値内のスコアを持つ並べ替えられたセットのメンバーをカウントします。 |
| ロング |
| ZRANGEBYSCORE | ソートされたセット内のメンバーの範囲をスコア別に返します。 |
| Set<Object> |
| ZREVRANGEBYSCORE | スコアが高いものから低いものへと並べられたスコアで、ソートされたセット内のメンバーの範囲を返します。 |
| Set<Object> |
| ZREMRANGEBYRANK | 指定されたインデックス内の並べ替えられたセットのすべてのメンバーを削除します。 |
| Void |
| ZREMRANGEBYSCORE | 指定されたスコア内の並べ替えられたセットのすべてのメンバーを削除します。 |
| Void |
| ZUNIONSTORE | 複数のソート済みセットを追加し、結果のソート済みセットを新しいキーに保存します。 |
| Void |
| ZINTERSTORE | 複数の並べ替えられたセットを交差させ、結果の並べ替えられたセットを新しいキーに格納します。 |
| Void |
| 文字列コマンド | 説明 | パラメーター | 結果 |
|---|---|---|---|
| SET | キーの文字列値を設定します。 |
| Void |
| GET | キーの値を取得する |
| オブジェクト |
| STRLEN | キーに格納されている値の長さを取得します。 |
| ロング |
| APPEND | キーに値を追加します。 |
| Integer |
| SETBIT | キーに格納されている文字列値のオフセットのビットを設定またはクリアします。 |
| Void |
| GETBIT | キーに格納されている文字列値のオフセットのビット値を返します。 |
| ブール値 |
| SETRANGE | 指定されたオフセットから始まるキーの文字列の一部を上書きします。 |
| Void |
| GETRANGE | キーに格納されている文字列の部分文字列を取得します。 |
| 文字列 |
| SETNX | キーが存在しない場合にのみ、キーの値を設定します。 |
| ブール値 |
| SETEX | キーの値と有効期限を設定します。 |
| Void |
| DECRBY | 指定された数だけキーの整数値を減らします。 |
| ロング |
| DECR | キーの整数値を 1 減らします。 |
| ロング |
| INCRBY | 指定された量だけキーの整数値を増やします。 |
| ロング |
| INCR | キーの整数値を 1 ずつ増やします。 |
| ロング |
| MGET | 指定されたすべてのキーの値を取得します。 |
| List<Object> |
| MSET | 複数のキーを複数の値に設定します。 |
| Void |
| MSETNX | キーが存在しない場合にのみ、複数のキーを複数の値に設定します。 |
| Void |
| GETSET | キーの文字列値を設定し、古い値を返します。 |
| オブジェクト |
| キーコマンド | 説明 | パラメーター | 結果 |
|---|---|---|---|
| EXISTS | キーが存在するかどうかを判断します。 |
| ブール値 |
| DEL | キーを削除します。 |
| Void |
| TYPE | キーに格納されている型を決定します。 |
| DataType |
| KEYS | 指定されたパターンに一致するすべてのキーを見つけます。 |
| Collection<String> |
| RANDOMKEY | キースペースからランダムなキーを返します。 |
| 文字列 |
| RENAME | キーの名前を変更します。 |
| Void |
| RENAMENX | 新しいキーが存在しない場合にのみ、キーの名前を変更します。 |
| ブール値 |
| EXPIRE | キーの存続時間を秒単位で設定します。 |
| ブール値 |
| SORT | リスト、セット、またはソートされたセット内の要素をソートします。 |
| List<Object> |
| PERSIST | キーから有効期限を削除します。 |
| ブール値 |
| EXPIREAT | キーの有効期限を UNIX タイムスタンプとして設定します。 |
| ブール値 |
| PEXPIRE | キーの存続時間をミリ秒単位で設定します。 |
| ブール値 |
| PEXPIREAT | ミリ秒単位で指定された UNIX タイムスタンプとしてキーの有効期限を設定します。 |
| ブール値 |
| TTL | キーの存続時間を取得します。 |
| ロング |
| MOVE | キーを別のデータベースに移動します。 |
| ブール値 |
| Geo コマンド | 説明 | パラメーター | 結果 |
|---|---|---|---|
| GEOADD | 指定された地理空間項目 (緯度、経度、名前) を指定されたキーに追加します。 |
| ロング |
| GEODIST | 指定されたキーの地理空間インデックス内にある 2 つのメンバー間の距離を返します。 |
| Distance |
| GEOHASH | 指定されたキーの地理空間インデックス内にある要素の位置を表す有効な Geohash 文字列を返します。 |
| List<String> |
| GEOPOS | 指定されたキーの地理空間インデックス内にある要素の位置 (経度、緯度) を返します。 |
| List<Point> |
| GEORADIUS | 指定されたキーの地理空間インデックス内にある、中心位置と中心からの最大距離 (半径) によって指定される境界内の要素を返します。 |
| GeoResults |
| GEORADIUSBYMEMBER | このコマンドは GEORADIUS とまったく同じですが、唯一の違いは、クエリーするエリアの中心として経度と緯度の値を取得する代わりに、指定されたキーの地理空間インデックス内にすでに存在するメンバーの名前を取得することです。 |
| GeoResults |
| その他のコマンド | 説明 | パラメーター | 結果 |
|---|---|---|---|
| MULTI | トランザクションブロックの開始をマークします。 | none | Void |
| DISCARD | MULTI の後に発行されたすべてのコマンドを破棄します。 | none | Void |
| EXEC | MULTI の後に発行されたすべてのコマンドを実行します。 | none | Void |
| WATCH | 指定されたキーを監視して、MULTI/EXEC ブロックの実行を決定します。 |
| Void |
| UNWATCH | 監視されているすべてのキーを忘れます。 | none | Void |
| ECHO | 指定された文字列をエコーします。 |
| 文字列 |
| PING | サーバーに ping を実行します。 | none | 文字列 |
| QUIT | 接続を閉じます。 | none | Void |
| PUBLISH | チャンネルにメッセージを投稿します。 |
| Void |