Jedis干啥用的

Posted 2023-04-23

redis是key-value存储系统。

key-value分布式存储系统查询速度快、存放数据量大、支持高并发，非常适合通过主键进行查询，但不能进行复杂的条件查询。

如果辅以Real-Time Search Engine（实时搜索引擎）进行复杂条件检索、全文检索，就可以替代并发性能较低的mysql等关系型数据库，达到高并发、高性能，节省几十倍服务器数 量的目的。

以MemcacheDB、Tokyo Tyrant为代表的key-value分布式存储，在上万并发连接下，轻松地完成高速查询。而MySQL，在几百个并发连接下，就基本上崩溃了。

在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。

扩展资料：

Jedis主存保护是存储保护的重要环节。主存保护一般有存储区域保护和访问方式保护。存储区域保护可采用界限寄存器方式，由系统软件经特权指令给定上、下界寄存器内容，从而划定每个用户程序的区域，禁止越界访问。

Jedis当两键符合时才允许执行存取操作，从而保护别的程序区域不被侵犯，环状保护是把系统程序和用户程序按重要性分层，称为环，对每个环都规定访问它的级别，违反规定的存取操作是非法的，以此实现对正在执行的程序的保护。

参考资料来源：百度百科-Key-Value

参考技术A redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)和zset(有序集合)。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。
　　Redis 是一个高性能的key-value数据库。 redis的出现，很大程度补偿了memcached这类key/value存储的不足，在部 分场合可以对关系数据库起到很好的补充作用。它提供了Python，Ruby，Erlang，php客户端，使用很方便。 参考技术B Jedis使用总结
前段时间细节的了解了Jedis的使用，Jedis是redis的java版本的客户端实现。
本文做个总结，主要分享如下内容：
【pipeline】【分布式的id生成器】【分布式锁【watch】【multi】】【redis分布式】
好了，一个一个来。
一、 Pipeline
官方的说明是：starts a pipeline,which is a very efficient way to send lots of command and read all the responses when you finish sending them。简单点说pipeline适用于批处理。当有大量的操作需要一次性执行的时候，可以用管道。
示例：
Jedis jedis = new Jedis(String, int);
Pipeline p = jedis.pipelined();
p.set(key,value);//每个操作都发送请求给redis-server
p.get(key,value);

p.sync();//这段代码获取所有的response
这里我进行了20w次连续操作（10w读，10w写），不用pipeline耗时：187242ms，用pipeline耗时：1188ms，可见使用管道后的性能上了一个台阶。看了代码了解到，管道通过一次性写入请求，然后一次性读取响应。也就是说jedis是：request response，request response，...；pipeline则是：request request... response response的方式。这样无需每次请求都等待server端的响应。
二、 跨jvm的id生成器
谈到这个话题，首先要知道redis-server端是单线程来处理client端的请求的。
这样来实现一个id生成器就非常简单了，只要简单的调用jdeis.incr(key);就搞定了。
你或许会问，incr是原子操作吗，能保证不会出现并发问题吗，不是说了吗，server端是单线程处理请求的。
三、 【跨jvm的锁实现【watch】【multi】】
首先说下这个问题的使用场景，有些时候我们业务逻辑是在不同的jvm进程甚至是不同的物理机上的jvm处理的。这样如何来实现不同jvm上的同步问题呢，其实我们可以基于redis来实现一个锁。
具体事务和监听请参考文章：redis学习笔记之事务
暂时找到三种实现方式：
1. 通过jedis.setnx(key,value)实现
import java.util.Random;
import org.apache.commons.pool.impl.GenericObjectPool.Config;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.Transaction;
/**
* @author Teaey
*/
public class RedisLock
//加锁标志
public static final String LOCKED = "TRUE";
public static final long ONE_MILLI_NANOS = 1000000L;
//默认超时时间（毫秒）
public static final long DEFAULT_TIME_OUT = 3000;
public static JedisPool pool;
public static final Random r = new Random();
//锁的超时时间（秒），过期删除
public static final int EXPIRE = 5 * 60;
static
pool = new JedisPool(new Config(), "host", 6379);

private Jedis jedis;
private String key;
//锁状态标志
private boolean locked = false;
public RedisLock(String key)
this.key = key;
this.jedis = pool.getResource();

