redissionclient redission使用教程 _redission

本文目录一览：

1、大厂面试题详解:如何用Redis实现分布式锁?
2、基于Redission使用Redis的Stream

大厂面试题详解:如何用Redis实现分布式锁?1、直接使用 set（key，value ， NX，EX，timeout）指令，同时设置锁和超时时间。以上两种方法，使用哪种方式都可以。释放锁的脚本两种方式都一样，直接调用 Redis 的 del 指令即可。
2、可以尽量把锁自动过期的时间设的冗余一些。但也不能彻底解决。可以在删除锁的时候先get值，判断值是否是当前线程存的随机值，只有相同才执行删锁的操作；当然也要使用 lua 脚本执行来保证原子性。
3、如返回1，则该客户端获得锁，把lock.foo的键值设置为时间值表示该键已被锁定，该客户端最后可以通过DEL lock.foo来释放该锁。如返回0，表明该锁已被其他客户端取得，这时我们可以先返回或进行重试等对方完成或等待锁超时。
4、使用分布式锁要满足的几个条件：系统是一个分布式系统（关键是分布式，单机的可以使用ReentrantLock或者synchronized代码块来实现）共享资源（各个系统访问同一个资源，资源的载体可能是传统关系型数据库或者NoSQL）。
5、原理很简单，set 一个锁-key，如果成功则说明加锁成功，反之则失败。
6、写在前面现在面试，一般都会聊聊分布式系统这块的东西。通常面试官都会从服务框架（Spring Cloud、Dubbo）聊起，一路聊到分布式事务、分布式锁、ZooKeeper等知识。
基于Redission使用Redis的Stream这里，有个group名字叫testGroup31 ，里面有消费者6个，pending代表目前有6个数据被读取了，但没有ack 。last_delivered-id代表这个group目前读到哪条消息。
创建Stream的名称是 stream-key 创建2个消息，aa和bb 表示从最后一个元素消费，不包括Stream中的最后一个元素，即消费最新的消息。
首先默认的队列监听是自动确认的，但是如出现异常不会自动确认，默认的失败机制是不断重试，这样会影响mq性能。其次可以在配置文件中指定失败重试次数和重试间隔。
使用XLEN命令来获取一个Stream的条目数量：按范围查询： XRANGE 和 XREVRANGE 要根据范围查询Stream，我们只需要提供两个ID，即start 和 end 。返回的区间数据将会包括ID是start和end的元素，因此区间是完全包含的。
【redissionclient redission使用教程】Stream是Redis0 引入的一个新的数据类型，官方把它定义为：以更抽象的方式模拟日志的数据结构。