执行器模式设计和使用

1.定义：
@Autowired
private JedisPool jedisPool;

public static interface Execution {
public <T> T process(Jedis jedis);
}

/**
* 执行请求，开始前获取资源，结束后返回资源
*
* @param execution
* @return
*/
public <T> T execute(Execution execution) {
Jedis jedis = null;
try {
jedis = jedisPool.getResource();
T result = execution.process(jedis);
return result;
} catch (JedisConnectionException e) {
throw e;
} finally {
if (null != jedis) {
jedis.close();
}
}
}

2.使用：

@Autowired
private JedisExecutionService jedisExecutionService;

public void set(final String key, final Object value, final int seconds) {

if (null == key) {
throw new IllegalArgumentException("Cached key cannot be null.");
}
if (null == value) {
throw new IllegalArgumentException("Cached value cannot be null.");
}

jedisExecutionService.execute(new Execution() {

@Override
public Object process(Jedis jedis) {
byte[] byteArray = serialize(value);
jedis.set(key.getBytes(), byteArray);
if (seconds > 0) {
jedis.expire(key.getBytes(), seconds);
}
return null;
}

});
}

public void expire(final String key, final int seconds) {
if (null == key) {
throw new IllegalArgumentException("Cached key cannot be null.");
}

jedisExecutionService.execute(new Execution() {

@Override
public Object process(Jedis jedis) {
jedis.expire(key.getBytes(), seconds);
return null;
}

});
}

public Object get(final String key) {

if (null == key) {
throw new IllegalArgumentException("Cached key cannot be null.");
}

return jedisExecutionService.execute(new Execution() {

@Override
public Object process(Jedis jedis) {
byte[] bs = jedis.get(key.getBytes());
if (null == bs) {
return null;
} else {
return deserialize(bs);
}
}

});

}