何謂redis

時間  2019-11-19
標籤 何謂 redis 欄目 Redis 简体版
原文   原文鏈接

Rides在spring中應用

一.  redis的簡介

2008 年，意大利一家創業公司 Merzia 的創始人 Salvatore Sanfilippo 爲了不 MySQL的低性能，親自定作一個數據庫，並於 2009 年開發完成，這個就是 Redis。java

從 2010 年 3 月 15 日起，Redis 的開發工做由 VMware 主持。mysql

從 2013 年 5 月開始，Redis 的開發由 Pivotal 贊助。linux

說明：Pivotal 公司是由 EMC 和 VMware 聯合成立的一家新公司。Pivotal 但願爲新一代的應用提供一個原生的基礎，創建在具備領導力的雲和網絡公司不斷轉型的IT特性之上。c++

Pivotal 的使命是推行這些創新，提供給企業 IT 架構師和獨立軟件提供商.web

二.  redis在linux服務器中的安裝

1.  上傳壓縮包到服務器.redis

2.  解壓壓縮包:tar zxvf redis-5.0.3.tar.gzspring

3.  安裝依賴:yum -y install gcc-c++ autoconf automakesql

4.  進行預編譯:切換到解壓目錄cd redis-5.0.3/make數據庫

5.  建立安裝目錄:mkdir -p /usr/local/redis(注意解壓目錄和安裝目分開)express

6.  啓動:安裝的默認目標路徑：/usr/local/redis/bin

7.  修改前臺啓動爲後臺啓動:複製 redis.conf 至安裝路徑下cp redis.conf /usr/local/redis/bin/

8.  修改防火牆(建議防火牆永久關閉),防火牆啓動命令:systemctl start/restart iptables.service 或者 service iptables start 或者 service iptables restart

9.  在Windows系統中安裝redis的客戶端

10.  修改配置文件 redis.conf:註釋掉 bind 127.0.0.1 可使全部的 ip 訪問 redis，如果想指定多個 ip 訪問，但並非所有的 ip 訪問，能夠 bind 設置

11.  重啓redis:修改後 kill -9 XXXX 殺死 redis 進程，重啓 redis

12.  查看進程的命令:ps -ef | grep redis

三.  redis-cli 命令操做 Redis 五種數據類型

1.  redis-cli 鏈接 redis

2.  操做 String:Set:添加一條 String 類型數據;Get:獲取一條 String 類型數據;Mset:添加多條 String 類型數據;Mget:獲取多條 String 類型數據

3.  操做 hash:Hset:添加一條 hash 類型數據;Hget:獲取一條 hash 類型數據;Hmset:添加多條 hash 類型數據;Hmget:獲取多條 hash 類型數據;HgetAll:獲取指定全部 hash 類型數據;hdel:刪除指定 hash 類型數據(一條或多條)

4.  操做 list:Lpush:左添加(頭)list 類型數據;Rpush:右添加(尾)類型數據;Lrange: 獲取 list 類型數據 start 起始下標 end 結束下標 包含關係;llen:獲取條數;lrem:刪除列表中幾個指定 list 類型數據

5.  操做 set:Sadd:添加 set 類型數據;Smembers:獲取 set 類型數據;scard:獲取條數;srem:刪除數據

6.  操做 sorted set:sorted set 是經過分數值來進行排序的，分數值越大，越靠後。Zadd:添加 sorted set 類型數據;Zrange:獲取 sorted set 類型數據;zcard:獲取條數;zrem:刪除數據;Zadd 須要將 Float 或者 Double 類型分數值參數，放置在值參數以前.

7.  Redis 中以層級關係、目錄形式存儲數據:即就是在創建語句時前面添加」:」

8.  設置 key 的失效時間:Redis 有四個不一樣的命令能夠用於設置鍵的生存時間(鍵能夠存在多久)或過時時間(鍵何時會被刪除) :

 EXPlRE <key> <ttl> 命令用於將鍵 key 的生存時間設置爲 ttl 秒。

PEXPIRE <key> <ttl> 命令用於將鍵 key 的生存時間設置爲 ttl 毫秒。 EXPIREAT <key> < timestamp> 命令用於將鍵 key 的過時時間設置爲 timestamp 所指定的秒數時間戳。

 PEXPIREAT <key> < timestamp > 命令用於將鍵 key 的過時時間設置爲 timestamp 所指定的毫秒數時間戳。 TTL:獲取的值爲-1 說明此 key 沒有設置有效期，當值爲-2 時證實過了有效期。

9.  刪除:Del:用於刪除數據（通用，適用於全部數據類型）;Hdel:用於刪除 hash 類型數據

四.  Java 操做 Redis 五種數據類型

1.  建立maven項目

2.  添加依賴

3.  Java鏈接jedis: Jedis jedis = new Jedis(IP,端口);

Jedis.auth(「設置認證密碼」);// 指定數據庫 默認是 0

 jedis.select(1);

 // 使用 ping 命令，測試鏈接是否成功

 String result = jedis.ping();

 System.out.println(result);// 返回 PONG

 // 添加一條數據

 jedis.set("username", "zhangsan");

 // 獲取一條數據

 String username = jedis.get("username");

 System.out.println(username);

 // 釋放資源if (jedis != null)

 jedis.close();

}

4. 經過 Redis 鏈接池獲取鏈接對象並操做服務器 :JedisPool jedisPool = new JedisPool(new JedisPoolConfig(),

"192.168.10.100", 6379, 10000, "root");

 // 從鏈接池獲取鏈接

 Jedis jedis = jedisPool.getResource();

 // 指定數據庫 默認是 0

 jedis.select(2);

 // 使用 ping 命令，測試鏈接是否成功

 String result = jedis.ping();

 System.out.println(result);// 返回 PONG

 // 添加一條數據

 jedis.set("username", "zhangsan");

 // 獲取一條數據

 String username = jedis.get("username");

 System.out.println(username);

 // 釋放資源

 if (jedis != null)

 jedis.close();

}

5. 封裝 JedisUtil 對外提供鏈接對象獲取方法://Redis 服務器 IP

 private static String ADDR = "192.168.10.100";

 //Redis 的端口號

 private static int PORT = 6379;

 //訪問密碼

 private static String AUTH = "root";

 //可用鏈接實例的最大數目，默認值爲 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.setMaxTotal(MAX_ACTIVE);

 config.setMaxIdle(MAX_IDLE);

 config.setMaxWaitMillis(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)

 return jedisPool.getResource();

 return null;

 } catch (Exception e) {

 e.printStackTrace();

 return null;

 }

 }

 /**

 * 釋放 jedis 資源

 *

 * @param jedis

 */

 public static void returnResource(final Jedis jedis) {

 if (jedis != null) {

 jedisPool.close();

 }

 }

}

6.//Redis 服務器 IP

 private static String ADDR = "192.168.10.100";

 //Redis 的端口號

 private static int PORT = 6379;

 //訪問密碼

 private static String AUTH = "root";

 //可用鏈接實例的最大數目，默認值爲 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.setMaxTotal(MAX_ACTIVE);

 config.setMaxIdle(MAX_IDLE);

 config.setMaxWaitMillis(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)

 return jedisPool.getResource();

 return null;

 } catch (Exception e) {

 e.printStackTrace();

 return null;

 }

 }

 /**

 * 釋放 jedis 資源

 *

 * @param jedis

 */

 public static void returnResource(final Jedis jedis) {

 if (jedis != null) {

 jedisPool.close();

 }

 }

}

7.獲取全部 key&事務&刪除

 // 獲取全部 key

 @Test

 public void testAllKeys() {

 // 當前庫 key 的數量

 System.out.println(jedis.dbSize());

 // 當前庫 key 的名稱

 Set<String> keys = jedis.keys("*");

 for (String key: keys) {

 System.out.println(key);

 }

 }

 // 操做事務

 @Test

 public void testMulti() {

 Transaction tx = jedis.multi();

 // 開啓事務

 tx.set("tel", "10010");

 

 // 提交事務

// tx.exec();

 

 // 回滾事務

 tx.discard();

 }

 

 // 刪除

 @Test

 public void testDelete() {

 // 刪除 通用 適用於全部數據類型

 jedis.del("score");

 }

8、操做 byte

SerializeUtil.java

package com.shsxt.util;

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

/**

* 序列化工具類

*/

public class SerializeUtil {

 

 /**

 * 將 java 對象轉換爲 byte 數組 序列化過程

 */

 public static byte[] serialize(Object object) {

 ObjectOutputStream oos = null;

 ByteArrayOutputStream baos = null;

 try {

 // 序列化

 baos = new ByteArrayOutputStream();

 oos = new ObjectOutputStream(baos);

 oos.writeObject(object);

 byte[] bytes = baos.toByteArray();

 return bytes;

 } catch (Exception e) {

 e.printStackTrace();

 }

 return null;

 }

 /**

 * 將 byte 數組轉換爲 java 對象 反序列化

 */

 public static Object unserialize(byte[] bytes) {

 if(bytes == null)return null;

 ByteArrayInputStream bais = null;

 try {

 // 反序列化

 bais = new ByteArrayInputStream(bytes);

 ObjectInputStream ois = new ObjectInputStream(bais);

 return ois.readObject();

 } catch (Exception e) {

 e.printStackTrace();

 }

 return null;

 }

}

User.java

package com.shsxt.entity;

import java.io.Serializable;

public class User implements Serializable {

 private static final long serialVersionUID = 9148937431079191022L;

 private Integer id;

 private String username;

 private String password;

 public Integer getId() {

 return id;

 }

 public void setId(Integer id) {

 this.id = id;

 }

 public String getUsername() {

 return username;

 }

 public void setUsername(String username) {

 this.username = username;

 }

 public String getPassword() {

 return password;

 }

 public void setPassword(String password) {

 this.password = password;

 }

 @Override

 public String toString() {

 return "User{" +

 "id=" + id +

 ", username='" + username + '\'' +

 ", password='" + password + '\'' +

 '}';

 }

}

JedisTest.java

// 操做 byte

@Test

