一个由Java实现的游戏服务器端框架，可快速开发出易维护、高性能、高扩展能力的游戏服务器

/* * Copyright © 2018 www.noark.xyz All Rights Reserved. * * 感谢您选择Noark框架，希望我们的努力能为您提供一个简单、易用、稳定的服务器端框架 ！ * 除非符合Noark许可协议，否则不得使用该文件，您可以下载许可协议文件： * * http://www.noark.xyz/LICENSE * * 1.未经许可，任何公司及个人不得以任何方式或理由对本框架进行修改、使用和传播; * 2.禁止在本项目或任何子项目的基础上发展任何派生版本、修改版本或第三方版本; * 3.无论你对源代码做出任何修改和改进，版权都归Noark研发团队所有，我们保留所有权利; * 4.凡侵犯Noark版权等知识产权的，必依法追究其法律责任，特此郑重法律声明！ */ package xyz.noark.redis; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; import redis.clients.jedis.JedisPubSub; import redis.clients.jedis.params.SetParams; import redis.clients.jedis.resps.Tuple; import xyz.noark.core.exception.ServerBootstrapException; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import static xyz.noark.log.LogHelper.logger; /** * Redis操作类. * * @author 小流氓[176543888@qq.com] * @since 3.0 */ public class Redis implements ValueOperations { /** * 默认超时（毫秒） */ private static final int DEFAULT_TIMEOUT = 3000; /** * 默认DB */ private static final int DEFAULT_INDEX = 0; /** * Ping-Pong 响应值 */ private static final String PONG = "PONG"; /** * REDIS链接池 */ private final JedisPool pool; public Redis(String host, int port) { this(host, port, DEFAULT_INDEX); } public Redis(String host, int port, int database) { this(host, port, null, database); } public Redis(String host, int port, String password) { this(host, port, password, DEFAULT_INDEX); } public Redis(String host, int port, String password, int index) { this.pool = new JedisPool(new JedisPoolConfig(), host, port, DEFAULT_TIMEOUT, password, index); logger.info("redis info. host={},port={},database={}", host, port, index); } public Redis(JedisPool pool) { this.pool = pool; } public Redis ping() { try (Jedis j = pool.getResource()) { if (PONG.equals(j.ping())) { logger.info("Redis链接正常."); } else { logger.warn("Redis链接异常."); } } catch (Exception e) { throw new ServerBootstrapException("Redis ping exception.", e); } return this; } // ------------------------------Key相关命令------------------------------ /** * 删除给定的一个或多个key. * <p> * 可用版本： &gt;= 1.0.0<br> * 时间复杂度： O(N)， N 为被删除的 key 的数量。<br> * 删除单个字符串类型的 key ，时间复杂度为O(1)。<br> * 删除单个列表、集合、有序集合或哈希表类型的 key ，时间复杂度为O(M)， M 为以上数据结构内的元素数量。 * <p> * 不存在的 key 会被忽略。 * * @param keys 一个或多个key * @return 被删除 key 的数量 */ public long del(String... keys) { try (Jedis jedis = pool.getResource()) { return jedis.del(keys); } } /** * 序列化指定的键key，并返回被序列化的值，使用{@link #restore(String, long, byte[])}命令可以将这个值反序列化为Redis键. * <p> * 序列化生成的值有以下几个特点： * <p> * 它带有 64 位的校验和，用于检测错误， RESTORE 在进行反序列化之前会先检查校验和。<br> * 值的编码格式和 RDB 文件保持一致。<br> * RDB版本会被编码在序列化值当中，如果因为Redis的版本不同造成RDB格式不兼容，那么Redis会拒绝对这个值进行反序列化操作。<br> * 序列化的值不包括任何生存时间信息。 * <p> * 可用版本： &gt;= 2.6.0<br> * 时间复杂度：<br> * 查找给定键的复杂度为O(1)，对键进行序列化的复杂度为 * O(N*M)，其中N是构成key的Redis对象的数量，而M则是这些对象的平均大小。<br> * 如果序列化的对象是比较小的字符串，那么复杂度为 O(1) 。<br> * * @param key 指定的键 * @return 如果key不存在，那么返回null,否则，返回序列化之后的值。 */ public byte[] dump(String key) { try (Jedis jedis = pool.getResource()) { return jedis.dump(key); } } /** * 反序列化给定的序列化值，并将它和给定的key关联。 * <p> * RESTORE在执行反序列化之前会先对序列化值的RDB版本和数据校验和进行检查，如果RDB版本不相同或者数据不完整的话，那么 * RESTORE会拒绝进行反序列化，并返回一个错误。 * <p> * 更多信息可以参考{@link #dump(String)}命令。 * <p> * 可用版本： &gt;= 2.6.0<br> * 时间复杂度：<br> * 查找给定键的复杂度为 O(1)，对键进行反序列化的复杂度为 * O(N*M)，其中N是构成key的Redis对象的数量，而M则是这些对象的平均大小。<br> * 有序集合(sorted set)的反序列化复杂度为 O(N*M*log(N)) ，因为有序集合每次插入的复杂度为 O(log(N)) 。<br> * 如果反序列化的对象是比较小的字符串，那么复杂度为 O(1) 。<br> * * @param key 指定的键 * @param ttl 以毫秒为单位为key设置生存时间；如果ttl为 0 ，那么不设置生存时间。 * @param serializedValue 要反序列化的字节数组 * @return 如果反序列化成功那么返回OK，否则返回一个错误。 */ public String restore(final String key, final long ttl, final byte[] serializedValue) { try (Jedis jedis = pool.getResource()) { return jedis.restore(key, ttl, serializedValue); } } /** * 判定指定的键是否存在。 * <p> * 可用版本： &gt;= 1.0.0<br> * 时间复杂度： O(1) * * @param key 指定的键 * @return 存在返回true, 否则返回false. */ public boolean exists(final String key) { try (Jedis jedis = pool.getResource()) { return jedis.exists(key); } } /** * 给指定键Key设置生存时间，当key过期时(生存时间为 0)，它会被自动删除。 * <p> * 更新生存时间<br> * 可以对一个已经带有生存时间的 key 执行 EXPIRE 命令，新指定的生存时间会取代旧的生存时间。 * <p> * 可用版本： &gt;= 1.0.0<br> * 时间复杂度： O(1) * * @param key 指定键 * @param seconds 秒 * @return 设置成功返回 1 。 当key不存在或者不能为 key设置生存时间时，返回 0 。 */ public long expire(final String key, long seconds) { try (Jedis jedis = pool.getResource()) { return jedis.expire(key, seconds); } } /** * EXPIREAT 的作用和 {@link Redis#expire(String, long)} 类似，都用于为key设置生存时间。<br> * 不同在于EXPIREAT命令接受的时间参数是UNIX时间戳(unix timestamp)。 * <p> * 可用版本： &gt;= 1.2.0<br> * 时间复杂度： O(1) * * @param key 指定键 * @param unixTime UNIX时间戳 * @return 如果生存时间设置成功，返回 1 。 当key不存在或没办法设置生存时间，返回 0 。 */ public long expireAt(final String key, long unixTime) { try (Jedis jedis = pool.getResource()) {