Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); replicator.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if (event instanceof KeyStringValueString) { KeyStringValueString kv = (KeyStringValueString) event; System.out.println(new String(kv.getKey())); System.out.println(new String(kv.getValue())); } else { // ... } } }); replicator.open();

Replicator r = new RedisReplicator("redis:///path/to/dump.rdb"); r.setRdbVisitor(new DumpRdbVisitor(r)); r.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if (!(event instanceof DumpKeyValuePair)) return; DumpKeyValuePair dkv = (DumpKeyValuePair) event; byte[] serialized = dkv.getValue(); // We can use the Redis RESTORE command to migrate this serialized value to another Redis instance. } }); r.open();

Replicator r = new RedisReplicator("redis:///path/to/dump.rdb"); r.setRdbVisitor(new SkipRdbVisitor(r)); r.open();

Replicator r = new RedisReplicator("redis://127.0.0.1:6379"); r.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { System.out.println(event); } }); r.open();

Replicator r = new RedisReplicator("redis://127.0.0.1:6379?enableScan=yes&scanStep=256"); r.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { System.out.println(event); } }); r.open();

@CommandSpec(command = "APPEND") public static class YourAppendCommand extends AbstractCommand { private final String key; private final String value; public YourAppendCommand(String key, String value) { this.key = key; this.value = value; } public String getKey() { return key; } public String getValue() { return value; } }

public class YourAppendParser implements CommandParser<YourAppendCommand> { @Override public YourAppendCommand parse(Object[] command) { return new YourAppendCommand(new String((byte[]) command[1], UTF_8), new String((byte[]) command[2], UTF_8)); } }

Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); replicator.addCommandParser(CommandName.name("APPEND"), new YourAppendParser());

replicator.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if(event instanceof YourAppendCommand){ YourAppendCommand appendCommand = (YourAppendCommand)event; // Your code goes here } } });

public class HelloTypeModuleParser implements ModuleParser<HelloTypeModule> { @Override public HelloTypeModule parse(RedisInputStream in, int version) throws IOException { DefaultRdbModuleParser parser = new DefaultRdbModuleParser(in); int elements = parser.loadUnsigned(version).intValue(); long[] ary = new long[elements]; int i = 0; while (elements-- > 0) { ary[i++] = parser.loadSigned(version); } return new HelloTypeModule(ary); } } public class HelloTypeModule implements Module { private final long[] value; public HelloTypeModule(long[] value) { this.value = value; } public long[] getValue() { return value; } }

public class HelloTypeParser implements CommandParser<HelloTypeCommand> { @Override public HelloTypeCommand parse(Object[] command) { String key = new String((byte[]) command[1], Constants.UTF_8); long value = Long.parseLong(new String((byte[]) command[2], Constants.UTF_8)); return new HelloTypeCommand(key, value); } } @CommandSpec(command = "hellotype.insert") public class HelloTypeCommand extends AbstractCommand { private final String key; private final long value; public long getValue() { return value; } public String getKey() { return key; } public HelloTypeCommand(String key, long value) { this.key = key; this.value = value; } }

public static void main(String[] args) throws IOException { Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); replicator.addCommandParser(CommandName.name("hellotype.insert"), new HelloTypeParser()); replicator.addModuleParser("hellotype", 0, new HelloTypeModuleParser()); replicator.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if (event instanceof KeyStringValueModule) { System.out.println(event); } if (event instanceof HelloTypeCommand) { System.out.println(event); } } }); replicator.open(); }

Replicator r = new RedisReplicator("redis://127.0.0.1:6379"); r.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if (event instanceof KeyStringValueStream) { KeyStringValueStream kv = (KeyStringValueStream)event; // Key String key = kv.getKey(); // Stream Stream stream = kv.getValueAsStream(); // Last stream ID stream.getLastId(); // Entries NavigableMap<Stream.ID, Stream.Entry> entries = stream.getEntries(); // Optional: Groups for (Stream.Group group : stream.getGroups()) { // Group PEL (Pending Entries List) NavigableMap<Stream.ID, Stream.Nack> gpel = group.getPendingEntries(); // Consumers for (Stream.Consumer consumer : group.getConsumers()) { // Consumer PEL (Pending Entries List) NavigableMap<Stream.ID, Stream.Nack> cpel = consumer.getPendingEntries(); } } } } }); r.open();

Replicator replicator = new RedisReplicator("127.0.0.1", 6379, Configuration.defaultSetting()); Replicator replicator = new RedisReplicator(new File("/path/to/dump.rdb"), FileType.RDB, Configuration.defaultSetting()); Replicator replicator = new RedisReplicator(new File("/path/to/appendonly.aof"), FileType.AOF, Configuration.defaultSetting()); Replicator replicator = new RedisReplicator(new File("/path/to/appendonly.aof"), FileType.MIXED, Configuration.defaultSetting());

Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); Replicator replicator = new RedisReplicator("redis:///path/to/dump.rdb"); Replicator replicator = new RedisReplicator("redis:///path/to/appendonly.aof"); // Configuration setting example Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379?authPassword=foobared&readTimeout=10000&ssl=yes"); Replicator replicator = new RedisReplicator("redis:///path/to/dump.rdb?rateLimit=1000000"); Replicator replicator = new RedisReplicator("rediss://user:pass@127.0.0.1:6379?rateLimit=1000000");

