Gitee 极速下载/jedipus

Jedipus

Jedipus is a Redis 3.2+ Java 8 client that manages client object pools and command execution.

final RedisClientExecutor rce = RedisClientExecutor.startBuilding()
  .createPooled(() -> Node.create("localhost", 6379));
// SET 42 107.6
rce.accept(client -> client.sendCmd(Cmds.SET, "42", "107.6"));
// GET 42
final String temp = rce.apply(client -> client.sendCmd(Cmds.GET, "42"));
if (temp.equals("107.6")) {
  System.out.println("Showers' ready, don't forget your towel.");
}
// ...
rce.close();

Features

Executes Consumer<RedisClient> and Function<RedisClient, R> lambdas.
Flexible generic or primitive return types to match the dynamic return type design of Redis.
Flexible command interface allows for calling Modules.
Performance focused:
- Minimal enforced (de)serialization. Write directly to the socket output stream buffer or socket output stream, and retrieve raw responses.
- Fire-And-Forget support using CLIENT REPLY ON|OFF|SKIP.
- Primitive long, long[] return types to avoid auto boxing, nice for BITFIELD commands.
- Locking is only applied to threads which are accessing slots that are migrating; there is no known node; or for which a client connection continually cannot be established; all of which will trigger a slot cache refresh.
- Load balance read-only requests across master and/or slave pools.
- Reuse known slot integers for direct O(1) primitive array access to a corresponding RedisClient pool.
Zero dependencies and PGP signed releases. Bintray verifies signatures automatically. See verifying your Jedipus jar.
SSL support.
Optional user supplied Node -> ClientPool<RedisClient> factories.
Optional user supplied LoadBalancedPools factories. By default, a round robin strategy is used.
Client side HostPort mapping to internally-networked clusters.
Configurable RedisConnectionException retry delays per cluster node. By default, an exponential back-off delay is used.
Execute directly against known or random nodes.
Lua script utilities.
Frequent point releases for new features, utilities and bug fixes.
Pub/Sub support.
Cluster partition handling on slot cache discovery.

Read Modes

Read modes control how pools to master and slave nodes are managed.

MASTER: Only pools to master nodes are maintained.
SLAVES: Only pools to slave nodes are maintained. Calls are load balanced across slave pools.
MIXED_SLAVES: Pools are managed for both masters and slave nodes. Calls are only load balanced across slave pools. Individual calls can be overridden with ReadMode.MASTER or ReadMode.MIXED. When no slave pools are available the master pool is used.
MIXED: Pools are managed for both masters and slave nodes. Calls are load balanced across both master and slave pools. Individual calls can be overridden with ReadMode.MASTER or ReadMode.SLAVES. When overriding with ReadMode.SLAVES and no slave pools are available the master pool is used.

Gotchas

All commands issued within a single lambda should be idempotent. If they are not, split them into separate calls, use a pipelined transaction, use a Lua script, or compile a C Module.
ASK redirects within pipelines are not supported, instead an UnhandledAskNodeException is thrown. The reason for this is that even if all of the keys point to the same slot Redis requires a new ASKING request in front of each command. It is cleaner to let the user handle recovery rather than injecting ASKING requests internally. See this integration test for an example of how to recover. MOVE redirects are supported within pipelines.
If only using CLIENT REPLY OFF your client will be oblivious to slot migrations. If you want to be resilient to re-partitioning, refresh the slot cache at a frequency you can tolerate.

Dependency Management

repositories {
   jcenter()
}

dependencies {
   compile 'com.fabahaba:jedipus:+'
}

Basic Usage Demos

Note: The examples auto close the RedisClusterExecutor but you probably want it to be a long lived object.

