redis入門篇

Redis用在哪里

1. 高并發緩存/共享session：

UserInfo getUserInfo (long id) {}

?。?/p>

userRedisKey = "user:info:" + id;

value = redis.get(userRedisKey?);

if (value != null) {

userInfo = deserialize(value);

return userInfo;

}

存：

userInfo = ***getUserInfo(id);

redis.setex(userRedisKey, 3600, serialize(userInfo));

用string存儲序列化后的數據，不夠立體直觀，可以轉為hmset存儲為哈希結構，存取更直觀

2. 簡單分布式鎖

setnx只有不存在時能設置成功，其余只能等待。單線程

3. 計數器 incr，因為是單線程，比cas等少了cpu消耗，性能更高

long incrVideoCounter (long id) {

key = "video:playCount:" + id;

return redis.incr(key);

}

4. 實現棧/隊列

棧: ? ? ? lpush + lpop

隊列: ? ?lpush + rpop

5. 流量控制/限速

phoneNum = "12345678999";

key = "shortMsg:limit:" +?phoneNum;

isExists = redis.set(key, 1, "EX 60", "NX");

if (isExists != null || redis.incr(key) <= 5) {

//通過

} else {

//不通過

}

6. 消息隊列

使用lpush + brpop可實現阻塞隊列，生產者從列表左端lpush插入元素，多個消費者從右端brpop阻塞獲取隊列尾部元素

7. 每個用戶有自己的文章，現在要分頁展示文章列表

hmset article:1 title xx context XXXX

lpush user:1:articles srticle:1 articles:3

articles = lrange user:1:articles 0 9

for article in {articles}

hgetall {article}

8. 關注等

： zincrby user:ranking:2016_03_15 mike 1

取消： zrem user:ranking:2016_03_15 mike

取得贊最多的10個用戶： zrevrangebyrank user:ranking:2016_03_15 0 9

展示用戶信息及分數： hgetall user:info:tom / ?zscore user:ranking:2016_03_15 mike / zrank user:ranking:2016_03_15 mike

9. bitmaps 計算大數據集合見的關系等

10. 排行榜

mike上傳了一個視頻并獲得了3個贊 ? zadd user:ranking:2016_03_15 mike 3

又有人給點了個贊 ?zincrby user:ranking:2016_03_15 mike 1

11. 共同關注

給用戶添加關注標簽 ? sadd?user:1:tags?tag1 tag2

給標簽添加用戶 ? ? ? ? ?sadd tag1:uses user:1

共同關注 ? sinter user:1:tags user:2:tags

sinter/sunion/sdiff

12. 發布訂閱

subscribe video:changes:

publish video:changeds "video1,video2"

for video in video1,video2

update (video)

每種數據type對應了多種底層數據結構實現(object encoding)，可以通過數據大小長度場景等切換，達到更高的效率

持久化RDB(子進程創建，二進制文件，恢復快，不夠實時)/AOF（appendonly。文本文件，實時寫操作先aop_buffer，然后通過配置寫入磁盤間隔，寫入磁盤，達到一定大小合并）

批量hmget等操作要轉為hscan等漸進式遍歷方法，否則容易阻塞

緩沖：客戶端緩沖（輸入/輸出），復制積壓緩沖，aof緩沖

復制： 全量/增量?復制偏移量/復制積壓緩沖（寫命令發送給從服務器同時還維護一個先進先出的隊列，等于主服務還保存著最近傳播的命令）/ID

sentinal: 實現高可用，本身是特殊的redis節點，可以自己配置集群，通過心跳等機制監控redis數據集群，當某一節點出現故障不可用，可以及時發現并自動遷移

cluster: 分布式集群，容錯選主等。將物理結點映射到16383個槽位實現動態性

1、redis介紹

redis是一個key-value存儲系統。和Memcached類似，它支持存儲的value類型相對更多，包括string(字符串)、list(鏈表)、set(集合)、zset(sorted set --有序集合)和hashs（哈希類型）。這些數據類型都支持push/pop、add/remove及取交集并集和差集及更豐富的操作，而且這些操作都是原子性的。在此基礎上，redis支持各種不同方式的排序。與memcached一樣，為了保證效率，數據都是緩存在內存中。區別的是redis會周期性的把更新的數據寫入磁盤或者把修改操作寫入追加的記錄文件，并且在此基礎上實現了master-slave(主從)同步。

Redis 是一個高性能的key-value數據庫。 redis的出現，很大程度補償了memcached這類key/value存儲的不足，在部分場合可以對關系數據庫起到很好的補充作用。它提供了Python，Ruby，Erlang，PHP客戶端，使用很方便。

2、windows下安裝redis

-https://github.com/dmajkic/redis/downloads。下載到的Redis支持32bit和64bit。根據自己實際情況選擇，我選擇32bit。把32bit文件內容拷貝到需要安裝的目錄下,比如：D:\dev\redis-2.4.5。

打開一個cmd窗口，使用cd命令切換到指定目錄（D:\dev\redis-2.4.5）運行?redis-server.exe redis.conf?。運行以后出現如下界面。

