封装导入步骤_【194期】Redis——第三方jar没有封装的命令我们该怎么执行？

点击上方“Java面试题精选”&＃xff0c;关注公众号

面试刷图&＃xff0c;查缺补漏

>>号外&＃xff1a;往期面试题&＃xff0c;10篇为一个单位归置到本公众号菜单栏->面试题&＃xff0c;有需要的欢迎翻阅

阶段汇总集合&＃xff1a;001期~180期汇总&＃xff0c;方便阅读(增加设计模式)

今天对redis的进阶操作给大家介绍一下&＃xff0c;以及对于jedis和redisTemplate等工具包没有封装的命令我们该如何使用&＃xff1f;相信大家读了本篇对redis的整体会有更深的认知。

1、redis的通常使用方式

大多数情况下&＃xff0c;我们都会通过请求-相应机制去操作redis。使用这种模式的步骤为

1. 获得jedis实例

2. 发送redis命令

3. 由于redis是单线程的&＃xff0c;所以处理完上一个指令之后才会进行执行该命令。

整个交互流程如下

2、Pipeline模式

然而使用Pipeline 模式&＃xff0c;客户端可以一次性的发送多个命令&＃xff0c;无需等待服务端返回。这样就大大的减少了网络往返时间&＃xff0c;提高了系统性能。

pipeline是多条命令的组合&＃xff0c;使用PIPELINE 可以解决网络开销的问题&＃xff0c;原理也非常简单,流程如下, 将多个指令打包后,一次性提交到Redis, 网络通信只有一次

3、性能对比

可以看到&＃xff0c;redis的延迟主要出现在网络请求的IO次数上&＃xff0c;因此我们在使用redis的时候&＃xff0c;尽量减少网络IO次数&＃xff0c;通过pipeline的方式将多个指令封装在一个命令里执行。

redis的简单事务是将一组需要一起执行的命令放到multi和exec两个命令之间&＃xff0c;其中multi代表事务开始&＃xff0c;exec代表事务结束

1、事务命令

• multi:事务开始

• exec:提交事务

• watch:事务监控

WATCH命令可以监控一个或多个键&＃xff0c;一旦其中有一个键被修改(或删除)&＃xff0c;之后的事务就不会执行。监控一直持续到

discard:停止事务

在执行exec之前执行该命令&＃xff0c;提交事务会失败&＃xff0c;执行的命令会进行回滚

127.0.0.1:6379> multi     //开始事务
 
OK
 
127.0.0.1:6379> sadd tt 1   //业务操作
 
QUEUED
 
127.0.0.1:6379> DISCARD   //停止事务
 
OK
 
127.0.0.1:6379> exec   //提交事务
 
(error) ERR EXEC without MULTI   //报不存在事务异常
 
127.0.0.1:6379> get tt  //获取不到对象
 
(nil)
 
127.0.0.1:6379>


2、事务异常

redis支持事务&＃xff0c;但他属于弱事务&＃xff0c;中间的一些异常可能会导致事务失效。

往期面试题&＃xff1a;001期~180期汇总

1、命令错误&＃xff0c;语法不正确&＃xff0c;导致事务不能正常结束

127.0.0.1:6379> multi   //开始事务
 
OK
 
127.0.0.1:6379> set aa 123  //业务操作
 
QUEUED
 
127.0.0.1:6379> sett bb 124  //命令错误
 
(error) ERR unknown command &＃39;sett&＃39;
 
127.0.0.1:6379> exec 
 
(error) EXECABORT Transaction discarded because of  previous errors.  //提交事务异常
 
127.0.0.1:6379> get aa  //查询不到数据
 
(nil)
 
127.0.0.1:6379>


2、运行错误&＃xff0c;语法正确&＃xff0c;但类型错误&＃xff0c;事务可以正常结束

127.0.0.1:6379> multi
 
OK
 
127.0.0.1:6379> set t 1   //业务操作1
 
QUEUED
 
127.0.0.1:6379> sadd t 1  //业务操作2
 
QUEUED
 
127.0.0.1:6379> set t 2  //业务操作3
 
QUEUED
 
127.0.0.1:6379> exec
 
1) OK
 
2) (error) WRONGTYPE Operation against a key holding the wrong kind of value  //类型异常
 
