设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

JFinal RedisSentinelPlugin

2016-7-29 15:47| 发布者: zhangjf| 查看: 605| 评论: 0

摘要: 详情见博客http://my.oschina.net/aixiaohua/blog/710734 package com.jfinal.plugin.redis;import java.util.HashSet;import java.util.Set;import org.apache.commons.pool2 ...
详情见博客http://my.oschina.net/aixiaohua/blog/710734
  1. package com.jfinal.plugin.redis;
  3. import java.util.HashSet;
  4. import java.util.Set;
  6. import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
  8. import redis.clients.jedis.HostAndPort;
  9. import redis.clients.jedis.JedisSentinelPool;
  10. import redis.clients.jedis.Protocol;
  12. import com.jfinal.kit.StrKit;
  13. import com.jfinal.plugin.IPlugin;
  14. import com.jfinal.plugin.redis.serializer.FstSerializer;
  15. import com.jfinal.plugin.redis.serializer.ISerializer;
  17. public class RedisSentinelPlugin implements IPlugin {
  19. private String cacheName;
  21. private String masterName = null;
  22. private int connectionTimeout = Protocol.DEFAULT_TIMEOUT;
  23. //下一jedis版本预留字段
  24. //private int soTimeout = Protocol.DEFAULT_TIMEOUT;
  25. private String password = null;
  26. private int database = Protocol.DEFAULT_DATABASE;
  27. //下一jedis版本预留字段
  28. //private String clientName = null;
  29. private Set<String> sentinels = new HashSet<String>();
  31. private ISerializer serializer;
  32. private IKeyNamingPolicy keyNamingPolicy;
  33. private GenericObjectPoolConfig poolConfig;
  36. public RedisSentinelPlugin(String cacheName, String masterName,
  37. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig) {
  38. this(cacheName, masterName, sentinels, poolConfig,
  39. Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE);
  40. }
  42. public RedisSentinelPlugin(String cacheName, String masterName,
  43. Set<HostAndPort> sentinels) {
  44. this(cacheName, masterName, sentinels, new GenericObjectPoolConfig(),
  45. Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE);
  46. }
  48. public RedisSentinelPlugin(String cacheName, String masterName,
  49. Set<HostAndPort> sentinels, String password) {
  50. this(cacheName, masterName, sentinels, new GenericObjectPoolConfig(),
  51. Protocol.DEFAULT_TIMEOUT, password);
  52. }
  54. public RedisSentinelPlugin(String cacheName, String masterName,
  55. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  56. int timeout, final String password) {
  57. this(cacheName, masterName, sentinels, poolConfig, timeout, password,
  58. Protocol.DEFAULT_DATABASE);
  59. }
  61. public RedisSentinelPlugin(String cacheName, String masterName,
  62. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  63. final int timeout) {
  64. this(cacheName, masterName, sentinels, poolConfig, timeout, null,
  65. Protocol.DEFAULT_DATABASE);
  66. }
  68. public RedisSentinelPlugin(String cacheName, String masterName,
  69. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  70. final String password) {
  71. this(cacheName, masterName, sentinels, poolConfig,
  72. Protocol.DEFAULT_TIMEOUT, password);
  73. }
  75. public RedisSentinelPlugin(String cacheName, String masterName,
  76. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  77. int timeout, final String password, final int database) {
  78. this(cacheName, masterName, sentinels, poolConfig, timeout, timeout,
  79. password, database);
  80. }
  82. public RedisSentinelPlugin(String cacheName, String masterName,
  83. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  84. int timeout, final String password, final int database,
  85. final String clientName) {
  86. this(cacheName, masterName, sentinels, poolConfig, timeout, timeout,
  87. password, database, clientName);
  88. }
  90. public RedisSentinelPlugin(String cacheName, String masterName,
  91. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  92. final int timeout, final int soTimeout, final String password,
  93. final int database) {
  94. this(cacheName, masterName, sentinels, poolConfig, timeout, soTimeout,
  95. password, database, null);
  96. }
  98. public RedisSentinelPlugin(String cacheName, String masterName,
  99. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  100. final int connectionTimeout, final int soTimeout,
  101. final String password, final int database, final String clientName) {
  102. if (StrKit.isBlank(cacheName))
  103. throw new IllegalArgumentException("cacheName can not be blank.");
  104. if (StrKit.isBlank(masterName))
  105. throw new IllegalArgumentException("masterName can not be blank.");
  106. if (null == sentinels || sentinels.isEmpty())
  107. throw new IllegalArgumentException("sentinels can not be blank.");
  108. if (null == poolConfig)
  109. throw new IllegalArgumentException("poolConfig can not be null.");
  110. for(HostAndPort hp : sentinels)
  111. {
  112. this.sentinels.add(hp.toString());
  113. }
  114. this.cacheName = cacheName.trim();
  115. this.masterName = masterName.trim();
  116. this.poolConfig = poolConfig;
  117. this.connectionTimeout = connectionTimeout;
  118. //this.soTimeout = soTimeout;
  119. this.password = password;
  120. this.database = database;
  121. //this.clientName = clientName;
  123. }
  125. public boolean start() {
  126. JedisSentinelPool jedisSentinelPool =new JedisSentinelPool(masterName, sentinels,
  127. poolConfig, connectionTimeout, password, database);
  128. if (serializer == null)
  129. serializer = FstSerializer.me;
  130. if (keyNamingPolicy == null)
  131. keyNamingPolicy = IKeyNamingPolicy.defaultKeyNamingPolicy;
  133. Cache cache = new Cache(cacheName, jedisSentinelPool, serializer,
  134. keyNamingPolicy);
  135. Redis.addCache(cache);
  136. return true;
  137. }
  139. public boolean stop() {
  140. Cache cache = Redis.removeCache(cacheName);
  141. if (cache == Redis.mainCache)
  142. Redis.mainCache = null;
  143. cache.jedisPool.destroy();
  144. return true;
  145. }
  147. /**
  148. * 当RedisSentinelPlugin 提供的设置属性仍然无法满足需求时，通过此方法获取到 JedisPoolConfig 对象，可对 redis
  149. * 进行更加细致的配置
  150. *
  151. * <pre>
  152. * 例如：
  153. * redisSentinelPlugin.getJedisPoolConfig().setMaxTotal(100);
  154. * </pre>
  155. */
  156. public GenericObjectPoolConfig getGenericObjectPoolConfig() {
  157. return poolConfig;
  158. }
  160. // ---------
  162. public void setSerializer(ISerializer serializer) {
  163. this.serializer = serializer;
  164. }
  166. public void setKeyNamingPolicy(IKeyNamingPolicy keyNamingPolicy) {
  167. this.keyNamingPolicy = keyNamingPolicy;
  168. }
  170. // ---------
  172. public void setTestWhileIdle(boolean testWhileIdle) {
  173. poolConfig.setTestWhileIdle(testWhileIdle);
  174. }
  176. public void setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis) {
  177. poolConfig
  178. .setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  179. }
  181. public void setTimeBetweenEvictionRunsMillis(
  182. int timeBetweenEvictionRunsMillis) {
  183. poolConfig
  184. .setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  185. }
  187. public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) {
  188. poolConfig.setNumTestsPerEvictionRun(numTestsPerEvictionRun);
  189. }
  191. //提供懒初始化初始数据库,避免太多构造器
  192. public void setDatabase(int database) {
  193. this.database = database;
  194. }
  199. }
