分散式快取技術redis學習系列（九）——Redis主從實現讀寫分離

阿新 • • 發佈：2018-12-25

前言
大家在工作中可能會遇到這樣的需求，即Redis讀寫分離，目的是為了壓力分散化。下面我將為大家介紹藉助AWS的ELB實現讀寫分離，以寫主讀從為例。

實現
引用庫檔案

<!-- redis客戶端 -->
<dependency>
 <groupId>redis.clients</groupId>
 <artifactId>jedis</artifactId>
 <version>2.6.2</version>
</dependency>

方式一，藉助切面

JedisPoolSelector

此類的目的是為讀和寫分別配置不同的註解，用來區分是主還是從。

package com.silence.spring.redis.readwriteseparation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * Created by keysilence on 16/10/26.
 */
@Retention 
(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface JedisPoolSelector {

  String value();

}

JedisPoolAspect
此類的目的是針對主和從的註解，進行動態連結池調配，即主的使用主連結池，從的使用從連線池。

package com.silence.spring.redis.readwriteseparation;

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.Aspect;
import 
 org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import redis.clients.jedis.JedisPool;

import javax.annotation.PostConstruct;
import java.lang.reflect.Method;
import java.util.Date;

/**
 * Created by keysilence on 16/10/26.
 */
@Aspect
public class JedisPoolAspect implements ApplicationContextAware {

  private ApplicationContext ctx;

  @PostConstruct
  public void init() {
    System.out.println("jedis pool aspectj started @" + new Date());
  }

  @Pointcut("execution(* com.silence.spring.redis.readwriteseparation.util.*.*(..))")
  private void allMethod() {

  }

  @Before("allMethod()")
  public void before(JoinPoint point)
  {
    Object target = point.getTarget();
    String method = point.getSignature().getName();

    Class classz = target.getClass();

    Class<?>[] parameterTypes = ((MethodSignature) point.getSignature())
        .getMethod().getParameterTypes();
    try {
      Method m = classz.getMethod(method, parameterTypes);
      if (m != null && m.isAnnotationPresent(JedisPoolSelector.class)) {
        JedisPoolSelector data = m
            .getAnnotation(JedisPoolSelector.class);
        JedisPool jedisPool = (JedisPool) ctx.getBean(data.value());
        DynamicJedisPoolHolder.putJedisPool(jedisPool);
      }

    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
    this.ctx = applicationContext;
  }

}

DynamicJedisPoolHolder
此類目的是儲存當前使用的JedisPool，即上面類賦值後的結果儲存。

package com.silence.spring.redis.readwriteseparation;

import redis.clients.jedis.JedisPool;

/**
 * Created by keysilence on 16/10/26.
 */
public class DynamicJedisPoolHolder {

  public static final ThreadLocal<JedisPool> holder = new ThreadLocal<JedisPool>();

  public static void putJedisPool(JedisPool jedisPool) {
    holder.set(jedisPool);
  }

  public static JedisPool getJedisPool() {
    return holder.get();
  }

}

RedisUtils
此類目的是對Redis具體的呼叫，裡面包含使用主還是從的方式呼叫。

package com.silence.spring.redis.readwriteseparation.util;

import com.silence.spring.redis.readwriteseparation.DynamicJedisPoolHolder;
import com.silence.spring.redis.readwriteseparation.JedisPoolSelector;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Created by keysilence on 16/10/26.
 */
public class RedisUtils {
  private static Logger logger = LoggerFactory.getLogger(RedisUtils.class);

  @JedisPoolSelector("master")
  public String setString(final String key, final String value) {

    String ret = DynamicJedisPoolHolder.getJedisPool().getResource().set(key, value);
    System.out.println("key:" + key + ",value:" + value + ",ret:" + ret);

    return ret;
  }

  @JedisPoolSelector("slave")
  public String get(final String key) {

    String ret = DynamicJedisPoolHolder.getJedisPool().getResource().get(key);
    System.out.println("key:" + key + ",ret:" + ret);

    return ret;
  }

}

spring-datasource.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:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">

  <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <!-- 池中最大連結數 -->
    <property name="maxTotal" value="100"/>
    <!-- 池中最大空閒連結數 -->
    <property name="maxIdle" value="50"/>
    <!-- 池中最小空閒連結數 -->
    <property name="minIdle" value="20"/>
    <!-- 當池中連結耗盡，呼叫者最大阻塞時間，超出此時間將跑出異常。（單位：毫秒；預設為-1，表示永不超時） -->
    <property name="maxWaitMillis" value="1000"/>
    <!-- 參考：http://biasedbit.com/redis-jedispool-configuration/ -->
    <!-- 呼叫者獲取連結時，是否檢測當前連結有效性。無效則從連結池中移除，並嘗試繼續獲取。（預設為false） -->
    <property name="testOnBorrow" value="true" />
    <!-- 向連結池中歸還連結時，是否檢測連結有效性。（預設為false） -->
    <property name="testOnReturn" value="true" />
    <!-- 呼叫者獲取連結時，是否檢測空閒超時。如果超時，則會被移除（預設為false） -->
    <property name="testWhileIdle" value="true" />
    <!-- 空閒連結檢測執行緒一次執行檢測多少條連結 -->
    <property name="numTestsPerEvictionRun" value="10" />
    <!-- 空閒連結檢測執行緒檢測週期。如果為負值，表示不執行檢測執行緒。（單位：毫秒，預設為-1） -->
    <property name="timeBetweenEvictionRunsMillis" value="60000" />
    <!-- 連結獲取方式。佇列：false；棧：true -->
    <!--<property name="lifo" value="false" />-->
  </bean>

  <bean id="master" class="redis.clients.jedis.JedisPool">
    <constructor-arg index="0" ref="poolConfig"/>
    <constructor-arg index="1" value="192.168.100.110" type="java.lang.String"/>
    <constructor-arg index="2" value="6379" type="int"/>
  </bean>

  <bean id="slave" class="redis.clients.jedis.JedisPool">
    <constructor-arg index="0" ref="poolConfig"/>
    <!-- 此處Host配置成ELB地址 -->
    <constructor-arg index="1" value="192.168.100.110" type="java.lang.String"/>
    <constructor-arg index="2" value="6380" type="int"/>
  </bean>

  <bean id="redisUtils" class="com.silence.spring.redis.readwriteseparation.util.RedisUtils">
  </bean>

  <bean id="jedisPoolAspect" class="com.silence.spring.redis.readwriteseparation.JedisPoolAspect" />

  <aop:aspectj-autoproxy proxy-target-class="true"/>

</beans>

Test

package com.silence.spring.redis.readwriteseparation;

import com.silence.spring.redis.readwriteseparation.util.RedisUtils;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * Created by keysilence on 16/10/26.
 */
public class Test {

  public static void main(String[] args) {

    ApplicationContext ctx = new ClassPathXmlApplicationContext("spring-datasource.xml");

    System.out.println(ctx);

    RedisUtils redisUtils = (RedisUtils) ctx.getBean("redisUtils");
    redisUtils.setString("aaa", "111");

    System.out.println(redisUtils.get("aaa"));
  }

}

方式二，依賴注入

與方式一類似，但是需要寫死具體使用主的池還是從的池，思路如下：
放棄註解的方式，直接將主和從的兩個連結池注入到具體實現類中。

RedisUtils

package com.silence.spring.redis.readwriteseparation.util;

import com.silence.spring.redis.readwriteseparation.DynamicJedisPoolHolder;
import com.silence.spring.redis.readwriteseparation.JedisPoolSelector;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.JedisPool;

/**
 * Created by keysilence on 16/10/26.
 */
public class RedisUtils {
  private static Logger logger = LoggerFactory.getLogger(RedisUtils.class);

  private JedisPool masterJedisPool;

  private JedisPool slaveJedisPool;

  public void setMasterJedisPool(JedisPool masterJedisPool) {
    this.masterJedisPool = masterJedisPool;
  }

  public void setSlaveJedisPool(JedisPool slaveJedisPool) {
    this.slaveJedisPool = slaveJedisPool;
  }

  public String setString(final String key, final String value) {

    String ret = masterJedisPool.getResource().set(key, value);
    System.out.println("key:" + key + ",value:" + value + ",ret:" + ret);

    return ret;
  }

  public String get(final String key) {

    String ret = slaveJedisPool.getResource().get(key);
    System.out.println("key:" + key + ",ret:" + ret);

    return ret;
  }

}

spring-datasource.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:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">

  <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <!-- 池中最大連結數 -->
    <property name="maxTotal" value="100"/>
    <!-- 池中最大空閒連結數 -->
    <property name="maxIdle" value="50"/>
    <!-- 池中最小空閒連結數 -->
    <property name="minIdle" value="20"/>
    <!-- 當池中連結耗盡，呼叫者最大阻塞時間，超出此時間將跑出異常。（單位：毫秒；預設為-1，表示永不超時） -->
    <property name="maxWaitMillis" value="1000"/>
    <!-- 參考：http://biasedbit.com/redis-jedispool-configuration/ -->
    <!-- 呼叫者獲取連結時，是否檢測當前連結有效性。無效則從連結池中移除，並嘗試繼續獲取。（預設為false） -->
    <property name="testOnBorrow" value="true" />
    <!-- 向連結池中歸還連結時，是否檢測連結有效性。（預設為false） -->
    <property name="testOnReturn" value="true" />
    <!-- 呼叫者獲取連結時，是否檢測空閒超時。如果超時，則會被移除（預設為false） -->
    <property name="testWhileIdle" value="true" />
    <!-- 空閒連結檢測執行緒一次執行檢測多少條連結 -->
    <property name="numTestsPerEvictionRun" value="10" />
    <!-- 空閒連結檢測執行緒檢測週期。如果為負值，表示不執行檢測執行緒。（單位：毫秒，預設為-1） -->
    <property name="timeBetweenEvictionRunsMillis" value="60000" />
    <!-- 連結獲取方式。佇列：false；棧：true -->
    <!--<property name="lifo" value="false" />-->
  </bean>

  <bean id="masterJedisPool" class="redis.clients.jedis.JedisPool">
    <constructor-arg index="0" ref="poolConfig"/>
    <constructor-arg index="1" value="192.168.100.110" type="java.lang.String"/>
    <constructor-arg index="2" value="6379" type="int"/>
  </bean>

  <bean id="slaveJedisPool" class="redis.clients.jedis.JedisPool">
    <constructor-arg index="0" ref="poolConfig"/>
    <constructor-arg index="1" value="192.168.100.110" type="java.lang.String"/>
    <constructor-arg index="2" value="6380" type="int"/>
  </bean>

  <bean id="redisUtils" class="com.silence.spring.redis.readwriteseparation.util.RedisUtils">
    <property name="masterJedisPool" ref="masterJedisPool"/>
    <property name="slaveJedisPool" ref="slaveJedisPool"/>
  </bean>

</beans>

分散式快取技術redis學習系列（九）——Redis主從實現讀寫分離

前言大家在工作中可能會遇到這樣的需求，即Redis讀寫分離，目的是為了壓力分散化。下面我將為大家介紹藉助AWS的ELB實現讀寫分離，以寫主讀從為例。實現引用庫檔案  <dependency&g

分散式快取技術redis學習系列（四）——redis高階應用（叢集搭建、叢集分割槽原理、叢集操作）

Redis叢集簡介 Redis 叢集是3.0之後才引入的，在3.0之前，使用哨兵（sentinel）機制（本文將不做介紹，大家可另行查閱）來監控各個節點之間的狀態。Redis 叢集可謂是讓很多人久等了。 Redis 叢集是一組能進行資料共享的Redis 例項（

分布式緩存技術redis學習系列（三）——redis高級應用（主從、事務與鎖、持久化）

master ica not ood www working can 出了 owin 上文《詳細講解redis數據結構（內存模型）以及常用命令》介紹了redis的數據類型以及常用命令，本文我們來學習下redis的一些高級特性。回到頂部安全性設置設置客戶端操作秘密

Redis學習記錄（九）------Redis 事務

Redis 事務 Redis 事務可以一次執行多個命令，並且帶有以下兩個重要的保證：批量操作在傳送 EXEC 命令前被放入佇列快取。收到 EXEC 命令後進入事務執行，事務中任意命令執行失敗，其餘的命令依然被執行。在事務執行過程，其他客戶端提交的命令請求不會插

分散式快取技術redis學習系列（六）——sentinel哨兵機制

一、簡介： 1、Redis 的 Sentinel 系統用於管理多個 Redis 伺服器（instance），該系統執行以下三個任務： 1)監控（Monitoring）：Sentinel 會不斷地檢查你的主伺服器和從伺服器是否運作正常。 2)提醒（Notifica

