Alawn/springside4
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

#221 加入对Jedis的封装

Browse Source
This commit is contained in:
Calvin
2013-07-10 15:39:48 +08:00
parent f43b92e6f4
commit b6036ccb0b
5 changed files with 27 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
examples/showcase/src/main/java/org/springside/examples/showcase/demos/redis/Utils.java → examples/showcase/src/main/java/org/springside/examples/showcase/demos/redis/JedisPoolFactory.java
+22 -20
View File
@@ -1,20 +1,22 @@
package org.springside.examples.showcase.demos.redis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class Utils {
public static JedisPool createJedisPool(String defaultHost, int defaultPort, int defaultTimeout, int threadCount) {
// merge default setting and system properties
String host = System.getProperty("benchmark.host", defaultHost);
String port = System.getProperty("benchmark.port", String.valueOf(defaultPort));
String timeout = System.getProperty("benchmark.timeout", String.valueOf(defaultTimeout));
// create jedis pool
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxActive(threadCount);
poolConfig.setMaxIdle(threadCount);
return new JedisPool(poolConfig, host, Integer.valueOf(port), Integer.valueOf(timeout));
}
}
package org.springside.examples.showcase.demos.redis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class JedisPoolFactory {
public static JedisPool createJedisPool(String defaultHost, int defaultPort, int defaultTimeout, int poolSize) {
// merge default setting and system properties
String host = System.getProperty("benchmark.host", defaultHost);
String port = System.getProperty("benchmark.port", String.valueOf(defaultPort));
String timeout = System.getProperty("benchmark.timeout", String.valueOf(defaultTimeout));
// 设置Pool
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxActive(poolSize);
poolConfig.setMaxIdle(poolSize);
// create jedis pool
return new JedisPool(poolConfig, host, Integer.valueOf(port), Integer.valueOf(timeout));
}
}
examples/showcase/src/main/java/org/springside/examples/showcase/demos/redis/RedisCounterBenchmark.java
+1 -1
View File
@@ -40,7 +40,7 @@ public class RedisCounterBenchmark extends ConcurrentBenchmark {
@Override
protected void setUp() {
pool = Utils.createJedisPool(DEFAULT_HOST, DEFAULT_PORT, DEFAULT_TIMEOUT, threadCount);
pool = JedisPoolFactory.createJedisPool(DEFAULT_HOST, DEFAULT_PORT, DEFAULT_TIMEOUT, threadCount);
jedisTemplate = new JedisTemplate(pool);
jedisTemplate.set(counterName, "0");
}
examples/showcase/src/main/java/org/springside/examples/showcase/demos/redis/RedisMassInsertionBenchmark.java
+1 -1
View File
@@ -46,7 +46,7 @@ public class RedisMassInsertionBenchmark extends ConcurrentBenchmark {
@Override
protected void setUp() {
// create jedis pool
pool = Utils.createJedisPool(DEFAULT_HOST, DEFAULT_PORT, DEFAULT_TIMEOUT, threadCount);
pool = JedisPoolFactory.createJedisPool(DEFAULT_HOST, DEFAULT_PORT, DEFAULT_TIMEOUT, threadCount);
jedisTemplate = new JedisTemplate(pool);
// remove all keys
examples/showcase/src/main/java/org/springside/examples/showcase/demos/redis/RedisSessionBenchmark.java
+1 -1
View File
@@ -45,7 +45,7 @@ public class RedisSessionBenchmark extends ConcurrentBenchmark {
@Override
protected void setUp() {
// create jedis pool
pool = Utils.createJedisPool(DEFAULT_HOST, DEFAULT_PORT, DEFAULT_TIMEOUT, threadCount);
pool = JedisPoolFactory.createJedisPool(DEFAULT_HOST, DEFAULT_PORT, DEFAULT_TIMEOUT, threadCount);
jedisTemplate = new JedisTemplate(pool);
// remove all keys
examples/showcase/src/main/java/org/springside/examples/showcase/demos/redis/job/JobProducer.java
+2 -2
View File
@@ -3,7 +3,7 @@ package org.springside.examples.showcase.demos.redis.job;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
import org.springside.examples.showcase.demos.redis.Utils;
import org.springside.examples.showcase.demos.redis.JedisPoolFactory;
import org.springside.modules.nosql.redis.scheduler.SchedulerManager;
import org.springside.modules.test.benchmark.BenchmarkTask;
import org.springside.modules.test.benchmark.ConcurrentBenchmark;
@@ -40,7 +40,7 @@ public class JobProducer extends ConcurrentBenchmark {
@Override
protected void setUp() {
// create jedis pool
pool = Utils.createJedisPool(JobManager.DEFAULT_HOST, JobManager.DEFAULT_PORT, JobManager.DEFAULT_TIMEOUT,
pool = JedisPoolFactory.createJedisPool(JobManager.DEFAULT_HOST, JobManager.DEFAULT_PORT, JobManager.DEFAULT_TIMEOUT,
threadCount);
scheduler = new SchedulerManager(pool, "ss");
}