天天看點

Redis【入門】就這一篇!

Redis 概述

在我們日常的Java Web開發中,無不都是使用資料庫來進行資料的存儲,由于一般的系統任務中通常不會存在高并發的情況,是以這樣看起來并沒有什麼問題,可是一旦涉及大資料量的需求,比如一些商品搶購的情景,或者是首頁通路量瞬間較大的時候,單一使用資料庫來儲存資料的系統會因為面向磁盤,磁盤讀/寫速度比較慢的問題而存在嚴重的性能弊端,一瞬間成千上萬的請求到來,需要系統在極短的時間内完成成千上萬次的讀/寫操作,這個時候往往不是資料庫能夠承受的,極其容易造成資料庫系統癱瘓,最終導緻服務當機的嚴重生産問題。

NoSQL 技術

為了克服上述的問題,Java Web項目通常會引入NoSQL技術,這是一種基于記憶體的資料庫,并且提供一定的持久化功能。

Redis和MongoDB是目前使用最廣泛的NoSQL,而就Redis技術而言,它的性能十分優越,可以支援每秒十幾萬此的讀/寫操作,其性能遠超資料庫,并且還支援叢集、分布式、主從同步等配置,原則上可以無限擴充,讓更多的資料存儲在記憶體中,更讓人欣慰的是它還支援一定的事務能力,這保證了高并發的場景下資料的安全和一緻性。

Redis 在 Java Web 中的應用

Redis 在 Java Web 主要有兩個應用場景:

  • 存儲 緩存 用的資料;
  • 需要高速讀/寫的場合使用它快速讀/寫;

緩存

在日常對資料庫的通路中,讀操作的次數遠超寫操作,比例大概在 1:9 到 3:7,是以需要讀的可能性是比寫的可能大得多的。當我們使用SQL語句去資料庫進行讀寫操作時,資料庫就會去磁盤把對應的資料索引取回來,這是一個相對較慢的過程。

如果我們把資料放在 Redis 中,也就是直接放在記憶體之中,讓服務端直接去讀取記憶體中的資料,那麼這樣速度明顯就會快上不少,并且會極大減小資料庫的壓力,但是使用記憶體進行資料存儲開銷也是比較大的,限于成本的原因,一般我們隻是使用 Redis 存儲一些常用和主要的資料,比如使用者登入的資訊等。

一般而言在使用 Redis 進行存儲的時候,我們需要從以下幾個方面來考慮:

  • 業務資料常用嗎?命中率如何?如果命中率很低,就沒有必要寫入緩存;
  • 該業務資料是讀操作多,還是寫操作多?如果寫操作多,頻繁需要寫入資料庫,也沒有必要使用緩存;
  • 業務資料大小如何?如果要存儲幾百兆位元組的檔案,會給緩存帶來很大的壓力,這樣也沒有必要;

在考慮了這些問題之後,如果覺得有必要使用緩存,那麼就使用它!使用 Redis 作為緩存的讀取邏輯如下圖所示:

從上圖我們可以知道以下兩點:

  1. 當第一次讀取資料的時候,讀取 Redis 的資料就會失敗,此時就會觸發程式讀取資料庫,把資料讀取出來,并且寫入 Redis 中;
  2. 當第二次以及以後需要讀取資料時,就會直接讀取 Redis,讀到資料後就結束了流程,這樣速度就大大提高了。

從上面的分析可以知道,讀操作的可能性是遠大于寫操作的,是以使用 Redis 來處理日常中需要經常讀取的資料,速度提升是顯而易見的,同時也降低了對資料庫的依賴,使得資料庫的壓力大大減少。

分析了讀操作的邏輯,下面我們來看看寫操作的流程:

從流程可以看出,更新或者寫入的操作,需要多個 Redis 的操作,如果業務資料寫次數遠大于讀次數那麼就沒有必要使用 Redis。