分散式快取技術redis學習系列（八）——JedisCluster原始碼解讀：叢集初始化、slot(槽)的分配、值的存取

redis叢集環境，客戶端使用JedisCluster獲取連線並操作redis服務，上一篇分散式快取技術redis學習系列（七）——spring整合jediscluster 簡單介紹了spring使用JedisCluster，這篇從JedisCluster原始

分散式快取技術redis學習系列（七）——spring整合jediscluster

1、maven依賴 <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version

SpringBoot 學習系列 | （九）SpringBoot快速整合Redis

話不多說，直接貼程式碼： Maven pom.xml引入依賴  <dependency> <groupId>org.springframework.boot</groupId> <

redis學習筆記（四）redis快取與資料庫一致性問題

redis系列文章目錄 redis與資料庫資料一致性問題是個老生常談的問題了，這裡也沒啥新鮮玩意，就是總結一下不一致產生的原因我們在使用redis過程中，或者網上一些資料，通常會這

redis學習筆記（14）---redis基本命令總結

del diff lan 命令列表對象很多順序 reg http://doc.redisfans.com/ 網頁，對所有redis命令的用法與示例進行了詳細的描述概述 Redis的鍵值可以使用物種數據類型：字符串，散列表，列表，集合，有序集合。本文詳細介紹這

