一、配置 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 example jedis.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 example jedis.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 it String 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 做好产品，做暖心服务的数码品牌！！！
文章下方有交流学习区！一起学习进步！也可以前往官网，加入官方微信交流群！！！
你的支持和鼓励是我创作的动力❗❗❗
官网：Doker 多克; 官方旗舰店：首页-Doker 多克官方旗舰店 全品优惠
