一、配置 Maven 依赖项

Jedis也通过Sonatype作为Maven Dependency 分发。要配置它，只需将以下 XML 代码段添加到您的 pom.xml 文件中。

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version><type>jar</type><scope>compile</scope>
</dependency>

二、基本用法示例

1、在多线程环境中使用 Jedis

您不应该使用来自不同线程的同一实例，因为会出现奇怪的错误。有时创建大量Jedis实例还不够好，因为这意味着大量的套接字和连接，这也会导致奇怪的错误。单个Jedis实例不是线程安全的！为了避免这些问题，您应该使用JedisPool，这是一个线程安全的网络连接池。如果完成后将Jedis实例返回到池中，则可以使用池可靠地创建多个Jedis示例。通过这种方式，您可以克服这些奇怪的错误并获得出色的性能。

要使用它，请初始化一个池：

JedisPool pool = new JedisPool(new JedisPoolConfig(), "localhost");

您可以将池静态存储在某个位置，它是线程安全的。

JedisPoolConfig 包括许多有用的 Redis 特定连接池默认值。JedisPool基于Commons Pool 2，所以你可能想看看Commons Pool的配置

您可以通过以下方式使用它：

/// Jedis implements Closeable. Hence, the jedis instance will be auto-closed after the last statement.
try (Jedis jedis = pool.getResource()) {/// ... do stuff here ... for examplejedis.set("foo", "bar");String foobar = jedis.get("foo");jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike"); Set<String> sose = jedis.zrange("sose", 0, -1);
}
/// ... when closing your application:
pool.close();

如果您不能在资源中使用try，您仍然可以使用Jedis.close（）。

Jedis jedis = null;
try {jedis = pool.getResource();/// ... do stuff here ... for examplejedis.set("foo", "bar");String foobar = jedis.get("foo");jedis.zadd("sose", 0, "car"); jedis.zadd("sose", 0, "bike"); Set<String> sose = jedis.zrange("sose", 0, -1);
} finally {// You have to close jedis object. If you don't close then// it doesn't release back to pool and you can't get a new// resource from pool.if (jedis != null) {jedis.close();}
}
/// ... when closing your application:
pool.close();

如果 Jedis 是从池中借来的，它将以正确的方法返回到池中，因为它已经确定发生了 JedisConnectionException。 如果 Jedis 不是从池中借来的，它将被断开并关闭。

2、设置主/从分配

启用复制

Redis 主要用于主/从分发。这意味着写入请求必须显式发送到主服务器（redis 服务器），后者将更改复制到从服务器（也是 redis 服务器）。然后，读取请求可以（但不一定）发送给从站，从而减轻了主站的负担。

您可以使用主控形状，如上所示。为了启用复制，有两种方法可以告诉从站它将是给定主服务器的“slaveOf”：

• 在 Redis 服务器的 Redis 配置文件的相应部分中指定它

• 在给定的 jedis 实例上（见上文），调用 slaveOf 方法并将 IP（或“localhost”）和端口作为参数传递：

jedis.slaveof("localhost", 6379);  //  if the master is on the same PC which runs your code
jedis.slaveof("192.168.1.35", 6379); 

注意：由于 Redis 2.6 从站默认为只读，因此对它们的写入请求将导致错误。

如果您更改该设置，它们的行为将像普通的 redis 服务器一样，并接受写入请求而不会出错，但更改不会被复制，因此，如果您混合使用 jedis 实例，这些更改有被静默覆盖的风险。

禁用复制/主服务器出现故障时，升级从属服务器

万一你的主人倒下了，你可能想提拔一个奴隶成为新的主人。您应该首先（尝试）首先禁用脱机主服务器的复制，然后，如果您有多个从站，请启用剩余从站到新主站的复制：

slave1jedis.slaveofNoOne();
slave2jedis.slaveof("192.168.1.36", 6379); 

三、高级用法

1、事务

要在Jedis中执行事务，必须将操作包装在事务块中，这与pipelining非常类似：

jedis.watch (key1, key2, ...);
Transaction t = jedis.multi();
t.set("foo", "bar");
t.exec();

注意：当你有任何返回值的方法时，你必须这样做：

Transaction t = jedis.multi();
t.set("fool", "bar");
Response<String> result1 = t.get("fool");t.zadd("foo", 1, "barowitch"); t.zadd("foo", 0, "barinsky"); t.zadd("foo", 0, "barikoviev");
Response<Set<String>> sose = t.zrange("foo", 0, -1);   // get the entire sortedset
t.exec();                                              // dont forget itString foolbar = result1.get();                       // use Response.get() to retrieve things from a Response
int soseSize = sose.get().size();                      // on sose.get() you can directly call Set methods!// List<Object> allResults = t.exec();                 // you could still get all results at once, as before

请注意，响应对象不包含调用 t.exec（） 之前的结果（它是一种未来）。忘记执行会给你例外。在最后一行中，您将看到在版本 2 之前如何处理事务/管道。您仍然可以这样做，但随后您需要从列表中提取对象，该列表还包含 Redis 状态消息。

注 2：Redis 不允许在同一事务中使用事务的中间结果。这不起作用：

// this does not work! Intra-transaction dependencies are not supported by Redis!
jedis.watch(...);
Transaction t = jedis.multi();
if(t.get("key1").equals("something"))t.set("key2", "value2");
else t.set("key", "value");

但是，有一些命令（如setnx）包含此类条件执行。这些当然在事务中得到支持。您可以使用 eval/ LUA 脚本构建自己的自定义命令。

2、Pipelining

有时您需要发送一系列不同的命令。一种非常酷的方法是使用Pipelining，它比简单的方法具有更好的性能。这样，您就可以发送命令而无需等待响应，而且您实际上可以在最后读取响应，这会更快。

Pipeline p = jedis.pipelined();
p.set("fool", "bar");
p.zadd("foo", 1, "barowitch");  p.zadd("foo", 0, "barinsky"); p.zadd("foo", 0, "barikoviev");
Response<String> pipeString = p.get("fool");
Response<Set<String>> sose = p.zrange("foo", 0, -1);
p.sync(); int soseSize = sose.get().size();
Set<String> setBack = sose.get();

3、发布/订阅

要在 Redis 中订阅频道，请创建一个 JedisPubSub 实例并在 Jedis 实例上调用订阅：

class MyListener extends JedisPubSub {public void onMessage(String channel, String message) {}public void onSubscribe(String channel, int subscribedChannels) {}public void onUnsubscribe(String channel, int subscribedChannels) {}public void onPSubscribe(String pattern, int subscribedChannels) {}public void onPUnsubscribe(String pattern, int subscribedChannels) {}public void onPMessage(String pattern, String channel, String message) {}
}MyListener l = new MyListener();jedis.subscribe(l, "foo");

请注意，订阅是一个阻塞操作，因为它将轮询 Redis 以获取调用订阅的线程上的响应。单个 JedisPubSub 实例可用于订阅多个频道。您可以在现有的 JedisPubSub 实例上调用订阅或订阅来更改您的订阅。

欢迎来到Doker,欢迎点赞和评论！或者加微信进入技术群聊！