feature: Realize the interface of console: get global session and global lock in the redis mode

changes/1.5.0.md

@@ -40,6 +40,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
   - [[#3968](https://github.com/seata/seata/pull/3968)] 支持 brpc-java RPC框架
   - [[#4134](https://github.com/seata/seata/pull/4134)] 初始化控制台基础代码
   - [[#4268](https://github.com/seata/seata/pull/4268)] 控制台Global Session页面File模式实现
+  - [[#4281](https://github.com/seata/seata/pull/4281)] 控制台Global Session页面和Global LockRedis模式实现
   - [[#4293](https://github.com/seata/seata/pull/4293)] 控制台Global Lock页面File模式实现
   - [[#4335](https://github.com/seata/seata/pull/4335)] 实现配置中心上传配置交互脚本(nacos,etcd3)
   - [[#4332](https://github.com/seata/seata/pull/4332)] 实现配置中心上传配置交互脚本(apollo,consul,zk)
@@ -234,6 +235,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
   - [anselleeyy](https://github.com/anselleeyy)
   - [GoodBoyCoder](https://github.com/GoodBoyCoder)
   - [xiaochangbai](https://github.com/xiaochangbai)
+  - [doubleDimple](https://github.com/doubleDimple)
   - [imherewait](https://github.com/imherewait)
   - [wangyuewen](https://github.com/2858917634)
   - [Bughue](https://github.com/Bughue)

changes/en-us/1.5.0.md

@@ -40,6 +40,7 @@
   - [[#3968](https://github.com/seata/seata/pull/3968)] support brpc-java RPC framework
   - [[#4134](https://github.com/seata/seata/pull/4134)] init the console basic code
   - [[#4268](https://github.com/seata/seata/pull/4268)] query global session in the file mode
+  - [[#4281](https://github.com/seata/seata/pull/4281)] query global session and global lock in the redis mode
   - [[#4293](https://github.com/seata/seata/pull/4293)] get global lock in the file mode
   - [[#4335](https://github.com/seata/seata/pull/4335)] Realize configuration center upload configuration interactive script (nacos,etcd3)
   - [[#4332](https://github.com/seata/seata/pull/4332)] Realize configuration center upload configuration interactive script (apollo,consul,zk)
@@ -237,6 +238,7 @@
   - [anselleeyy](https://github.com/anselleeyy)
   - [GoodBoyCoder](https://github.com/GoodBoyCoder)
   - [xiaochangbai](https://github.com/xiaochangbai)
+  - [doubleDimple](https://github.com/doubleDimple)
   - [imherewait](https://github.com/imherewait)
   - [wangyuewen](https://github.com/2858917634)
   - [Bughue](https://github.com/Bughue)

core/src/main/java/io/seata/core/console/param/GlobalLockParam.java

@@ -41,6 +41,14 @@ public class GlobalLockParam extends BaseParam implements Serializable {
      * the branch id
      */
     private String branchId;
+    /**
+     * the primary Key
+     */
+    private String pk;
+    /**
+     * the resourceId
+     */
+    private String resourceId;
 
     public String getTransactionId() {
         return transactionId;
@@ -74,13 +82,31 @@ public void setTableName(String tableName) {
         this.tableName = tableName;
     }
 
+    public String getPk() {
+        return pk;
+    }
+
+    public void setPk(String pk) {
+        this.pk = pk;
+    }
+
+    public String getResourceId() {
+        return resourceId;
+    }
+
+    public void setResourceId(String resourceId) {
+        this.resourceId = resourceId;
+    }
+
     @Override
     public String toString() {
         return "GlobalLockParam{" +
                 "xid='" + xid + '\'' +
                 ", tableName='" + tableName + '\'' +
                 ", transactionId='" + transactionId + '\'' +
                 ", branchId='" + branchId + '\'' +
+                ", pk='" + pk + '\'' +
+                ", resourceId='" + resourceId + '\'' +
                 '}';
     }
 }

core/src/main/java/io/seata/core/console/result/PageResult.java

@@ -15,15 +15,16 @@
  */
 package io.seata.core.console.result;
 
-import java.io.Serializable;
-import java.util.List;
-
 import io.seata.common.exception.FrameworkErrorCode;
+import io.seata.core.console.param.BaseParam;
 
+import java.io.Serializable;
+import java.util.List;
 /**
  * The page result
  * @author: zhongxiang.wang
  * @author miaoxueyu
+ * @author doubleDimple
  */
 public class PageResult<T> extends Result<T>  implements Serializable {
     private static final long serialVersionUID = 7761262662429121287L;
@@ -84,6 +85,20 @@ public static <T> PageResult<T> build(List<T> list, Integer pageNum, Integer pag
         );
     }
 
+    public PageResult(List<T> data, Integer total, Integer pageNum, Integer pageSize) {
+        super(SUCCESS_CODE, SUCCESS_MSG);
+        this.total = total;
+        this.pageNum = pageNum;
+        this.pageSize = pageSize;
+        this.data = data;
+
+        if (total % pageSize == 0) {
+            this.pages = total / pageSize;
+        } else {
+            this.pages = total / pageSize + 1;
+        }
+    }
+
     public static <T> PageResult<T> failure(String code, String msg) {
         return new PageResult<>(code, msg);
     }
@@ -99,6 +114,19 @@ public static <T> PageResult<T> success() {
     public static <T> PageResult<T> success(List<T> data, Integer total, Integer pages, Integer pageNum, Integer pageSize) {
         return new PageResult<>(data, total, pages, pageNum, pageSize);
     }
+    public static <T> PageResult<T> success(List<T> data, Integer total, Integer pageNum, Integer pageSize) {
+        return new PageResult<>(data, total, pageNum, pageSize);
+    }
+
+    public static void checkPage(BaseParam param) {
+        if (param.getPageNum() <= 0) {
+            param.setPageNum(1);
+        }
+
+        if (param.getPageSize() <= 0) {
+            param.setPageSize(20);
+        }
+    }
 
     public Integer getTotal() {
         return total;

core/src/main/java/io/seata/core/constants/RedisKeyConstants.java

@@ -141,4 +141,19 @@ public class RedisKeyConstants {
      */
     public static final String REDIS_KEY_BRANCH_GMT_MODIFIED = "gmtModified";
 
+    /**
+     * The globalLock key
+     */
+    public static final String DEFAULT_REDIS_SEATA_GLOBAL_LOCK_PREFIX = "SEATA_GLOBAL_LOCK";
+
+    /**
+     * The globalLock keys
+     */
+    public static final String DEFAULT_REDIS_SEATA_ROW_LOCK_PREFIX = "SEATA_ROW_LOCK_";
+
+    /**
+     * The split
+     */
+    public static final String SPLIT = "^^^";
+
 }

server/src/main/java/io/seata/server/console/impl/redis/BranchSessionRedisServiceImpl.java

@@ -15,16 +15,24 @@
  */
 package io.seata.server.console.impl.redis;
 
-import io.seata.common.exception.NotSupportYetException;
-import io.seata.core.console.vo.BranchSessionVO;
+import java.util.ArrayList;
+import java.util.List;
+import io.seata.common.util.CollectionUtils;
+import io.seata.common.util.StringUtils;
 import io.seata.core.console.result.PageResult;
+import io.seata.core.console.vo.BranchSessionVO;
+import io.seata.core.store.BranchTransactionDO;
 import io.seata.server.console.service.BranchSessionService;
+import io.seata.server.storage.redis.store.RedisTransactionStoreManager;
+import org.springframework.beans.BeanUtils;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.stereotype.Component;
 
 /**
  * Branch Session Redis ServiceImpl
+ *
  * @author: zhongxiang.wang
+ * @author: doubleDimple
  */
 @Component
 @org.springframework.context.annotation.Configuration
@@ -33,6 +41,24 @@ public class BranchSessionRedisServiceImpl implements BranchSessionService {
 
     @Override
     public PageResult<BranchSessionVO> queryByXid(String xid) {
-        throw new NotSupportYetException();
+        if (StringUtils.isBlank(xid)) {
+            return PageResult.success();
+        }
+
+        List<BranchSessionVO> branchSessionVos = new ArrayList<>();
+
+        RedisTransactionStoreManager instance = RedisTransactionStoreManager.getInstance();
+
+        List<BranchTransactionDO> branchSessionDos = instance.findBranchSessionByXid(xid);
+
+        if (CollectionUtils.isNotEmpty(branchSessionDos)) {
+            for (BranchTransactionDO branchSessionDo : branchSessionDos) {
+                BranchSessionVO branchSessionVO = new BranchSessionVO();
+                BeanUtils.copyProperties(branchSessionDo, branchSessionVO);
+                branchSessionVos.add(branchSessionVO);
+            }
+        }
+
+        return PageResult.success(branchSessionVos, branchSessionVos.size(), 0, branchSessionVos.size());
     }
 }

server/src/main/java/io/seata/server/console/impl/redis/GlobalLockRedisServiceImpl.java

@@ -15,17 +15,32 @@
  */
 package io.seata.server.console.impl.redis;
 
-import io.seata.common.exception.NotSupportYetException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import io.seata.common.util.CollectionUtils;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
+import org.springframework.stereotype.Component;
+import io.seata.common.util.BeanUtils;
 import io.seata.core.console.param.GlobalLockParam;
-import io.seata.core.console.vo.GlobalLockVO;
 import io.seata.core.console.result.PageResult;
+import io.seata.core.console.vo.GlobalLockVO;
 import io.seata.server.console.service.GlobalLockService;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
-import org.springframework.stereotype.Component;
+import io.seata.server.storage.redis.JedisPooledFactory;
+import redis.clients.jedis.Jedis;
+import static io.seata.common.Constants.ROW_LOCK_KEY_SPLIT_CHAR;
+import static io.seata.common.exception.FrameworkErrorCode.ParameterRequired;
+import static io.seata.common.util.StringUtils.isNotBlank;
+import static io.seata.core.console.result.PageResult.checkPage;
+import static io.seata.core.constants.RedisKeyConstants.DEFAULT_REDIS_SEATA_GLOBAL_LOCK_PREFIX;
+import static io.seata.core.constants.RedisKeyConstants.DEFAULT_REDIS_SEATA_ROW_LOCK_PREFIX;
+import static io.seata.core.constants.RedisKeyConstants.SPLIT;
 
 /**
  * Global Lock Redis Service Impl
  * @author: zhongxiang.wang
+ * @author: doubleDimple
  */
 @Component
 @org.springframework.context.annotation.Configuration
@@ -34,7 +49,71 @@ public class GlobalLockRedisServiceImpl implements GlobalLockService {
 
     @Override
     public PageResult<GlobalLockVO> query(GlobalLockParam param) {
-        throw new NotSupportYetException();
+
+        int total = 0;
+        List<GlobalLockVO> globalLockVos;
+        checkPage(param);
+        if (isNotBlank(param.getXid())) {
+            globalLockVos = queryGlobalByXid(param.getXid());
+            total = globalLockVos.size();
+            return PageResult.success(globalLockVos,total,param.getPageNum(),param.getPageSize());
+        } else if (isNotBlank(param.getTableName()) && isNotBlank(param.getPk()) && isNotBlank(param.getResourceId())) {
+            //SEATA_ROW_LOCK_jdbc:mysql://116.62.62.26/seata-order^^^order^^^2188
+            String tableName = param.getTableName();
+            String pk = param.getPk();
+            String resourceId = param.getResourceId();
+            globalLockVos = queryGlobalLockByRowKey(buildRowKey(tableName,pk,resourceId));
+            total = globalLockVos.size();
+            return PageResult.success(globalLockVos,total,param.getPageNum(),param.getPageSize());
+        } else {
+            return PageResult.failure(ParameterRequired.getErrCode(),"only three parameters of tableName,pk,resourceId or Xid are supported");
+        }
+    }
+
+    private List<GlobalLockVO> queryGlobalLockByRowKey(String buildRowKey) {
+        return readGlobalLockByRowKey(buildRowKey);
+    }
+
+    private String buildRowKey(String tableName, String pk,String resourceId) {
+        return DEFAULT_REDIS_SEATA_ROW_LOCK_PREFIX + resourceId + SPLIT + tableName + SPLIT + pk;
+    }
+
+
+    private List<GlobalLockVO> queryGlobalByXid(String xid) {
+        return readGlobalLockByXid(DEFAULT_REDIS_SEATA_GLOBAL_LOCK_PREFIX + xid);
+    }
+
+    private List<GlobalLockVO> readGlobalLockByXid(String key) {
+        List<GlobalLockVO> vos = new ArrayList<>();
+        try (Jedis jedis = JedisPooledFactory.getJedisInstance()) {
+            Map<String, String> mapGlobalKeys = jedis.hgetAll(key);
+            if (CollectionUtils.isNotEmpty(mapGlobalKeys)) {
+                List<String> rowLockKeys = new ArrayList<>();
+                mapGlobalKeys.forEach((k,v) -> rowLockKeys.addAll(Arrays.asList(v.split(ROW_LOCK_KEY_SPLIT_CHAR))));
+                for (String rowLoclKey : rowLockKeys) {
+                    Map<String, String> mapRowLockKey = jedis.hgetAll(rowLoclKey);
+                    GlobalLockVO vo = (GlobalLockVO)BeanUtils.mapToObject(mapRowLockKey, GlobalLockVO.class);
+                    if (vo != null) {
+                        vos.add(vo);
+                    }
+                }
+            }
+        }
+
+        return vos;
+    }
+
+
+    private List<GlobalLockVO> readGlobalLockByRowKey(String key) {
+        List<GlobalLockVO> vos = new ArrayList<>();
+        try (Jedis jedis = JedisPooledFactory.getJedisInstance()) {
+            Map<String, String> map = jedis.hgetAll(key);
+            GlobalLockVO vo = (GlobalLockVO)BeanUtils.mapToObject(map, GlobalLockVO.class);
+            if (vo != null) {
+                vos.add(vo);
+            }
+        }
+        return vos;
     }
 
 }