3) OK
 
127.0.0.1:6379> get t  //可以获取到t
 
"2"
 
127.0.0.1:6379>
三、redis发布与订阅

redis提供了“发布、订阅”模式的消息机制&＃xff0c;其中消息订阅者与发布者不直接通信&＃xff0c;发布者向指定的频道(channel)发布消息&＃xff0c;订阅该频道的每个客户端都可以接收到消息

1、Redis发布订阅常用命令

2、性能测试

参考:

https://blog.csdn.net/b379685397/article/details/95626295

3、应用场景

redis主要提供发布消息、订阅频道、取消订阅以及按照模式订阅和取消订阅&＃xff0c;和很多专业的消息队列(kafka rabbitmq),redis的发布订阅显得很lower, 比如无法实现消息规程和回溯&＃xff0c; 但就是简单&＃xff0c;如果能满足应用场景&＃xff0c;用这个也可以

1. 订阅号、公众号、微博关注、邮件订阅系统等

2. 即使通信系统

3. 群聊部落系统(微信群)

键迁移大家可能用的不是很多&＃xff0c;因为一般都是使用redis主从同步。不过对于我们做数据统计分析使用的时候&＃xff0c;可能会使用到&＃xff0c;比如用户标签。为了避免key批量删除导致的redis雪崩&＃xff0c;一般都是通过一个计算使用的redis和一个最终业务使用的redis&＃xff0c;通过将计算时用的redis里的键值通过迁移的方式一个一个的更新到业务redis中&＃xff0c;使其对业务冲击最小化。

1、move

move指令将redis一个库中的数据迁移到另外一个库中。

move key db  //reids有16个库&＃xff0c; 编号为0&＃xff0d;15
set name DK;  move name 5 //迁移到第6个库
elect 5 ;//数据库切换到第6个库&＃xff0c;
get name  可以取到james1


如果key在目标数据库中已存在&＃xff0c;那么什么也不会发生。这种模式不建议在生产环境使用&＃xff0c;在同一个reids里可以玩

2、dump

Redis DUMP 命令用于将key给序列化 &＃xff0c;并返回被序列化的值。用于导入到其他服务中

一般通过dump命令导出&＃xff0c;使用restore命令导入。

1,在A服务器上

set name james;
dump name;       //  得到"\x00\x05james\b\x001\x82;f\"DhJ"


2,在B服务器上

restore name 0 "\x00\x05james\b\x001\x82;f\"DhJ"    //0代表没有过期时间
get name           //返回james


3、migrate

migrate用于在Redis实例间进行数据迁移&＃xff0c;实际上migrate命令是将dump、restore、del三个命令进行组合&＃xff0c;从而简化了操作流程。

往期面试题&＃xff1a;001期~180期汇总

migrate命令具有原子性&＃xff0c;从Redis 3.0.6版本后已经支持迁移多个键的功能。migrate命令的数据传输直接在源Redis和目标Redis上完成&＃xff0c;目标Redis完成restore后会发送OK给源Redis。

比如&＃xff1a;把111上的name键值迁移到112上的redis

192.168.42.111:6379> migrate 192.168.42.112 6379 name 0 1000 copy
五、自定义命令封装

当我们使用jedis或者jdbctemplate时&＃xff0c;想执行键迁移的指令的时候&＃xff0c;发现根本没有给我们封装相关指令&＃xff0c;这个时候我们该怎么办呢&＃xff1f;除了框架帮我们封装的方法外&＃xff0c;我们自己也可以通过反射的方式进行命令的封装&＃xff0c;主要步骤如下

1. 建立Connection链接&＃xff0c;使用Connection连接Redis

2. 通过反射获取Connection中的sendCommand方法(protected Connection sendCommand(Command cmd, String... args))。

3. 调用connection的sendCommand方法&＃xff0c;第二个参数为执行的命令(比如set,get,client等)&＃xff0c;第三个参数为命令的参数。可以看到ProtocolCommand这个枚举对象包含了redis的所有指令&＃xff0c;即所有的指令都可以通过这个对象获取到。并封装执行

4. 执行invoke方法&＃xff0c;并且按照redis的指令封装参数

5. 获取Redis的命令执行结果

package com.james.cache.jedis;
 
import redis.clients.jedis.Connection;
import redis.clients.jedis.Protocol;
 
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
 
/**
 * &＃64;Auther: DK
 * &＃64;Date: 2020/10/11 23:17
 * &＃64;Description:
 */
public class RedisKeyMove {
 
    public static void main(String[] args) throws IOException {
        //1.使用Connection连接Redis
        try (Connection connection &＃61; new Connection("10.1.253.188", 6379)) {
            // 2. 通过反射获取Connection中的sendCommand方法(protected Connection sendCommand(Command cmd, String... args))。
            Method method &＃61; Connection.class.getDeclaredMethod("sendCommand", Protocol.Command.class, String[].class);
            method.setAccessible(true); // 设置可以访问private和protected方法
            // 3. 调用connection的sendCommand方法&＃xff0c;第二个参数为执行的命令(比如set,get,client等)&＃xff0c;第三个参数为命令的参数。
            // 3.1 该命令最终对应redis中为: set test-key test-value
            method.invoke(connection, Protocol.Command.MIGRATE,
                    new String[] {"10.1.253.69", "6379", "name", "0", "1000", "copy"});
            // 4.获取Redis的命令执行结果
            System.out.println(connection.getBulkReply());
        } catch (NoSuchMethodException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }
    }
}
六、键全量遍历

1、keys

考虑到是单线程&＃xff0c;使用改命令会阻塞线程&＃xff0c; 在生产环境不建议使用&＃xff0c;键多可能会阻塞。

2、渐进式遍历 scan

1&＃xff0c;初始化数据

mset n1 1 n2 2 n3 3 n4 4 n5 5 n6 6 n7 7 n8 8 n9 9 n10 10 n11 11 n12 12 n13 13


2&＃xff0c;遍历匹配

scan 0 match n* count 5    匹配以n开头的键&＃xff0c;最大是取5条&＃xff0c;第一次scan 0开始


第二次从游标4096开始取20个以n开头的键&＃xff0c;相当于一页一页的取当最后返回0时&＃xff0c;键被取完。

3、scan 和keys对比

1. 通过游标分布进行的&＃xff0c;不会阻塞线程;

2. 提供 limit 参数&＃xff0c;可以控制每次返回结果的最大条数&＃xff0c;limit 不准&＃xff0c;返回的结果可多可少;

3. 同 keys 一样&＃xff0c;Scan也提供模式匹配功能;

4. 服务器不需要为游标保存状态&＃xff0c;游标的唯一状态就是 scan 返回给客户端的游标整数;

5. scan返回的结果可能会有重复&＃xff0c;需要客户端去重复;

6. scan遍历的过程中如果有数据修改&＃xff0c;改动后的数据能不能遍历到是不确定的;

7. 单次返回的结果是空的并不意味着遍历结束&＃xff0c;而要看返回的游标值是否为零;

4、其他遍历命令

SCAN 命令用于迭代当前数据库中的数据库键。

SSCAN 命令用于迭代集合键中的元素。

HSCAN 命令用于迭代哈希键中的键值对。

ZSCAN 命令用于迭代有序集合中的元素(包括元素成员和元素分值)。

用法和scan一样

END

来源&＃xff1a;blog.csdn.net/b379685397/article/details/109015852

十期推荐

【181期】HashMap 面试二十一问&＃xff01;

【182期】SpringCloud常见面试题(2020最新版)

【183期】面试官&＃xff1a;线上服务平均响应时间太长&＃xff0c;怎么排查&＃xff1f;

【184期】SQL数据库面试题以及答案(50例题)

【185期】面试官&＃xff1a;你能说说 Synchronized实现对象锁的两种方式以及它的原理吗&＃xff1f;

【186期】一口气说出 Synchronized 同步方法的八种使用场景

【187期】出现几率比较大的Redis面试题(含答案)

【188期】面试官&＃xff1a;delete、truncate、drop的区别有哪些&＃xff0c;该如何选择

【189期】delete后加 limit是个好习惯么

【190期】MQ消息中间件&＃xff0c;面试能问写什么&＃xff1f;

与其在网上拼命找题&＃xff1f; 不如马上关注我们~