Skip to content

Commit

Permalink
RedisService封装简化
Browse files Browse the repository at this point in the history
  • Loading branch information
javahongxi committed Dec 29, 2018
1 parent f337413 commit 3fb0e98
Show file tree
Hide file tree
Showing 12 changed files with 267 additions and 775 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,10 +32,10 @@ public void set(String key, String value) {
}
}

public void set(String key, String value, int activeTime) {
public void set(String key, String value, int seconds) {
ShardedJedis jedis = fetchJedis();
try {
jedis.setex(key, activeTime, value);
jedis.setex(key, seconds, value);
} finally {
release(jedis);
}
Expand Down

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -2,122 +2,63 @@

import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Set;

public interface RedisService<T> {
/**
* <pre>
*
* 通过key删除
* &#64;param keys
* &#64;return 被删除的记录数
* </pre>
*/
long delete(String... keys);

/**
* <pre>
*
* 通过keys删除
* &#64;param keys
* &#64;return 被删除的记录数
* </pre>
*/
long delete(Collection<String> keys);

/**
* <pre>
*
* &#64;param key
* &#64;param value
* &#64;param activeTime 秒
* &#64;return 添加key value 并且设置存活时间
* </pre>
*/
boolean set(byte[] key, byte[] value, long activeTime);

/**
* <pre>
*
* &#64;param key
* &#64;param value
* &#64;param activeTime 秒
* &#64;return 添加key value 并且设置存活时间
* </pre>
*/
boolean set(String key, String value, long activeTime);

/**
* <pre>
*
* &#64;param key
* &#64;param value
* &#64;return 添加key value
* </pre>
*/
boolean set(String key, String value);

/**
* <pre>
*
* &#64;param key
* &#64;param value
* &#64;return 添加key value
* </pre>
*/
boolean set(byte[] key, byte[] value);

boolean set(byte[] key, T value, long activeTime);

boolean set(String key, T value, long activeTime);

boolean set(String key, T value);

/**
* <pre>
*
* &#64;param key
* &#64;return 获得value
* </pre>
*/
String get(String key);

T getObject(String key, Class<T> c);

byte[] getBytes(String key);

/**
* <pre>
*
* &#64;param pattern
* &#64;return 通过正则匹配keys
* </pre>
*/
Set<String> matchKeys(String pattern);

/**
* <pre>
*
* &#64;param key
* &#64;return 检查key是否已经存在
* </pre>
*/
boolean exists(String key);

/**
* <pre>
*
* &#64;return 清空所有数据
* </pre>
*/
boolean flushDB();

/**
* <pre>
*
* &#64;param keys
* &#64;return 批量获取key的值
* </pre>
*/
List<T> multiGet(Collection keys);
/**
* Created by shenhongxi on 2018/12/24.
*/
public interface RedisService {

void set(String key, String value);

void set(String key, String value, long seconds);

void setIfAbsent(String key, String value);

String get(String key);

String getAndSet(String key, String value);

void multiSet(Map<String, String> map);

List<String> multiGet(Collection<String> keys);

Long increment(String key, long delta);

Double increment(String key, double delta);

Integer append(String key, String value);

String get(String key, long start, long end);

Long size(String key);

Boolean setBit(String key, long offset, boolean value);

Boolean getBit(String key, long offset);

long sadd(String key, String... values);

Set<String> smembers(String key);

void convertAndSend(String channel, Object obj);

void delete(String key);

boolean exists(String key);

Set<String> matchKeys(String pattern);

<T> void set(String key, T value, long seconds) throws Exception;

<T> void set(String key, T value) throws Exception;

<T> T get(String key, Class<T> clazz);

boolean set(byte[] key, byte[] value, long seconds);

boolean set(byte[] key, byte[] value);

byte[] getBytes(String key);
}

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit 3fb0e98

Please sign in to comment.