public void testByte() {

 User user = new User();

 user.setId(2);

 user.setUsername("zhangsan");

 user.setPassword("123");

 // 序列化

 byte[] userKey = SerializeUtil.serialize("user:" + user.getId());

 byte[] userValue = SerializeUtil.serialize(user);

 jedis.set(userKey, userValue);

 // 獲取數據

 byte[] userResult = jedis.get(userKey);

 // 反序列化

 User u = (User) SerializeUtil.unserialize(userResult);

 System.out.println(u);

}

五.  Redis 搭建主從複用-讀寫分離

1.建立三個目錄（數據文件、日誌文件、配置文件）

2.複製 redis.conf 至/opt/redis/conf 目錄下

3.修改 redis-common.conf 公共配置文件:註釋掉 bind 127.0.0.1 ;關閉保護模式，修改成 no;註釋公共配置端口;修改成後臺啓動;註釋進程編號記錄文件;註釋公共配置日誌文件;註釋公共配置數據文件、修改數據文件路徑;添加從服務器訪問主服務器認證;添加訪問認證;註釋公共配置追加文件;從服務器默認是隻讀不容許寫操做(不用修改);

4.添加3個服務的私有配置文件

5.運行3個redis進程

6.查看 redis 服務器主從狀態

六.Redis 搭建主從複用-主備切換 

1.redis節點準備:單臺服務器不一樣端口模擬多臺服務器配置

127.0.0.1 6379(master-主節點)

127.0.0.1 6380(slave-從節點)

127.0.0.1 6381(slave-從節點)

2.主從節點 redis.conf 配置:參照上面的《Redis 搭建主從複用-讀寫分離》進行配置

3.修改 sentinel-common.conf 哨兵公共配置文件:從 redis 解壓目錄下複製 sentinel.conf 至/opt/redis/conf/(cp sentinel.conf /opt/redis/conf/sentinel-common.conf);指示 Sentinel 去監視一個名爲 master 的主服務器，這個主服務器的 IP 地址爲127.0.0.1，端口號爲 6379，而將這個主服務器判斷爲失效至少須要 1 個(通常設置爲2個)。Sentinel 贊成 （只要贊成 Sentinel 的數量不達標，自動故障遷移就不會執行）。這個要配局域網 IP，不然遠程連不上。註釋哨兵監聽進程端口號;設置 master 和 slaves 的密碼;Sentinel 認爲服務器已經斷線所需的毫秒數;若 sentinel 在該配置值內未能完成 failover 操做（即故障時 master/slave 自動切換），則認爲本次 failover 失敗;關閉保護模式，修改成 no;修改成後臺啓動(爲了方便查看日誌，先註釋掉，搭好環境後再打開)

4.添加 3 個哨兵的私有配置文件

5.啓動進行測試:

/usr/local/redis/bin/redis-server/opt/redis/conf/redis-6379.conf

/usr/local/redis/bin/redis-server/opt/redis/conf/redis-6380.conf

/usr/local/redis/bin/redis-server/opt/redis/conf/redis-6381.conf

6.啓動哨兵服務

/usr/local/redis/bin/redis-sentinel  /opt/redis/conf/sentinel-26379.conf

/usr/local/redis/bin/redis-sentinel  /opt/redis/conf/sentinel-26380.conf

/usr/local/redis/bin/redis-sentinel  /opt/redis/conf/sentinel-26381.conf

7.  查看主從狀態

七.Spring Data Redis操做Redis五種數據類型

1. 項目添加依賴:

dependency>

 <groupId>junit</groupId>

 <artifactId>junit</artifactId>

 <version>4.12</version>

 <scope>test</scope>

</dependency>

<!-- spring test 依賴 -->

<dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-test</artifactId>

 <version>4.3.7.RELEASE</version>

</dependency>

<!-- Redis 依賴 2.9.1 版本爲了兼容 springdata-redis -->

<dependency>

 <groupId>redis.clients</groupId>

 <artifactId>jedis</artifactId>

 <version>2.9.1</version>

</dependency>

<!-- spring data redis 依賴使用 1+最新版本由於 2+須要 spring5+版本 -->

<dependency>

2.  添加 applicationContext-redis.xml 配置文件:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xmlns:p="http://www.springframework.org/schema/p"

 xsi:schemaLocation="http://www.springframework.org/schema/beans

 http://www.springframework.org/schema/beans/spring-beans.xsd">

 <!-- 鏈接池配置 -->

 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

 <!-- 最大鏈接數 -->

 <property name="maxTotal" value="1024"/>

 <!-- 最大 空閒鏈接數 -->

 <property name="maxIdle" value="200"/>

 <!-- 獲取鏈接時最大等待毫秒數 -->

 <property name="maxWaitMillis" value="10000"/>

 <!-- 在獲取鏈接時檢查有效性 -->

 <property name="testOnBorrow" value="true"/>

 </bean>

 <!-- 客戶端鏈接工廠 -->

 <bean id="jedisConnFactory"

 class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"

 p:use-pool="true" p:host-name="192.168.10.100" p:port="6379" p:password="root">

 <!-- 鏈接池引用 -->

 <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>

 </bean>

 <!-- redisTemplate 配置 -->

 <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"

 p:connection-factory-ref="jedisConnFactory">

 <!-- 配置序列化操做 -->

 <property name="keySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="valueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashKeySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashValueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 </bean>

</beans>

3.  藉助spring測試環境測試環境是否搭建成功

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.*;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.util.*;

import java.util.Map.Entry;

/*

* @RunWith 就是一個運行器

* @RunWith(JUnit4.class)就是指用 JUnit4 來運行

* @RunWith(SpringJUnit4ClassRunner.class)，讓測試運行於 Spring 測試環境

*/

@RunWith(SpringJUnit4ClassRunner.class)

/*

* @ContextConfiguration Spring 整合 JUnit4 測試時，使用註解引入多個配置文件

* 單個文件 @ContextConfiguration(locations = "classpath:spring/applicationContext.xml")

* 多個文件 @ContextConfiguration(locations = {"classpath:spring/spring1.xml",

"classpath:mybatis/config.xml"})

*/

@ContextConfiguration(locations = "classpath:applicationContext-redis.xml")

public class SpringDateRedisTest {

 @Autowired

 private RedisTemplate<String, Object> redisTemplate;

 /**

 * redisTemplate.opsForValue() -> ValueOperations<String, Object>;// 操做字符串

 * redisTemplate.opsForHash() -> HashOperations<String, String, String>;// 操做 hash

 * redisTemplate.opsForList() -> ListOperations<String, Object>;// 操做 list

 * redisTemplate.opsForSet() -> SetOperations<String, Object>;// 操做 set

 * redisTemplate.opsForZSet() -> ZSetOperations<String, Object>;// 操做 SortedSet

 */

}

4.  操做五種數據類型

4.1.操做 String

@Test

public void testString() {

 ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();

 // 添加一條數據

 valueOperations.set("username", "zhangsan");

 valueOperations.set("age", "18");

// redis 中以層級關係、目錄形式存儲數據

valueOperations.set("user:01", "lisi");

valueOperations.set("user:02", "wangwu");

 // 添加多條數據

 Map<String, String> userMap = new HashMap<>();

 userMap.put("address", "bj");

 userMap.put("sex", "1");

 valueOperations.multiSet(userMap);

 // 獲取一條數據

 Object username = valueOperations.get("username");

 System.out.println(username);

 // 獲取多條數據

 List<String> keys = new ArrayList<>();

 keys.add("username");

 keys.add("age");

 keys.add("address");

 keys.add("sex");

 List<Object> resultList = valueOperations.multiGet(keys);

 for (Object str : resultList) {

 System.out.println(str);

 }

 // 刪除

 redisTemplate.delete("username");

}

4.二、 操做 hash

// 2.操做 Hash

@Test

public void testHash() {

 HashOperations<String, String, String> hashOperations =

redisTemplate.opsForHash();

 /*

 * 添加一條數據

 * 參數一：redis 的 key

 * 參數二：hash 的 key

 * 參數三：hash 的 value

 */

 hashOperations.put("userInfo","name","lisi");

 // 添加多條數據

 Map<String, String> map = new HashMap();

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

 map.put("sex", "1");

 hashOperations.putAll("userInfo", map);

 // 獲取一條數據

 String name = hashOperations.get("userInfo", "name");

 System.out.println(name);

 // 獲取多條數據

 List<String> keys = new ArrayList<>();

 keys.add("age");

 keys.add("sex");

 List<String> resultlist =hashOperations.multiGet("userInfo", keys);

 for (String str : resultlist) {

 System.out.println(str);

 }

 // 獲取 Hash 類型全部的數據

 Map<String, String> userMap = hashOperations.entries("userInfo");

 for (Entry<String, String> userInfo : userMap.entrySet()) {

 System.out.println(userInfo.getKey() + "--" + userInfo.getValue());

 }

 // 刪除 用於刪除 hash 類型數據

 hashOperations.delete("userInfo", "name");

}

4.三、 操做 list

 // 3.操做 list

 @Test

 public void testList() {

 ListOperations<String, Object> listOperations =

redisTemplate.opsForList();

 // 左添加(上)

// listOperations.leftPush("students", "Wang Wu");

// listOperations.leftPush("students", "Li Si");

 // 左添加(上) 把 value 值放到 key 對應列表中 pivot 值的左面，若是 pivot 值存在的話

 //listOperations.leftPush("students", "Wang Wu", "Li Si");

 // 右添加(下)

// listOperations.rightPush("students", "Zhao Liu");

 // 獲取 start 起始下標 end 結束下標 包含關係

 List<Object> students = listOperations.range("students", 0,2);

 for (Object stu : students) {

 System.out.println(stu);

 }

 // 根據下標獲取

 Object stu = listOperations.index("students", 1);

 System.out.println(stu);

 // 獲取總條數

 Long total = listOperations.size("students");

 System.out.println("總條數：" + total);

 // 刪除單條 刪除列表中存儲的列表中幾個出現的 Li Si。

 listOperations.remove("students", 1, "Li Si");

 // 刪除多條

 redisTemplate.delete("students");

 }

4.四、 操做 set

// 4.操做 set-無序

@Test