關于使用記憶體存儲資料,我知道谷歌好像就是把所有網際網路的資料都存儲在記憶體條的,是以才會有如此高品質、高效的搜尋,但它畢竟是谷歌...

高速讀/寫的場合

在如今的網際網路中,越來越多的存在高并發的情況,比如天貓雙11、搶紅包、搶演唱會門票等,這些場合都是在某一個瞬間或者是某一個短暫的時刻有成千上萬的請求到達伺服器,如果單純的使用資料庫來進行處理,就算不崩,也會很慢的,輕則造成使用者體驗極差使用者量流失,重則資料庫癱瘓,服務當機,而這樣的場合都是不允許的!

是以我們需要使用 Redis 來應對這樣的高并發需求的場合,我們先來看看一次請求操作的流程圖:

我們來進一步闡述這個過程:

  1. 當一個請求到達伺服器時,隻是把業務資料在 Redis 上進行讀寫,而沒有對資料庫進行任何的操作,這樣就能大大提高讀寫的速度,進而滿足高速響應的需求;
  2. 但是這些緩存的資料仍然需要持久化,也就是存入資料庫之中,是以在一個請求操作完 Redis 的讀/寫之後,會去判斷該高速讀/寫的業務是否結束,這個判斷通常會在秒殺商品為0,紅包金額為0時成立,如果不成立,則不會操作資料庫;如果成立,則觸發事件将 Redis 的緩存的資料以批量的形式一次性寫入資料庫,進而完成持久化的工作。

Redis 的安裝

通路位址:https://github.com/ServiceStack/redis-windows/tree/master/downloads

把 Redis 下載下傳下來後找到一個合适的地方解壓,就能得到如下圖所示的目錄(這裡空格被替換成了%20...):

為了友善啟動,我們在該目錄下建立一個 startup.cmd 的檔案,然後将以下内容寫入檔案:

redis-server redis.windows.conf
           

這個指令其實就是在調用 redis-server.exe 指令來讀取 redis.window.conf 的内容,我們輕按兩下剛才建立好的 startup.cmd 檔案,就能成功的看到 Redis 啟動:

上圖的提示資訊告訴了我們:① Redis 目前的版本為 3.0.503;② Redis 運作在 6379 端口;③ Redis 程序的 PID 為 14748;④ 64 位。

我們可以打開同一個檔案夾下的 redis-cli.exe 檔案,這是 Redis 自帶的一個用戶端工具,它可以用來連接配接到我們目前的 Redis 伺服器,我們做以下測試:

如此,我們便在 Windows 的環境下安裝好了 Redis。

在 Java 中使用 Redis

第一步:添加 Jedis 依賴

想要在 Java 中使用 Redis 緩存,需要添加相關的Jar包依賴,打開Maven倉庫的網站:https://mvnrepository.com/ ,搜尋Jedis:

把它導入工程中去就可以啦,下面我們來對Redis的寫入性能做一下測試:

@Test
public void redisTester() {
	Jedis jedis = new Jedis("localhost", 6379, 100000);
	int i = 0;
	try {
		long start = System.currentTimeMillis();// 開始毫秒數
		while (true) {
			long end = System.currentTimeMillis();
			if (end - start >= 1000) {// 當大于等于1000毫秒(相當于1秒)時,結束操作
				break;
			}
			i++;
			jedis.set("test" + i, i + "");
		}
	} finally {// 關閉連接配接
		jedis.close();
	}
	// 列印1秒内對Redis的操作次數
	System.out.println("redis每秒操作:" + i + "次");
}
-----------測試結果-----------
redis每秒操作:10734次
           

據說 Redis 的性能能達到十萬級别,我不敢相信我的桌上型電腦電腦隻有十分之一不到的性能,雖然說這裡不是流水線的操作,會造成一定的影響,但我還是不信邪,我查到了官方的性能測試方法:

首先在Redis根目錄下召喚Cmd:具體方法是按住【Shift】點選右鍵