try (final RedisClusterExecutor rce =
    RedisClusterExecutor.startBuilding(Node.create("localhost", 7000)).create()) {

  final String skey = "skey";

  final FutureLongReply numMembers = rce.applyPipeline(skey, pipeline -> {
    // Fire-And-Forget: skip() issues a pipelined CLIENT REPLY SKIP
    pipeline.skip().sendCmd(Cmds.SADD, skey, "member");
    // Optional primitive return types.
    final FutureLongReply futureReply = pipeline.sendCmd(Cmds.SCARD.prim(), skey);
    pipeline.sync();
    // Check reply to leverage library error handling.
    return futureReply.checkReply();
  });

  // This long was never auto boxed.
  final long primitiveNumMembers = numMembers.getAsLong();
  System.out.format("'%s' has %d members.%n", skey, primitiveNumMembers);
}

try (final RedisClusterExecutor rce =
    RedisClusterExecutor.startBuilding(Node.create("localhost", 7000))
        .withReadMode(ReadMode.MIXED_SLAVES).create()) {

  // Hash tagged pipelined transaction.
  final String hashTag = CRC16.createNameSpacedHashTag("HT");
  final int slot = CRC16.getSlot(hashTag);

  final String fooKey = hashTag + "foo";

  // Implicit multi applied.
  final Object[] sortedBars = rce.applyPipelinedTransaction(ReadMode.MASTER, slot, pipeline -> {

    pipeline.sendCmd(Cmds.ZADD, fooKey, "NX", "-1", "barowitch");
    // New key will still be hashtag pinned to the same slot/node.
    pipeline.sendCmd(Cmds.ZADD, fooKey + "a", "XX", "-2", "barowitch");
    // Handle different ZADD return types with flexible command design.
    pipeline.sendCmd(Cmds.ZADD_INCR, fooKey + "b", "XX", "INCR", "-1", "barowitch");
    // Utilities to avoid extra array creation.
    pipeline.sendCmd(Cmds.ZADD, ZAddParams.fillNX(new byte[][] {RESP.toBytes(fooKey), null,
        RESP.toBytes(.37), RESP.toBytes("barinsky")}));
    pipeline.sendCmd(Cmds.ZADD, fooKey, "42", "barikoviev");

    final FutureReply<Object[]> barsReply =
        pipeline.sendCmd(Cmds.ZRANGE_WITHSCORES, fooKey, "0", "-1", "WITHSCORES");

    // Note: Pipelines and transactions (multi) are merely started by the the library.
    // 'exec' and 'sync' must be called by the user.
    pipeline.execSync();

    // Note: Replys must be captured within this lambda closure in order to properly
    // leverage error handling.
    return barsReply.get();
  });

  // '{HT}:foo': [barowitch (-1.0), barinsky (0.37), barikoviev (42.0)]
  System.out.format("%n'%s':", fooKey);

  for (int i = 0; i < sortedBars.length;) {
    System.out.format(" %s (%s)", RESP.toString(sortedBars[i++]),
        RESP.toDouble(sortedBars[i++]));
  }

  // Optional primitive return types; no auto boxing!
  final long numRemoved =
      rce.applyPrim(ReadMode.MASTER, slot, client -> client.sendCmd(Cmds.DEL.prim(), fooKey));
  System.out.format("%nRemoved %d keys.%n", numRemoved);
}

try (final RedisClusterExecutor rce =
    RedisClusterExecutor.startBuilding(Node.create("localhost", 7000))
        .withReadMode(ReadMode.MIXED_SLAVES).create()) {

  // Ping-Pong all masters.
  rce.acceptAllMasters(
      master -> System.out.format("%s from %s%n", master.sendCmd(Cmds.PING), master.getNode()));

  // Ping-Pong all slaves concurrently.
  rce.applyAllSlaves(
      slave -> String.format("%s from %s", slave.sendCmd(Cmds.PING, "Howdy"), slave.getNode()),
      1, ForkJoinPool.commonPool()).stream().map(CompletableFuture::join)
      .forEach(System.out::println);
}

Gitee 极速下载 / jedipus

Jedipus

Features

Read Modes

Gotchas

Dependency Management

Basic Usage Demos

简介

发行版

贡献者

近期动态

Gitee 极速下载 / jedipus .gitee-modal { width: 500px !important; }

Jedipus

Features

Read Modes

Gotchas

Dependency Management

Basic Usage Demos

简介

发行版

贡献者

近期动态

搜索帮助

Gitee 极速下载 / jedipus