public void testSet() {

 SetOperations<String, Object> setOperations = redisTemplate.opsForSet();

 // 添加數據

 String[] letters = new String[]{"aaa", "bbb", "ccc", "ddd", "eee"};

 //setOperations.add("letters", "aaa", "bbb", "ccc", "ddd", "eee");

 setOperations.add("letters", letters);

 // 獲取數據

 Set<Object> let = setOperations.members("letters");

 for (Object letter: let) {

 System.out.println(letter);

 }

 // 刪除

 setOperations.remove("letters", "aaa", "bbb");

}

4.五、 操做 sorted set

// 5.操做 sorted set-有序

@Test

public void testSortedSet() {

 ZSetOperations<String, Object> zSetOperations =

redisTemplate.opsForZSet();

 ZSetOperations.TypedTuple<Object> objectTypedTuple1 =

 new DefaultTypedTuple<Object>("zhangsan", 7D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple2 =

 new DefaultTypedTuple<Object>("lisi", 3D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple3 =

 new DefaultTypedTuple<Object>("wangwu", 5D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple4 =

 new DefaultTypedTuple<Object>("zhaoliu", 6D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple5 =

 new DefaultTypedTuple<Object>("tianqi", 2D);

 Set<ZSetOperations.TypedTuple<Object>> tuples = new

HashSet<ZSetOperations.TypedTuple<Object>>();

 tuples.add(objectTypedTuple1);

 tuples.add(objectTypedTuple2);

 tuples.add(objectTypedTuple3);

 tuples.add(objectTypedTuple4);

 tuples.add(objectTypedTuple5);

 // 添加數據

 zSetOperations.add("score", tuples);

 // 獲取數據

 Set<Object> scores = zSetOperations.range("score", 0, 4);

 for (Object score: scores) {

 System.out.println(score);

 }

 // 獲取總條數

 Long total = zSetOperations.size("score");

 System.out.println("總條數：" + total);

 // 刪除

 zSetOperations.remove("score", "zhangsan", "lisi");

}

4.六、 獲取全部 key&刪除

// 獲取全部 key

@Test

public void testAllKeys() {

 // 當前庫 key 的名稱

 Set<String> keys = redisTemplate.keys("*");

 for (String key: keys) {

 System.out.println(key);

 }

}

// 刪除

@Test

public void testDelete() {

 // 刪除 通用 適用於全部數據類型

 redisTemplate.delete("score");

}

4.七、 設置 key 的失效時間

@Test

public void testEx() {

 ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();

 // 方法一：插入一條數據並設置失效時間

 valueOperations.set("code", "abcd", 180, TimeUnit.SECONDS);

 // 方法二：給已存在的 key 設置失效時間

 boolean flag = redisTemplate.expire("code", 180, TimeUnit.SECONDS);

 // 獲取指定 key 的失效時間

 Long l = redisTemplate.getExpire("code");

}

5.  SpringDataRedis 整合使用哨兵機制

配置applicationContext-redis.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xmlns:p="http://www.springframework.org/schema/p"

 xsi:schemaLocation="http://www.springframework.org/schema/beans

 http://www.springframework.org/schema/beans/spring-beans.xsd">

 <!-- 鏈接池配置 -->

 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

 <!-- 最大鏈接數 -->

 <property name="maxTotal" value="1024"/>

 <!-- 最大 空閒鏈接數 -->

 <property name="maxIdle" value="200"/>

 <!-- 獲取鏈接時最大等待毫秒數 -->

 <property name="maxWaitMillis" value="10000"/>

 <!-- 在獲取鏈接時檢查有效性 -->

 <property name="testOnBorrow" value="true"/>

 </bean>

 <!-- 哨兵配置 -->

 <bean id="redisSentinelConfiguration"

class="org.springframework.data.redis.connection.RedisSentinelConfiguration">

 <property name="sentinels">

 <set>

 <bean name="sentinelNode1" class="org.springframework.data.redis.connection.RedisNode">

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="26379"/>

 </bean>

 <bean name="sentinelNode2" class="org.springframework.data.redis.connection.RedisNode">

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="26380"/>

 </bean>

 <bean name="sentinelNode3" class="org.springframework.data.redis.connection.RedisNode">

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="26381"/>

 </bean>

 </set>

 </property>

 <property name="master">

 <bean name="masterNode" class="org.springframework.data.redis.connection.RedisNode">

 <!-- 必須指定主節點名稱 -->

 <property name="name" value="mymaster"/>

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="6380"/>

 </bean>

 </property>

 </bean>

 <!-- 客戶端鏈接工廠 設置主節點信息 -->

 <bean id="jedisConnFactory"

 class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"

 p:use-pool="true" p:host-name="192.168.10.24" p:port="6380" p:password="root">

 <!-- 鏈接池引用 -->

 <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>

 <!-- 哨兵引用 -->

 <constructor-arg name="sentinelConfig" ref="redisSentinelConfiguration"/>

 </bean>

 <!-- redisTemplate 配置 -->

 <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"

 p:connection-factory-ref="jedisConnFactory">

 <!-- 配置序列化操做 -->

 <property name="keySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="valueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashKeySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashValueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 </bean>

</beans>

6.  項目中集成 Redis 緩存數據

6.1pom.xml

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0

http://maven.apache.org/xsd/maven-4.0.0.xsd">

 <modelVersion>4.0.0</modelVersion>

 <groupId>com.shsxt</groupId>

 <artifactId>spring-data-redis</artifactId>

 <version>1.0-SNAPSHOT</version>

 <name>spring-data-redis</name>

 <!-- FIXME change it to the project's website -->

 <url>http://www.example.com</url>

 <properties>

 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

 <maven.compiler.source>1.7</maven.compiler.source>

 <maven.compiler.target>1.7</maven.compiler.target>

 </properties>

 <dependencies>

 <dependency>

 <groupId>junit</groupId>

 <artifactId>junit</artifactId>

 <version>4.12</version>

 <scope>test</scope>

 </dependency>

 <!-- spring 核心 jar -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-context</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring 測試 jar -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-test</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring jdbc -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-jdbc</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring 事物 -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-tx</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- aspectj 切面編程的 jar -->

 <dependency>

 <groupId>org.aspectj</groupId>

 <artifactId>aspectjweaver</artifactId>

 <version>1.8.9</version>

 </dependency>

 <!-- c3p0 鏈接池 -->

 <dependency>

 <groupId>c3p0</groupId>

 <artifactId>c3p0</artifactId>

 <version>0.9.1.2</version>

 </dependency>

 <!-- mybatis -->

 <dependency>

 <groupId>org.mybatis</groupId>

 <artifactId>mybatis</artifactId>

 <version>3.4.1</version>

 </dependency>

 <!-- 添加 mybatis 與 Spring 整合的核心包 -->

 <dependency>

 <groupId>org.mybatis</groupId>

 <artifactId>mybatis-spring</artifactId>

 <version>1.3.0</version>

 </dependency>

 <!-- mysql 驅動包 -->

 <dependency>

 <groupId>mysql</groupId>

 <artifactId>mysql-connector-java</artifactId>

 <version>5.1.39</version>

 </dependency>

 <!-- 日誌打印相關的 jar -->

 <dependency>

 <groupId>org.slf4j</groupId>

 <artifactId>slf4j-log4j12</artifactId>

 <version>1.7.2</version>

 </dependency>

 <dependency>

 <groupId>org.slf4j</groupId>

 <artifactId>slf4j-api</artifactId>

 <version>1.7.2</version>

 </dependency>

 <!-- springmvc 依賴 jar -->

 <!-- spring web -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-web</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring mvc -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-webmvc</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- 添加 json 依賴 jar 包 -->

 <dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-core</artifactId>

 <version>2.7.0</version>

 </dependency>

 <dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-databind</artifactId>

 <version>2.7.0</version>

 </dependency>

 <dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-annotations</artifactId>

 <version>2.7.0</version>

 </dependency>

 <dependency>

 <groupId>commons-fileupload</groupId>

 <artifactId>commons-fileupload</artifactId>

 <version>1.3.2</version>

 </dependency>

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-context-support </artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <dependency>

 <groupId>org.freemarker</groupId>

 <artifactId>freemarker</artifactId>

 <version>2.3.21</version>

 </dependency>

 <dependency>

 <groupId>org.apache.commons</groupId>

 <artifactId>commons-lang3</artifactId>

 <version>3.3.2</version>

 </dependency>

 <!-- Redis 依賴 -->

 <dependency>

 <groupId>redis.clients</groupId>

 <artifactId>jedis</artifactId>

 <version>2.9.1</version>

 </dependency>

 <!-- spring data redis 依賴 -->

 <dependency>

 <groupId>org.springframework.data</groupId>

 <artifactId>spring-data-redis</artifactId>

 <version>1.8.18.RELEASE</version>

 </dependency>

 </dependencies>

 <build>

 <!-- 讀取配置文件 -->

 <resources>

 <resource>

 <directory>src/main/resources</directory>

 </resource>

 <resource>

 <directory>src/main/java</directory>

 <includes>

 <include>**/*.xml</include>

 <include>**/*.properties</include>

 <include>**/*.tld</include>

 </includes>

 <filtering>false</filtering>

 </resource>

 </resources>

 </build>

</project>

6.2jdbc.properties 

jdbc.driver=com.mysql.jdbc.Driver

jdbc.url=jdbc:mysql://127.0.0.1:3306/p2p?useUnicode=true&characterEncoding=utf8

jdbc.username=root

jdbc.password=root

6.3log4j.properties

log4j.rootLogger=DEBUG, Console

#Console

log4j.appender.Console=org.apache.log4j.ConsoleAppender

log4j.appender.Console.layout=org.apache.log4j.PatternLayout

log4j.appender.Console.layout.ConversionPattern=%d [%t] %-5p [%c]

- %m%n

log4j.logger.java.sql.ResultSet=INFO

log4j.logger.org.apache=INFO

log4j.logger.java.sql.Connection=DEBUG

log4j.logger.java.sql.Statement=DEBUG

log4j.logger.java.sql.PreparedStatement=DEBUG

6.4applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xmlns:context="http://www.springframework.org/schema/context"

 xmlns:aop="http://www.springframework.org/schema/aop"

 xmlns:tx="http://www.springframework.org/schema/tx"

 xsi:schemaLocation="http://www.springframework.org/schema/beans

 http://www.springframework.org/schema/beans/spring-beans.xsd

 http://www.springframework.org/schema/context

 http://www.springframework.org/schema/context/spring-context.xsd

 http://www.springframework.org/schema/aop

 http://www.springframework.org/schema/aop/spring-aop.xsd

 http://www.springframework.org/schema/tx

 http://www.springframework.org/schema/tx/spring-tx.xsd">

 <context:property-placeholder location="classpath:jdbc.properties"/>

 <context:component-scan base-package="com.shsxt.service"></context:component-scan>

 <!-- 配置數據源 -->

 <!-- 配置 c3p0 數據源 -->

 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">

 <property name="driverClass" value="${jdbc.driver}"></property>

 <property name="jdbcUrl" value="${jdbc.url}"></property>

 <property name="user" value="${jdbc.username}"></property>

 <property name="password" value="${jdbc.password}"></property>

 </bean>

 <!-- 配置事務管理器 -->

 <bean id="txManager"

class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

 <property name="dataSource" ref="dataSource"></property>

 </bean>

 <!-- 設置事務加強 -->

 <tx:advice id="txAdvice" transaction-manager="txManager">

 <tx:attributes>

 <tx:method name="get*" read-only="true"/>

 <tx:method name="find*" read-only="true"/>

 <tx:method name="query*" read-only="true"/>

 <tx:method name="load*" read-only="true"/>

 <tx:method name="add*" propagation="REQUIRED"/>

 <tx:method name="insert*" propagation="REQUIRED"/>

 <tx:method name="update*" propagation="REQUIRED"/>

 <tx:method name="del*" propagation="REQUIRED"/>

 <tx:method name="save*" propagation="REQUIRED"/>

 </tx:attributes>

 </tx:advice>

 <!-- aop 切面配置 -->

 <aop:config>

 <aop:pointcut id="servicePointcut" expression="execution(*

com.shsxt.service.impl.*.*(..))"/>

 <aop:advisor advice-ref="txAdvice" pointcut-ref="servicePointcut"/>

 </aop:config>

 <!-- 配置 sqlSessionFactory -->

 <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">

 <property name="dataSource" ref="dataSource"></property>

 <property name="mapperLocations" value="classpath:com/shsxt/mapper/*.xml"/>

 </bean>

 <!-- 配置掃描器 -->

 <bean id="mapperScanner" class="org.mybatis.spring.mapper.MapperScannerConfigurer">

 <!-- 掃描 com.shsxt.dao 這個包以及它的子包下的全部映射接口類 -->

 <property name="basePackage" value="com.shsxt.dao"/>

 <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>

 </bean>

</beans>

6.5代碼

6.5.1JsonUtil.java

package com.shsxt.util;

import java.io.IOException;

import com.fasterxml.jackson.core.JsonParseException;

import com.fasterxml.jackson.core.JsonProcessingException;

import com.fasterxml.jackson.databind.JsonMappingException;

import com.fasterxml.jackson.databind.ObjectMapper;

/**

* Json 轉換工具類

*/

public class JsonUtil {

 private static ObjectMapper objectMapper = new ObjectMapper();

 

 /**

 * 將對象轉換成 json 字符串

 * @param obj

 * @return

 */

 public static String object2JsonStr(Object obj){

 try {

 return objectMapper.writeValueAsString(obj);

 } catch (JsonProcessingException e) {

 //打印異常信息

 e.printStackTrace();

 }

 return null;

 }

 

 /**

 * 將字符串轉換爲對象

 * @param <T> 泛型

 */

 public static <T> T jsonStr2Object(String jsonStr, Class<T> clazz){

 try {

 return objectMapper.readValue(jsonStr.getBytes("UTF-8"), clazz);

 } catch (JsonParseException e) {

 e.printStackTrace();

 } catch (JsonMappingException e) {

 e.printStackTrace();

 } catch (IOException e) {

 e.printStackTrace();

 }

 return null;

 }

 

}

6.5.2UserDaoI.java

package com.shsxt.dao;

import com.shsxt.entity.User;

public interface UserDaoI {

 public User queryUserById(Integer userId);

}

6.5.3User.java

package com.shsxt.entity;

import java.io.Serializable;

public class User implements Serializable {

 private static final long serialVersionUID = 5751725238117698007L;

 private Integer id;

 private String username;

 private String password;

 public Integer getId() {

 return id;

 }

 public void setId(Integer id) {

 this.id = id;

 }

 public String getUsername() {

 return username;

 }

 public void setUsername(String username) {

 this.username = username;

 }

 public String getPassword() {

 return password;

 }

 public void setPassword(String password) {

 this.password = password;

 }

 @Override

 public String toString() {

 return "User{" +

 "id=" + id +

 ", username='" + username + '\'' +

 ", password='" + password + '\'' +

 '}';

 }

}

6.5.4UserMapper.xml

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="com.shsxt.dao.UserDaoI">

 <select id="queryUserById" resultType="com.shsxt.entity.User">

 SELECT id,

 username,

 password

 FROM bas_user

 WHERE id = #{userId}

 </select>

</mapper>

6.5.5.UserServiceI.java

package com.shsxt.service;

import com.shsxt.entity.User;

public interface UserServiceI {

 public User queryUserById(Integer userId);

}

6.5.6.UserServiceImpl.java

package com.shsxt.service.impl;

import com.shsxt.dao.UserDaoI;

import com.shsxt.entity.User;

import com.shsxt.service.UserServiceI;

import com.shsxt.util.JsonUtil;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.stereotype.Service;

@Service

public class UserServiceImpl implements UserServiceI {

 @Autowired

 private RedisTemplate<String, Object> redisTemplate;

 @Autowired

 private UserDaoI userDao;

 @Override

 public User queryUserById(Integer userId) {

// return doQueryUserById(userId);

 return doQueryUserById2Json(userId);

 }

 public User doQueryUserById(Integer userId) {

 // 先從 Redis 查詢

 User user = (User) redisTemplate.opsForValue().get("user:id_" + userId);

 if(null != user){

 return user;

 }

 // Redis 沒有再從 mysql 查詢

 user = userDao.queryUserById(userId);

 if(null != user){

 redisTemplate.opsForValue().set("user:id_" + userId, user);

 return user;

 }

 return null;

 }

 public User doQueryUserById2Json(Integer userId) {

 // 先從 Redis 查詢

 Object jsonUser = redisTemplate.opsForValue().get("user:id_" + userId);

 User user = null;

 if(null != user){

 user = JsonUtil.jsonStr2Object((String) jsonUser, User.class);

 return user;

 }

 // Redis 沒有再從 mysql 查詢

 user = userDao.queryUserById(userId);

 if(null != user){

 redisTemplate.opsForValue().set("user:id_" + userId,

JsonUtil.object2JsonStr(user));

 return user;

 }

 return null;

 }

}

6.5.7.UserServiceTest.java

package com.shsxt.service;

import com.shsxt.entity.User;

import com.shsxt.service.UserServiceI;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.test.context.ContextConfiguration;

import

org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/*

* @RunWith 就是一個運行器

* @RunWith(JUnit4.class)就是指用 JUnit4 來運行

* @RunWith(SpringJUnit4ClassRunner.class)，讓測試運行於 Spring 測試環境

*/

@RunWith(SpringJUnit4ClassRunner.class)

/*

* @ContextConfiguration Spring 整合 JUnit4 測試時，使用註解引入多個配置文

件

* 單個文件 @ContextConfiguration(locations =

"classpath:spring/applicationContext.xml")

* 多個文件 @ContextConfiguration(locations =

{"classpath:spring/spring1.xml", "classpath:mybatis/config.xml"})

*/

@ContextConfiguration(locations = {"classpath:applicationContext.xml",

"classpath:applicationContext-redis.xml"})

public class UserServiceTest {

 @Autowired

 private UserServiceI userService;

 @Test

 public void test() {

 User user = userService.queryUserById(1);

 System.out.println(user);

 }

}

八.  緩存雪崩,緩存擊穿,緩存穿透

1.緩存穿透

描述：

  緩存穿透是指緩存和數據庫中都沒有的數據，而用戶不斷髮起請求，如發起爲id爲「-1」的數據或id爲特別大不存在的數據。這時的用戶極可能是攻擊者，攻擊會致使數據庫壓力過大。

解決方案：

(1).接口層增長校驗，如用戶鑑權校驗，id作基礎校驗，id<=0的直接攔截；

(2).從緩存取不到的數據，在數據庫中也沒有取到，這時也能夠將key-value對寫爲key-null，緩存有效時間能夠設置短點，如30秒（設置太長會致使正常狀況也無法使用）。這樣能夠防止攻擊用戶反覆用同一個id暴力攻擊.

2.緩存擊穿

描述：

緩存擊穿是指緩存中沒有但數據庫中有的數據（通常是緩存時間到期），這時因爲併發用戶特別多，同時讀緩存沒讀到數據，又同時去數據庫去取數據，引發數據庫壓力瞬間增大，形成過大壓力

解決方案：

(1).設置熱點數據永遠不過時。

(2).加互斥鎖，互斥鎖

3.緩存雪崩

描述：

 緩存雪崩是指緩存中數據大批量到過時時間，而查詢數據量巨大，引發數據庫壓力過大甚至down機。和緩存擊穿不一樣的是，緩存擊穿指併發查同一條數據，緩存雪崩是不一樣數據都過時了，不少數據都查不到從而查數據庫。

解決方案：

(1).緩存數據的過時時間設置隨機，防止同一時間大量數據過時現象發生。若是緩存數據庫是分佈式部署，將熱點數據均勻分佈在不一樣搞得緩存數據庫中。

(2).設置熱點數據永遠不過時。

 

Rides在spring中應用

一.  redis的簡介

2008 年，意大利一家創業公司 Merzia 的創始人 Salvatore Sanfilippo 爲了不 MySQL的低性能，親自定作一個數據庫，並於 2009 年開發完成，這個就是 Redis。

從 2010 年 3 月 15 日起，Redis 的開發工做由 VMware 主持。

從 2013 年 5 月開始，Redis 的開發由 Pivotal 贊助。

說明：Pivotal 公司是由 EMC 和 VMware 聯合成立的一家新公司。Pivotal 但願爲新一代的應用提供一個原生的基礎，創建在具備領導力的雲和網絡公司不斷轉型的IT特性之上。

Pivotal 的使命是推行這些創新，提供給企業 IT 架構師和獨立軟件提供商.

二.  redis在linux服務器中的安裝

1.  上傳壓縮包到服務器.

2.  解壓壓縮包:tar zxvf redis-5.0.3.tar.gz

3.  安裝依賴:yum -y install gcc-c++ autoconf automake

4.  進行預編譯:切換到解壓目錄cd redis-5.0.3/make

5.  建立安裝目錄:mkdir -p /usr/local/redis(注意解壓目錄和安裝目分開)

6.  啓動:安裝的默認目標路徑：/usr/local/redis/bin

7.  修改前臺啓動爲後臺啓動:複製 redis.conf 至安裝路徑下cp redis.conf /usr/local/redis/bin/

8.  修改防火牆(建議防火牆永久關閉),防火牆啓動命令:systemctl start/restart iptables.service 或者 service iptables start 或者 service iptables restart

9.  在Windows系統中安裝redis的客戶端

10.  修改配置文件 redis.conf:註釋掉 bind 127.0.0.1 可使全部的 ip 訪問 redis，如果想指定多個 ip 訪問，但並非所有的 ip 訪問，能夠 bind 設置

11.  重啓redis:修改後 kill -9 XXXX 殺死 redis 進程，重啓 redis

12.  查看進程的命令:ps -ef | grep redis

三.  redis-cli 命令操做 Redis 五種數據類型

1.  redis-cli 鏈接 redis

2.  操做 String:Set:添加一條 String 類型數據;Get:獲取一條 String 類型數據;Mset:添加多條 String 類型數據;Mget:獲取多條 String 類型數據

3.  操做 hash:Hset:添加一條 hash 類型數據;Hget:獲取一條 hash 類型數據;Hmset:添加多條 hash 類型數據;Hmget:獲取多條 hash 類型數據;HgetAll:獲取指定全部 hash 類型數據;hdel:刪除指定 hash 類型數據(一條或多條)

4.  操做 list:Lpush:左添加(頭)list 類型數據;Rpush:右添加(尾)類型數據;Lrange: 獲取 list 類型數據 start 起始下標 end 結束下標 包含關係;llen:獲取條數;lrem:刪除列表中幾個指定 list 類型數據

5.  操做 set:Sadd:添加 set 類型數據;Smembers:獲取 set 類型數據;scard:獲取條數;srem:刪除數據

6.  操做 sorted set:sorted set 是經過分數值來進行排序的，分數值越大，越靠後。Zadd:添加 sorted set 類型數據;Zrange:獲取 sorted set 類型數據;zcard:獲取條數;zrem:刪除數據;Zadd 須要將 Float 或者 Double 類型分數值參數，放置在值參數以前.

7.  Redis 中以層級關係、目錄形式存儲數據:即就是在創建語句時前面添加」:」

8.  設置 key 的失效時間:Redis 有四個不一樣的命令能夠用於設置鍵的生存時間(鍵能夠存在多久)或過時時間(鍵何時會被刪除) :

 EXPlRE <key> <ttl> 命令用於將鍵 key 的生存時間設置爲 ttl 秒。

PEXPIRE <key> <ttl> 命令用於將鍵 key 的生存時間設置爲 ttl 毫秒。 EXPIREAT <key> < timestamp> 命令用於將鍵 key 的過時時間設置爲 timestamp 所指定的秒數時間戳。

 PEXPIREAT <key> < timestamp > 命令用於將鍵 key 的過時時間設置爲 timestamp 所指定的毫秒數時間戳。 TTL:獲取的值爲-1 說明此 key 沒有設置有效期，當值爲-2 時證實過了有效期。

9.  刪除:Del:用於刪除數據（通用，適用於全部數據類型）;Hdel:用於刪除 hash 類型數據

四.  Java 操做 Redis 五種數據類型

1.  建立maven項目

2.  添加依賴

3.  Java鏈接jedis: Jedis jedis = new Jedis(IP,端口);

Jedis.auth(「設置認證密碼」);// 指定數據庫 默認是 0

 jedis.select(1);

 // 使用 ping 命令，測試鏈接是否成功

 String result = jedis.ping();

 System.out.println(result);// 返回 PONG

 // 添加一條數據

 jedis.set("username", "zhangsan");

 // 獲取一條數據

 String username = jedis.get("username");

 System.out.println(username);

 // 釋放資源if (jedis != null)

 jedis.close();

}

4. 經過 Redis 鏈接池獲取鏈接對象並操做服務器 :JedisPool jedisPool = new JedisPool(new JedisPoolConfig(),

"192.168.10.100", 6379, 10000, "root");

 // 從鏈接池獲取鏈接

 Jedis jedis = jedisPool.getResource();

 // 指定數據庫 默認是 0

 jedis.select(2);

 // 使用 ping 命令，測試鏈接是否成功

 String result = jedis.ping();

 System.out.println(result);// 返回 PONG

 // 添加一條數據

 jedis.set("username", "zhangsan");

 // 獲取一條數據

 String username = jedis.get("username");

 System.out.println(username);

 // 釋放資源

 if (jedis != null)

 jedis.close();

}

5. 封裝 JedisUtil 對外提供鏈接對象獲取方法://Redis 服務器 IP

 private static String ADDR = "192.168.10.100";

 //Redis 的端口號

 private static int PORT = 6379;

 //訪問密碼

 private static String AUTH = "root";

 //可用鏈接實例的最大數目，默認值爲 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.setMaxTotal(MAX_ACTIVE);

 config.setMaxIdle(MAX_IDLE);

 config.setMaxWaitMillis(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)

 return jedisPool.getResource();

 return null;

 } catch (Exception e) {

 e.printStackTrace();

 return null;

 }

 }

 /**

 * 釋放 jedis 資源

 *

 * @param jedis

 */

 public static void returnResource(final Jedis jedis) {

 if (jedis != null) {

 jedisPool.close();

 }

 }

}