然後輸入指令:【redis-benchmark -n 100000 -q】:來同時執行10萬個請求測試性能

好吧,我同時在我的筆記本上測試了一下,結果更加慘淡...low啊low...

第二步:使用 Redis 連接配接池

跟資料庫連接配接池相同,Java Redis也同樣提供了類

redis.clients.jedis.JedisPool

來管理我們的Reids連接配接池對象,并且我們可以使用

redis.clients.jedis.JedisPoolConfig

來對連接配接池進行配置,代碼如下:

JedisPoolConfig poolConfig = new JedisPoolConfig();
// 最大空閑數
poolConfig.setMaxIdle(50);
// 最大連接配接數
poolConfig.setMaxTotal(100);
// 最大等待毫秒數
poolConfig.setMaxWaitMillis(20000);
// 使用配置建立連接配接池
JedisPool pool = new JedisPool(poolConfig, "localhost");
// 從連接配接池中擷取單個連接配接
Jedis jedis = pool.getResource();
// 如果需要密碼
//jedis.auth("password");
           

Redis 隻能支援六種資料類型(string/hash/list/set/zset/hyperloglog)的操作,但在 Java 中我們卻通常以類對象為主,是以在需要 Redis 存儲的五中資料類型與 Java 對象之間進行轉換,如果自己編寫一些工具類,比如一個角色對象的轉換,還是比較容易的,但是涉及到許多對象的時候,這其中無論工作量還是工作難度都是很大的,是以總體來說,就操作對象而言,使用 Redis 還是挺難的,好在 Spring 對這些進行了封裝和支援。

第三步:在 Spring 中使用 Redis

上面說到了 Redis 無法操作對象的問題,無法在那些基礎類型和 Java 對象之間友善的轉換,但是在 Spring 中,這些問題都可以通過使用RedisTemplate得到解決!

想要達到這樣的效果,除了 Jedis 包以外還需要在 Spring 引入 spring-data-redis 包:https://mvnrepository.com/artifact/org.springframework.data/spring-data-redis

這裡把2.0.7最新版本标紅的意思是:别老想着使用最新的Jar包,特别是涉及到架構的一些東西,筆者用實際的操作體驗告訴你們,引入該版本的包是會導緻Jar包沖突的(也就是莫名其妙的錯誤),我乖乖換回了1.7.2的版本,代碼就通了...我們來看看怎麼做吧:

(1)第一步:使用Spring配置JedisPoolConfig對象

大部分的情況下,我們還是會用到連接配接池的,于是先用 Spring 配置一個 JedisPoolConfig 對象:

<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <!--最大空閑數-->
    <property name="maxIdle" value="50"/>
    <!--最大連接配接數-->
    <property name="maxTotal" value="100"/>
    <!--最大等待時間-->
    <property name="maxWaitMillis" value="20000"/>
</bean>
           

(2)第二步:為連接配接池配置工廠模型

好了,我們現在配置好了連接配接池的相關屬性,那麼具體使用哪種工廠實作呢?在Spring Data Redis中有四種可供我們選擇的工廠模型,它們分别是:

  • JredisConnectionFactory
  • JedisConnectionFactory
  • LettuceConnectionFactory
  • SrpConnectionFactory

我們這裡就簡單配置成JedisConnectionFactory:

<bean id="connectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
    <!--Redis服務位址-->
    <property name="hostName" value="localhost"/>
    <!--端口号-->
    <property name="port" value="6379"/>
    <!--如果有密碼則需要配置密碼-->
    <!--<property name="password" value="password"/>-->
    <!--連接配接池配置-->
    <property name="poolConfig" ref="poolConfig"/>
</bean>
           

(3)第三步:配置RedisTemplate

普通的連接配接根本沒有辦法直接将對象直接存入 Redis 記憶體中,我們需要替代的方案:将對象序列化(可以簡單的了解為繼承Serializable接口)。我們可以把對象序列化之後存入Redis緩存中,然後在取出的時候又通過轉換器,将序列化之後的對象反序列化回對象,這樣就完成了我們的要求:

RedisTemplate可以幫助我們完成這份工作,它會找到對應的序列化器去轉換Redis的鍵值:

<bean id="redisTemplate"
      class="org.springframework.data.redis.core.RedisTemplate"
      p:connection-factory-ref="connectionFactory"/>
           
筆者從《JavaEE網際網路輕量級架構整合開發》中了解到,這一步需要配置單獨的序列化器去支撐這一步的工作,但是自己在測試當中,發現隻要我們的POJO類實作了Serializable接口,就不會出現問題...是以我直接省略掉了配置序列化器這一步...

(4)第四步:編寫測試

首先編寫好支援我們測試的POJO類:

/**
 * @author: @我沒有三顆心髒
 * @create: 2018-05-30-下午 22:31
 */
public class Student implements Serializable{

	private String name;
	private int age;

	/**
	 * 給該類一個服務類用于測試
	 */
	public void service() {
		System.out.println("學生名字為:" + name);
		System.out.println("學生年齡為:" + age);
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public int getAge() {
		return age;
	}

	public void setAge(int age) {
		this.age = age;
	}
}
           

然後編寫測試類:

@Test
public void test() {
	ApplicationContext context =
			new ClassPathXmlApplicationContext("applicationContext.xml");
	RedisTemplate redisTemplate = context.getBean(RedisTemplate.class);
	Student student = new Student();
	student.setName("我沒有三顆心髒");
	student.setAge(21);
	redisTemplate.opsForValue().set("student_1", student);
	Student student1 = (Student) redisTemplate.opsForValue().get("student_1");
	student1.service();
}
           

運作可以成功看到結果:

第四步:在 SpringBoot 中使用 Redis

(1)在SpringBoot中添加Redis依賴:

<!-- Radis -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
           

(2)添加配置檔案:

在SpringBoot中使用

.properties

或者

.yml

都可以,這裡給出

.properties

的例子,因為自己的

.yml

檔案看上去感覺亂糟糟的:

# REDIS (RedisProperties)
# Redis資料庫索引(預設為0)
spring.redis.database=0
# Redis伺服器位址
spring.redis.host=localhost
# Redis伺服器連接配接端口
spring.redis.port=6379
# Redis伺服器連接配接密碼(預設為空)
spring.redis.password=
# 連接配接池最大連接配接數(使用負值表示沒有限制)
spring.redis.pool.max-active=8
# 連接配接池最大阻塞等待時間(使用負值表示沒有限制)
spring.redis.pool.max-wait=-1
# 連接配接池中的最大空閑連接配接
spring.redis.pool.max-idle=8
# 連接配接池中的最小空閑連接配接
spring.redis.pool.min-idle=0
# 連接配接逾時時間(毫秒)
spring.redis.timeout=0
           

(3)測試通路:

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest()
public class ApplicationTests {

	@Autowired
	private StringRedisTemplate stringRedisTemplate;

	@Test
	public void test() throws Exception {

		// 儲存字元串
		stringRedisTemplate.opsForValue().set("aaa", "111");
		Assert.assertEquals("111", stringRedisTemplate.opsForValue().get("aaa"));

	}
}
           

通過上面這段極為簡單的測試案例示範了如何通過自動配置的StringRedisTemplate對象進行Redis的讀寫操作,該對象從命名中就可注意到支援的是String類型。原本是RedisTemplate<K, V>接口,StringRedisTemplate就相當于RedisTemplate<String, String>的實作。

運作測試,如果一切成功則不會報錯,如果我們沒有拿到或者拿到的數不是我們想要的 “111” ,那麼則會報錯,這是使用Assert的好處(下面是我改成112之後運作報錯的結果):

(4)存儲對象:

這一步跟上面使用Spring一樣,隻需要将POJO類實作Serializable接口就可以了,我這裡就貼一下測試代碼:

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest()
public class ApplicationTests {