redis使用基礎（九） ——Redis虛擬內存

兩個數據規則導致文件中寫入 ron 開始路徑 redis使用基礎（九） ——Redis虛擬內存（轉載請附上本文鏈接——linhxx）一、概述 Redis的數據是保存在內存中，當物理內存不足，其會保存在虛擬內存（VM）中。Redis的

Redis學習總結（1）——Redis記憶體資料庫詳細教程

1.Redis是什麼 2.redis的作者何許人也 3.誰在使用redis 4.學會安裝redis 5.學會啟動redis 6.使用redis客戶端 7.redis資料結構 – 簡介 8.redis資料結構 – strings 9.redis資料結構 – lists 10.redis

Redis學習筆記（一）---Redis的五種資料型別的簡單介紹和使用

1.準備工作：　　1.1在Linux下安裝Redis 　　https://www.cnblogs.com/dddyyy/p/9763098.html　　　1.2啟動Redis 　　　　先把root/redis的redis.conf放到 /usr/local/redis/

Redis學習筆記（1）—— Redis簡介

一、NoSQL概述 1.1 什麼是NoSQL 　　NoSQL(NoSQL = Not Only SQL)，意指“不僅僅是SQL”，是一項全新的資料庫理念，泛指非關係型的資料庫。 1.2 為什麼需要NoSQL 　　隨著網際網路web2.0網站的興起，非關係型的資料庫成了一個極其熱門的新領域，非關係型資料