6.//Redis 服務器 IP

 private static String ADDR = "192.168.10.100";

 //Redis 的端口號

 private static int PORT = 6379;

 //訪問密碼

 private static String AUTH = "root";

 //可用鏈接實例的最大數目，默認值爲 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.setMaxTotal(MAX_ACTIVE);

 config.setMaxIdle(MAX_IDLE);

 config.setMaxWaitMillis(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)

 return jedisPool.getResource();

 return null;

 } catch (Exception e) {

 e.printStackTrace();

 return null;

 }

 }

 /**

 * 釋放 jedis 資源

 *

 * @param jedis

 */

 public static void returnResource(final Jedis jedis) {

 if (jedis != null) {

 jedisPool.close();

 }

 }

}

7.獲取全部 key&事務&刪除

 // 獲取全部 key

 @Test

 public void testAllKeys() {

 // 當前庫 key 的數量

 System.out.println(jedis.dbSize());

 // 當前庫 key 的名稱

 Set<String> keys = jedis.keys("*");

 for (String key: keys) {

 System.out.println(key);

 }

 }

 // 操做事務

 @Test

 public void testMulti() {

 Transaction tx = jedis.multi();

 // 開啓事務

 tx.set("tel", "10010");

 

 // 提交事務

// tx.exec();

 

 // 回滾事務

 tx.discard();

 }

 

 // 刪除

 @Test

 public void testDelete() {

 // 刪除 通用 適用於全部數據類型

 jedis.del("score");

 }