public boolean lock(long timeout)
long nano = System.nanoTime();
timeout *= ONE_MILLI_NANOS;
try
while ((System.nanoTime() - nano) < timeout)
if (jedis.setnx(key, LOCKED) == 1)
jedis.expire(key, EXPIRE);
locked = true;
return locked;

// 短暂休眠，nano避免出现活锁
Thread.sleep(3, r.nextInt(500));

catch (Exception e)

return false;

public boolean lock()
return lock(DEFAULT_TIME_OUT);

// 无论是否加锁成功，必须调用
public void unlock()
try
if (locked)
jedis.del(key);
finally
pool.returnResource(jedis);



2. 通过事务(multi)实现
由于采纳第一张方法，第二种跟第三种实现只贴了关键代码，望谅解。^_^
public boolean lock_2(long timeout)
long nano = System.nanoTime();
timeout *= ONE_MILLI_NANOS;
try
while ((System.nanoTime() - nano) < timeout)
Transaction t = jedis.multi();
// 开启事务，当server端收到multi指令
// 会将该client的命令放入一个队列，然后依次执行，知道收到exec指令
t.getSet(key, LOCKED);
t.expire(key, EXPIRE);
String ret = (String) t.exec().get(0);
if (ret == null || ret.equals("UNLOCK"))
return true;

// 短暂休眠，nano避免出现活锁
Thread.sleep(3, r.nextInt(500));

catch (Exception e)

return false;

3. 通过事务+监听实现
public boolean lock_3(long timeout)
long nano = System.nanoTime();
timeout *= ONE_MILLI_NANOS;
try
while ((System.nanoTime() - nano) < timeout)
jedis.watch(key);
// 开启watch之后，如果key的值被修改，则事务失败，exec方法返回null
String value = jedis.get(key);
if (value == null || value.equals("UNLOCK"))
Transaction t = jedis.multi();
t.setex(key, EXPIRE, LOCKED);
if (t.exec() != null)
return true;


jedis.unwatch();
// 短暂休眠，nano避免出现活锁
Thread.sleep(3, r.nextInt(500));

catch (Exception e)

return false;

最终采用第一种实现，因为加锁只需发送一个请求，效率最高。
四、 【redis分布式】
最后一个话题，jedis的分布式。在jedis的源码里发现了两种hash算法（MD5，MURMUR Hash(默认）），也可以自己实现redis.clients.util.Hashing接口扩展。
List<JedisShardInfo> hosts = new ArrayList<JedisShardInfo>();
//server1
JedisShardInfo host1 = new JedisShardInfo("", 6380, 2000);
//server2
JedisShardInfo host2 = new JedisShardInfo("", 6381, 2000);
hosts.add(host1);
hosts.add(host2);
ShardedJedis jedis = new ShardedJedis(hosts);
jedis.set("key", "");本回答被提问者和网友采纳

这个“1342177280”标志是干啥用的？

【中文标题】这个“1342177280”标志是干啥用的？

【英文标题】：For whats this "1342177280" flag for?这个“1342177280”标志是干什么用的？

【发布时间】：2020-11-04 03:02:32

【问题描述】：

我有一些代码 sn-p 用于打开带有以下标志的 whatsapp

  Intent intent = new Intent();
            intent.setClassName("com.whatsapp", "com.whatsapp.HomeActivity");
            intent.addFlags(1342177280);
            intent.addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
            startActivityForResult(intent, 9);

上面的 sn-p 显示错误 1342177280 如下所示

Error image here

我不明白这个标志 1342177280 是关于什么的，知道吗？

【问题讨论】：

这些是标志 OR'ed 在一起 (developer.android.com/reference/android/content/…); 10100000000000000000000000000000 二进制。 （也许：FLAG_ACTIVITY_NEW_TASK 和 FLAG_RECEIVER_REGISTERED_ONLY）

警告是因为您使用的是显式整数，而不是在“已批准”标志列表中绘制。

【参考方案1】：

我正在扩展 codebod 的评论

警告是因为您使用的是显式整数，而不是在“已批准”标志列表中绘制。

Intent 的 addFlags() 方法接受一个在 android 框架中预定义为常量的 int 参数。预定义的常量具有相应的整数值。您看到该错误是因为您输入的整数值与任何预定义值都不匹配。

查看this 文档以查看 Intent 的 addFlags() 方法可以接受的有效参数列表。