复制代码
  1. package com.jfinal.plugin.redis;
  3. import java.util.HashSet;
  4. import java.util.Set;
  6. import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
  8. import redis.clients.jedis.HostAndPort;
  9. import redis.clients.jedis.JedisSentinelPool;
  10. import redis.clients.jedis.Protocol;
  12. import com.jfinal.kit.StrKit;
  13. import com.jfinal.plugin.IPlugin;
  14. import com.jfinal.plugin.redis.serializer.FstSerializer;
  15. import com.jfinal.plugin.redis.serializer.ISerializer;
  17. public class RedisSentinelPlugin implements IPlugin {
  19. private String cacheName;
  21. private String masterName = null;
  22. private int connectionTimeout = Protocol.DEFAULT_TIMEOUT;
  23. //下一jedis版本预留字段
  24. //private int soTimeout = Protocol.DEFAULT_TIMEOUT;
  25. private String password = null;
  26. private int database = Protocol.DEFAULT_DATABASE;
  27. //下一jedis版本预留字段
  28. //private String clientName = null;
  29. private Set<String> sentinels = new HashSet<String>();
  31. private ISerializer serializer;
  32. private IKeyNamingPolicy keyNamingPolicy;
  33. private GenericObjectPoolConfig poolConfig;
  36. public RedisSentinelPlugin(String cacheName, String masterName,
  37. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig) {
  38. this(cacheName, masterName, sentinels, poolConfig,
  39. Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE);
  40. }
  42. public RedisSentinelPlugin(String cacheName, String masterName,
  43. Set<HostAndPort> sentinels) {
  44. this(cacheName, masterName, sentinels, new GenericObjectPoolConfig(),
  45. Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE);
  46. }
  48. public RedisSentinelPlugin(String cacheName, String masterName,
  49. Set<HostAndPort> sentinels, String password) {
  50. this(cacheName, masterName, sentinels, new GenericObjectPoolConfig(),
  51. Protocol.DEFAULT_TIMEOUT, password);
  52. }
  54. public RedisSentinelPlugin(String cacheName, String masterName,
  55. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  56. int timeout, final String password) {
  57. this(cacheName, masterName, sentinels, poolConfig, timeout, password,
  58. Protocol.DEFAULT_DATABASE);
  59. }
  61. public RedisSentinelPlugin(String cacheName, String masterName,
  62. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  63. final int timeout) {
  64. this(cacheName, masterName, sentinels, poolConfig, timeout, null,
  65. Protocol.DEFAULT_DATABASE);
  66. }
  68. public RedisSentinelPlugin(String cacheName, String masterName,
  69. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  70. final String password) {
  71. this(cacheName, masterName, sentinels, poolConfig,
  72. Protocol.DEFAULT_TIMEOUT, password);
  73. }
  75. public RedisSentinelPlugin(String cacheName, String masterName,
  76. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  77. int timeout, final String password, final int database) {
  78. this(cacheName, masterName, sentinels, poolConfig, timeout, timeout,
  79. password, database);
  80. }
  82. public RedisSentinelPlugin(String cacheName, String masterName,
  83. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  84. int timeout, final String password, final int database,
  85. final String clientName) {
  86. this(cacheName, masterName, sentinels, poolConfig, timeout, timeout,
  87. password, database, clientName);
  88. }
  90. public RedisSentinelPlugin(String cacheName, String masterName,
  91. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  92. final int timeout, final int soTimeout, final String password,
  93. final int database) {
  94. this(cacheName, masterName, sentinels, poolConfig, timeout, soTimeout,
  95. password, database, null);
  96. }
  98. public RedisSentinelPlugin(String cacheName, String masterName,
  99. Set<HostAndPort> sentinels, final GenericObjectPoolConfig poolConfig,
  100. final int connectionTimeout, final int soTimeout,
  101. final String password, final int database, final String clientName) {
  102. if (StrKit.isBlank(cacheName))
  103. throw new IllegalArgumentException("cacheName can not be blank.");
  104. if (StrKit.isBlank(masterName))
  105. throw new IllegalArgumentException("masterName can not be blank.");
  106. if (null == sentinels || sentinels.isEmpty())
  107. throw new IllegalArgumentException("sentinels can not be blank.");
  108. if (null == poolConfig)
  109. throw new IllegalArgumentException("poolConfig can not be null.");
  110. for(HostAndPort hp : sentinels)
  111. {
  112. this.sentinels.add(hp.toString());
  113. }
  114. this.cacheName = cacheName.trim();
  115. this.masterName = masterName.trim();
  116. this.poolConfig = poolConfig;
  117. this.connectionTimeout = connectionTimeout;
  118. //this.soTimeout = soTimeout;
  119. this.password = password;
  120. this.database = database;
  121. //this.clientName = clientName;
  123. }
  125. public boolean start() {
  126. JedisSentinelPool jedisSentinelPool =new JedisSentinelPool(masterName, sentinels,
  127. poolConfig, connectionTimeout, password, database);
  128. if (serializer == null)
  129. serializer = FstSerializer.me;
  130. if (keyNamingPolicy == null)
  131. keyNamingPolicy = IKeyNamingPolicy.defaultKeyNamingPolicy;
  133. Cache cache = new Cache(cacheName, jedisSentinelPool, serializer,
  134. keyNamingPolicy);
  135. Redis.addCache(cache);
  136. return true;
  137. }
  139. public boolean stop() {
  140. Cache cache = Redis.removeCache(cacheName);
  141. if (cache == Redis.mainCache)
  142. Redis.mainCache = null;
  143. cache.jedisPool.destroy();
  144. return true;
  145. }
  147. /**
  148. * 当RedisSentinelPlugin 提供的设置属性仍然无法满足需求时，通过此方法获取到 JedisPoolConfig 对象，可对 redis
  149. * 进行更加细致的配置
  150. *
  151. * <pre>
  152. * 例如：
  153. * redisSentinelPlugin.getJedisPoolConfig().setMaxTotal(100);
  154. * </pre>
  155. */
  156. public GenericObjectPoolConfig getGenericObjectPoolConfig() {
  157. return poolConfig;
  158. }
  160. // ---------
  162. public void setSerializer(ISerializer serializer) {
  163. this.serializer = serializer;
  164. }
  166. public void setKeyNamingPolicy(IKeyNamingPolicy keyNamingPolicy) {
  167. this.keyNamingPolicy = keyNamingPolicy;
  168. }
  170. // ---------
  172. public void setTestWhileIdle(boolean testWhileIdle) {
  173. poolConfig.setTestWhileIdle(testWhileIdle);
  174. }
  176. public void setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis) {
  177. poolConfig
  178. .setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  179. }
  181. public void setTimeBetweenEvictionRunsMillis(
  182. int timeBetweenEvictionRunsMillis) {
  183. poolConfig
  184. .setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  185. }
  187. public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) {
  188. poolConfig.setNumTestsPerEvictionRun(numTestsPerEvictionRun);
  189. }
  191. //提供懒初始化初始数据库,避免太多构造器
  192. public void setDatabase(int database) {
  193. this.database = database;
  194. }
  199. }
复制代码
收藏 邀请
上一篇：java多线程综合练习——生产者消费者模式下一篇：mysql 查询表死锁 和结束死锁的表方法和步骤

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-11-1 04:26

Copyright 2015-2025 djqfx

返回顶部