8、操做 byte

SerializeUtil.java

package com.shsxt.util;

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

/**

* 序列化工具類

*/

public class SerializeUtil {

 

 /**

 * 將 java 對象轉換爲 byte 數組 序列化過程

 */

 public static byte[] serialize(Object object) {

 ObjectOutputStream oos = null;

 ByteArrayOutputStream baos = null;

 try {

 // 序列化

 baos = new ByteArrayOutputStream();

 oos = new ObjectOutputStream(baos);

 oos.writeObject(object);

 byte[] bytes = baos.toByteArray();

 return bytes;

 } catch (Exception e) {

 e.printStackTrace();

 }

 return null;

 }

 /**

 * 將 byte 數組轉換爲 java 對象 反序列化

 */

 public static Object unserialize(byte[] bytes) {

 if(bytes == null)return null;

 ByteArrayInputStream bais = null;

 try {

 // 反序列化

 bais = new ByteArrayInputStream(bytes);

 ObjectInputStream ois = new ObjectInputStream(bais);

 return ois.readObject();

 } catch (Exception e) {

 e.printStackTrace();

 }

 return null;

 }

}

User.java

package com.shsxt.entity;

import java.io.Serializable;

public class User implements Serializable {

 private static final long serialVersionUID = 9148937431079191022L;

 private Integer id;

 private String username;

 private String password;

 public Integer getId() {

 return id;

 }

 public void setId(Integer id) {

 this.id = id;

 }

 public String getUsername() {

 return username;

 }

 public void setUsername(String username) {

 this.username = username;

 }

 public String getPassword() {

 return password;

 }

 public void setPassword(String password) {

 this.password = password;

 }

 @Override

 public String toString() {

 return "User{" +

 "id=" + id +

 ", username='" + username + '\'' +

 ", password='" + password + '\'' +

 '}';

 }

}

JedisTest.java

// 操做 byte

@Test

public void testByte() {

 User user = new User();

 user.setId(2);

 user.setUsername("zhangsan");

 user.setPassword("123");

 // 序列化

 byte[] userKey = SerializeUtil.serialize("user:" + user.getId());

 byte[] userValue = SerializeUtil.serialize(user);

 jedis.set(userKey, userValue);

 // 獲取數據

 byte[] userResult = jedis.get(userKey);

 // 反序列化

 User u = (User) SerializeUtil.unserialize(userResult);

 System.out.println(u);

}

