`

7.Jedis常用命令和系统命令

阅读更多

 

常用命令

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 作为默认参数。

 

 

 

0
0
分享到:
评论

相关推荐

    Jedis API中文使用文档.-比较详细

    下面是 Jedis API 的详细使用文档,适合新手和老程序员进行复习。 Jedis 的基本使用 Jedis 提供了多种方式来连接 Redis 服务器,包括单例模式、线程池模式等。单例模式下,每个线程中使用相同的 Jedis 实例可能会...

    jedis简单实例

    Jedis是Java开发者用于操作Redis数据库的最常用和推荐的客户端库。Redis是一款高性能的键值存储系统,适用于多种数据结构存储,如字符串、哈希、列表、集合和有序集合。Jedis通过提供丰富的API,使得在Java应用程序...

    Jedis-Util

    Jedis不仅提供基本的Redis命令支持,还包含了连接池管理,使得在Java应用中使用Redis变得更加便捷和高效。 **1. Jedis的核心功能** - **命令接口**:Jedis提供了一系列方法,与Redis的各种数据类型(字符串、哈希...

    Java通过Jedis操作Redis

    常用的方法有zadd、zrem和zrange。 接下来,我们将讨论Java中使用Jedis实现Redis的主从复制。主从复制是提高Redis可用性和数据安全性的重要手段。主节点负责写操作,从节点同步主节点的数据,当主节点出现问题时,...

    使用redisson替代jedis

    下面将逐一介绍如何将Jedis中的常用命令替换为Redisson中的对应方法。 1. **获取键值** (`GET`) - **Jedis**: `jedis.get(key)` - **Redisson**: `RBucket&lt;String&gt; rBucket = redisson.getBucket(key); rBucket....

    jedis-2.7.0.jar安装包

    7. **pipeline与事务**:通过pipeline,Jedis能批量发送命令,减少网络延迟,提高效率。同时,pipeline也可以与事务结合使用。 8. **复制与sentinel支持**:Jedis支持Redis的主从复制和哨兵(Sentinel)系统,可以...

    redis-4.0.2 Linux版本及手写安装文档及jedis jar

    对于Java开发者,Jedis是连接Redis的常用Java客户端。首先,需要在项目中引入Jedis的依赖。如果你使用的是Maven,可以在pom.xml文件中添加如下依赖: ```xml &lt;groupId&gt;redis.clients &lt;artifactId&gt;jedis ...

    jedis 和 common-pool

    总结,Jedis和Apache Commons Pool的结合使用,可以大大提高Redis操作的效率和系统的资源利用率。通过正确配置和使用连接池,可以确保在高并发环境下,系统能够稳定、高效地处理Redis操作。在实际项目中,我们还需要...

    redis常用命令,redis配置文件,redis持久化,redis事务,redis主从复制,jedis的使用

    下面是对 Redis 的常用命令、配置文件、持久化、事务、主从复制、Jedis 使用的详细讲解。 Redis 常用命令 Redis 提供了很多有用的命令来管理和操作数据。下面是一些常用的 Redis 命令: * SET key value:设置...

    RedisUtil_RedisUtil_redis_jedis常用util_

    Redis是一种高性能的键值对数据存储系统,常用于缓存、数据库和消息中间件等场景。Jedis是Java语言中广泛使用的Redis客户端库,提供了丰富的API来操作Redis服务器。`RedisUtil`通常是一个封装了Jedis操作的工具类,...

    Jedis源码-供查询redis API源码

    3. **Pipelining and Transactions** - Jedis支持命令管道(pipelining)和事务(transactions),以提高性能和并发处理能力。通过`Pipeline`类可以批量发送命令,而`Transaction`类则处理Redis的事务操作。 4. **...

    redis所需jar包

    源码可以帮助我们深入学习Jedis的工作原理,比如它是如何执行命令、处理网络I/O和连接管理的。 使用这些jar包进行Redis操作时,首先需要在项目中引入依赖,如果是Maven项目,可以在pom.xml中添加如下依赖: ```xml ...

    commons-pool2-2.4.2和jedis-2.7.2

    标题中的"commons-pool2-2.4.2和jedis-2.7.2"提到了两个关键的Java库,它们是与Redis交互时常用的重要组件。让我们深入了解一下这两个库以及它们在Redis操作中的作用。 `commons-pool2-2.4.2.jar`是Apache Commons ...

    redis运行环境(UNIX,WINDOWS),对应的jedis jar包

    对于Java开发者,Jedis是一个常用的Redis客户端库,能够方便地在Java应用中与Redis服务器进行通信。这里提到的`jedis-2.0.0.jar`是Jedis的一个早期版本,包含了连接Redis、执行命令、处理响应等功能。使用Jedis时,...

    jedis2.7版本

    Jedis 封装了 Redis 的大部分命令,包括字符串、哈希、列表、集合、有序集合等数据类型的常用操作。例如: - 字符串操作:`set(key, value)` 设置键值对,`get(key)` 获取键对应的值。 - 哈希操作:`hset(hashKey, ...

    jedis依赖包.zip

    - **jedis.jar**:这是Jedis的核心库,包含了连接Redis服务器、执行命令、处理响应等所有功能的类和接口。开发中,通常会直接引入这个库来进行Redis操作。 - **lettuce-core.jar**:Lettuce是另一个Java客户端,...

    jedis手机验证码和秒杀案例.rar

    5. **结果通知**:秒杀成功后,将用户的秒杀信息存储在Redis中,或者通过消息队列异步处理,通知用户和系统结果。 通过这个案例,你可以了解到Jedis在实际应用场景中的强大功能,以及如何利用它来处理高并发和实时...

    redis常用命令以及在java中的具体实现以及配置.docx

    ### Redis 常用命令及 Java 实现 #### 一、Redis 命令简介 Redis 是一个开源的键值数据库系统,它提供了多种数据结构的存储方式,并且支持简单的事务处理、主从同步等功能。在开发过程中,Redis 的一些基本命令被...

    jedis-2.4.2.jar

    4. **排序与搜索**:对于有序集合,Jedis提供了一系列命令来排序和查找元素,如`sort`。 5. **持久化操作**:Jedis也提供了对Redis的RDB和AOF两种持久化方式的支持,如触发`SAVE`或`BGSAVE`命令。 6. **连接池管理...

    05次课 redis-03 java中使用Redis.doc

    5. Redis 常用命令 Redis 提供了多种命令来操作键值对,例如: * SET 命令:用于设置键值对。 * GET 命令:用于获取键对应的值。 * DEL 命令:用于删除键值对。 * EXISTS 命令:用于检查键是否存在。 6. Redis ...

Global site tag (gtag.js) - Google Analytics