Java工程師是如何使用Redis的?


在分佈式和微服務等架構遍地開花的實踐中,Redis始終作為分佈式緩存的首選,可謂經久不衰、獨樹一幟。Redis基於內存運行並支持持久化的NoSQL數據庫,是當前最熱門的NoSql數據庫之一,也被人們稱為數據結構服務器。

而為何要使用Redis呢?Redis不僅僅支持簡單的k/v類型的數據,同時還提供list,set,zset,hash等數據結構的存儲。Redis支持master-slave(主-從)模式應用。Redis支持數據持久化,可以將內存中的數據保持在磁盤中,重啟的時候可以再次加載進行使用。Redis單個value的最大限制是1GB,memcached只能保存1MB的數據。基於種種原因,Redis成為我們緩存架構的首選,而我在開啟碼農生涯時,就接觸到Redis,只是當時的使用比較簡單。

最開始時,因互聯網化團隊初建,各種所需要的中間件都需要自己搭建,包含Redis,而我們使用Docker搭建Redis集群,採用主從的Redis架構,再使用Sentinel(哨兵)模式來監控該Redis集群,使用也是通過Sentinel來使用。通過Spring或Spring Boot的哨兵連接方式連接Redis,註冊成Bean,然後使用序列化的Key-Value結構來緩存所需要的數據。而因領導的風格原因,我們也僅僅被允許採用Key-Value的基礎功能來進行Redis操作。至於其中的原因,也沒有深究。

而隨後,跳槽到現公司,其將Redis作為基礎服務進行封裝,而業務團隊僅通過加密串即可進行直接連接,其背後的可高用、主從分片、災備等均由基礎架構團隊負責。基礎架構團隊提供的操作方式,就不僅僅限於使用Key-Value的get、set、delete等方法,而幾乎完全提供了Redis的所有命令,包含inc、sadd等計數、集合操作。當然,有了這些,對程序員的要求更高,要在合適的場景中選擇恰當的命令進行操作,也不是一件容易的事。

或許,使用Redis有這樣那樣的原因,但在我看來,最重要的就兩條:其一,它能提高用戶的訪問速度,大量的降低系統響應的TP99;其二,它是主流,大家都在用,而且經過了時間的檢驗,抗住了一個又一個電商大促的業務場景。



夕陽雨晴


不僅僅是Java工程師,基本上所有平臺開發工程師都需要使用redis,主要是作為代替memcached的緩存。

由於涉及到底層,所以Redis是用C語言編程的一種能夠快速讀寫的工具。但是實際使用中,Java,PHP,Python等編程語言,都是可以使用Redis的,這種良好的語言擴展性,使Redis快速在原本memcached一家獨大的緩存領域裡攻城略地,並迅速劃定了自己的圈地。

Redis最突出的優點就是讀寫速度極快,既可以作為Server與MySQL之間的緩存,也可以作為分佈式集群系統中多臺Server之間的緩存。

接下來我們就由上述兩種情況來簡單介紹。

Server與MySql之間的緩存

眾所周知,MySQL雖然藉助索引能夠提高查詢速度,但是如果用戶所有的讀請求都到MySQL中去拿的話,還是會有很多的查詢與讀取消耗。這種場景,如果將一段時間內頻繁被讀取的數據提前放到redis中,利用其快速讀取優勢,一方面減少了MySQL的讀庫壓力,一方面也能夠加速用戶側感受到的頁面訪問速度。比如情人節快到了,大眾點評直接將花店,送花外賣等信息放到緩存裡,絕對能夠大幅減少MySQL的讀取壓力。

此外,在一些場景下,有些數據在完全入庫之前,還需要數次的修改。中間的修改過程,如果每次都要去修改MySQL,也是對MySQL增加了讀寫壓力,這時候,如果使用Redis來存儲中間態,就能進一步緩解MySQL的讀寫壓力,從而提高整體服務的穩定性。

server與server之間的緩存

出於擴展性和穩定性方面的考慮,一些集群規模的服務,通常會有多臺相同功能的Tomcat。這樣就有一種可能,假如一個任務由2個步驟組成,第一個步驟是用戶發起任務,第二個步驟是Tomcat反饋後用戶點擊確認才會繼續處理。此時,有一個用戶發來一個任務,這個任務由A Tomcat處理了第一步,然後反饋給了用戶,用戶點擊了確認後這個請求卻被髮送給了B Tomcat,作為B Tomcat也是一臉矇蔽,由於並不能與A Tomcat相互通信,它並不知道前因後果。

這時候假如沒有server之間的緩存,這個任務就進行不下去了。