這就說明Redis服務端已經安裝成功。

重新打開一個cmd窗口，使用cd命令切換到指定目錄（D:\dev\redis-2.4.5）運行?redis-cli.exe -h 127.0.0.1 -p 6379，其中 127.0.0.1是本地ip，6379是redis服務端的默認端口。運行成功如下圖所示。

這樣，Redis windows環境下搭建已經完成，是不是很簡單。

這樣，Redis windows環境下搭建已經完成，是不是很簡單。

環境已經搭建好，總得測試下吧。比如：存儲一個key為test，value為hello word的字符串，然后獲取key值。

正確輸出 hell word，測試成功！

package com.test;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import org.junit.Before;

import org.junit.Test;

import redis.clients.jedis.Jedis;

public class TestRedis {

private Jedis jedis;

@Before

public void setup() {

//連接redis服務器，192.168.0.100:6379

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

//權限認證

jedis.auth("admin");

}

/**

* redis存儲字符串

*/

@Test

public void testString() {

//-----添加數據----------

jedis.set("name","xinxin");//向key-->name中放入了value-->xinxin

System.out.println(jedis.get("name"));//執行結果：xinxin

jedis.append("name", " is my lover"); //拼接

System.out.println(jedis.get("name"));

jedis.del("name"); //刪除某個鍵

System.out.println(jedis.get("name"));

//設置多個鍵值對

jedis.mset("name","liuling","age","23","qq","476777XXX");

jedis.incr("age"); //進行加1操作

System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));

}

/**

* redis操作Map

*/

@Test

public void testMap() {

//-----添加數據----------

Map map = new HashMap();

map.put("name", "xinxin");

map.put("age", "22");

map.put("qq", "123456");

jedis.hmset("user",map);

//取出user中的name，執行結果:[minxr]-->注意結果是一個泛型的List

//第一個參數是存入redis中map對象的key，后面跟的是放入map中的對象的key，后面的key可以跟多個，是可變參數

List rsmap = jedis.hmget("user", "name", "age", "qq");

System.out.println(rsmap);

//刪除map中的某個鍵值

jedis.hdel("user","age");

System.out.println(jedis.hmget("user", "age")); //因為刪除了，所以返回的是null

System.out.println(jedis.hlen("user")); //返回key為user的鍵中存放的值的個數2

System.out.println(jedis.exists("user"));//是否存在key為user的記錄 返回true

System.out.println(jedis.hkeys("user"));//返回map對象中的所有key

System.out.println(jedis.hvals("user"));//返回map對象中的所有value

Iterator iter=jedis.hkeys("user").iterator();

while (iter.hasNext()){

String key = iter.next();

System.out.println(key+":"+jedis.hmget("user",key));

}

}

/**

* jedis操作List

*/

@Test

public void testList(){

//開始前，先移除所有的內容

jedis.del("java framework");

System.out.println(jedis.lrange("java framework",0,-1));

//先向key java framework中存放三條數據

jedis.lpush("java framework","spring");

jedis.lpush("java framework","struts");

jedis.lpush("java framework","hibernate");

//再取出所有數據jedis.lrange是按范圍取出，

// 第一個是key，第二個是起始位置，第三個是結束位置，jedis.llen獲取長度 -1表示取得所有

System.out.println(jedis.lrange("java framework",0,-1));

jedis.del("java framework");

jedis.rpush("java framework","spring");

jedis.rpush("java framework","struts");

jedis.rpush("java framework","hibernate");

System.out.println(jedis.lrange("java framework",0,-1));

}

/**

* jedis操作Set

*/

@Test

public void testSet(){

//添加

jedis.sadd("user","liuling");

jedis.sadd("user","xinxin");

jedis.sadd("user","ling");

jedis.sadd("user","zhangxinxin");

jedis.sadd("user","who");

//移除noname

jedis.srem("user","who");

System.out.println(jedis.smembers("user"));//獲取所有加入的value

System.out.println(jedis.sismember("user", "who"));//判斷 who 是否是user集合的元素

System.out.println(jedis.srandmember("user"));

System.out.println(jedis.scard("user"));//返回集合的元素個數

}

@Test

public void test() throws InterruptedException {

//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));

}

@Test

public void testRedisPool() {

RedisUtil.getJedis().set("newname", "中文測試");

System.out.println(RedisUtil.getJedis().get("newname"));

}

}

package com.test;

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 = "192.168.0.100";

//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, AUTH);

} 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);

}

}

}

Redis

版權聲明：本文內容由網絡用戶投稿，版權歸原作者所有，本站不擁有其著作權，亦不承擔相應法律責任。如果您發現本站中有涉嫌抄襲或描述失實的內容，請聯系我們jiasou666@gmail.com 處理，核實后本網站將在24小時內刪除侵權內容。

版權聲明：本文內容由網絡用戶投稿，版權歸原作者所有，本站不擁有其著作權，亦不承擔相應法律責任。如果您發現本站中有涉嫌抄襲或描述失實的內容，請聯系我們jiasou666@gmail.com 處理，核實后本網站將在24小時內刪除侵權內容。