五.  Redis 搭建主從複用-讀寫分離

1.建立三個目錄（數據文件、日誌文件、配置文件）

2.複製 redis.conf 至/opt/redis/conf 目錄下

3.修改 redis-common.conf 公共配置文件:註釋掉 bind 127.0.0.1 ;關閉保護模式，修改成 no;註釋公共配置端口;修改成後臺啓動;註釋進程編號記錄文件;註釋公共配置日誌文件;註釋公共配置數據文件、修改數據文件路徑;添加從服務器訪問主服務器認證;添加訪問認證;註釋公共配置追加文件;從服務器默認是隻讀不容許寫操做(不用修改);

4.添加3個服務的私有配置文件

5.運行3個redis進程

6.查看 redis 服務器主從狀態

六.Redis 搭建主從複用-主備切換 

1.redis節點準備:單臺服務器不一樣端口模擬多臺服務器配置

127.0.0.1 6379(master-主節點)

127.0.0.1 6380(slave-從節點)

127.0.0.1 6381(slave-從節點)

2.主從節點 redis.conf 配置:參照上面的《Redis 搭建主從複用-讀寫分離》進行配置

3.修改 sentinel-common.conf 哨兵公共配置文件:從 redis 解壓目錄下複製 sentinel.conf 至/opt/redis/conf/(cp sentinel.conf /opt/redis/conf/sentinel-common.conf);指示 Sentinel 去監視一個名爲 master 的主服務器，這個主服務器的 IP 地址爲127.0.0.1，端口號爲 6379，而將這個主服務器判斷爲失效至少須要 1 個(通常設置爲2個)。Sentinel 贊成 （只要贊成 Sentinel 的數量不達標，自動故障遷移就不會執行）。這個要配局域網 IP，不然遠程連不上。註釋哨兵監聽進程端口號;設置 master 和 slaves 的密碼;Sentinel 認爲服務器已經斷線所需的毫秒數;若 sentinel 在該配置值內未能完成 failover 操做（即故障時 master/slave 自動切換），則認爲本次 failover 失敗;關閉保護模式，修改成 no;修改成後臺啓動(爲了方便查看日誌，先註釋掉，搭好環境後再打開)

4.添加 3 個哨兵的私有配置文件

5.啓動進行測試:

/usr/local/redis/bin/redis-server/opt/redis/conf/redis-6379.conf

/usr/local/redis/bin/redis-server/opt/redis/conf/redis-6380.conf

/usr/local/redis/bin/redis-server/opt/redis/conf/redis-6381.conf

6.啓動哨兵服務

/usr/local/redis/bin/redis-sentinel  /opt/redis/conf/sentinel-26379.conf

/usr/local/redis/bin/redis-sentinel  /opt/redis/conf/sentinel-26380.conf

/usr/local/redis/bin/redis-sentinel  /opt/redis/conf/sentinel-26381.conf

7.  查看主從狀態

七.Spring Data Redis操做Redis五種數據類型

1. 項目添加依賴:

dependency>

 <groupId>junit</groupId>

 <artifactId>junit</artifactId>

 <version>4.12</version>

 <scope>test</scope>

</dependency>

<!-- spring test 依賴 -->

<dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-test</artifactId>

 <version>4.3.7.RELEASE</version>

</dependency>

<!-- Redis 依賴 2.9.1 版本爲了兼容 springdata-redis -->

<dependency>

 <groupId>redis.clients</groupId>

 <artifactId>jedis</artifactId>

 <version>2.9.1</version>

</dependency>

<!-- spring data redis 依賴使用 1+最新版本由於 2+須要 spring5+版本 -->

<dependency>

2.  添加 applicationContext-redis.xml 配置文件:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xmlns:p="http://www.springframework.org/schema/p"

 xsi:schemaLocation="http://www.springframework.org/schema/beans

 http://www.springframework.org/schema/beans/spring-beans.xsd">

 <!-- 鏈接池配置 -->

 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

 <!-- 最大鏈接數 -->

 <property name="maxTotal" value="1024"/>

 <!-- 最大 空閒鏈接數 -->

 <property name="maxIdle" value="200"/>

 <!-- 獲取鏈接時最大等待毫秒數 -->

 <property name="maxWaitMillis" value="10000"/>

 <!-- 在獲取鏈接時檢查有效性 -->

 <property name="testOnBorrow" value="true"/>

 </bean>

 <!-- 客戶端鏈接工廠 -->

 <bean id="jedisConnFactory"

 class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"

 p:use-pool="true" p:host-name="192.168.10.100" p:port="6379" p:password="root">

 <!-- 鏈接池引用 -->

 <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>

 </bean>

 <!-- redisTemplate 配置 -->

 <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"

 p:connection-factory-ref="jedisConnFactory">

 <!-- 配置序列化操做 -->

 <property name="keySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="valueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashKeySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashValueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 </bean>

</beans>

3.  藉助spring測試環境測試環境是否搭建成功

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.*;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.util.*;

import java.util.Map.Entry;

/*

* @RunWith 就是一個運行器

* @RunWith(JUnit4.class)就是指用 JUnit4 來運行

* @RunWith(SpringJUnit4ClassRunner.class)，讓測試運行於 Spring 測試環境

*/

@RunWith(SpringJUnit4ClassRunner.class)

/*

* @ContextConfiguration Spring 整合 JUnit4 測試時，使用註解引入多個配置文件

* 單個文件 @ContextConfiguration(locations = "classpath:spring/applicationContext.xml")

* 多個文件 @ContextConfiguration(locations = {"classpath:spring/spring1.xml",

"classpath:mybatis/config.xml"})

*/

@ContextConfiguration(locations = "classpath:applicationContext-redis.xml")

public class SpringDateRedisTest {

 @Autowired

 private RedisTemplate<String, Object> redisTemplate;

 /**

 * redisTemplate.opsForValue() -> ValueOperations<String, Object>;// 操做字符串

 * redisTemplate.opsForHash() -> HashOperations<String, String, String>;// 操做 hash

 * redisTemplate.opsForList() -> ListOperations<String, Object>;// 操做 list

 * redisTemplate.opsForSet() -> SetOperations<String, Object>;// 操做 set

 * redisTemplate.opsForZSet() -> ZSetOperations<String, Object>;// 操做 SortedSet

 */

}

4.  操做五種數據類型

4.1.操做 String

@Test

public void testString() {

 ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();

 // 添加一條數據

 valueOperations.set("username", "zhangsan");

 valueOperations.set("age", "18");

// redis 中以層級關係、目錄形式存儲數據

valueOperations.set("user:01", "lisi");

valueOperations.set("user:02", "wangwu");

 // 添加多條數據

 Map<String, String> userMap = new HashMap<>();

 userMap.put("address", "bj");

 userMap.put("sex", "1");

 valueOperations.multiSet(userMap);

 // 獲取一條數據

 Object username = valueOperations.get("username");

 System.out.println(username);

 // 獲取多條數據

 List<String> keys = new ArrayList<>();

 keys.add("username");

 keys.add("age");

 keys.add("address");

 keys.add("sex");

 List<Object> resultList = valueOperations.multiGet(keys);

 for (Object str : resultList) {

 System.out.println(str);

 }

 // 刪除

 redisTemplate.delete("username");

}

4.二、 操做 hash

// 2.操做 Hash

@Test

public void testHash() {

 HashOperations<String, String, String> hashOperations =

redisTemplate.opsForHash();

 /*

 * 添加一條數據

 * 參數一：redis 的 key

 * 參數二：hash 的 key

 * 參數三：hash 的 value

 */

 hashOperations.put("userInfo","name","lisi");

 // 添加多條數據

 Map<String, String> map = new HashMap();

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

 map.put("sex", "1");

 hashOperations.putAll("userInfo", map);

 // 獲取一條數據

 String name = hashOperations.get("userInfo", "name");

 System.out.println(name);

 // 獲取多條數據

 List<String> keys = new ArrayList<>();

 keys.add("age");

 keys.add("sex");

 List<String> resultlist =hashOperations.multiGet("userInfo", keys);

 for (String str : resultlist) {

 System.out.println(str);

 }

 // 獲取 Hash 類型全部的數據

 Map<String, String> userMap = hashOperations.entries("userInfo");

 for (Entry<String, String> userInfo : userMap.entrySet()) {

 System.out.println(userInfo.getKey() + "--" + userInfo.getValue());

 }

 // 刪除 用於刪除 hash 類型數據

 hashOperations.delete("userInfo", "name");

}

4.三、 操做 list

 // 3.操做 list

 @Test

 public void testList() {

 ListOperations<String, Object> listOperations =

redisTemplate.opsForList();

 // 左添加(上)

// listOperations.leftPush("students", "Wang Wu");

// listOperations.leftPush("students", "Li Si");

 // 左添加(上) 把 value 值放到 key 對應列表中 pivot 值的左面，若是 pivot 值存在的話

 //listOperations.leftPush("students", "Wang Wu", "Li Si");

 // 右添加(下)

// listOperations.rightPush("students", "Zhao Liu");

 // 獲取 start 起始下標 end 結束下標 包含關係

 List<Object> students = listOperations.range("students", 0,2);

 for (Object stu : students) {

 System.out.println(stu);

 }

 // 根據下標獲取

 Object stu = listOperations.index("students", 1);

 System.out.println(stu);

 // 獲取總條數

 Long total = listOperations.size("students");

 System.out.println("總條數：" + total);

 // 刪除單條 刪除列表中存儲的列表中幾個出現的 Li Si。

 listOperations.remove("students", 1, "Li Si");

 // 刪除多條

 redisTemplate.delete("students");

 }

4.四、 操做 set

// 4.操做 set-無序

@Test

public void testSet() {

 SetOperations<String, Object> setOperations = redisTemplate.opsForSet();

 // 添加數據

 String[] letters = new String[]{"aaa", "bbb", "ccc", "ddd", "eee"};

 //setOperations.add("letters", "aaa", "bbb", "ccc", "ddd", "eee");

 setOperations.add("letters", letters);

 // 獲取數據

 Set<Object> let = setOperations.members("letters");

 for (Object letter: let) {

 System.out.println(letter);

 }

 // 刪除

 setOperations.remove("letters", "aaa", "bbb");

}

