redis 学习笔记

在一本别的技术资料里面，看到了这个东东，目前手上的项目是用不到的，但是号称“每秒10000的读写操作”，并且高并发的一些运用，比如微信，淘宝都在使用，当然这个东东才10000行不到的C源代码，他们使用的都是自己定制版的。（嘿嘿，相信随便找个像我这样30+的程序苦逼，研究个3个月足以重写了）。

当然对于可预知的未来，这个“每秒10000的读写操作”的性能实现，对我来说已经足够，所以暂时之研究下怎么使用这个东东。

事前准备需要知道的内容

官网：https://redis.io/

他本身是在CentOS上跑的东西，微软给他写了一个Win64位版，所以我们也能在Windows下使用

微软的代码：https://github.com/MSOpenTech/redis （简单安装，下一步下一步就OK了）

这个东东，基于内存访问所以实现高速存取，当然它不是关系型数据库，所以想用SQL文是不行的，但是简单的SET/GET，那是相当不错。

接下来是代码：

首先在官网上要下载驱动，JAVA，.NET都能找到 https://redis.io/clients

具体到使用

jedis = new Jedis("localhost", 6379);

Jedis jedis = new Jedis("localhost", 6379);
//最基础的使用方式，就是普通的SET和GET  
jedis.set("name","Akechi");
System.out.println(jedis.get("name"));
//同时加入多个数据
jedis.mset("name","akechi","age","37","Mail","[email protected]");
System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));  
//我们还可以做些简单的计算
jedis.incr("age"); //进行加1操作
//还支持排序等等
//jedis 排序  
//注意，此处的rpush和lpush是List的操作。是一个双向链表（但从表现来看的）  
jedis.del("a");//先清除数据，再加入数据进行测试  
jedis.rpush("a", "1");  
jedis.lpush("a","6");  
jedis.lpush("a","3");  
jedis.lpush("a","9");  
System.out.println(jedis.lrange("a",0,-1));// [9, 3, 6, 1]  
System.out.println(jedis.sort("a")); //[1, 3, 6, 9]  //输入排序后结果  
System.out.println(jedis.lrange("a",0,-1));

最后，它还支持链接池，这时候需要apache的CommonPool这个包,从别的地方找到的直接考过来

https://commons.apache.org/proper/commons-pool/

package com.exp.redis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public final class RedisUtil {
    
    //Redis服务器IP
    private static String ADDR = "localhost";
    
    //Redis的端口号
    private static int PORT = 6379;
    
    //访问密码
    private static String AUTH = "admin";
    
    //可用连接实例的最大数目，默认值为8；
    //如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。
    private static int MAX_ACTIVE = 1024;
    
    //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。
    private static int MAX_IDLE = 200;
    
    //等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；
    private static int MAX_WAIT = 10000;
    
    private static int TIMEOUT = 10000;
    
    //在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
    private static boolean TEST_ON_BORROW = true;
    
    private static JedisPool jedisPool = null;
    
    /**
     * 初始化Redis连接池
     */
    static {
        try {
            JedisPoolConfig config = new JedisPoolConfig();
            config.setMaxActive(MAX_ACTIVE);
            config.setMaxIdle(MAX_IDLE);
            config.setMaxWait(MAX_WAIT);
            config.setTestOnBorrow(TEST_ON_BORROW);
            jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    /**
     * 获取Jedis实例
     * @return
     */
    public synchronized static Jedis getJedis() {
        try {
            if (jedisPool != null) {
                Jedis resource = jedisPool.getResource();
                return resource;
            } else {
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
    
    /**
     * 释放jedis资源
     * @param jedis
     */
    public static void returnResource(final Jedis jedis) {
        if (jedis != null) {
            jedisPool.returnResource(jedis);
        }
    }
}

作者

归档

分类