记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 9c02b7cf authored by anjiabin's avatar anjiabin
Browse files
Options

提交chime社交相关-屏蔽redis调用

parent 9d6621fb
Hide whitespace changes
Inline Side-by-side
Showing with 100 additions and 44 deletions
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/test/java/com.liquidnet.client.admin/TestRedisMultdb.java 0 → 100644
View file @ 9c02b7cf
package com.liquidnet.client.admin;
import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.commons.lang.util.CollectionUtil;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.connection.stream.StreamRecords;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.HashMap;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: TestRedisMultdb
* @Package com.liquidnet.client.admin
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/10/22 11:30
*/
@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class TestRedisMultdb {
@Autowired
private RedisDataSourceUtil redisDataSourceUtil;
@Test
public void testRedisTemplate(){
redisDataSourceUtil.getRedisKylinUtil().set("redis-test","12345");
System.out.println(redisDataSourceUtil.getRedisKylinUtil().get("redis-test"));
}
@Test
public void testStringRedisTemplate(){
HashMap<String, String> map = CollectionUtil.mapStringString();
map.put("message", "testAdmin20211022-001");
log.info("testStringRedisTemplate.stream===",redisDataSourceUtil.getRedisKylinUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("dragon:stream:dragon-pay")));
}
}
liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/MathUtil.java
View file @ 9c02b7cf
......@@ -41,6 +41,7 @@ public class MathUtil {
RedisConfig redisConfig = new RedisConfig();
log.info("redisConfig.defaultDb===",redisConfig.defaultDb);
log.info("redisConfig.totalDbs===",redisConfig.totalDbs);
redisConfig.getRedisTemplateByDb(MathUtil.getIndex("1",redisConfig.defaultDb,redisConfig.totalDbs));
// redisConfig.getRedisTemplateByDb(MathUtil.getIndex("1",redisConfig.defaultDb,redisConfig.totalDbs));
System.out.println(""+MathUtil.getIndex("redis-test",1,16));
}
}
liquidnet-bus-config/liquidnet-config/application-dev.yml
View file @ 9c02b7cf
......@@ -55,11 +55,11 @@ liquidnet:
port: 6379
password: 3Xa%8p
candy:
dbs: 0,16
database: 15
host: 39.106.122.201
port: 6379
password: 3Xa%8p
database: 255
dbs: 0,256
host: r-2ze7002ckw5u75fgukpd.redis.rds.aliyuncs.com
port: 6380
password: PO@B!Iud32
mongodb:
host: 39.106.122.201:27017
port: 27017
......
liquidnet-bus-config/liquidnet-config/liquidnet-service-platform.yml
View file @ 9c02b7cf
......@@ -99,42 +99,42 @@ spring:
max-wait: -1
max-idle: 8
min-idle: 0
# sweet:
# database: 15
# dbs: ${liquidnet.redis.sweet.dbs}
# port: ${liquidnet.redis.sweet.port}
# host: ${liquidnet.redis.sweet.host}
# password: ${liquidnet.redis.sweet.password}
# lettuce:
# pool:
# max-active: 8
# max-wait: -1
# max-idle: 8
# min-idle: 0
# adam:
# database: 15
# dbs: ${liquidnet.redis.adam.dbs}
# port: ${liquidnet.redis.adam.port}
# host: ${liquidnet.redis.adam.host}
# password: ${liquidnet.redis.adam.password}
# lettuce:
# pool:
# max-active: 8
# max-wait: -1
# max-idle: 8
# min-idle: 0
# candy:
# database: 15
# dbs: ${liquidnet.redis.candy.dbs}
# port: ${liquidnet.redis.candy.port}
# host: ${liquidnet.redis.candy.host}
# password: ${liquidnet.redis.candy.password}
# lettuce:
# pool:
# max-active: 8
# max-wait: -1
# max-idle: 8
# min-idle: 0
sweet:
database: 15
dbs: ${liquidnet.redis.sweet.dbs}
port: ${liquidnet.redis.sweet.port}
host: ${liquidnet.redis.sweet.host}
password: ${liquidnet.redis.sweet.password}
lettuce:
pool:
max-active: 8
max-wait: -1
max-idle: 8
min-idle: 0
adam:
database: 15
dbs: ${liquidnet.redis.adam.dbs}
port: ${liquidnet.redis.adam.port}
host: ${liquidnet.redis.adam.host}
password: ${liquidnet.redis.adam.password}
lettuce:
pool:
max-active: 8
max-wait: -1
max-idle: 8
min-idle: 0
candy:
database: 15
dbs: ${liquidnet.redis.candy.dbs}
port: ${liquidnet.redis.candy.port}
host: ${liquidnet.redis.candy.host}
password: ${liquidnet.redis.candy.password}
lettuce:
pool:
max-active: 8
max-wait: -1
max-idle: 8
min-idle: 0
redisson:
singleServerConfig:
......
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/test/java/com/liquidnet/service/platform/test/TestRedis.java
View file @ 9c02b7cf
......@@ -2,15 +2,18 @@ package com.liquidnet.service.platform.test;
import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
import com.liquidnet.common.cache.redis.util.RedisUtil;
import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.service.dragon.dto.DragonOrdersDto;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.connection.stream.StreamRecords;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Set;
......@@ -52,8 +55,18 @@ public class TestRedis {
@Test
public void getRedisQueue(){
log.info("getRedisKylinUtil.stream===",redisDataSourceUtil.getRedisKylinUtil().getStringRedisTemplate().opsForStream().size("dragon:stream:dragon-pay"));
log.info("getRedisDragonUtil.stream===",redisDataSourceUtil.getRedisDragonUtil().getStringRedisTemplate().opsForStream().size("dragon:stream:dragon-pay"));
HashMap<String, String> map = CollectionUtil.mapStringString();
map.put("message", "test20211022-001");
log.info("getRedisKylinUtil.stream===",redisDataSourceUtil.getRedisKylinUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("dragon:stream:dragon-pay")));
map.put("message", "test20211022-002");
log.info("getRedisDragonUtil.stream===",redisDataSourceUtil.getRedisDragonUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("dragon:stream:dragon-pay")));
map.put("message", "test20211022-003");
log.info("getRedisSweetUtil.stream===",redisDataSourceUtil.getRedisSweetUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("dragon:stream:dragon-pay")));
log.info("getRedisAdamUtil.stream===",redisDataSourceUtil.getRedisAdamUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("adam:stream:rk.sql.ucenter")));
log.info("getRedisCandyUtil.stream===",redisDataSourceUtil.getRedisCandyUtil().getStringRedisTemplate().opsForStream().add(StreamRecords.mapBacked(map).withStreamKey("candy:stream:rk.coupon.back")));
// log.info("getRedisKylinUtil.stream===",redisDataSourceUtil.getRedisKylinUtil().getStringRedisTemplate().opsForStream().size("dragon:stream:dragon-pay"));
// log.info("getRedisDragonUtil.stream===",redisDataSourceUtil.getRedisDragonUtil().getStringRedisTemplate().opsForStream().size("dragon:stream:dragon-pay"));
// log.info("getRedisSweetUtil.stream===",redisDataSourceUtil.getRedisSweetUtil().getStringRedisTemplate().opsForStream().size("abc"));
// log.info("getRedisAdamUtil.stream===",redisDataSourceUtil.getRedisAdamUtil().getStringRedisTemplate().opsForStream().size("abc"));
// log.info("getRedisCandyUtil.stream===",redisDataSourceUtil.getRedisCandyUtil().getStringRedisTemplate().opsForStream().size("abc"));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment