Klien mengadopsi jedis terbaru 2.7
1. Ketergantungan:
<dependency> <GroupId> redis.clients </groupid> <ArTifactId> jedis </artifactid> <version> 2.7.3 </version> </dependency>
2. Tambahkan Konfigurasi Musim Semi
<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 = "ALCHAELDCONFIG"> <value> classpath: connect-redis.properties </ value> </preate> <properti name = "addresskeyprefix" value = "address" /> <!-awalan kunci dalam file properti-> <nama properti = "timeout" value = "300000" /<Properti nama = "maxredirections" value = "6" value = "300000" /<properti name = "maxredirections" value = "" value "a name =" 300000 " Ref = "GenericObjectPoolConfig" /> < /bean>
3. Tambahkan file konfigurasi connect-redis.properties
6 node dikonfigurasi di sini
alamat1 =*:*address2 =*:*address3 =*:*address4 =*:*address5 =*:*address6 =*:*address6 =*:*
4. Tambahkan Kelas Java:
impor java.util.hashset; impor java.util.properties; impor java.util.set; import java.util.regex.pattern; impor org.apache.commons.pool2.impl.genericObjectpoolconfig; impor org.springframework.beans.facpory.facpory org.springframework.beans.factory.initializingBean; impor org.springframework.core.io.Resource; impor redis.clients.jedis.hostandport; impor redis.jedis.jediscluster; AddressKeyPrefix; jediscluster pribadi jediscluster; private integer timeout; private integer maxredirections; private genericObjectPoolConfig genericObjectPoolConfig; Private Pattern P = Pattern.Compile ("^.+[:] // D {1,5} // S*$");@@overlidePublic Public Public Public (1Sisclow {1,5} // S*$ ");@@overovidepublic Public Public {1,5} // s*$"); jediscluster;}@overridepublic class <? Extends JedisCluster> getObjectType () {return (this.jedisCluster! = null? this.jediscluster.getClass (): jediscluster.class);}@overridepublic boolean issingleton () {return true;} set pribadi set <hostandport> parsehostPort () {return true;} private set <hostandport> parsehostPort () {return {hostandport> parsehostport () {return {hostandport> parsehostport () {return {hostandport> parsehostport () {return {hostandport> parsehostport () {return {hostandport> Parsehostport () Properties (); prop.load (this.addressConfig.getInputStream ()); set <hostandport> hasps = hashset baru <hostandport> (); for (tombol objek: prop.keyset ()) {if (! ((String) key) .startswith (addresskeyprefix)) {ow; if (! (String). p.matcher(val).matches();if (!isIpPort) {throw new IllegalArgumentException("ip or port is illegal");}String[] ipAndPort = val.split(":");HostAndPort hap = new HostAndPort(ipAndPort[0], Integer.parseint(ipAndPort[1]));haps.add(hap);}return haps;} catch (IllegalArgumentException ex) {throw ex;} catch (Exception ex) {throw new Exception ("Parse Jedis File Konfigurasi Gagal", ex);}@overridepublic void afterpropertiesset () melempar pengecualian {set <hostandport> hasps = this.parsehosset () lemparan (hostandport> haspport = this.parsehapsEndusport () lemparan (hostandport> haspport = this. Timeout, MaxRedirections, GenericObjectPoolConfig);} public void setaddressConfig (sumber daya addressconfig) {this.addressConfig = addressConfig;} public void setTimeout (int tim) {this.timeout = timeout;} public void setMaxredirections (int intredirections (this.timeout = timeout;} public void setMaxredirections (Int MaxRedirections (this.timeout = {{} public void setMaxedirectionse (int intredirections; setAddressKeyPrefix (string addressKeyPrefix) {this.addressKeyprefix = addresskeyprefix;} public void setGenericObjectPoolConfig (genericObjectPoolConfig genericObjectpoolConfig) {this.genericjectPoolConfig = genericObcoLConfig; 5. Konfigurasi selesai pada saat ini
Saat digunakan, cukup suntikkannya secara langsung, seperti yang ditunjukkan di bawah ini:
@AutowiredJEdiscluster jediscluster;
Meringkaskan
Di atas adalah semua penjelasan terperinci tentang integrasi musim semi redis cluster, saya harap ini akan membantu semua orang. Jika ada kekurangan, silakan tinggalkan pesan untuk menunjukkannya. Terima kasih teman atas dukungan Anda untuk situs ini!