Redis學習筆記（5）—— Redis的持久化方案&Redis的叢集搭建

一、Redis的持久化方案　　Redis的高效能是由於其將所有資料都儲存在了記憶體中，為了使Redis在重啟之後仍能保證資料不丟失，需要將資料從記憶體中同步到硬碟中，這一過程就是持久化。 Redis支援兩種方式的持久化，一種是RDB方式，一種是AOF

Redis學習記錄（十）------Redis 指令碼

Redis 指令碼 Redis 指令碼使用 Lua 直譯器來執行指令碼。 Redis 2.6 版本通過內嵌支援 Lua 環境。執行指令碼的常用命令為 EVAL。語法 Eval 命令的基本語法如下： redis 127.0.0.1:6379> EVAL scri

Redis 學習筆記（1）—— Redis安裝，String 型別測試

1 Redis 介紹 1.1 概述 Redis是一個開源，先進的key-value儲存，並用於構建高效能，可擴充套件的應用程式的完美解決方案。 Redis資料庫完全在記憶體中，使用磁碟僅用於永續性。相比許多鍵值資料儲存，Redis擁有一套較為豐富的資料型別。

Redis 學習筆記（3）—— Redis List 型別

1 Redis List 型別 1.1 案例1 package mylist; import redis.clients.jedis.BinaryClient; import redis.clients.jedis.Jedis; import java.ut

Redis 學習筆記（5）—— Redis sortSet 型別

1 sortSet 1.1 案例1 package sortset; import redis.clients.jedis.Jedis; import java.util.Set; public

Redis學習總結（12）——Redis常見面試題再總結

1、什麼是Redis？ Redis本質上是一個Key-Value型別的記憶體資料庫，很像memcached，整個資料庫統統載入在記憶體當中進行操作，定期通過非同步操作把資料庫資料flush到硬碟上進行儲存。因為是純記憶體操作，Redis的效能非常出色，每秒可以處理超過 10

分散式快取技術redis學習系列（九）——Redis主從實現讀寫分離

相關推薦