1.数据库管理
mysql 中有一个重要的概念,database
- 1个 mysql 服务器上可以有很多个 database
- 1个 database 上可以有很多个 表
- mysql 上可以随心所欲的 创建/删除 数据库~~
1.1 切换数据库
select dbIndex
Redis 中虽然⽀持多数据库,但随着版本的升级,其实不是特别建议使⽤多数据库特性。如果真的需要完全隔离的两套键值对,更好的做法是维护多个 Redis 实例,⽽不是在⼀个Redis 实例中维护多数据库。这是因为本⾝ Redis 并没有为多数据库提供太多的特性,其次⽆论是否有多个数据库,Redis 都是使⽤单线程模型,所以彼此之间还是需要排队等待命令的执⾏。同时多数据库还会让开发、调试和运维⼯作变得复杂。所以实践中,始终使⽤数据库 0 其实是⼀个很好的选择。
1.2 清除数据库
2.客户端
2.1 基本介绍
- 前面学习的主要是各种 redis 的基本操作/命令.都是在 redis 命令行客户端,手动执行的
- 这种操作方式不是我们日常开发中主要的形式~~
- 更多的时候, 是使用 redis 的 api,来实现定制化的 redis 客户端程序,进一步操作 redis 服务器.
- 用程序来操作 redis ~~
- 以前学习 MySQL 的时候~也会涉及到, 关于使用程序来操作 MySQL 服务器
- C++: MySQL 原生 API
- Java: JDBC & MyBatis
- redis 提供的命令行客户端/第三方的图形化客户端 ….
他们本质上都属于是“通用的客户端程序"
相比之下,我们在工作中更希望使用到的是"专用的""定制化"的客户端程序~~ -
我们要了解 Redis 服务端和客⼾端的通信协议,以及 C++/Java 语⾔的 Redis 客⼾端使⽤⽅法。
2.2 认识RESP
- 为什么我们能编写出一个自定义的 redis 客户端??
- 咱们能不能编写出一个 qq的自定义客户端/亡者农药的自定义客户端/xxxxx 自定义客户端??
不能!! 因为他们没有公开自己使用的自定义协议!!
虽然 腾讯 没公开 q9 的协议,但是我看到说网上还是有一些开源项目实现了自定制的 qq客户端~
RESP:自定义的应用层协议
一文彻底理解Redis序列化协议,你也可以编写Redis客户端-腾讯云开发者社区-腾讯云 (tencent.com)
1.中文官网
Redis协议详细规范
2.优点
1)简单好实现
2)快速进行解析
3)肉眼可读
传输层这里基于 TCP, 但是和 TCP 又没有强耦合~
请求和响应之间的通信模型是一问一答的形式~~(客户端给服务器发一个请求,服务器返回一个响应~)因此,redis 客户端服务器
要做的工作,就是
1.按照上述格式,构造出字符串,往 socket 中写入2.从 socket 中读取字符串,按照上述格式解析~
3.引入jedis依赖
java 生态中,封装了 RESP 协议, 实现的 redis 客户端是有很多的~~
咱们此处使用的是 jedis (这里提供的 api 和 redis 命令高度一致的)
jedis 也可以通过 maven 来下载安装~
<dependencies>
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>4.2.3</version>
</dependency>
</dependencies>
4.关于开放redis端口的问题
一. 直接让 java 程序, 也在 linux 上运行~~
这就需要咱们自己把代码打成可执行的 jar 包,然后把 jar 包拷贝到 linux 服务器上执行~~
如果手工完成,还挺麻烦~~
也可以通过一些第三方的插件,来简化上述步骤~~
二.配置 ssh 端口转发,把云服务器的redis端口,映射到本地主机~~一个 linux 主机上,存在的服务器有很多, ssh 也可能需要来给多个端口传递数据~~
这个时候,为了区分不同的端口,往往会把服务器的端口在本地用另外一个端口来进行表示~~
若断开连接再看
没了
- 当配置了 端口转发 之后,一定要断开之前的连接,重新连接才能生效~~
- 后续 Java 代码中, 通过 127.0.0.1:8888 就能操作到咱们云服务器的 redis 了同时外面的客户端,是无法直接访问云服务器的 6379 的~~
public static void main(String[] args) { //连接到Redis服务器 JedisPool jedisPool=new JedisPool("tcp://127.0.0.1:8888"); try(Jedis jedis=jedisPool.getResource()) { //redis的各种命令,都对应到jedis对象的各种方法 String pong=jedis.ping(); System.out.println(pong); } }
5.jedis进行redis的通用命令
5.1 get&set
public static void test1(Jedis jedis) {
System.out.println("get 和 set 的使用");
// 先清空数据库. 要避免上一组测试的残留数据影响到下一组测试的结果.
jedis.flushAll();
jedis.set("key", "111");
jedis.set("key2", "222");
SetParams params = new SetParams();
params.ex(10);
params.nx();
jedis.set("key", "333", params);
String value = jedis.get("key");
System.out.println("value=" + value);
}
5.2 exists和del
public static void test2(Jedis jedis) {
System.out.println("exists 和 del");
jedis.flushAll();
jedis.set("key", "111");
jedis.set("key2", "222");
jedis.set("key3", "333");
boolean result = jedis.exists("key");
System.out.println("result: " + result);
long result2 = jedis.del("key");
System.out.println("result2: " + result2);
result = jedis.exists("key");
System.out.println("result: " + result);
result2 = jedis.del("key", "key2", "key3");
System.out.println("result2: " + result2);
}
5.3 set
public static void test2(Jedis jedis) {
System.out.println("exists 和 del");
jedis.flushAll();
jedis.set("key", "111");
jedis.set("key2", "222");
jedis.set("key3", "333");
boolean result = jedis.exists("key");
System.out.println("result: " + result);
long result2 = jedis.del("key");
System.out.println("result2: " + result2);
result = jedis.exists("key");
System.out.println("result: " + result);
result2 = jedis.del("key", "key2", "key3");
System.out.println("result2: " + result2);
}
5.3 expire,ttl,type
public static void test4(Jedis jedis) {
System.out.println("expire 和 ttl");
jedis.flushAll();
jedis.set("key", "111");
jedis.expire("key", 10);
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
long time = jedis.ttl("key");
System.out.println("time: " + time);
}
public static void test5(Jedis jedis) {
System.out.println("type");
jedis.flushAll();
jedis.set("key", "111");
String type = jedis.type("key");
System.out.println("type: " + type);
jedis.lpush("key2", "111", "222", "333");
type = jedis.type("key2");
System.out.println("type: " + type);
jedis.hset("key3", "f1", "111");
type = jedis.type("key3");
System.out.println("type: " + type);
jedis.sadd("key4", "111", "222", "333");
type = jedis.type("key4");
System.out.println("type: " + type);
jedis.zadd("key5", 10, "zhangsan");
type = jedis.type("key5");
System.out.println("type: " + type);
}
6.使用string命令
6.1 mset&mget
public static void test1(Jedis jedis) {
System.out.println("mget 和 mset");
jedis.flushAll();
jedis.mset("key1", "111", "key2", "222", "key3", "333");
List<String> values = jedis.mget("key1", "key2", "key100", "key3");
System.out.println("values: " + values);
}
6.2 getrange&setrange
public static void test2(Jedis jedis) {
System.out.println("getrange 和 setrange");
jedis.flushAll();
jedis.set("key", "abcdefghijk");
String result = jedis.getrange("key", 2, 5);
System.out.println("result: " + result);
jedis.setrange("key", 2, "xyz");
String value = jedis.get("key");
System.out.println("value: " + value);
}
6.3 append
public static void test3(Jedis jedis) {
System.out.println("append");
jedis.flushAll();
jedis.set("key", "abcdef");
jedis.append("key", "ghij");
String value = jedis.get("key");
System.out.println("value: " + value);
}
6.4 incr&decr
public static void test4(Jedis jedis) {
System.out.println("incr 和 decr");
jedis.flushAll();
jedis.set("key", "100");
long result = jedis.incr("key");
System.out.println("result: " + result);
String value = jedis.get("key");
System.out.println("value: " + value);
result = jedis.decr("key");
System.out.println("result: " + result);
value = jedis.get("key");
System.out.println("value: " + value);
}
7.使用list命令
7.1 lpush&lrange
public static void test1(Jedis jedis) {
System.out.println("lpush 和 lrange");
jedis.flushAll();
jedis.lpush("key", "111", "222", "333");
List<String> result = jedis.lrange("key", 0, -1);
System.out.println(result);
}
7.2 rpush
public static void test2(Jedis jedis) {
System.out.println("rpush");
jedis.flushAll();
jedis.rpush("key", "111", "222", "333");
List<String> result = jedis.lrange("key", 0, -1);
System.out.println("result: " + result);
}
7.3 lpop
public static void test3(Jedis jedis) {
System.out.println("lpop");
jedis.flushAll();
jedis.rpush("key", "111", "222", "333");
String result = jedis.lpop("key");
System.out.println("result: " + result);
result = jedis.lpop("key");
System.out.println("result: " + result);
result = jedis.lpop("key");
System.out.println("result: " + result);
result = jedis.lpop("key");
System.out.println("result: " + result);
}
7.4 rpop
public static void test4(Jedis jedis) {
System.out.println("rpop");
jedis.flushAll();
jedis.rpush("key", "111", "222", "333");
String result = jedis.rpop("key");
System.out.println("result: " + result);
result = jedis.rpop("key");
System.out.println("result: " + result);
result = jedis.rpop("key");
System.out.println("result: " + result);
result = jedis.rpop("key");
System.out.println("result: " + result);
}
7.5 blpop
public static void test5(Jedis jedis) {
System.out.println("blpop");
jedis.flushAll();
// 返回结果是一个 "二元组", 一个是从哪个 key 对应的list中删除的, 一个是删除的元素是什么.
List<String> results = jedis.blpop(100, "key");
System.out.println("results[0]: " + results.get(0));
System.out.println("results[1]: " + results.get(1));
}
7.6 llen
public static void test6(Jedis jedis) {
System.out.println("llen");
jedis.flushAll();
jedis.rpush("key", "111", "222", "333");
long len = jedis.llen("key");
System.out.println("len: " + len);
}
8.set的使用
8.1 sadd&smembers
public static void test1(Jedis jedis) {
System.out.println("sadd 和 smembers");
jedis.flushAll();
jedis.sadd("key", "111", "222", "333");
Set<String> result = jedis.smembers("key");
System.out.println("result: " + result);
}
8.2 sismember
public static void test2(Jedis jedis) {
System.out.println("sismember");
jedis.flushAll();
jedis.sadd("key", "111", "222", "333");
boolean result = jedis.sismember("key", "100");
System.out.println("result: " + result);
}
8.3 scard
public static void test3(Jedis jedis) {
System.out.println("scard");
jedis.flushAll();
jedis.sadd("key", "111", "222", "333");
long result = jedis.scard("key");
System.out.println("result: " + result);
}
8.4 spop
public static void test4(Jedis jedis) {
System.out.println("spop");
jedis.flushAll();
jedis.sadd("key", "111", "222", "333", "444", "555");
String result = jedis.spop("key");
System.out.println("result: " + result);
}
8.5 sinter
public static void test5(Jedis jedis) {
System.out.println("sinter");
jedis.flushAll();
jedis.sadd("key", "111", "222", "333");
jedis.sadd("key2", "111", "222", "444");
Set<String> result = jedis.sinter("key", "key2");
System.out.println("result: " + result);
}
8.6 sinterstore
public static void test6(Jedis jedis) {
System.out.println("sinterstore");
jedis.flushAll();
jedis.sadd("key", "111", "222", "333");
jedis.sadd("key2", "111", "222", "444");
long len = jedis.sinterstore("key3", "key", "key2");
System.out.println("len: " + len);
Set<String> result = jedis.smembers("key3");
System.out.println("result: " + result);
}
9.hash的使用
9.1 hset&hget
public static void test1(Jedis jedis) {
System.out.println("hset 和 hget");
jedis.flushAll();
jedis.hset("key", "f1", "111");
Map<String, String> fields = new HashMap<>();
fields.put("f2", "222");
fields.put("f3", "333");
jedis.hset("key", fields);
String result = jedis.hget("key", "f1");
System.out.println("result: " + result);
result = jedis.hget("key", "f2");
System.out.println("result: " + result);
result = jedis.hget("key", "f100");
System.out.println("result: " + result);
}
9.2 hexists
public static void test2(Jedis jedis) {
System.out.println("hexists");
jedis.flushAll();
jedis.hset("key", "f1", "111");
jedis.hset("key", "f2", "111");
jedis.hset("key", "f3", "111");
boolean result = jedis.hexists("key", "f1");
System.out.println("result: " + result);
result = jedis.hexists("key", "f100");
System.out.println("result: " + result);
}
9.3 hdel
public static void test3(Jedis jedis) {
System.out.println("hdel");
jedis.flushAll();
jedis.hset("key", "f1", "111");
jedis.hset("key", "f2", "111");
jedis.hset("key", "f3", "111");
long result = jedis.hdel("key", "f1", "f2");
System.out.println("result: " + result);
boolean exists = jedis.hexists("key", "f1");
System.out.println("exists: " + exists);
exists = jedis.hexists("key", "f2");
System.out.println("exists: " + exists);
}
9.4 hkeys&hvals
public static void test4(Jedis jedis) {
System.out.println("hkeys 和 hvals");
jedis.flushAll();
jedis.hset("key", "f1", "111");
jedis.hset("key", "f2", "111");
jedis.hset("key", "f3", "111");
Set<String> fields = jedis.hkeys("key");
List<String> vals = jedis.hvals("key");
System.out.println("fields: " + fields);
System.out.println("vals: " + vals);
}
9.5 hmset&hmget
public static void test5(Jedis jedis) {
System.out.println("hmget 和 hmset");
jedis.flushAll();
Map<String, String> map = new HashMap<>();
map.put("f1", "111");
map.put("f2", "222");
map.put("f3", "333");
jedis.hmset("key", map);
List<String> values = jedis.hmget("key", "f2", "f1", "f3");
System.out.println("values: " + values);
}
10.zset的使用
10.1 zadd&zrange
public static void test1(Jedis jedis) {
System.out.println("zadd 和 zrange");
jedis.flushAll();
jedis.zadd("key", 10, "zhangsan");
Map<String, Double> map = new HashMap<>();
map.put("lisi", 20.0);
map.put("wangwu", 30.0);
jedis.zadd("key", map);
List<String> members = jedis.zrange("key", 0, -1);
System.out.println("members: " + members);
List<Tuple> membersWithScore = jedis.zrangeWithScores("key", 0, -1);
System.out.println("membersWithScore: " + membersWithScore);
String member = membersWithScore.get(0).getElement();
double score = membersWithScore.get(0).getScore();
System.out.println("member: " + member + ", score: " + score);
}
10.2 zcard
public static void test2(Jedis jedis) {
System.out.println("zcard");
jedis.flushAll();
jedis.zadd("key", 10, "zhangsan");
jedis.zadd("key", 20, "lisi");
jedis.zadd("key", 30, "wangwu");
long len = jedis.zcard("key");
System.out.println("len: " + len);
}
10.3 zrem
public static void test3(Jedis jedis) {
System.out.println("zrem");
jedis.flushAll();
jedis.zadd("key", 10, "zhangsan");
jedis.zadd("key", 20, "lisi");
jedis.zadd("key", 30, "wangwu");
long n = jedis.zrem("key", "zhangsan", "lisi");
System.out.println("n: " + n);
List<Tuple> result = jedis.zrangeWithScores("key", 0, -1);
System.out.println("result: " + result);
}
10.4 zscore
public static void test4(Jedis jedis) {
System.out.println("zscore");
jedis.flushAll();
jedis.zadd("key", 10, "zhangsan");
jedis.zadd("key", 20, "lisi");
jedis.zadd("key", 30, "wangwu");
Double score = jedis.zscore("key", "zhangsan2");
System.out.println("score: " + score);
}
10.5 zrank 获取某一个值的排名
public static void test5(Jedis jedis) {
System.out.println("zrank");
jedis.flushAll();
jedis.zadd("key", 10, "zhangsan");
jedis.zadd("key", 20, "lisi");
jedis.zadd("key", 30, "wangwu");
Long rank = jedis.zrank("key", "zhangsan2");
System.out.println("rank: " + rank);
}
Jedis 这个库的本质就是针对 redis 的各种命令进行了封装
调用某个方法, 就相当于在 redis 客户端中敲下了对应的命令
GitHub - redis/jedis: Redis Java client
官方文档:
jedis 5.2.0-beta2 javadoc (redis.clients)