常用命令
import com.gqshao.redis.JedisTest; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * 常用命令测试 */ public class CommandTest extends JedisTest { protected static Logger logger = LoggerFactory.getLogger(CommandTest.class); /** * keys [patten] 返回满足给定patten的所有key * dbsize 统计key的数量 * exists [key] 确认一个key是否存在,返回boolean * del [key...] 删除一个key或多个key * expire [key] [seconds] 设置一个key的过期时间(单位:秒),可多次使用来更新过期时间 * ttl [key] 检查过期时间,返回值是秒 * persist [key] 移除给定key的过期时间 * randomkey 随机返回一个key * rename [oldKey] [newKey] 重命名key,最好先用exists检测一下,不存在会抛出JedisDataException * type [key] value的类型 */ @Test public void testKeys() { // keys logger.info("test keys"); logger.info("mset keym1 value1 keym2 value2 keym3 value3 : " + jedis.mset("keym1", "value1", "keym2", "value2", "keym3", "value3")); logger.info("keys keym* : " + jedis.keys("keym*") + "\n"); // dbsize logger.info("test dbsize"); logger.info("dbsize : "+jedis.dbSize()+"\n"); // exists logger.info("test exists"); logger.info("exists keym1 : " + jedis.exists("keym1")); logger.info("exists keym4 : " + jedis.exists("keym4") + "\n"); // expire logger.info("test expire"); logger.info("expire keym3 1 : " + jedis.expire("keym3", 1)); logger.info("ttl keym3 : " + jedis.ttl("keym3")); logger.info("sleep 1500"); try { Thread.sleep(1500); } catch (InterruptedException e) { e.printStackTrace(); } logger.info("ttl keym3 : " + jedis.ttl("keym3") + "\n"); // persist logger.info("test persist"); logger.info("expire keym2 10 : " + jedis.expire("keym2", 10)); logger.info("ttl keym2 : " + jedis.ttl("keym2")); logger.info("persist keym2 : " + jedis.persist("keym2")); logger.info("ttl keym2 : " + jedis.ttl("keym2") + "\n"); // randomkey logger.info("test randomkey"); logger.info("randomkey : " + jedis.randomKey() + "\n"); // rename logger.info("test randomkey"); logger.info("rename keym2 keynew2 : " + jedis.rename("keym2", "keynew2")); logger.info("get keynew2 : " + jedis.get("keynew2") + "\n"); // type logger.info("test type"); logger.info("type keym1 : " + jedis.type("keym1")); logger.info("del keym1 keym2 keynew2 keym3 : " + jedis.del("keym1", "keym2", "keynew2", "keym3")); } /** * select [dbIndex] 显示选择数据库 * move [key] [dbIndex] 将当前数据库中的key转移到指定数据库中 * flushdb 清空当前数据库 * flushall 清空所有数据库 * dbsize 返回当前数据库里面的keys数量 */ @Test public void testDB() { // 慎用 // jedis.flushDB(); // jedis.flushAll(); // select // 显示使用数据库0 logger.info("select 0 : " + jedis.select(0)); // move logger.info("设置kv"); logger.info("set mykey value : " + jedis.set("mykey", "foo")); logger.info("get mykey : " + jedis.get("mykey")); logger.info("将mykey移动到数据库1"); logger.info("move mykey 1 : " + jedis.move("mykey", 1)); logger.info("数据库0中查询不到"); logger.info("get mykey : " + jedis.get("mykey")); logger.info("使用数据库1"); logger.info("select 1 : " + jedis.select(1)); logger.info("get mykey : " + jedis.get("mykey") + "\n"); // dbsize logger.info("test dbsize"); logger.info("dbsize : " + jedis.dbSize()); // del logger.info("del mykey : " + jedis.del("mykey")); } }
系统命令
import com.gqshao.redis.JedisTest; import org.junit.Ignore; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import redis.clients.jedis.JedisMonitor; public class ServerTest extends JedisTest { protected static Logger logger = LoggerFactory.getLogger(ServerTest.class); /** * quit 退出连接,只对当前得到的连接有影响,不影响pool中连接 */ @Test public void testQuit() { // quit logger.info("test quit"); logger.info("quit : " + jedis.quit()); try { logger.info("ping : " + jedis.ping() + "\n"); } catch (Exception e) { logger.warn("已经退出连接"); e.printStackTrace(); } } /** * ping 测试连接是否存活 * echo 打印一些内容 * dbsize 统计key的数量 * info 获取服务器的信息和统计 * config get [parameter] 获取服务器配置信息 */ @Test public void test() { // ping logger.info("test ping"); logger.info("ping : " + jedis.ping() + "\n"); // echo logger.info("test echo"); logger.info("echo \"Hello World!\"" + jedis.echo("Hello World!") + "\n"); // dbsize logger.info("test dbsize"); logger.info("dbsize : " + jedis.dbSize()); // info logger.info("test info"); logger.info("info" + jedis.info() + "\n"); // config get logger.info("config get test"); logger.info("config get dir" + jedis.configGet("dir")); } /** * monitor 实时监控服务器 */ @Ignore @Test public void testMonitor() { new Thread(new Runnable() { public void run() { for (int i = 0; i < 100; i++) { jedis.ping(); try { Thread.sleep(200); } catch (InterruptedException e) { } } jedis.disconnect(); } }).start(); jedis.monitor(new JedisMonitor() { public void onCommand(String command) { System.out.println(command); } }); } }
INFO 查看Redis信息和状态
INFO [section] 以一种易于解释(parse)且易于阅读的格式,返回关于 Redis 服务器的各种信息和统计数值。 通过给定可选的参数 section ,可以让命令只返回某一部分的信息: server 部分记录了 Redis 服务器的信息,它包含以下域: redis_version : Redis 服务器版本 redis_git_sha1 : Git SHA1 redis_git_dirty : Git dirty flag os : Redis 服务器的宿主操作系统 arch_bits : 架构(32 或 64 位) multiplexing_api : Redis 所使用的事件处理机制 gcc_version : 编译 Redis 时所使用的 GCC 版本 process_id : 服务器进程的 PID run_id : Redis 服务器的随机标识符(用于 Sentinel 和集群) tcp_port : TCP/IP 监听端口 uptime_in_seconds : 自 Redis 服务器启动以来,经过的秒数 uptime_in_days : 自 Redis 服务器启动以来,经过的天数 lru_clock : 以分钟为单位进行自增的时钟,用于 LRU 管理 clients 部分记录了已连接客户端的信息,它包含以下域: connected_clients : 已连接客户端的数量(不包括通过从属服务器连接的客户端) client_longest_output_list : 当前连接的客户端当中,最长的输出列表 client_longest_input_buf : 当前连接的客户端当中,最大输入缓存 blocked_clients : 正在等待阻塞命令(BLPOP、BRPOP、BRPOPLPUSH)的客户端的数量 memory 部分记录了服务器的内存信息,它包含以下域: used_memory : 由 Redis 分配器分配的内存总量,以字节(byte)为单位 used_memory_human : 以人类可读的格式返回 Redis 分配的内存总量 used_memory_rss : 从操作系统的角度,返回 Redis 已分配的内存总量(俗称常驻集大小)。这个值和 top 、 ps等命令的输出一致。 used_memory_peak : Redis 的内存消耗峰值(以字节为单位) used_memory_peak_human : 以人类可读的格式返回 Redis 的内存消耗峰值 used_memory_lua : Lua 引擎所使用的内存大小(以字节为单位) mem_fragmentation_ratio : used_memory_rss 和 used_memory 之间的比率 mem_allocator : 在编译时指定的, Redis 所使用的内存分配器。可以是 libc 、 jemalloc 或者 tcmalloc 。 在理想情况下, used_memory_rss 的值应该只比 used_memory 稍微高一点儿。 当 rss > used ,且两者的值相差较大时,表示存在(内部或外部的)内存碎片。 内存碎片的比率可以通过 mem_fragmentation_ratio 的值看出。 当 used > rss 时,表示 Redis 的部分内存被操作系统换出到交换空间了,在这种情况下,操作可能会产生明显的延迟。 Because Redis does not have control over how its allocations are mapped to memory pages, highused_memory_rss is often the result of a spike in memory usage. 当 Redis 释放内存时,分配器可能会,也可能不会,将内存返还给操作系统。 如果 Redis 释放了内存,却没有将内存返还给操作系统,那么 used_memory 的值可能和操作系统显示的 Redis 内存占用并不一致。 查看 used_memory_peak 的值可以验证这种情况是否发生。 persistence 部分记录了跟 RDB 持久化和 AOF 持久化有关的信息,它包含以下域: loading : 一个标志值,记录了服务器是否正在载入持久化文件。 rdb_changes_since_last_save : 距离最近一次成功创建持久化文件之后,经过了多少秒。 rdb_bgsave_in_progress : 一个标志值,记录了服务器是否正在创建 RDB 文件。 rdb_last_save_time : 最近一次成功创建 RDB 文件的 UNIX 时间戳。 rdb_last_bgsave_status : 一个标志值,记录了最近一次创建 RDB 文件的结果是成功还是失败。 rdb_last_bgsave_time_sec : 记录了最近一次创建 RDB 文件耗费的秒数。 rdb_current_bgsave_time_sec : 如果服务器正在创建 RDB 文件,那么这个域记录的就是当前的创建操作已经耗费的秒数。 aof_enabled : 一个标志值,记录了 AOF 是否处于打开状态。 aof_rewrite_in_progress : 一个标志值,记录了服务器是否正在创建 AOF 文件。 aof_rewrite_scheduled : 一个标志值,记录了在 RDB 文件创建完毕之后,是否需要执行预约的 AOF 重写操作。 aof_last_rewrite_time_sec : 最近一次创建 AOF 文件耗费的时长。 aof_current_rewrite_time_sec : 如果服务器正在创建 AOF 文件,那么这个域记录的就是当前的创建操作已经耗费的秒数。 aof_last_bgrewrite_status : 一个标志值,记录了最近一次创建 AOF 文件的结果是成功还是失败。 如果 AOF 持久化功能处于开启状态,那么这个部分还会加上以下域: aof_current_size : AOF 文件目前的大小。 aof_base_size : 服务器启动时或者 AOF 重写最近一次执行之后,AOF 文件的大小。 aof_pending_rewrite : 一个标志值,记录了是否有 AOF 重写操作在等待 RDB 文件创建完毕之后执行。 aof_buffer_length : AOF 缓冲区的大小。 aof_rewrite_buffer_length : AOF 重写缓冲区的大小。 aof_pending_bio_fsync : 后台 I/O 队列里面,等待执行的 fsync 调用数量。 aof_delayed_fsync : 被延迟的 fsync 调用数量。 stats 部分记录了一般统计信息,它包含以下域: total_connections_received : 服务器已接受的连接请求数量。 total_commands_processed : 服务器已执行的命令数量。 instantaneous_ops_per_sec : 服务器每秒钟执行的命令数量。 rejected_connections : 因为最大客户端数量限制而被拒绝的连接请求数量。 expired_keys : 因为过期而被自动删除的数据库键数量。 evicted_keys : 因为最大内存容量限制而被驱逐(evict)的键数量。 keyspace_hits : 查找数据库键成功的次数。 keyspace_misses : 查找数据库键失败的次数。 pubsub_channels : 目前被订阅的频道数量。 pubsub_patterns : 目前被订阅的模式数量。 latest_fork_usec : 最近一次 fork() 操作耗费的毫秒数。 replication : 主/从复制信息 role : 如果当前服务器没有在复制任何其他服务器,那么这个域的值就是 master ;否则的话,这个域的值就是slave 。注意,在创建复制链的时候,一个从服务器也可能是另一个服务器的主服务器。 如果当前服务器是一个从服务器的话,那么这个部分还会加上以下域: master_host : 主服务器的 IP 地址。 master_port : 主服务器的 TCP 监听端口号。 master_link_status : 复制连接当前的状态, up 表示连接正常, down 表示连接断开。 master_last_io_seconds_ago : 距离最近一次与主服务器进行通信已经过去了多少秒钟。 master_sync_in_progress : 一个标志值,记录了主服务器是否正在与这个从服务器进行同步。 如果同步操作正在进行,那么这个部分还会加上以下域: master_sync_left_bytes : 距离同步完成还缺少多少字节数据。 master_sync_last_io_seconds_ago : 距离最近一次因为 SYNC 操作而进行 I/O 已经过去了多少秒。 如果主从服务器之间的连接处于断线状态,那么这个部分还会加上以下域: master_link_down_since_seconds : 主从服务器连接断开了多少秒。 以下是一些总会出现的域: connected_slaves : 已连接的从服务器数量。 对于每个从服务器,都会添加以下一行信息: slaveXXX : ID、IP 地址、端口号、连接状态 cpu 部分记录了 CPU 的计算量统计信息,它包含以下域: used_cpu_sys : Redis 服务器耗费的系统 CPU 。 used_cpu_user : Redis 服务器耗费的用户 CPU 。 used_cpu_sys_children : 后台进程耗费的系统 CPU 。 used_cpu_user_children : 后台进程耗费的用户 CPU 。 commandstats 部分记录了各种不同类型的命令的执行统计信息,比如命令执行的次数、命令耗费的 CPU 时间、执行每个命令耗费的平均 CPU 时间等等。对于每种类型的命令,这个部分都会添加一行以下格式的信息: cmdstat_XXX:calls=XXX,usec=XXX,usecpercall=XXX cluster 部分记录了和集群有关的信息,它包含以下域: cluster_enabled : 一个标志值,记录集群功能是否已经开启。 keyspace 部分记录了数据库相关的统计信息,比如数据库的键数量、数据库已经被删除的过期键数量等。对于每个数据库,这个部分都会添加一行以下格式的信息: dbXXX:keys=XXX,expires=XXX 除上面给出的这些值以外, section 参数的值还可以是下面这两个: all : 返回所有信息 default : 返回默认选择的信息 当不带参数直接调用 INFO 命令时,使用 default 作为默认参数。
相关推荐
下面是 Jedis API 的详细使用文档,适合新手和老程序员进行复习。 Jedis 的基本使用 Jedis 提供了多种方式来连接 Redis 服务器,包括单例模式、线程池模式等。单例模式下,每个线程中使用相同的 Jedis 实例可能会...
Jedis是Java开发者用于操作Redis数据库的最常用和推荐的客户端库。Redis是一款高性能的键值存储系统,适用于多种数据结构存储,如字符串、哈希、列表、集合和有序集合。Jedis通过提供丰富的API,使得在Java应用程序...
Jedis不仅提供基本的Redis命令支持,还包含了连接池管理,使得在Java应用中使用Redis变得更加便捷和高效。 **1. Jedis的核心功能** - **命令接口**:Jedis提供了一系列方法,与Redis的各种数据类型(字符串、哈希...
常用的方法有zadd、zrem和zrange。 接下来,我们将讨论Java中使用Jedis实现Redis的主从复制。主从复制是提高Redis可用性和数据安全性的重要手段。主节点负责写操作,从节点同步主节点的数据,当主节点出现问题时,...
下面将逐一介绍如何将Jedis中的常用命令替换为Redisson中的对应方法。 1. **获取键值** (`GET`) - **Jedis**: `jedis.get(key)` - **Redisson**: `RBucket<String> rBucket = redisson.getBucket(key); rBucket....
7. **pipeline与事务**:通过pipeline,Jedis能批量发送命令,减少网络延迟,提高效率。同时,pipeline也可以与事务结合使用。 8. **复制与sentinel支持**:Jedis支持Redis的主从复制和哨兵(Sentinel)系统,可以...
对于Java开发者,Jedis是连接Redis的常用Java客户端。首先,需要在项目中引入Jedis的依赖。如果你使用的是Maven,可以在pom.xml文件中添加如下依赖: ```xml <groupId>redis.clients <artifactId>jedis ...
总结,Jedis和Apache Commons Pool的结合使用,可以大大提高Redis操作的效率和系统的资源利用率。通过正确配置和使用连接池,可以确保在高并发环境下,系统能够稳定、高效地处理Redis操作。在实际项目中,我们还需要...
下面是对 Redis 的常用命令、配置文件、持久化、事务、主从复制、Jedis 使用的详细讲解。 Redis 常用命令 Redis 提供了很多有用的命令来管理和操作数据。下面是一些常用的 Redis 命令: * SET key value:设置...
Redis是一种高性能的键值对数据存储系统,常用于缓存、数据库和消息中间件等场景。Jedis是Java语言中广泛使用的Redis客户端库,提供了丰富的API来操作Redis服务器。`RedisUtil`通常是一个封装了Jedis操作的工具类,...
3. **Pipelining and Transactions** - Jedis支持命令管道(pipelining)和事务(transactions),以提高性能和并发处理能力。通过`Pipeline`类可以批量发送命令,而`Transaction`类则处理Redis的事务操作。 4. **...
源码可以帮助我们深入学习Jedis的工作原理,比如它是如何执行命令、处理网络I/O和连接管理的。 使用这些jar包进行Redis操作时,首先需要在项目中引入依赖,如果是Maven项目,可以在pom.xml中添加如下依赖: ```xml ...
标题中的"commons-pool2-2.4.2和jedis-2.7.2"提到了两个关键的Java库,它们是与Redis交互时常用的重要组件。让我们深入了解一下这两个库以及它们在Redis操作中的作用。 `commons-pool2-2.4.2.jar`是Apache Commons ...
对于Java开发者,Jedis是一个常用的Redis客户端库,能够方便地在Java应用中与Redis服务器进行通信。这里提到的`jedis-2.0.0.jar`是Jedis的一个早期版本,包含了连接Redis、执行命令、处理响应等功能。使用Jedis时,...
Jedis 封装了 Redis 的大部分命令,包括字符串、哈希、列表、集合、有序集合等数据类型的常用操作。例如: - 字符串操作:`set(key, value)` 设置键值对,`get(key)` 获取键对应的值。 - 哈希操作:`hset(hashKey, ...
- **jedis.jar**:这是Jedis的核心库,包含了连接Redis服务器、执行命令、处理响应等所有功能的类和接口。开发中,通常会直接引入这个库来进行Redis操作。 - **lettuce-core.jar**:Lettuce是另一个Java客户端,...
5. **结果通知**:秒杀成功后,将用户的秒杀信息存储在Redis中,或者通过消息队列异步处理,通知用户和系统结果。 通过这个案例,你可以了解到Jedis在实际应用场景中的强大功能,以及如何利用它来处理高并发和实时...
### Redis 常用命令及 Java 实现 #### 一、Redis 命令简介 Redis 是一个开源的键值数据库系统,它提供了多种数据结构的存储方式,并且支持简单的事务处理、主从同步等功能。在开发过程中,Redis 的一些基本命令被...
4. **排序与搜索**:对于有序集合,Jedis提供了一系列命令来排序和查找元素,如`sort`。 5. **持久化操作**:Jedis也提供了对Redis的RDB和AOF两种持久化方式的支持,如触发`SAVE`或`BGSAVE`命令。 6. **连接池管理...
5. Redis 常用命令 Redis 提供了多种命令来操作键值对,例如: * SET 命令:用于设置键值对。 * GET 命令:用于获取键对应的值。 * DEL 命令:用于删除键值对。 * EXISTS 命令:用于检查键是否存在。 6. Redis ...