English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
Introduzione
In lavoro, potresti incontrare esigenze come la separazione della lettura e della scrittura di Redis, che ha lo scopo di distribuire il carico. Di seguito, vi introdurrò come realizzare la separazione della lettura e della scrittura utilizzando AWS ELB, prendendo come esempio la scrittura principale e la lettura secondaria.
Implementazione
Riferimento ai file delle librerie
<!-- client Redis --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.6.2</version> </dependency>
Metodo 1,attraverso l'aspetto
JedisPoolSelector
Lo scopo di questa classe è configurare annotazioni diverse per la lettura e la scrittura, per distinguere tra il principale e il secondario.
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'obiettivo di questa classe è mirato a gestire dinamicamente il pool di connessioni tra il master e lo slave, ovvero l'uso del pool di connessioni master per il master e del pool di connessioni slave per lo slave.
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 avviato @" + new Date());
}
@Pointcut("execution(* com.silence.spring.redis.readwriteseparation.util.*.*(..))")
private void allMethod() {
}
@Before("allMethod()")
public void before(JoinPoint point)
{
Oggetto obiettivo = 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
Il fine di questa classe è memorizzare il JedisPool attualmente utilizzato, ovvero il risultato dell'assegnamento della classe sopra.
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
Questo classe ha lo scopo di chiamare specificamente Redis, includendo come chiamare il modo principale o secondario.
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">
<!-- Puntata massima di connessioni nel pool -->
<property name="maxTotal" value="100"/>
<!-- Numero massimo di collegamenti inattivi nel pool -->
<property name="maxIdle" value="50"/>
<!-- Numero minimo di collegamenti inattivi nel pool -->
<property name="minIdle" value="20"/>
<!-- Quando i collegamenti del pool sono esauriti, il tempo massimo di blocco massimo dell'utente. Se superato questo tempo, viene lanciata un'eccezione. (Unità: millisecondi; predefinito -1, che significa mai in timeout) -->
<property name="maxWaitMillis" value="1000"/>
<!-- Riferimento: http://biasedbit.com/redis-jedispool-configuration/ -->
<!-- Durante l'acquisizione del collegamento dall'utente, se viene rilevata la validità del collegamento corrente. Se non valido, viene rimosso dal pool di collegamenti e viene tentato di continuare a ottenere. (Predefinito false) -->
<property name="testOnBorrow" value="true" />
<!-- Durante il restituzione del collegamento al pool, se viene rilevata la validità del collegamento. (Predefinito false) -->
<property name="testOnReturn" value="true" />
<!-- Durante l'acquisizione del collegamento dall'utente, se viene rilevato un timeout inattivo. Se si verifica un timeout, viene rimosso (predefinito false) -->
<property name="testWhileIdle" value="true" />
<!-- Numero di collegamenti da rilevare durante l'esecuzione del thread di rilevamento dei collegamenti inattivi -->
<property name="numTestsPerEvictionRun" value="10" />
<!-- Periodo di rilevamento del thread di rilevamento dei collegamenti inattivi. Se è un valore negativo, significa che non viene eseguito il rilevamento del thread. (Unità: millisecondi, predefinito -1) -->
<property name="timeBetweenEvictionRunsMillis" value="60000" />
<!-- Modo di acquisizione del collegamento. Coda: false; Pila: 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"));
}
}
Metodo due,Iniezione di dipendenza
Simile al metodo uno, ma è necessario scrivere a mano quale pool utilizzare, il pensiero è il seguente:
Abbandonare l'annotazione, direttamente inserire i due pool di connessione principale e secondario nel classe di implementazione specifica.
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">
<!-- Puntata massima di connessioni nel pool -->
<property name="maxTotal" value="100"/>
<!-- Numero massimo di collegamenti inattivi nel pool -->
<property name="maxIdle" value="50"/>
<!-- Numero minimo di collegamenti inattivi nel pool -->
<property name="minIdle" value="20"/>
<!-- Quando i collegamenti del pool sono esauriti, il tempo massimo di blocco massimo dell'utente. Se superato questo tempo, viene lanciata un'eccezione. (Unità: millisecondi; predefinito -1, che significa mai in timeout) -->
<property name="maxWaitMillis" value="1000"/>
<!-- Riferimento: http://biasedbit.com/redis-jedispool-configuration/ -->
<!-- Durante l'acquisizione del collegamento dall'utente, se viene rilevata la validità del collegamento corrente. Se non valido, viene rimosso dal pool di collegamenti e viene tentato di continuare a ottenere. (Predefinito false) -->
<property name="testOnBorrow" value="true" />
<!-- Durante il restituzione del collegamento al pool, se viene rilevata la validità del collegamento. (Predefinito false) -->
<property name="testOnReturn" value="true" />
<!-- Durante l'acquisizione del collegamento dall'utente, se viene rilevato un timeout inattivo. Se si verifica un timeout, viene rimosso (predefinito false) -->
<property name="testWhileIdle" value="true" />
<!-- Numero di collegamenti da rilevare durante l'esecuzione del thread di rilevamento dei collegamenti inattivi -->
<property name="numTestsPerEvictionRun" value="10" />
<!-- Periodo di rilevamento del thread di rilevamento dei collegamenti inattivi. Se è un valore negativo, significa che non viene eseguito il rilevamento del thread. (Unità: millisecondi, predefinito -1) -->
<property name="timeBetweenEvictionRunsMillis" value="60000" />
<!-- Modo di acquisizione del collegamento. Coda: false; Pila: 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>
Questo è tutto il contenuto dell'articolo, speriamo che sia utile per la tua apprendimento, e ti preghiamo di sostenere e fare eco della guida tutorial.
Dichiarazione: il contenuto di questo articolo è stato tratto da Internet, il copyright è di proprietà del rispettivo proprietario, il contenuto è stato contribuito e caricato autonomamente dagli utenti di Internet, questo sito non possiede il diritto di proprietà, non è stato editato manualmente e non assume responsabilità per le relative responsabilità legali. Se trovi contenuti sospetti di copyright, ti preghiamo di inviare una email a: notice#oldtoolbag.com (al momento dell'invio dell'email, sostituisci # con @) per segnalare e fornire prove pertinenti. Una volta verificata, questo sito eliminerà immediatamente i contenuti sospetti di copyright.