新增：redis 缓存（从 redkalex-plugin 迁移至此）
This commit is contained in:
parent
873d86fd60
commit
bf410c13f3
419
src/com/zdemo/cachex/MyRedisCacheSource.java
Normal file
419
src/com/zdemo/cachex/MyRedisCacheSource.java
Normal file
@ -0,0 +1,419 @@
|
||||
package com.zdemo.cachex;
|
||||
|
||||
|
||||
import org.redkale.convert.Convert;
|
||||
import org.redkale.service.Local;
|
||||
import org.redkale.source.CacheSource;
|
||||
import org.redkale.util.AutoLoad;
|
||||
import org.redkale.util.ResourceType;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.lang.reflect.Type;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.util.*;
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
@Local
|
||||
@AutoLoad(false)
|
||||
@ResourceType(CacheSource.class)
|
||||
public class MyRedisCacheSource<V extends Object> extends RedisCacheSource<V> {
|
||||
//--------------------- oth ------------------------------
|
||||
public boolean setnx(String key, Object v) {
|
||||
byte[][] bytes = Stream.of(key, v).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Serializable rs = send("SETNX", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
return rs == null ? false : (long) rs == 1;
|
||||
}
|
||||
//--------------------- oth ------------------------------
|
||||
|
||||
//--------------------- bit ------------------------------
|
||||
public boolean getBit(String key, int offset) {
|
||||
byte[][] bytes = Stream.of(key, offset).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Serializable v = send("GETBIT", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
return v == null ? false : (long) v == 1;
|
||||
}
|
||||
|
||||
public void setBit(String key, int offset, boolean bool) {
|
||||
byte[][] bytes = Stream.of(key, offset, bool ? 1 : 0).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
send("SETBIT", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
//--------------------- bit ------------------------------
|
||||
//--------------------- lock ------------------------------
|
||||
// 尝试加锁，成功返回0，否则返回上一锁剩余毫秒值
|
||||
public int tryLock(String key, int millis) {
|
||||
byte[][] bytes = Stream.of("" +
|
||||
"if (redis.call('exists',KEYS[1]) == 0) then " +
|
||||
"redis.call('psetex', KEYS[1], ARGV[1], 1) " +
|
||||
"return 0; " +
|
||||
"else " +
|
||||
"return redis.call('PTTL', KEYS[1]); " +
|
||||
"end; ", 1, key, millis).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
int n = (int) send("EVAL", CacheEntryType.OBJECT, (Type) null, null, bytes).join();
|
||||
return n;
|
||||
}
|
||||
|
||||
// 加锁
|
||||
public void lock(String key, int millis) {
|
||||
int i;
|
||||
do {
|
||||
i = tryLock(key, millis);
|
||||
try {
|
||||
Thread.sleep(10);
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
} while (i > 0);
|
||||
}
|
||||
|
||||
// 解锁
|
||||
public void unlock(String key) {
|
||||
remove(key);
|
||||
}
|
||||
|
||||
|
||||
//--------------------- key ------------------------------
|
||||
|
||||
public long getTtl(String key) {
|
||||
return (long) send("TTL", CacheEntryType.OBJECT, (Type) null, key, key.getBytes(StandardCharsets.UTF_8)).join();
|
||||
}
|
||||
|
||||
public long getPttl(String key) {
|
||||
return (long) send("PTTL", CacheEntryType.OBJECT, (Type) null, key, key.getBytes(StandardCharsets.UTF_8)).join();
|
||||
}
|
||||
|
||||
public int remove(String... keys) {
|
||||
if (keys == null || keys.length == 0) {
|
||||
return 0;
|
||||
}
|
||||
List<String> para = new ArrayList<>();
|
||||
para.add("" +
|
||||
" local args = ARGV;" +
|
||||
" local x = 0;" +
|
||||
" for i,v in ipairs(args) do" +
|
||||
" local inx = redis.call('del', v);" +
|
||||
" if(inx > 0) then" +
|
||||
" x = x + 1;" +
|
||||
" end" +
|
||||
" end" +
|
||||
" return x;");
|
||||
|
||||
para.add("0");
|
||||
for (Object field : keys) {
|
||||
para.add(String.valueOf(field));
|
||||
}
|
||||
byte[][] bytes = para.stream().map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
return (int) send("EVAL", CacheEntryType.OBJECT, (Type) null, null, bytes).join();
|
||||
}
|
||||
|
||||
//--------------------- hmget ------------------------------
|
||||
public <T extends Object> V getHm(String key, T field) {
|
||||
// return (V) send("HMGET", CacheEntryType.OBJECT, (Type) null, key, key.getBytes(StandardCharsets.UTF_8), field.getBytes(StandardCharsets.UTF_8)).join();
|
||||
Map<Object, V> map = getHms(key, field);
|
||||
return map.get(field);
|
||||
}
|
||||
|
||||
public <T extends Object> Map<T, V> getHms(String key, T... field) {
|
||||
if (field == null || field.length == 0) {
|
||||
return new HashMap<>();
|
||||
}
|
||||
byte[][] bytes = Stream.concat(Stream.of(key), Stream.of(field)).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Map<T, V> result = new HashMap<>();
|
||||
|
||||
List<V> vs = (List) send("HMGET", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
for (int i = 0; i < field.length; i++) { // /*vs != null && vs.size() > i &&*/
|
||||
if (vs.get(i) == null) {
|
||||
continue;
|
||||
}
|
||||
result.put(field[i], vs.get(i));
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
public Map<String, V> getHmall(String key) {
|
||||
List<V> vs = (List) send("HGETALL", CacheEntryType.OBJECT, (Type) null, key, key.getBytes(StandardCharsets.UTF_8)).join();
|
||||
Map<String, V> result = new HashMap<>(vs.size() / 2);
|
||||
for (int i = 0; i < vs.size(); i += 2) {
|
||||
result.put(String.valueOf(vs.get(i)), vs.get(i + 1));
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
//--------------------- hmset、hmdel、incr ------------------------------
|
||||
public <T> void setHm(String key, T field, V value) {
|
||||
byte[][] bytes = Stream.of(key, field, value).map(x -> x.toString().getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
send("HMSET", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
public <T> void setHms(String key, Map<T, V> kv) {
|
||||
List<String> args = new ArrayList();
|
||||
args.add(key);
|
||||
|
||||
kv.forEach((k, v) -> {
|
||||
args.add(String.valueOf(k));
|
||||
args.add(String.valueOf(v));
|
||||
});
|
||||
|
||||
byte[][] bytes = args.stream().map(x -> x.getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
send("HMSET", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
public <T> Long incrHm(String key, T field, long n) {
|
||||
byte[][] bytes = Stream.of(key, String.valueOf(field), String.valueOf(n)).map(x -> x.getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
return (Long) send("HINCRBY", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
public <T> Double incrHm(String key, T field, double n) {
|
||||
byte[][] bytes = Stream.of(key, String.valueOf(field), String.valueOf(n)).map(x -> x.getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Serializable v = send("HINCRBYFLOAT", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
if (v == null) {
|
||||
return null;
|
||||
}
|
||||
return Double.parseDouble(String.valueOf(v));
|
||||
}
|
||||
|
||||
public <T> void hdel(String key, T... field) {
|
||||
byte[][] bytes = Stream.concat(Stream.of(key), Stream.of(field)).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
send("HDEL", null, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
public <T> List<T> zexists(String key, T... fields) {
|
||||
if (fields == null || fields.length == 0) {
|
||||
return new ArrayList<>();
|
||||
}
|
||||
List<String> para = new ArrayList<>();
|
||||
para.add("" +
|
||||
" local key = KEYS[1];" +
|
||||
" local args = ARGV;" +
|
||||
" local result = {};" +
|
||||
" for i,v in ipairs(args) do" +
|
||||
" local inx = redis.call('ZREVRANK', key, v);" +
|
||||
" if(inx) then" +
|
||||
" table.insert(result,1,v);" +
|
||||
" end" +
|
||||
" end" +
|
||||
" return result;");
|
||||
para.add("1");
|
||||
para.add(key);
|
||||
for (Object field : fields) {
|
||||
para.add(String.valueOf(field));
|
||||
}
|
||||
byte[][] bytes = para.stream().map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
return (List<T>) send("EVAL", CacheEntryType.OBJECT, (Type) null, null, bytes).join();
|
||||
}
|
||||
|
||||
//--------------------- ------------------------------
|
||||
//--------------------- list ------------------------------
|
||||
public CompletableFuture<Void> appendListItemsAsync(String key, V... values) {
|
||||
byte[][] bytes = Stream.concat(Stream.of(key), Stream.of(values)).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
return (CompletableFuture) send("RPUSH", null, (Type) null, key, bytes);
|
||||
}
|
||||
|
||||
public CompletableFuture<Void> lpushListItemAsync(String key, V value) {
|
||||
return (CompletableFuture) send("LPUSH", null, (Type) null, key, key.getBytes(StandardCharsets.UTF_8), formatValue(CacheEntryType.OBJECT, (Convert) null, (Type) null, value));
|
||||
}
|
||||
|
||||
public void lpushListItem(String key, V value) {
|
||||
lpushListItemAsync(key, value).join();
|
||||
}
|
||||
|
||||
public void appendListItems(String key, V... values) {
|
||||
appendListItemsAsync(key, values).join();
|
||||
}
|
||||
|
||||
public void appendSetItems(String key, V... values) {
|
||||
// todo:
|
||||
for (V v : values) {
|
||||
appendSetItem(key, v);
|
||||
}
|
||||
}
|
||||
|
||||
// 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
|
||||
public CompletableFuture<Collection<V>> getCollectionAsync(String key, int offset, int limit) {
|
||||
return (CompletableFuture) send("OBJECT", null, (Type) null, key, "ENCODING".getBytes(StandardCharsets.UTF_8), key.getBytes(StandardCharsets.UTF_8)).thenCompose(t -> {
|
||||
if (t == null) return CompletableFuture.completedFuture(null);
|
||||
if (new String((byte[]) t).contains("list")) { //list
|
||||
return send("LRANGE", CacheEntryType.OBJECT, (Type) null, false, key, key.getBytes(StandardCharsets.UTF_8), String.valueOf(offset).getBytes(StandardCharsets.UTF_8), String.valueOf(offset + limit - 1).getBytes(StandardCharsets.UTF_8));
|
||||
} else {
|
||||
return send("SMEMBERS", CacheEntryType.OBJECT, (Type) null, true, key, key.getBytes(StandardCharsets.UTF_8));
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
public Collection<V> getCollection(String key, int offset, int limit) {
|
||||
return getCollectionAsync(key, offset, limit).join();
|
||||
}
|
||||
|
||||
public V brpop(String key, int seconds) {
|
||||
byte[][] bytes = Stream.concat(Stream.of(key), Stream.of(seconds)).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
return (V) send("BRPOP", null, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
//--------------------- zset ------------------------------
|
||||
public <N extends Number> void zadd(String key, Map<V, N> kv) {
|
||||
if (kv == null || kv.isEmpty()) {
|
||||
return;
|
||||
}
|
||||
List<String> args = new ArrayList();
|
||||
args.add(key);
|
||||
|
||||
kv.forEach((k, v) -> {
|
||||
args.add(String.valueOf(v));
|
||||
args.add(String.valueOf(k));
|
||||
});
|
||||
|
||||
byte[][] bytes = args.stream().map(x -> x.getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
send("ZADD", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
public <N extends Number> double zincr(String key, Object number, N n) {
|
||||
byte[][] bytes = Stream.of(key, n, number).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Serializable v = send("ZINCRBY", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
return Double.parseDouble(String.valueOf(v));
|
||||
}
|
||||
|
||||
public void zrem(String key, V... vs) {
|
||||
List<String> args = new ArrayList();
|
||||
args.add(key);
|
||||
for (V v : vs) {
|
||||
args.add(String.valueOf(v));
|
||||
}
|
||||
byte[][] bytes = args.stream().map(x -> x.getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
send("ZREM", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
}
|
||||
|
||||
public int getZrank(String key, V v) {
|
||||
byte[][] bytes = Stream.of(key, v).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Long t = (Long) send("ZRANK", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
|
||||
return t == null ? -1 : (int) (long) t;
|
||||
}
|
||||
|
||||
public int getZrevrank(String key, V v) {
|
||||
byte[][] bytes = Stream.of(key, v).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Long t = (Long) send("ZREVRANK", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
|
||||
return t == null ? -1 : (int) (long) t;
|
||||
}
|
||||
|
||||
//ZRANGE/ZREVRANGE key start stop
|
||||
public List<V> getZset(String key) {
|
||||
byte[][] bytes = Stream.of(key, 0, -1).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
List<V> vs = (List<V>) send("ZREVRANGE", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
List<V> vs2 = new ArrayList(vs.size());
|
||||
|
||||
for (int i = 0; i < vs.size(); ++i) {
|
||||
if (i % 2 == 1) {
|
||||
vs2.add(this.convert.convertFrom(this.objValueType, String.valueOf(vs.get(i))));
|
||||
} else {
|
||||
vs2.add(vs.get(i));
|
||||
}
|
||||
}
|
||||
|
||||
return vs2;
|
||||
}
|
||||
|
||||
public List<V> getZset(String key, int offset, int limit) {
|
||||
byte[][] bytes = Stream.of(key, offset, offset + limit - 1).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
List<V> vs = (List<V>) send("ZREVRANGE", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
List<V> vs2 = new ArrayList(vs.size());
|
||||
|
||||
for (int i = 0; i < vs.size(); ++i) {
|
||||
if (i % 2 == 1) {
|
||||
vs2.add(this.convert.convertFrom(this.objValueType, String.valueOf(vs.get(i))));
|
||||
} else {
|
||||
vs2.add(vs.get(i));
|
||||
}
|
||||
}
|
||||
|
||||
return vs2;
|
||||
}
|
||||
|
||||
public LinkedHashMap<V, Long> getZsetLongScore(String key) {
|
||||
LinkedHashMap<V, Double> map = getZsetDoubleScore(key);
|
||||
if (map.isEmpty()) {
|
||||
return new LinkedHashMap<>();
|
||||
}
|
||||
|
||||
LinkedHashMap<V, Long> map2 = new LinkedHashMap<>(map.size());
|
||||
map.forEach((k, v) -> map2.put(k, (long) (double) v));
|
||||
return map2;
|
||||
}
|
||||
|
||||
public LinkedHashMap<V, Long> getZsetItemsLongScore(String key) {
|
||||
byte[][] bytes = Stream.of(key, 0, -1, "WITHSCORES").map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
List vs = (List) send("ZRANGE", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
|
||||
LinkedHashMap<V, Long> map = new LinkedHashMap<>();
|
||||
for (int i = 0; i < vs.size(); i += 2) {
|
||||
map.put((V) vs.get(i), (long) Double.parseDouble((String) vs.get(i + 1)));
|
||||
}
|
||||
return map;
|
||||
}
|
||||
|
||||
public Long getZsetLongScore(String key, V v) {
|
||||
Double score = getZsetDoubleScore(key, v);
|
||||
if (score == null) {
|
||||
return null;
|
||||
}
|
||||
return (long) (double) score;
|
||||
}
|
||||
|
||||
public LinkedHashMap<V, Double> getZsetDoubleScore(String key) {
|
||||
byte[][] bytes = Stream.of(key, 0, -1, "WITHSCORES").map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
List vs = (List) send("ZREVRANGE", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
|
||||
LinkedHashMap<V, Double> map = new LinkedHashMap<>();
|
||||
for (int i = 0; i < vs.size(); i += 2) {
|
||||
map.put((V) vs.get(i), Double.parseDouble((String) vs.get(i + 1)));
|
||||
}
|
||||
return map;
|
||||
}
|
||||
|
||||
public Double getZsetDoubleScore(String key, V v) {
|
||||
byte[][] bytes = Stream.of(key, v).map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
Serializable zscore = send("ZSCORE", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
if (zscore == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return Double.parseDouble(String.valueOf(zscore));
|
||||
}
|
||||
|
||||
public LinkedHashMap<V, Long> getZsetLongScore(String key, int offset, int limit) {
|
||||
byte[][] bytes = Stream.of(key, offset, offset + limit - 1, "WITHSCORES").map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
List vs = (List) send("ZREVRANGE", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
|
||||
LinkedHashMap<V, Long> map = new LinkedHashMap<>();
|
||||
for (int i = 0; i < vs.size(); i += 2) {
|
||||
map.put((V) vs.get(i), (long) Double.parseDouble((String) vs.get(i + 1)));
|
||||
}
|
||||
return map;
|
||||
}
|
||||
|
||||
public LinkedHashMap<V, Double> getZsetDoubleScore(String key, int offset, int limit) {
|
||||
byte[][] bytes = Stream.of(key, offset, offset + limit - 1, "WITHSCORES").map(x -> String.valueOf(x).getBytes(StandardCharsets.UTF_8)).toArray(byte[][]::new);
|
||||
List vs = (List) send("ZREVRANGE", CacheEntryType.OBJECT, (Type) null, key, bytes).join();
|
||||
|
||||
LinkedHashMap<V, Double> map = new LinkedHashMap<>();
|
||||
for (int i = 0; i < vs.size(); i += 2) {
|
||||
map.put((V) vs.get(i), Double.parseDouble(vs.get(i + 1) + ""));
|
||||
}
|
||||
return map;
|
||||
}
|
||||
|
||||
// ----------
|
||||
protected byte[] formatValue(CacheEntryType cacheType, Convert convert0, Type resultType, Object value) {
|
||||
if (value == null) return "null".getBytes(StandardCharsets.UTF_8);
|
||||
if (convert0 == null) convert0 = convert;
|
||||
if (cacheType == CacheEntryType.LONG || cacheType == CacheEntryType.ATOMIC)
|
||||
return String.valueOf(value).getBytes(StandardCharsets.UTF_8);
|
||||
if (cacheType == CacheEntryType.STRING) return convert0.convertToBytes(String.class, value);
|
||||
|
||||
if (value instanceof String) return String.valueOf(value).getBytes(StandardCharsets.UTF_8);
|
||||
if (value instanceof Number) return String.valueOf(value).getBytes(StandardCharsets.UTF_8);
|
||||
return convert0.convertToBytes(resultType == null ? objValueType : resultType, value);
|
||||
}
|
||||
}
|
||||
2240
src/com/zdemo/cachex/RedisCacheSource.java
Normal file
2240
src/com/zdemo/cachex/RedisCacheSource.java
Normal file
File diff suppressed because it is too large
Load Diff
237
src/com/zdemo/cachex/RedisTest.java
Normal file
237
src/com/zdemo/cachex/RedisTest.java
Normal file
@ -0,0 +1,237 @@
|
||||
package com.zdemo.cachex;
|
||||
|
||||
import org.redkale.convert.json.JsonFactory;
|
||||
import org.redkale.util.AnyValue;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
public class RedisTest {
|
||||
|
||||
static MyRedisCacheSource<String> source = new MyRedisCacheSource();
|
||||
|
||||
static {
|
||||
AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue();
|
||||
conf.addValue("node", new AnyValue.DefaultAnyValue().addValue("addr", "47.111.150.118").addValue("port", "6064").addValue("password", "*Zhong9307!").addValue("db", 2));
|
||||
|
||||
source.defaultConvert = JsonFactory.root().getConvert();
|
||||
source.initValueType(String.class); //value用String类型
|
||||
source.init(conf);
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
|
||||
//System.out.println(source.remove("a", "b"));
|
||||
|
||||
// bit
|
||||
/*source.initValueType(Integer.class);
|
||||
source.remove("a");
|
||||
boolean a = source.getBit("a", 1);
|
||||
System.out.println(a);
|
||||
|
||||
source.setBit("a", 1, true);
|
||||
a = source.getBit("a", 1);
|
||||
System.out.println("bit-a-1: " + a);
|
||||
|
||||
source.setBit("a", 1, false);
|
||||
a = source.getBit("a", 1);
|
||||
System.out.println("bit-a-1: " + a);*/
|
||||
|
||||
source.remove("a");
|
||||
|
||||
// setnx
|
||||
System.out.println(source.setnx("a", 1));
|
||||
source.remove("a");
|
||||
System.out.println(source.setnx("a", 1));
|
||||
|
||||
/*int[] arr = {0};
|
||||
ExecutorService executor = Executors.newFixedThreadPool(10);
|
||||
CountDownLatch latch = new CountDownLatch(10_0000);
|
||||
for (int i = 0; i < 10_0000; i++) {
|
||||
executor.submit(() -> {
|
||||
try {
|
||||
source.lock("a", 50000);
|
||||
arr[0]++;
|
||||
System.out.println("Thread: " + Thread.currentThread().getName());
|
||||
Thread.sleep(2000);
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
} finally {
|
||||
source.unlock("a");
|
||||
latch.countDown();
|
||||
}
|
||||
});
|
||||
}
|
||||
try {
|
||||
latch.await();
|
||||
System.out.println("n=" + arr[0]);
|
||||
executor.shutdown();
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}*/
|
||||
|
||||
|
||||
/*List<String> list = (List) source.getCollection("gamerank-comment-stat");
|
||||
System.out.println(list);*/
|
||||
|
||||
/*for (int i = 0; i < 10; i++) {
|
||||
String brpop = source.brpop("z", 2);
|
||||
System.out.println(brpop);
|
||||
}*/
|
||||
|
||||
// key 测试
|
||||
/*source.set("a", "123321");
|
||||
System.out.println(source.get("a")); // 123321
|
||||
System.out.println(source.getTtl("a")); // -1
|
||||
System.out.println(source.getPttl("a")); // -1
|
||||
System.out.println(source.getPttl("x")); // -2*/
|
||||
|
||||
// hashmap 测试
|
||||
/*source.remove("sk");
|
||||
source.setHm("sk", "a", "1");
|
||||
source.setHm("sk", "b", "2");
|
||||
System.out.println(source.getHm("sk", "a")); // 1
|
||||
source.remove("sk");
|
||||
|
||||
source.setHms("sk", Map.of("b", "5", "c", "3", "a", "1"));
|
||||
source.hdel("sk", "a");
|
||||
|
||||
Map map = source.getHms("sk", "a", "x", "b", "c", "f"); // {b=5, c=3}
|
||||
System.out.println(map);
|
||||
System.out.println(source.getHmall("sk")); //{b=5, c=3}
|
||||
System.out.println(source.incrHm("sk", "b", 1.1d)); // b = 6.1
|
||||
System.out.println(source.incrHm("sk", "c", 1)); // c = 4
|
||||
System.out.println(source.getHmall("sk")); //{b=6.1, c=4}
|
||||
|
||||
System.out.println("--------------");
|
||||
System.out.println(source.hexists("sk", "b")); // true
|
||||
System.out.println(source.getCollectionSize("sk")); // 2*/
|
||||
|
||||
|
||||
Map<String, String> hms = source.getHms("supportusers", "5-kfeu0f", "xxxx", "3-0kbt7u8t", "95q- ");
|
||||
hms.forEach((k, v) -> {
|
||||
System.out.println(k + " : " + v);
|
||||
});
|
||||
|
||||
|
||||
/*MyRedisCacheSource<String> source2 = new MyRedisCacheSource();
|
||||
source2.defaultConvert = JsonFactory.root().getConvert();
|
||||
source2.initValueType(String.class); //value用String类型
|
||||
source2.init(conf);*/
|
||||
|
||||
/*Map<String, String> gcMap = source.getHmall("hot-gamecomment");
|
||||
gcMap.forEach((k,v) -> {
|
||||
System.out.println(k + " : " + v);
|
||||
});*/
|
||||
|
||||
|
||||
//Map<String, String> gameinfo = source.getHms("gameinfo", "22759", "22838", "10097", "22751", "22632", "22711", "22195", "15821", "10099", "16313", "11345", "10534", "22768", "22647", "22924", "18461", "15871", "17099", "22640", "22644", "10744", "10264", "18032", "22815", "13584", "10031", "22818", "22452", "22810", "10513", "10557", "15848", "11923", "15920", "22808", "20073", "22809", "15840", "12332", "15803", "10597", "22624", "17113", "19578", "22664", "22621", "20722", "16226", "10523", "12304", "10597","11923","10031");
|
||||
//Map<String, String> gameinfo = source.getHms("gameinfo", "22759","22838","10097","22751","22632","22711","22195","15821","10099","16313","11345","10534","22768","22647","22924","18461","15871","17099","22363","22640","22644","10744","10264","18032","22815","13584","22818","22452","22810","10513","10557","15848","15920","22808","20073","22809","15840","12332","15803","10597","22624","17113","19578","22627","22664","22621","20722","16226","10523","12304");
|
||||
|
||||
/*gameinfo.forEach((k,v ) -> {
|
||||
System.out.println(v);
|
||||
});*/
|
||||
|
||||
|
||||
/*source.queryKeysStartsWith("articlebean:").forEach(x -> {
|
||||
System.out.println(x);
|
||||
//source.remove(x);
|
||||
//System.out.println(source.getHmall(x));
|
||||
});*/
|
||||
|
||||
// list 测试
|
||||
/*MyRedisCacheSource<Integer> sourceInt = new MyRedisCacheSource();
|
||||
sourceInt.defaultConvert = JsonFactory.root().getConvert();
|
||||
sourceInt.initValueType(Integer.class); //value用String类型
|
||||
sourceInt.init(conf);
|
||||
sourceInt.remove("list");
|
||||
Collection<Integer> list = sourceInt.getCollection("list");
|
||||
System.out.println(list);
|
||||
for (int i = 1; i <= 10; i++) {
|
||||
sourceInt.appendListItem("list", i);
|
||||
}
|
||||
System.out.println(sourceInt.getCollection("list")); // [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
|
||||
|
||||
sourceInt.appendListItems("list", 11, 12, 13);
|
||||
System.out.println(sourceInt.getCollection("list")); // [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13]
|
||||
System.out.println(sourceInt.getCollection("list", 0, 5)); // [1, 2, 3, 4, 5]
|
||||
System.out.println(sourceInt.getCollectionSize("list")); // 13
|
||||
|
||||
List<Integer> ids = new ArrayList<>(100);
|
||||
for (int i = 0; i < 5000; i++) {
|
||||
ids.add(i);
|
||||
}
|
||||
sourceInt.remove("abx");
|
||||
sourceInt.appendListItems("abx", ids.toArray(Integer[]::new));
|
||||
System.out.println(sourceInt.getCollection("abx"));*/
|
||||
|
||||
/*System.out.println(sourceInt.getCollectionSize("recommend-user-quality"));
|
||||
Collection<Integer> uid = sourceInt.getCollection("recommend-user-quality");
|
||||
System.out.println(uid);*/
|
||||
|
||||
// zset 测试
|
||||
/*source.initValueType(String.class); //value用Integer类型
|
||||
source.remove("zx");
|
||||
source.zadd("zx", Map.of("a", 1, "b", 2));
|
||||
|
||||
source.zadd("zx", Map.of("a", 1, "c", 5L));
|
||||
source.zadd("zx", Map.of("x", 20, "j", 3.5));
|
||||
source.zadd("zx", Map.of("f", System.currentTimeMillis(), "c", 5L));
|
||||
source.zadd("zx", Map.of("a", 1, "c", 5L));
|
||||
|
||||
System.out.println(source.zincr("zx", "a", 1.34)); // 2.34
|
||||
System.out.println(source.getZsetDoubleScore("zx")); // {f=1592924555704, x=20, c=5, j=3, b=2.34, a=1}
|
||||
source.zrem("zx", "b", "c", "e", "x");
|
||||
System.out.println(source.getZsetLongScore("zx")); // {f=1592924555704, j=3, a=2}
|
||||
|
||||
System.out.println("--------------");
|
||||
System.out.println(source.getZsetLongScore("zx", "f"));
|
||||
|
||||
System.out.println(source.getZrevrank("zx", "f")); // 0
|
||||
System.out.println(source.getZrank("zx", "f")); // 2
|
||||
System.out.println(source.getZrank("zx", "Y")); // -1
|
||||
System.out.println(source.getCollectionSize("zx")); // 3
|
||||
|
||||
System.out.println(source.getZset("zx"));
|
||||
System.out.println(source.zexists("zx", "f", "x", "a"));*/
|
||||
|
||||
/*LocalDate date = LocalDate.of(2019, 12, 31);
|
||||
for (int i = 0; i < 60; i++) {
|
||||
LocalDate localDate = date.plusDays(-i);
|
||||
String day = localDate.format(DateTimeFormatter.ISO_LOCAL_DATE);
|
||||
System.out.println(String.format("mkdir %s; mv *%s*.zip %s", day, day, day));
|
||||
}*/
|
||||
|
||||
|
||||
/*MyRedisCacheSource<UserDetail> source = new MyRedisCacheSource();
|
||||
source.defaultConvert = JsonFactory.root().getConvert();
|
||||
source.initValueType(UserDetail.class);
|
||||
source.init(conf);
|
||||
|
||||
|
||||
Map<String, UserDetail> map = source.getHmall("user-detail");
|
||||
|
||||
Integer[] array = map.values().stream().map(x -> x.getUserid()).toArray(Integer[]::new);
|
||||
|
||||
System.out.println(JsonConvert.root().convertTo(array));
|
||||
|
||||
Map<Integer, UserDetail> hms = source.getHms("user-detail", 11746, 11988, 11504, 11987, 11745, 11503, 11748, 11506, 11747, 11989, 11505, 11508, 11507, 11509, 11980, 11740, 11982, 11981, 11984, 11742, 11500, 11983, 11741, 11502, 11744, 11986, 11985, 11501, 11743, 11999, 11757, 11515, 1, 11514, 11998, 11756, 2, 11517, 11516, 11758, 3, 11519, 4, 5, 11518, 6, 7, 11991, 8, 11990, 9, 11993, 11751, 11750, 11992, 11753, 11511, 11995, 11994, 11510, 11752, 11755, 11513, 11997, 11512, 11996, 11754, 11724, 11966, 11965, 11723, 11968, 11726, 11967, 11725, 11728, 11969, 11727, 11729, 11960, 11720, 11962, 11961, 11722, 11964, 11721);
|
||||
|
||||
System.out.println(hms.size());*/
|
||||
|
||||
/*source.getCollection("article-comment-list", 19, 1).forEach(x -> System.out.println(x));
|
||||
|
||||
|
||||
while (true) {
|
||||
System.out.println("---" + Utility.now() + "---");
|
||||
source.getHmall("ck").forEach((k, v) -> {
|
||||
System.out.println(k + ":" + v);
|
||||
});
|
||||
try {
|
||||
Thread.sleep(60 * 1000);
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}*/
|
||||
}
|
||||
}
|
||||
1944
src/com/zdemo/cachex/RedissionCacheSource.java
Normal file
1944
src/com/zdemo/cachex/RedissionCacheSource.java
Normal file
File diff suppressed because it is too large
Load Diff
Loading…
Reference in New Issue
Block a user