O cliente adota os mais recentes Jedis 2.7
1. Dependências MAVEN:
<Depencency> <PuerpId> redis.clients </frupid> <stifactId> jedis </storkactid> <versão> 2.7.3 </sipers> </dependency>
2. Adicione a configuração da mola
<bean name = "genericobjectpoolconfig"> <propriedade name = "maxwaitmillis" value = "-1" /> <propriedade name = "maxtotal" value = "1000" /> <propriedade name = "minidle" value = "8" /> <nome da propriedade = "maxidle" = "100 /> < /bean> < /bean =" 8 " /> <nome da propriedade =" maxidle "=" 100 100 "< /bean> name = "endereçoconfig"> <Value> ClassPath: Connect-Redis.properties < /value> < /Property> <propriedade name = "endereçoKeyPrefix" value = "endereço" /> <!-prefixo da chave no arquivo da propriedade-> <names name = "timeout" = "300000" /> <nome do nome = "maxredirections" REF = "GenericoBjectPoolConfig" /> </Sean>
3. Adicione o arquivo de configuração Connect-Redis.Properties
6 nós estão configurados aqui
endereço1 =*:*endereço2 =*:*endereço3 =*:*endereço4 =*:*endereço5 =*:*endereço6 =*:*endereço6 =*:*
4. Adicione a classe java:
importar java.util.hashset; importar java.util.properties; importar java.util.set; importar java.util.regex.pattern; importar org.apache.commons.pool2.impl.genericoBjectPoolCoolFig; importação org.sPeringFramewanS.Factory.Factory.Factory.Factory.Factory.Factory; org.springframework.beans.factory.initializandoBean; importar org.springframework.core.io.resource; importar redis.clients.jedis.hostandport; importectern {deplusterBestorMCluster; Endereço KeyPrefix; private Jediscluster Jediscluster; Timeout de Inteiro Privado; MaxRredirections privado inteiro; JEDISCLUSTER;}@SubsteridePublic Class <? estende JEDIScluster> getObjectType () {return (this.jediscluster! = null? this.jediscluster.getclass (): jediscluster.class);}@substituição de toups (experidepublic = trows Issingleton () {return;}}}} private conjunto <iferendport> parseHorTport () Propriedades (); Prop.Load (this.addressConfig.getInputStream ()); set <dostAndport> hasps = new HashSet <dostandport> (); para (chave do objeto: prop.keyset ()) {if (! p.matcher (val) .matches (); if (! isipport) {lança novo ilegalargumentException ("ip ou porta é ilegal");} string [] ipandport = val.split (":"); hostAndport hap = new HostAndport (ipandport [0], hAVGER.PAREINT (IPandport [1]); (IlegalargumentException ex) {tiro ex maxRredirections, genicobjectpoolconfig);} public void setAddressConfig (recurso endereçoConfig) {this.addressConfig = endereçoConfig;} public void setTimeout (int timeout) {thistimeout = timeout;} public Void setMirioSAx (int maxredirections) {timeout; setAddressKeyPrefix (String endereçoKeyPix) {this.AddressKeyPrefix = addresskeyPrefix;} public void SetGenericObjectPoolConfig (GenericObjectPoolConfig GENICOBJETPOOLCOLCONFIG) {this.GenerericToBjectPoolConfig = GenericoBjectPoolConfig; 5. A configuração é concluída neste momento
Quando em uso, basta injetar -o diretamente, como mostrado abaixo:
@AUTOWIEDJEDISCLUSTER JEDISCLUSTER;
Resumir
O exposto acima é toda a explicação detalhada do cluster Redis Integration Redis, espero que seja útil para todos. Se houver alguma falha, deixe uma mensagem para apontá -la. Obrigado amigos pelo seu apoio para este site!