Configuration.defaultSetting().setVerbose(true); // As a Redis URI parameter "redis://127.0.0.1:6379?verbose=yes"

System.setProperty("javax.net.ssl.keyStore", "/path/to/keystore"); System.setProperty("javax.net.ssl.keyStorePassword", "password"); System.setProperty("javax.net.ssl.keyStoreType", "your_type"); System.setProperty("javax.net.ssl.trustStore", "/path/to/truststore"); System.setProperty("javax.net.ssl.trustStorePassword", "password"); System.setProperty("javax.net.ssl.trustStoreType", "your_type"); Configuration.defaultSetting().setSsl(true); // Optional settings Configuration.defaultSetting().setSslSocketFactory(sslSocketFactory); Configuration.defaultSetting().setSslParameters(sslParameters); Configuration.defaultSetting().setHostnameVerifier(hostnameVerifier); // As a Redis URI parameter "redis://127.0.0.1:6379?ssl=yes" "rediss://127.0.0.1:6379"

RedisSslContextFactory factory = new RedisSslContextFactory(); factory.setKeyStorePath("/path/to/redis/tests/tls/redis.p12"); factory.setKeyStoreType("pkcs12"); factory.setKeyStorePassword("password"); factory.setTrustStorePath("/path/to/redis/tests/tls/redis.p12"); factory.setTrustStoreType("pkcs12"); factory.setTrustStorePassword("password"); SslConfiguration ssl = SslConfiguration.defaultSetting().setSslContextFactory(factory); Replicator replicator = new RedisReplicator("rediss://127.0.0.1:6379", ssl);

Configuration.defaultSetting().setAuthUser("default"); Configuration.defaultSetting().setAuthPassword("foobared"); // As a Redis URI parameter "redis://127.0.0.1:6379?authPassword=foobared&authUser=default" "redis://default:foobared@127.0.0.1:6379"

Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); final long start = System.currentTimeMillis(); final AtomicInteger acc = new AtomicInteger(0); replicator.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if(event instanceof PreRdbSyncEvent) { System.out.println("pre rdb sync"); } else if(event instanceof PostRdbSyncEvent) { long end = System.currentTimeMillis(); System.out.println("time elapsed:" + (end - start)); System.out.println("rdb event count:" + acc.get()); } else { acc.incrementAndGet(); } } }); replicator.open();

System.setProperty("javax.net.ssl.keyStore", "/path/to/redis/tests/tls/redis.p12"); System.setProperty("javax.net.ssl.keyStorePassword", "password"); System.setProperty("javax.net.ssl.keyStoreType", "pkcs12"); System.setProperty("javax.net.ssl.trustStore", "/path/to/redis/tests/tls/redis.p12"); System.setProperty("javax.net.ssl.trustStorePassword", "password"); System.setProperty("javax.net.ssl.trustStoreType", "pkcs12"); Replicator replicator = new RedisReplicator("rediss://127.0.0.1:6379");

Replicator replicator = new RedisReplicator("redis://user:pass@127.0.0.1:6379");

Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); replicator.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if (event instanceof Function) { Function function = (Function) event; function.getCode(); // Your code goes here } } }); replicator.open();

Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); replicator.setRdbVisitor(new DumpRdbVisitor(replicator)); replicator.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if (event instanceof DumpFunction) { DumpFunction function = (DumpFunction) event; byte[] serialized = function.getSerialized(); // Your code goes here // You can use FUNCTION RESTORE to restore the serialized data to a target Redis instance } } }); replicator.open();

Replicator replicator = new RedisReplicator("redis://127.0.0.1:6379"); replicator.addEventListener(new EventListener() { @Override public void onEvent(Replicator replicator, Event event) { if (event instanceof KeyStringValueTTLHash) { KeyStringValueTTLHash skv = (KeyStringValueTTLHash) event; // Key byte[] key = skv.getKey(); // TTL Hash Map<byte[], TTLValue> ttlHash = skv.getValue(); for (Map.Entry<byte[], TTLValue> entry : ttlHash.entrySet()) { System.out.println("field: " + Strings.toString(entry.getKey())); System.out.println("value: " + Strings.toString(entry.getValue().getValue())); System.out.println("field ttl: " + entry.getValue().getExpires()); } } } }); replicator.open();