有了server之間的緩存,A Tomcat在處理完第一個步驟後,會把自己做的事情記錄在redis中,然後等第二個步驟需要執行的時候,無論請求是給了A還是B,只需要到redis中讀取下上一步的記錄,就能繼續進行了。

這就是server間緩存的意義。

以上只是我舉的非常簡單的例子,希望能夠輔助大家理解,並且明白redis並不侷限於JAVA語言。

我是蘇蘇思量,來自BAT的Java開發工程師,每日分享科技類見聞,歡迎關注我,與我共同進步。


蘇蘇思量


redis算是用的最多的key-value型緩存組件了!

因為使用了key-value型,所以存取效率極好,簡單來說就類似JAVA中的hashMap,不過是用整個服務器內存來當做map,但是redis的數據可以通過配置指令保存到硬盤(同步保存save,異步保存bgsave)!


redis是單線程模式,這能保證redis中存取的數據庫絕對線程安全,同時,因為避免多線程之間切換的開銷,redis的存取性能跟使用多線程的memcache在一定程度上旗鼓相當,都非常高的性能,不過redis的value支持G級別的數據,能用來存放大文本等,這是memcache不能做到的。。

為了進一步提升redis的穩定性和存取性能,redis支持集群,具體搭建方式,可參考我之前的一篇回答!

那麼redis在實際的開發中,主要用來做什麼呢?

1,數據存取:無需多說!

2,加鎖:因為redis是單線程的,提供的比如incr,setnx等方法均可以用來當做鎖使用!

3,秒殺系統:商品存隊列,請求進來進行匹配,然後異步出單即可!

4,計數器:對同一個key的value計數即可!

5,超時問題:比如頁面訪問超時啥的,頁面訪問接口的時候持續更新某個設定值,超過某個時間段再訪問,則超時!

當然,redis在使用過程中會存在持久化失敗,緩存擊穿,擴容困難等問題,不過無論如何,redis都是一款最值得用的緩存工具!

使用過程中有任何問題,歡迎大家一起交流,redis還有什麼遺漏功能,也請大家補充,謝謝!


哎喲JAVA不錯哦


Java 使用Redis緩存工具的詳細解說

開始在 Java 中使用 Redis 前, 我們需要確保已經安裝了 redis 服務及 Java redis 驅動,且你的機器上能正常使用 Java。

(1)Java的安裝配置可以參考我們的 Java開發環境配置

(2)安裝了 redis 服務;