	@Autowired
	private RedisTemplate redisTemplate;

	@Test
	public void test() throws Exception {

		User user = new User();
		user.setName("我沒有三顆心髒");
		user.setAge(21);

		redisTemplate.opsForValue().set("user_1", user);
		User user1 = (User) redisTemplate.opsForValue().get("user_1");

		System.out.println(user1.getName());
	}
}
           

仍然沒有任何問題:

參考文章:

1.https://www.cnblogs.com/ityouknow/p/5748830.html

2.http://blog.didispace.com/springbootredis/

在Redis中操作集合

引用文章:https://www.jianshu.com/p/29aaac3172b5

直接黏上兩段簡單的示例代碼:

在Redis中操作List

// list資料類型适合于消息隊列的場景:比如12306并發量太高,而同一時間段内隻能處理指定數量的資料!必須滿足先進先出的原則,其餘資料處于等待
@Test
public void listPushResitTest() {
	// leftPush依次由右邊添加
	stringRedisTemplate.opsForList().rightPush("myList", "1");
	stringRedisTemplate.opsForList().rightPush("myList", "2");
	stringRedisTemplate.opsForList().rightPush("myList", "A");
	stringRedisTemplate.opsForList().rightPush("myList", "B");
	// leftPush依次由左邊添加
	stringRedisTemplate.opsForList().leftPush("myList", "0");
}

@Test
public void listGetListResitTest() {
	// 查詢類别所有元素
	List<String> listAll = stringRedisTemplate.opsForList().range("myList", 0, -1);
	logger.info("list all {}", listAll);
	// 查詢前3個元素
	List<String> list = stringRedisTemplate.opsForList().range("myList", 0, 3);
	logger.info("list limit {}", list);
}

@Test
public void listRemoveOneResitTest() {
	// 删除先進入的B元素
	stringRedisTemplate.opsForList().remove("myList", 1, "B");
}

@Test
public void listRemoveAllResitTest() {
	// 删除所有A元素
	stringRedisTemplate.opsForList().remove("myList", 0, "A");
}
           

在Redis中操作Hash

@Test
public void hashPutResitTest() {
	// map的key值相同,後添加的覆寫原有的
	stringRedisTemplate.opsForHash().put("banks:12600000", "a", "b");
}

@Test
public void hashGetEntiresResitTest() {
	// 擷取map對象
	Map<Object, Object> map = stringRedisTemplate.opsForHash().entries("banks:12600000");
	logger.info("objects:{}", map);
}

@Test
public void hashGeDeleteResitTest() {
	// 根據map的key删除這個元素
	stringRedisTemplate.opsForHash().delete("banks:12600000", "c");
}

@Test
public void hashGetKeysResitTest() {
	// 獲得map的key集合
	Set<Object> objects = stringRedisTemplate.opsForHash().keys("banks:12600000");
	logger.info("objects:{}", objects);
}

@Test
public void hashGetValueListResitTest() {
	// 獲得map的value清單
	List<Object> objects = stringRedisTemplate.opsForHash().values("banks:12600000");
	logger.info("objects:{}", objects);
}

@Test
public void hashSize() { // 擷取map對象大小
	long size = stringRedisTemplate.opsForHash().size("banks:12600000");
	logger.info("size:{}", size);
}
           

總結

在網上看到了關于MySQL的性能測試,讀寫操作大概就每秒1000以下的樣子,而且這還和引擎相關,是以可以看出Redis确實能在性能方面幫助許多

歡迎轉載,轉載請注明出處!

簡書ID:@我沒有三顆心髒

github:wmyskxz

歡迎關注公衆微信号:wmyskxz_javaweb

分享自己的Java Web學習之路以及各種Java學習資料

繼續閱讀