麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久99热浪潮_成人一区二区三区四区

首頁(yè) > 數(shù)據(jù)庫(kù) > Redis > 正文

Redis主從實(shí)現(xiàn)讀寫(xiě)分離

2020-10-28 21:38:42
字體:
來(lái)源:轉(zhuǎn)載
供稿:網(wǎng)友

前言

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

實(shí)現(xiàn)

引用庫(kù)文件

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

方式一,借助切面

JedisPoolSelector

此類(lèi)的目的是為讀和寫(xiě)分別配置不同的注解,用來(lái)區(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

此類(lèi)的目的是針對(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. */@Aspectpublic 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

此類(lèi)目的是存儲(chǔ)當(dāng)前使用的JedisPool,即上面類(lèi)賦值后的結(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 ThreadLocal<JedisPool> holder = new ThreadLocal<JedisPool>();  public static void putJedisPool(JedisPool jedisPool) {    holder.set(jedisPool);  }  public static JedisPool getJedisPool() {    return holder.get();  }}

RedisUtils

此類(lèi)目的是對(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í),是否檢測(cè)當(dāng)前鏈接有效性。無(wú)效則從鏈接池中移除,并嘗試?yán)^續(xù)獲取。(默認(rèn)為false) -->    <property name="testOnBorrow" value="true" />    <!-- 向鏈接池中歸還鏈接時(shí),是否檢測(cè)鏈接有效性。(默認(rèn)為false) -->    <property name="testOnReturn" value="true" />    <!-- 調(diào)用者獲取鏈接時(shí),是否檢測(cè)空閑超時(shí)。如果超時(shí),則會(huì)被移除(默認(rèn)為false) -->    <property name="testWhileIdle" value="true" />    <!-- 空閑鏈接檢測(cè)線(xiàn)程一次運(yùn)行檢測(cè)多少條鏈接 -->    <property name="numTestsPerEvictionRun" value="10" />    <!-- 空閑鏈接檢測(cè)線(xiàn)程檢測(cè)周期。如果為負(fù)值,表示不運(yùn)行檢測(cè)線(xià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"));  }}

方式二,依賴(lài)注入

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

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í),是否檢測(cè)當(dāng)前鏈接有效性。無(wú)效則從鏈接池中移除,并嘗試?yán)^續(xù)獲取。(默認(rèn)為false) -->    <property name="testOnBorrow" value="true" />    <!-- 向鏈接池中歸還鏈接時(shí),是否檢測(cè)鏈接有效性。(默認(rèn)為false) -->    <property name="testOnReturn" value="true" />    <!-- 調(diào)用者獲取鏈接時(shí),是否檢測(cè)空閑超時(shí)。如果超時(shí),則會(huì)被移除(默認(rèn)為false) -->    <property name="testWhileIdle" value="true" />    <!-- 空閑鏈接檢測(cè)線(xiàn)程一次運(yùn)行檢測(cè)多少條鏈接 -->    <property name="numTestsPerEvictionRun" value="10" />    <!-- 空閑鏈接檢測(cè)線(xiàn)程檢測(cè)周期。如果為負(fù)值,表示不運(yùn)行檢測(cè)線(xià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>

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持武林網(wǎng)。

發(fā)表評(píng)論 共有條評(píng)論
用戶(hù)名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: omofun 动漫在线观看 | 九九视屏 | 亚洲视频高清 | 伊人午夜| 草久网 | 久久久久久中文字幕 | 哪里可以看免费的av | 日本aaaa片毛片免费观蜜桃 | 九九热欧美 | 91麻豆精品国产91久久久无需广告 | 少妇一级淫片免费放正片 | 亚洲成人免费网站 | 国产精品久久久乱弄 | 一级免费 | 国产精选久久久 | 久草久视频| 成人毛片100部免费观看 | 国产精品视频一区二区三区四 | 九草视频 | 欧美在线观看黄色 | 亚洲成人在线免费 | 青青国产在线视频 | 久久精品久久久久 | 欧美色大成网站www永久男同 | 亚洲一区在线免费视频 | 欧美日本不卡 | 九九视频精品在线观看 | 九九精品在线观看视频 | 亚洲一区成人在线 | 中国美女一级黄色大片 | 澳门一级淫片免费视频 | 欧美在线观看黄色 | 国产精品高潮视频 | h视频免费在线 | 欧美性色黄大片www 成人免费网站在线观看 | 美女91视频| 性欧美一区| 黄色视频一级毛片 | 狠狠操操| 91精品观看91久久久久久国产 | 成年性羞羞视频免费观看 |