請參考:Windows環境下使用Redis緩存工具的圖文詳細方法(http://www.elecfans.com/d/633308.html)

或是:

首先你需要下載驅動包,下載 jedis.jar,確保下載最新驅動包。

在你的classpath中包含該驅動包。

一、新建一個javaweb項目。

1. 新建一個Jedis的項目。

Java 使用Redis緩存工具的詳細解說

Java 使用Redis緩存工具的詳細解說

效果如下:

Java 使用Redis緩存工具的詳細解說

二、下載redis依賴包。

http://yunpan.cn/c36syrdrC6MDx 訪問密碼 0cd6

三、實戰案例

1. 連接本地的 Redis 服務和查看服務是否運行

package com.souvc.redis;

import redis.clients.jedis.Jedis;

/**

* 類名: RedisJava

* 包名: com.souvc.redis

* 描述: 連接本地的 Redis 服務和查看服務是否運行 《/br>

* 開發人員: souvc

* 創建時間: 2015-12-9

* 發佈版本:V1.0

*/

public class RedisJava {

public static void main(String[] args) {

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

System.out.println(“連接本地的 Redis 服務成功!”);

// 查看服務是否運行

System.out.println(“服務 正在運行: ” + jedis.ping());

}

}

效果如下:

Java 使用Redis緩存工具的詳細解說

為什麼會報錯,是我們忘了開redis服務了。

Java 使用Redis緩存工具的詳細解說

Java 使用Redis緩存工具的詳細解說

重新運行,發現:

連接本地的 Redis 服務成功!

Server is running: PONG

以後,我們需要用redis,需要開啟這個服務。

2. Redis Java String(字符串) 實例

package com.souvc.redis;

import redis.clients.jedis.Jedis;

/**

* 類名: RedisJava

* 包名: com.souvc.redis

* 描述: Redis Java String(字符串) 實例

* 開發人員: souvc

* 創建時間: 2015-12-9

* 發佈版本:V1.0

*/

public class RedisStringJava {

public static void main(String[] args) {

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

System.out.println(“連接本地的 Redis 服務成功!”);

// 設置 redis 字符串數據

jedis.set(“souvc”, “http://www.cnblogs.com/liuhongfeng/”);

// 獲取存儲的數據並輸出

System.out.println(“redis存儲的字符串是: ” + jedis.get(“souvc”));

}

}

效果如下:

連接本地的 Redis 服務成功!

redis存儲的字符串是: http://www.cnblogs.com/liuhongfeng/

3. Redis Java List(列表) 實例 (1)

package com.souvc.redis;

import java.util.List;

import redis.clients.jedis.Jedis;

/**

* 類名: RedisListJava

* 包名: com.souvc.redis

* 描述: Redis Java List(列表) 實例

* 開發人員: souvc

* 創建時間: 2015-12-9

* 發佈版本:V1.0

*/

public class RedisListJava {

public static void main(String[] args) {

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

System.out.println(“連接本地的 Redis 服務成功!”);

// 存儲數據到列表中

jedis.lpush(“kecheng”, “java”);

jedis.lpush(“kecheng”, “php”);

jedis.lpush(“kecheng”, “Mysql”);

// 獲取存儲的數據並輸出

List《String> list = jedis.lrange(“kecheng”, 0, 5);

for (int i = 0; i < list.size(); i++) {

System.out.println(“redis list裡面存儲的值是:” + list.get(i));

}

}

}

效果如下:

連接本地的 Redis 服務成功!

redis list裡面存儲的值是:Mysql

redis list裡面存儲的值是:php

redis list裡面存儲的值是:java

Redis Java List(列表) 實例 (2)

package com.souvc.redis;

import redis.clients.jedis.Jedis;

public class RedisListJava2 {

/**

* 方法名:main

* 詳述:Redis Java List(列表) 實例 2

* 開發人員:souvc

* 創建時間:2015-12-9

* @param args 說明返回值含義

* @throws 說明發生此異常的條件

*/

public static void main(String[] args) {

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

System.out.println(“連接本地的 Redis 服務成功!”);

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

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

}

}

效果如下:

連接本地的 Redis 服務成功!

[]

[hibernate, struts, spring]

[spring, struts, hibernate]

4. Redis Java Map 實例

package com.souvc.redis;

import java.util.HashMap;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import redis.clients.jedis.Jedis;

public class RedisMapJava {

/**

* 方法名:main

* 詳述:redis操作Map

* 開發人員:souvc

* 創建時間:2015-12-10

* @param args 說明返回值含義

* @throws 說明發生此異常的條件

*/

public static void main(String[] args) {

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

System.out.println(“連接本地的 Redis 服務成功!”);

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

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可以跟多個,是可變參數

Listrsmap = 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《String> iter=jedis.hkeys(“user”).iterator();

while (iter.hasNext()){

String key = iter.next();

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

}

}

}

效果:

連接本地的 Redis 服務成功!

[xinxin, 22, 123456]

[null]

2

true

[qq, name]

[123456, xinxin]

qq:[123456]

name:[xinxin]

5. Redis Java Set 實例

package com.souvc.redis;

import redis.clients.jedis.Jedis;

public class RedisSetJava {

/**

* 方法名:main

* 詳述:Redis Java Set 實例

* 開發人員:souvc

* 創建時間:2015-12-10

* @param args 說明返回值含義

* @throws 說明發生此異常的條件

*/

public static void main(String[] args) {

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

System.out.println(“連接本地的 Redis 服務成功!”);

//刪除map中的某個鍵值

//jedis.hdel(“user”);

//添加

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”));//返回集合的元素個數

}

}

效果如下:

連接本地的 Redis 服務成功!

[xinxin, liuling, ling, zhangxinxin]

false

ling

4

5. Redis Java Sort實例

package com.souvc.redis;

import redis.clients.jedis.Jedis;

public class RedisSortJava {

/**

* 方法名:main

* 詳述:jedis 排序

* 開發人員:souvc

* 創建時間:2015-12-10

* @param args 說明返回值含義

* @throws 說明發生此異常的條件

*/

public static void main(String[] args) {

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

System.out.println(“連接本地的 Redis 服務成功!”);

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

}

}

效果:

連接本地的 Redis 服務成功!

[9, 3, 6, 1]

[1, 3, 6, 9]

[9, 3, 6, 1]

注意:如果是出現這個錯誤,那麼是因為設置了密碼。

Java 使用Redis緩存工具的詳細解說

我們需要加上一個auth方法進行校驗。

// 連接本地的 Redis 服務

Jedis jedis = new Jedis(“localhost”);

//jedis.auth(“souvc”);

System.out.println(“連接本地的 Redis 服務成功!”);


分享到:


相關文章: