Der Kunde übernimmt den neuesten Jedis 2.7
1.Maven -Abhängigkeiten:
<De vorangestellt> <gruppe> redis.clients </Groupid> <artifactId> jedis </artifactId> <version> 2.7.3 </Version> </abhängig>
2. Federkonfiguration hinzufügen
<bean name="genericObjectPoolConfig" ><property name="maxWaitMillis" value="-1" /><property name="maxTotal" value="1000" /><property name="minIdle" value="8" /><property name="maxIdle" value="100" /></bean><bean id="jedisCluster"><property name = "adressConfig"> <wert> classPath: connect-redis.properties < /value> < /property> <Eigenschaft name = "adresskeyprefix" value = "address" /> <!-Vorfix der Schlüssel in der Eigenschaftsdatei-> <Eigenschaft name = "timeout" value = "300000" /> < ref = "genericObjectPoolConfig" /> < /bean>
3. Fügen Sie die Konfigurationsdatei Connect-Redis.Properties hinzu
6 Knoten sind hier konfiguriert
address1 =*:*address2 =*:*address3 =*:*address4 =*:*address5 =*:*address6 =*:*address6 =*:*
4. Fügen Sie Java -Klasse hinzu:
Import Java.util.hashset; Import Java.util.Properties; Import Java.util.set; Import Java.util.Regex.pattern; org.springframework.beans.factory.initializingBean; import org.springframework.core.io.resource; importieren.clients.jedis.hostandport; addreskeyprefix; private jediscluster jediscluster; jediscluster;}@oversidepublic class <? erweitert jediscluster> getObjecttype () {return (this.jedIscluster! Properties (); prop.load (this.addressConfig.getInputStream ()); set <StandPort> HaSps = new Hashset <StandArtPort> (); für (Objektschlüssel: prop.Keyset ()) {if (! (String). P.Matcher (Val) .Matches (); if (! issipport) {neue illegalArgumentException ("IP oder Port ist illegal");} String [] ipandport = val.Split (":"); (IllegalArgumentException ex) {throw ex;} catch (Ausnahme ex) {neue Ausnahme werfen ("Parse jedis -Konfigurationsdatei fehlgeschlagen", ex);}}@oversidepublic void AfterPertiesset () Ausnahme {set <HostandPort> HaSps = this.parsehostport (); maxRedirections,genericObjectPoolConfig);}public void setAddressConfig(Resource addressConfig) {this.addressConfig = addressConfig;}public void setTimeout(int timeout) {this.timeout = timeout;}public void setMaxRedirections(int maxRedirections) {this.maxRedirections = maxRedirections;}public void setAddressKeyprefix (String addressKeyprefix) {this.addressKeyprefix = addresskeyprefix;} public void setgenericoxconfig (genericObjectpoolconfig GenericObjectPoolConfig) {this.genericObjectconfig = GenericObjectConfig;}}}}}}}}}}} 5. Die Konfiguration ist an diesem Punkt abgeschlossen
Geben Sie es beim Gebrauch einfach direkt ein, wie unten gezeigt:
@Autowiredjediscluster Jediscluster;
Zusammenfassen
Das obige ist die detaillierte Erklärung des Frühlingsintegrations -Redis -Clusters. Ich hoffe, es wird für alle hilfreich sein. Wenn es Mängel gibt, hinterlassen Sie bitte eine Nachricht, um darauf hinzuweisen. Vielen Dank an Freunde für Ihre Unterstützung für diese Seite!