4.五、 操做 sorted set

// 5.操做 sorted set-有序

@Test

public void testSortedSet() {

 ZSetOperations<String, Object> zSetOperations =

redisTemplate.opsForZSet();

 ZSetOperations.TypedTuple<Object> objectTypedTuple1 =

 new DefaultTypedTuple<Object>("zhangsan", 7D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple2 =

 new DefaultTypedTuple<Object>("lisi", 3D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple3 =

 new DefaultTypedTuple<Object>("wangwu", 5D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple4 =

 new DefaultTypedTuple<Object>("zhaoliu", 6D);

 ZSetOperations.TypedTuple<Object> objectTypedTuple5 =

 new DefaultTypedTuple<Object>("tianqi", 2D);

 Set<ZSetOperations.TypedTuple<Object>> tuples = new

HashSet<ZSetOperations.TypedTuple<Object>>();

 tuples.add(objectTypedTuple1);

 tuples.add(objectTypedTuple2);

 tuples.add(objectTypedTuple3);

 tuples.add(objectTypedTuple4);

 tuples.add(objectTypedTuple5);

 // 添加數據

 zSetOperations.add("score", tuples);

 // 獲取數據

 Set<Object> scores = zSetOperations.range("score", 0, 4);

 for (Object score: scores) {

 System.out.println(score);

 }

 // 獲取總條數

 Long total = zSetOperations.size("score");

 System.out.println("總條數：" + total);

 // 刪除

 zSetOperations.remove("score", "zhangsan", "lisi");

}

4.六、 獲取全部 key&刪除

// 獲取全部 key

@Test

public void testAllKeys() {

 // 當前庫 key 的名稱

 Set<String> keys = redisTemplate.keys("*");

 for (String key: keys) {

 System.out.println(key);

 }

}

// 刪除

@Test

public void testDelete() {

 // 刪除 通用 適用於全部數據類型

 redisTemplate.delete("score");

}

4.七、 設置 key 的失效時間

@Test

public void testEx() {

 ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();

 // 方法一：插入一條數據並設置失效時間

 valueOperations.set("code", "abcd", 180, TimeUnit.SECONDS);

 // 方法二：給已存在的 key 設置失效時間

 boolean flag = redisTemplate.expire("code", 180, TimeUnit.SECONDS);

 // 獲取指定 key 的失效時間

 Long l = redisTemplate.getExpire("code");

}

5.  SpringDataRedis 整合使用哨兵機制

配置applicationContext-redis.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xmlns:p="http://www.springframework.org/schema/p"

 xsi:schemaLocation="http://www.springframework.org/schema/beans

 http://www.springframework.org/schema/beans/spring-beans.xsd">

 <!-- 鏈接池配置 -->

 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

 <!-- 最大鏈接數 -->

 <property name="maxTotal" value="1024"/>

 <!-- 最大 空閒鏈接數 -->

 <property name="maxIdle" value="200"/>

 <!-- 獲取鏈接時最大等待毫秒數 -->

 <property name="maxWaitMillis" value="10000"/>

 <!-- 在獲取鏈接時檢查有效性 -->

 <property name="testOnBorrow" value="true"/>

 </bean>

 <!-- 哨兵配置 -->

 <bean id="redisSentinelConfiguration"

class="org.springframework.data.redis.connection.RedisSentinelConfiguration">

 <property name="sentinels">

 <set>

 <bean name="sentinelNode1" class="org.springframework.data.redis.connection.RedisNode">

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="26379"/>

 </bean>

 <bean name="sentinelNode2" class="org.springframework.data.redis.connection.RedisNode">

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="26380"/>

 </bean>

 <bean name="sentinelNode3" class="org.springframework.data.redis.connection.RedisNode">

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="26381"/>

 </bean>

 </set>

 </property>

 <property name="master">

 <bean name="masterNode" class="org.springframework.data.redis.connection.RedisNode">

 <!-- 必須指定主節點名稱 -->

 <property name="name" value="mymaster"/>

 <constructor-arg name="host" value="192.168.10.24"/>

 <constructor-arg name="port" value="6380"/>

 </bean>

 </property>

 </bean>

 <!-- 客戶端鏈接工廠 設置主節點信息 -->

 <bean id="jedisConnFactory"

 class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"

 p:use-pool="true" p:host-name="192.168.10.24" p:port="6380" p:password="root">

 <!-- 鏈接池引用 -->

 <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>

 <!-- 哨兵引用 -->

 <constructor-arg name="sentinelConfig" ref="redisSentinelConfiguration"/>

 </bean>

 <!-- redisTemplate 配置 -->

 <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"

 p:connection-factory-ref="jedisConnFactory">

 <!-- 配置序列化操做 -->

 <property name="keySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="valueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashKeySerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 <property name="hashValueSerializer">

 <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>

 </property>

 </bean>

</beans>

6.  項目中集成 Redis 緩存數據

6.1pom.xml

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0

http://maven.apache.org/xsd/maven-4.0.0.xsd">

 <modelVersion>4.0.0</modelVersion>

 <groupId>com.shsxt</groupId>

 <artifactId>spring-data-redis</artifactId>

 <version>1.0-SNAPSHOT</version>

 <name>spring-data-redis</name>

 <!-- FIXME change it to the project's website -->

 <url>http://www.example.com</url>

 <properties>

 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

 <maven.compiler.source>1.7</maven.compiler.source>

 <maven.compiler.target>1.7</maven.compiler.target>

 </properties>

 <dependencies>

 <dependency>

 <groupId>junit</groupId>

 <artifactId>junit</artifactId>

 <version>4.12</version>

 <scope>test</scope>

 </dependency>

 <!-- spring 核心 jar -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-context</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring 測試 jar -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-test</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring jdbc -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-jdbc</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring 事物 -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-tx</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- aspectj 切面編程的 jar -->

 <dependency>

 <groupId>org.aspectj</groupId>

 <artifactId>aspectjweaver</artifactId>

 <version>1.8.9</version>

 </dependency>

 <!-- c3p0 鏈接池 -->

 <dependency>

 <groupId>c3p0</groupId>

 <artifactId>c3p0</artifactId>

 <version>0.9.1.2</version>

 </dependency>

 <!-- mybatis -->

 <dependency>

 <groupId>org.mybatis</groupId>

 <artifactId>mybatis</artifactId>

 <version>3.4.1</version>

 </dependency>

 <!-- 添加 mybatis 與 Spring 整合的核心包 -->

 <dependency>

 <groupId>org.mybatis</groupId>

 <artifactId>mybatis-spring</artifactId>

 <version>1.3.0</version>

 </dependency>

 <!-- mysql 驅動包 -->

 <dependency>

 <groupId>mysql</groupId>

 <artifactId>mysql-connector-java</artifactId>

 <version>5.1.39</version>

 </dependency>

 <!-- 日誌打印相關的 jar -->

 <dependency>

 <groupId>org.slf4j</groupId>

 <artifactId>slf4j-log4j12</artifactId>

 <version>1.7.2</version>

 </dependency>

 <dependency>

 <groupId>org.slf4j</groupId>

 <artifactId>slf4j-api</artifactId>

 <version>1.7.2</version>

 </dependency>

 <!-- springmvc 依賴 jar -->

 <!-- spring web -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-web</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- spring mvc -->

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-webmvc</artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <!-- 添加 json 依賴 jar 包 -->

 <dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-core</artifactId>

 <version>2.7.0</version>

 </dependency>

 <dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-databind</artifactId>

 <version>2.7.0</version>

 </dependency>

 <dependency>

 <groupId>com.fasterxml.jackson.core</groupId>

 <artifactId>jackson-annotations</artifactId>

 <version>2.7.0</version>

 </dependency>

 <dependency>

 <groupId>commons-fileupload</groupId>

 <artifactId>commons-fileupload</artifactId>

 <version>1.3.2</version>

 </dependency>

 <dependency>

 <groupId>org.springframework</groupId>

 <artifactId>spring-context-support </artifactId>

 <version>4.3.2.RELEASE</version>

 </dependency>

 <dependency>

 <groupId>org.freemarker</groupId>

 <artifactId>freemarker</artifactId>

 <version>2.3.21</version>

 </dependency>

 <dependency>

 <groupId>org.apache.commons</groupId>

 <artifactId>commons-lang3</artifactId>

 <version>3.3.2</version>

 </dependency>

 <!-- Redis 依賴 -->

 <dependency>

 <groupId>redis.clients</groupId>

 <artifactId>jedis</artifactId>

 <version>2.9.1</version>

 </dependency>

 <!-- spring data redis 依賴 -->

 <dependency>

 <groupId>org.springframework.data</groupId>

 <artifactId>spring-data-redis</artifactId>

 <version>1.8.18.RELEASE</version>

 </dependency>

 </dependencies>

 <build>

 <!-- 讀取配置文件 -->

 <resources>

 <resource>

 <directory>src/main/resources</directory>

 </resource>

 <resource>

 <directory>src/main/java</directory>

 <includes>

 <include>**/*.xml</include>

 <include>**/*.properties</include>

 <include>**/*.tld</include>

 </includes>

 <filtering>false</filtering>

 </resource>

 </resources>

 </build>

</project>

6.2jdbc.properties 

jdbc.driver=com.mysql.jdbc.Driver

jdbc.url=jdbc:mysql://127.0.0.1:3306/p2p?useUnicode=true&characterEncoding=utf8

jdbc.username=root

jdbc.password=root

6.3log4j.properties

log4j.rootLogger=DEBUG, Console

#Console

log4j.appender.Console=org.apache.log4j.ConsoleAppender

log4j.appender.Console.layout=org.apache.log4j.PatternLayout

log4j.appender.Console.layout.ConversionPattern=%d [%t] %-5p [%c]

- %m%n

log4j.logger.java.sql.ResultSet=INFO

log4j.logger.org.apache=INFO

log4j.logger.java.sql.Connection=DEBUG

log4j.logger.java.sql.Statement=DEBUG

log4j.logger.java.sql.PreparedStatement=DEBUG

6.4applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

 xmlns:context="http://www.springframework.org/schema/context"

 xmlns:aop="http://www.springframework.org/schema/aop"

 xmlns:tx="http://www.springframework.org/schema/tx"

 xsi:schemaLocation="http://www.springframework.org/schema/beans

 http://www.springframework.org/schema/beans/spring-beans.xsd

 http://www.springframework.org/schema/context

 http://www.springframework.org/schema/context/spring-context.xsd

 http://www.springframework.org/schema/aop

 http://www.springframework.org/schema/aop/spring-aop.xsd

 http://www.springframework.org/schema/tx

 http://www.springframework.org/schema/tx/spring-tx.xsd">

 <context:property-placeholder location="classpath:jdbc.properties"/>

 <context:component-scan base-package="com.shsxt.service"></context:component-scan>

 <!-- 配置數據源 -->

 <!-- 配置 c3p0 數據源 -->

 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">

 <property name="driverClass" value="${jdbc.driver}"></property>

 <property name="jdbcUrl" value="${jdbc.url}"></property>

 <property name="user" value="${jdbc.username}"></property>

 <property name="password" value="${jdbc.password}"></property>

 </bean>

 <!-- 配置事務管理器 -->

 <bean id="txManager"

class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

 <property name="dataSource" ref="dataSource"></property>

 </bean>

 <!-- 設置事務加強 -->

 <tx:advice id="txAdvice" transaction-manager="txManager">

 <tx:attributes>

 <tx:method name="get*" read-only="true"/>

 <tx:method name="find*" read-only="true"/>

 <tx:method name="query*" read-only="true"/>

 <tx:method name="load*" read-only="true"/>

 <tx:method name="add*" propagation="REQUIRED"/>

 <tx:method name="insert*" propagation="REQUIRED"/>

 <tx:method name="update*" propagation="REQUIRED"/>

 <tx:method name="del*" propagation="REQUIRED"/>

 <tx:method name="save*" propagation="REQUIRED"/>

 </tx:attributes>

 </tx:advice>

 <!-- aop 切面配置 -->

 <aop:config>

 <aop:pointcut id="servicePointcut" expression="execution(*

com.shsxt.service.impl.*.*(..))"/>

 <aop:advisor advice-ref="txAdvice" pointcut-ref="servicePointcut"/>

 </aop:config>

 <!-- 配置 sqlSessionFactory -->

 <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">

 <property name="dataSource" ref="dataSource"></property>

 <property name="mapperLocations" value="classpath:com/shsxt/mapper/*.xml"/>

 </bean>

 <!-- 配置掃描器 -->

 <bean id="mapperScanner" class="org.mybatis.spring.mapper.MapperScannerConfigurer">

 <!-- 掃描 com.shsxt.dao 這個包以及它的子包下的全部映射接口類 -->

 <property name="basePackage" value="com.shsxt.dao"/>

 <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>

 </bean>

</beans>

6.5代碼

6.5.1JsonUtil.java

package com.shsxt.util;

import java.io.IOException;

import com.fasterxml.jackson.core.JsonParseException;

import com.fasterxml.jackson.core.JsonProcessingException;

import com.fasterxml.jackson.databind.JsonMappingException;

import com.fasterxml.jackson.databind.ObjectMapper;

/**

* Json 轉換工具類

*/

public class JsonUtil {

 private static ObjectMapper objectMapper = new ObjectMapper();

 

 /**

 * 將對象轉換成 json 字符串

 * @param obj

 * @return

 */

 public static String object2JsonStr(Object obj){

 try {

 return objectMapper.writeValueAsString(obj);

 } catch (JsonProcessingException e) {

 //打印異常信息

 e.printStackTrace();

 }

 return null;

 }

 

 /**

 * 將字符串轉換爲對象

 * @param <T> 泛型

 */

 public static <T> T jsonStr2Object(String jsonStr, Class<T> clazz){

 try {

 return objectMapper.readValue(jsonStr.getBytes("UTF-8"), clazz);

 } catch (JsonParseException e) {

 e.printStackTrace();

 } catch (JsonMappingException e) {

 e.printStackTrace();

 } catch (IOException e) {

 e.printStackTrace();

 }

 return null;

 }

 

}

6.5.2UserDaoI.java

package com.shsxt.dao;

import com.shsxt.entity.User;

public interface UserDaoI {

 public User queryUserById(Integer userId);

}

6.5.3User.java

package com.shsxt.entity;

import java.io.Serializable;

public class User implements Serializable {

 private static final long serialVersionUID = 5751725238117698007L;

 private Integer id;

 private String username;

 private String password;

 public Integer getId() {

 return id;

 }

 public void setId(Integer id) {

 this.id = id;

 }

 public String getUsername() {

 return username;

 }

 public void setUsername(String username) {

 this.username = username;

 }

 public String getPassword() {

 return password;

 }

 public void setPassword(String password) {

 this.password = password;

 }

 @Override

 public String toString() {

 return "User{" +

 "id=" + id +

 ", username='" + username + '\'' +

 ", password='" + password + '\'' +

 '}';

 }

}

6.5.4UserMapper.xml

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="com.shsxt.dao.UserDaoI">

 <select id="queryUserById" resultType="com.shsxt.entity.User">

 SELECT id,

 username,

 password

 FROM bas_user

 WHERE id = #{userId}

 </select>

</mapper>

6.5.5.UserServiceI.java

package com.shsxt.service;

import com.shsxt.entity.User;

public interface UserServiceI {

 public User queryUserById(Integer userId);

}

6.5.6.UserServiceImpl.java

package com.shsxt.service.impl;

import com.shsxt.dao.UserDaoI;

import com.shsxt.entity.User;

import com.shsxt.service.UserServiceI;

import com.shsxt.util.JsonUtil;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.stereotype.Service;

@Service

public class UserServiceImpl implements UserServiceI {

 @Autowired

 private RedisTemplate<String, Object> redisTemplate;

 @Autowired

 private UserDaoI userDao;

 @Override

 public User queryUserById(Integer userId) {

// return doQueryUserById(userId);

 return doQueryUserById2Json(userId);

 }

 public User doQueryUserById(Integer userId) {

 // 先從 Redis 查詢

 User user = (User) redisTemplate.opsForValue().get("user:id_" + userId);

 if(null != user){

 return user;

 }

 // Redis 沒有再從 mysql 查詢

 user = userDao.queryUserById(userId);

 if(null != user){

 redisTemplate.opsForValue().set("user:id_" + userId, user);

 return user;

 }

 return null;

 }

 public User doQueryUserById2Json(Integer userId) {

 // 先從 Redis 查詢

 Object jsonUser = redisTemplate.opsForValue().get("user:id_" + userId);

 User user = null;

 if(null != user){

 user = JsonUtil.jsonStr2Object((String) jsonUser, User.class);

 return user;

 }

 // Redis 沒有再從 mysql 查詢

 user = userDao.queryUserById(userId);

 if(null != user){

 redisTemplate.opsForValue().set("user:id_" + userId,

JsonUtil.object2JsonStr(user));

 return user;

 }

 return null;

 }

}

6.5.7.UserServiceTest.java

package com.shsxt.service;

import com.shsxt.entity.User;

import com.shsxt.service.UserServiceI;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.test.context.ContextConfiguration;

import

org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/*

* @RunWith 就是一個運行器

* @RunWith(JUnit4.class)就是指用 JUnit4 來運行

* @RunWith(SpringJUnit4ClassRunner.class)，讓測試運行於 Spring 測試環境

*/

@RunWith(SpringJUnit4ClassRunner.class)

/*

* @ContextConfiguration Spring 整合 JUnit4 測試時，使用註解引入多個配置文

件

* 單個文件 @ContextConfiguration(locations =

"classpath:spring/applicationContext.xml")

* 多個文件 @ContextConfiguration(locations =

{"classpath:spring/spring1.xml", "classpath:mybatis/config.xml"})

*/

@ContextConfiguration(locations = {"classpath:applicationContext.xml",

"classpath:applicationContext-redis.xml"})

public class UserServiceTest {

 @Autowired

 private UserServiceI userService;

 @Test

 public void test() {

 User user = userService.queryUserById(1);

 System.out.println(user);

 }

}

八.  緩存雪崩,緩存擊穿,緩存穿透

1.緩存穿透

描述：

  緩存穿透是指緩存和數據庫中都沒有的數據，而用戶不斷髮起請求，如發起爲id爲「-1」的數據或id爲特別大不存在的數據。這時的用戶極可能是攻擊者，攻擊會致使數據庫壓力過大。

解決方案：

(1).接口層增長校驗，如用戶鑑權校驗，id作基礎校驗，id<=0的直接攔截；

(2).從緩存取不到的數據，在數據庫中也沒有取到，這時也能夠將key-value對寫爲key-null，緩存有效時間能夠設置短點，如30秒（設置太長會致使正常狀況也無法使用）。這樣能夠防止攻擊用戶反覆用同一個id暴力攻擊.

2.緩存擊穿

描述：

緩存擊穿是指緩存中沒有但數據庫中有的數據（通常是緩存時間到期），這時因爲併發用戶特別多，同時讀緩存沒讀到數據，又同時去數據庫去取數據，引發數據庫壓力瞬間增大，形成過大壓力

解決方案：

(1).設置熱點數據永遠不過時。

(2).加互斥鎖，互斥鎖

3.緩存雪崩

描述：

 緩存雪崩是指緩存中數據大批量到過時時間，而查詢數據量巨大，引發數據庫壓力過大甚至down機。和緩存擊穿不一樣的是，緩存擊穿指併發查同一條數據，緩存雪崩是不一樣數據都過時了，不少數據都查不到從而查數據庫。

解決方案：

(1).緩存數據的過時時間設置隨機，防止同一時間大量數據過時現象發生。若是緩存數據庫是分佈式部署，將熱點數據均勻分佈在不一樣搞得緩存數據庫中。

(2).設置熱點數據永遠不過時。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程