佳木斯湛栽影视文化发展公司
主頁 > 知識(shí)庫 > Redis主從實(shí)現(xiàn)讀寫分離

Redis主從實(shí)現(xiàn)讀寫分離
熱門標(biāo)簽：網(wǎng)站排名優(yōu)化 鐵路電話系統(tǒng) 呼叫中心市場需求 百度競價(jià)排名 AI電銷 地方門戶網(wǎng)站 Linux服務(wù)器 服務(wù)外包

前言

大家在工作中可能會(huì)遇到這樣的需求，即Redis讀寫分離，目的是為了壓力分散化。下面我將為大家介紹借助AWS的ELB實(shí)現(xiàn)讀寫分離，以寫主讀從為例。

實(shí)現(xiàn)

引用庫文件

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

方式一，借助切面

JedisPoolSelector

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

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

此類的目的是針對(duì)主和從的注解，進(jìn)行動(dòng)態(tài)鏈接池調(diào)配，即主的使用主鏈接池，從的使用從連接池。

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

此類目的是存儲(chǔ)當(dāng)前使用的JedisPool，即上面類賦值后的結(jié)果保存。

package com.silence.spring.redis.readwriteseparation;

import redis.clients.jedis.JedisPool;

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

  public static final ThreadLocalJedisPool> holder = new ThreadLocalJedisPool>();

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

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

}

RedisUtils

此類目的是對(duì)Redis具體的調(diào)用，里面包含使用主還是從的方式調(diào)用。

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">
    !-- 池中最大鏈接數(shù) -->
    property name="maxTotal" value="100"/>
    !-- 池中最大空閑鏈接數(shù) -->
    property name="maxIdle" value="50"/>
    !-- 池中最小空閑鏈接數(shù) -->
    property name="minIdle" value="20"/>
    !-- 當(dāng)池中鏈接耗盡，調(diào)用者最大阻塞時(shí)間，超出此時(shí)間將跑出異常。（單位：毫秒；默認(rèn)為-1，表示永不超時(shí)） -->
    property name="maxWaitMillis" value="1000"/>
    !-- 參考：http://biasedbit.com/redis-jedispool-configuration/ -->
    !-- 調(diào)用者獲取鏈接時(shí)，是否檢測當(dāng)前鏈接有效性。無效則從鏈接池中移除，并嘗試?yán)^續(xù)獲取。（默認(rèn)為false） -->
    property name="testOnBorrow" value="true" />
    !-- 向鏈接池中歸還鏈接時(shí)，是否檢測鏈接有效性。（默認(rèn)為false） -->
    property name="testOnReturn" value="true" />
    !-- 調(diào)用者獲取鏈接時(shí)，是否檢測空閑超時(shí)。如果超時(shí)，則會(huì)被移除（默認(rèn)為false） -->
    property name="testWhileIdle" value="true" />
    !-- 空閑鏈接檢測線程一次運(yùn)行檢測多少條鏈接 -->
    property name="numTestsPerEvictionRun" value="10" />
    !-- 空閑鏈接檢測線程檢測周期。如果為負(fù)值，表示不運(yùn)行檢測線程。（單位：毫秒，默認(rèn)為-1） -->
    property name="timeBetweenEvictionRunsMillis" value="60000" />
    !-- 鏈接獲取方式。隊(duì)列：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"));
  }

}

方式二，依賴注入

與方式一類似，但是需要寫死具體使用主的池還是從的池，思路如下：
放棄注解的方式，直接將主和從的兩個(gè)鏈接池注入到具體實(shí)現(xiàn)類中。

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">
    !-- 池中最大鏈接數(shù) -->
    property name="maxTotal" value="100"/>
    !-- 池中最大空閑鏈接數(shù) -->
    property name="maxIdle" value="50"/>
    !-- 池中最小空閑鏈接數(shù) -->
    property name="minIdle" value="20"/>
    !-- 當(dāng)池中鏈接耗盡，調(diào)用者最大阻塞時(shí)間，超出此時(shí)間將跑出異常。（單位：毫秒；默認(rèn)為-1，表示永不超時(shí)） -->
    property name="maxWaitMillis" value="1000"/>
    !-- 參考：http://biasedbit.com/redis-jedispool-configuration/ -->
    !-- 調(diào)用者獲取鏈接時(shí)，是否檢測當(dāng)前鏈接有效性。無效則從鏈接池中移除，并嘗試?yán)^續(xù)獲取。（默認(rèn)為false） -->
    property name="testOnBorrow" value="true" />
    !-- 向鏈接池中歸還鏈接時(shí)，是否檢測鏈接有效性。（默認(rèn)為false） -->
    property name="testOnReturn" value="true" />
    !-- 調(diào)用者獲取鏈接時(shí)，是否檢測空閑超時(shí)。如果超時(shí)，則會(huì)被移除（默認(rèn)為false） -->
    property name="testWhileIdle" value="true" />
    !-- 空閑鏈接檢測線程一次運(yùn)行檢測多少條鏈接 -->
    property name="numTestsPerEvictionRun" value="10" />
    !-- 空閑鏈接檢測線程檢測周期。如果為負(fù)值，表示不運(yùn)行檢測線程。（單位：毫秒，默認(rèn)為-1） -->
    property name="timeBetweenEvictionRunsMillis" value="60000" />
    !-- 鏈接獲取方式。隊(duì)列：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>

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:
  • Redis如何實(shí)現(xiàn)數(shù)據(jù)庫讀寫分離詳解
  • redis客戶端實(shí)現(xiàn)高可用讀寫分離的方式詳解
  • Redis讀寫分離搭建的完整步驟

標(biāo)簽：崇左 衡水 湖南 仙桃 銅川 蘭州 黃山 湘潭

巨人網(wǎng)絡(luò)通訊聲明：本文標(biāo)題《Redis主從實(shí)現(xiàn)讀寫分離》，本文關(guān)鍵詞  ；如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題，煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們，我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò)，涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 收縮
    • 微信客服
    • 微信二維碼

    • 電話咨詢

    • 400-1100-266
    延安市| 德保县| 专栏| 即墨市| 宜兴市| 波密县| 巴东县| 彭水| 青川县| 上栗县| 定日县| 黎川县| 印江| 海晏县| 永丰县| 福贡县| 离岛区| 和平区| 新民市| 沂源县| 屯门区| 保定市| 阳原县| 阿合奇县| 天津市| 井研县| 济南市| 乌拉特后旗| 北京市| 沅陵县| 辽阳市| 简阳市| 池州市| 永宁县| 安远县| 蒙自县| 宝应县| 九龙坡区| 姜堰市| 佛冈县| 钟山县|