Redisson连接redis单机和哨兵模式

  • A+
所属分类：redis

从图中可以看出redisson对于不同的redis模式给出了不同的配置类

  • MasterSlaveServersConfig

  • SentinelServersConfig

  • SingleServerConfig

具体配置

  • application.properties


  1. # redisson-single

  2. # redisson.address=redis://101.241.71.70:9090

  3. # redisson.password=123456



  6. # redisson-sentinel

  7. redisson.masterName=mymaster

  8. redisson.schema=redis://

  9. redisson.sentinelAddresses=101.241.71.70:26377,101.241.71.70:26378,101.241.71.70:26379

  10. redisson.password=123456

  • pom.xml


  1. <dependency>

  2. <groupId>org.redisson</groupId>

  3. <artifactId>redisson</artifactId>

  4. <!--<version>3.11.4</version>-->

  5. <version>3.13.4</version>

  6. </dependency>

RedissionConfiguration.class
 


  1. import org.apache.commons.lang3.StringUtils;

  2. import org.redisson.Redisson;

  3. import org.redisson.api.RedissonClient;

  4. import org.redisson.config.Config;

  5. import org.redisson.config.SentinelServersConfig;

  6. import org.springframework.boot.context.properties.ConfigurationProperties;

  7. import org.springframework.context.annotation.Bean;

  8. import org.springframework.context.annotation.Configuration;



  11. @Configuration

  12. @ConfigurationProperties(prefix = "redisson")

  13. public class RedissionConfiguration {

  14. private int timeout = 3000;

  15. private String schema = "redis://";

  16. private String address;

  17. private String password;

  18. private int connectionPoolSize = 64;

  19. private int connectionMinimumIdleSize = 10;

  20. private int slaveConnectionPoolSize = 250;

  21. private int masterConnectionPoolSize = 250;

  22. private String[] sentinelAddresses;

  23. private String masterName;


  25. public int getTimeout() {

  26. return timeout;

  27. }


  29. public void setTimeout(int timeout) {

  30. this.timeout = timeout;

  31. }


  33. public String getSchema() {

  34. return schema;

  35. }


  37. public void setSchema(String schema) {

  38. this.schema = schema;

  39. }


  41. public String getAddress() {

  42. return address;

  43. }


  45. public void setAddress(String address) {

  46. this.address = address;

  47. }


  49. public String getPassword() {

  50. return password;

  51. }


  53. public void setPassword(String password) {

  54. this.password = password;

  55. }


  57. public int getConnectionPoolSize() {

  58. return connectionPoolSize;

  59. }


  61. public void setConnectionPoolSize(int connectionPoolSize) {

  62. this.connectionPoolSize = connectionPoolSize;

  63. }


  65. public int getConnectionMinimumIdleSize() {

  66. return connectionMinimumIdleSize;

  67. }


  69. public void setConnectionMinimumIdleSize(int connectionMinimumIdleSize) {

  70. this.connectionMinimumIdleSize = connectionMinimumIdleSize;

  71. }


  73. public int getSlaveConnectionPoolSize() {

  74. return slaveConnectionPoolSize;

  75. }


  77. public void setSlaveConnectionPoolSize(int slaveConnectionPoolSize) {

  78. this.slaveConnectionPoolSize = slaveConnectionPoolSize;

  79. }


  81. public int getMasterConnectionPoolSize() {

  82. return masterConnectionPoolSize;

  83. }


  85. public void setMasterConnectionPoolSize(int masterConnectionPoolSize) {

  86. this.masterConnectionPoolSize = masterConnectionPoolSize;

  87. }


  89. public String[] getSentinelAddresses() {

  90. return sentinelAddresses;

  91. }


  93. public void setSentinelAddresses(String[] sentinelAddresses) {

  94. this.sentinelAddresses = sentinelAddresses;

  95. }


  97. public String getMasterName() {

  98. return masterName;

  99. }


  101. public void setMasterName(String masterName) {

  102. this.masterName = masterName;

  103. }




  107. /*测试时mock使用*/

  108. /*@Bean

  109.     RedissonClient redissonSingle() {

  110.         RedissonClient redissonClient = Mockito.mock(RedissonClient.class);

  111.         return redissonClient;

  112.     }*/


  114. /**

  115.      * 单机模式

  116.      */

  117. /*@Bean

  118.     RedissonClient redissonSingle() {

  119.         Config config = new Config();

  120.         SingleServerConfig serverConfig = config.useSingleServer()

  121.                 .setAddress(address)

  122.                 .setTimeout(timeout)

  123.                 .setConnectionPoolSize(connectionPoolSize)

  124.                 .setConnectionMinimumIdleSize(getConnectionMinimumIdleSize());

  125.         if (StringUtils.isNotBlank(password)) {

  126.             serverConfig.setPassword(password);

  127.         }

  128.         return Redisson.create(config);

  129.     }*/


  131. /**

  132.      * 哨兵模式

  133.      * @return

  134.      */

  135. @Bean

  136. RedissonClient redissonSentinel() {

  137. Config config = new Config();


  139. // 拼接协议

  140. String[] sentinelAddressesWithSchema = new String[sentinelAddresses.length];

  141. for (int i = 0; i < sentinelAddresses.length; i++) {

  142. sentinelAddressesWithSchema[i] = schema + sentinelAddresses[i];

  143. }


  145. SentinelServersConfig serversConfig = config.useSentinelServers()

  146. .setMasterName(masterName)

  147. .addSentinelAddress(sentinelAddressesWithSchema)

  148. .setMasterConnectionPoolSize(masterConnectionPoolSize)

  149. .setSlaveConnectionPoolSize(slaveConnectionPoolSize)

  150. .setMasterConnectionMinimumIdleSize(getConnectionMinimumIdleSize())

  151. .setSlaveConnectionMinimumIdleSize(getConnectionMinimumIdleSize());


  153. if (StringUtils.isNotBlank(password)) {

  154. serversConfig.setPassword(password);

  155. }

  156. return Redisson.create(config);

  157. }

  158. }

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: