diff --git a/raincat-common/src/main/java/com/raincat/common/bean/TransactionInvocation.java b/raincat-common/src/main/java/com/raincat/common/bean/TransactionInvocation.java
index 0ca82b2b..7487c6fb 100644
--- a/raincat-common/src/main/java/com/raincat/common/bean/TransactionInvocation.java
+++ b/raincat-common/src/main/java/com/raincat/common/bean/TransactionInvocation.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.bean;
import lombok.AllArgsConstructor;
@@ -25,33 +26,38 @@
import java.io.Serializable;
/**
+ * TransactionInvocation.
* @author xiaoyu
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class TransactionInvocation implements Serializable {
+
private static final long serialVersionUID = 7722060715819141844L;
+
/**
- * 事务执行器
+ * 事务执行器.
*/
@Getter
private Class targetClazz;
+
/**
- * 方法
+ * 方法.
*/
@Getter
private String method;
+
/**
- * 参数值
+ * 参数值.
*/
@Getter
private Object[] argumentValues;
+
/**
- * 参数类型
+ * 参数类型.
*/
@Getter
private Class[] argumentTypes;
-
}
diff --git a/raincat-common/src/main/java/com/raincat/common/bean/TransactionRecover.java b/raincat-common/src/main/java/com/raincat/common/bean/TransactionRecover.java
index 74683f0b..50fa6730 100644
--- a/raincat-common/src/main/java/com/raincat/common/bean/TransactionRecover.java
+++ b/raincat-common/src/main/java/com/raincat/common/bean/TransactionRecover.java
@@ -15,8 +15,8 @@
* along with this distribution; if not, see .
*
*/
-package com.raincat.common.bean;
+package com.raincat.common.bean;
import com.raincat.common.enums.TransactionStatusEnum;
import lombok.Data;
@@ -25,57 +25,56 @@
import java.util.Date;
/**
+ * TransactionRecover.
* @author xiaoyu
*/
@Data
public class TransactionRecover implements Serializable {
private static final long serialVersionUID = -3262858695515766275L;
+
/**
- * 主键id
+ * 主键id.
*/
private String id;
-
/**
- * 重试次数,
+ * 重试次数.
*/
- private int retriedCount = 0;
+ private int retriedCount;
/**
- * 创建时间
+ * 创建时间.
*/
private Date createTime = new Date();
-
/**
- * 创建时间
+ * 创建时间.
*/
private Date lastTime = new Date();
/**
- * 版本控制 防止并发问题
+ * 版本控制 防止并发问题.
*/
private int version = 1;
/**
- * 事务组id
+ * 事务组id.
*/
private String groupId;
/**
- * 任务id
+ * 任务id.
*/
private String taskId;
/**
- * 事务执行方法
+ * 事务执行方法.
*/
private TransactionInvocation transactionInvocation;
-
/**
- * {@linkplain TransactionStatusEnum}
+ * 状态. {@linkplain TransactionStatusEnum}
*/
private int status;
diff --git a/raincat-common/src/main/java/com/raincat/common/bean/TransactionXid.java b/raincat-common/src/main/java/com/raincat/common/bean/TransactionXid.java
deleted file mode 100644
index bfa685c9..00000000
--- a/raincat-common/src/main/java/com/raincat/common/bean/TransactionXid.java
+++ /dev/null
@@ -1,150 +0,0 @@
-/*
- *
- * Copyright 2017-2018 549477611@qq.com(xiaoyu)
- *
- * This copyrighted material is made available to anyone wishing to use, modify,
- * copy, or redistribute it subject to the terms and conditions of the GNU
- * Lesser General Public License, as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
- * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
- * for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this distribution; if not, see .
- *
- */
-package com.raincat.common.bean;
-
-
-import javax.transaction.xa.Xid;
-import java.io.Serializable;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import java.util.UUID;
-
-/**
- * @author xiaoyu
- */
-public class TransactionXid implements Xid, Serializable {
-
- private static final long serialVersionUID = -6817267250789142043L;
-
- private int formatId = 1;
-
- private byte[] globalTransactionId;
-
- private byte[] branchQualifier;
-
- public TransactionXid() {
- globalTransactionId = uuidToByteArray(UUID.randomUUID());
- branchQualifier = uuidToByteArray(UUID.randomUUID());
- }
-
- public void setGlobalTransactionId(byte[] globalTransactionId) {
- this.globalTransactionId = globalTransactionId;
- }
-
- public void setBranchQualifier(byte[] branchQualifier) {
- this.branchQualifier = branchQualifier;
- }
-
- public TransactionXid(byte[] globalTransactionId) {
- this.globalTransactionId = globalTransactionId;
- branchQualifier = uuidToByteArray(UUID.randomUUID());
- }
-
- public TransactionXid(byte[] globalTransactionId, byte[] branchQualifier) {
- this.globalTransactionId = globalTransactionId;
- this.branchQualifier = branchQualifier;
- }
-
- @Override
- public int getFormatId() {
- return formatId;
- }
-
- @Override
- public byte[] getGlobalTransactionId() {
- return globalTransactionId;
- }
-
- @Override
- public byte[] getBranchQualifier() {
- return branchQualifier;
- }
-
- @Override
- public String toString() {
-
- return "globalTransactionId:" + UUID.nameUUIDFromBytes(globalTransactionId).toString() +
- "," + "branchQualifier:" + UUID.nameUUIDFromBytes(branchQualifier).toString();
- }
-
- @Override
- public TransactionXid clone() {
-
- byte[] cloneGlobalTransactionId = null;
- byte[] cloneBranchQualifier = null;
-
- if (globalTransactionId != null) {
- cloneGlobalTransactionId = new byte[globalTransactionId.length];
- System.arraycopy(globalTransactionId, 0, cloneGlobalTransactionId, 0, globalTransactionId.length);
- }
-
- if (branchQualifier != null) {
- cloneBranchQualifier = new byte[branchQualifier.length];
- System.arraycopy(branchQualifier, 0, cloneBranchQualifier, 0, branchQualifier.length);
- }
-
- TransactionXid clone = new TransactionXid(cloneGlobalTransactionId, cloneBranchQualifier);
- return clone;
- }
-
- @Override
- public int hashCode() {
- final int prime = 31;
- int result = 1;
- result = prime * result + this.getFormatId();
- result = prime * result + Arrays.hashCode(branchQualifier);
- result = prime * result + Arrays.hashCode(globalTransactionId);
- return result;
- }
-
- @Override
- public boolean equals(Object obj) {
- if (this == obj) {
- return true;
- } else if (obj == null) {
- return false;
- } else if (getClass() != obj.getClass()) {
- return false;
- }
- TransactionXid other = (TransactionXid) obj;
- if (this.getFormatId() != other.getFormatId()) {
- return false;
- } else if (Arrays.equals(branchQualifier, other.branchQualifier) == false) {
- return false;
- } else if (Arrays.equals(globalTransactionId, other.globalTransactionId) == false) {
- return false;
- }
- return true;
- }
-
- public static byte[] uuidToByteArray(UUID uuid) {
- ByteBuffer bb = ByteBuffer.wrap(new byte[16]);
- bb.putLong(uuid.getMostSignificantBits());
- bb.putLong(uuid.getLeastSignificantBits());
- return bb.array();
- }
-
- public static UUID byteArrayToUUID(byte[] bytes) {
- ByteBuffer bb = ByteBuffer.wrap(bytes);
- long firstLong = bb.getLong();
- long secondLong = bb.getLong();
- return new UUID(firstLong, secondLong);
- }
-}
-
-
diff --git a/raincat-common/src/main/java/com/raincat/common/bean/TxTransactionInfo.java b/raincat-common/src/main/java/com/raincat/common/bean/TxTransactionInfo.java
index 53cfd744..93cc15de 100644
--- a/raincat-common/src/main/java/com/raincat/common/bean/TxTransactionInfo.java
+++ b/raincat-common/src/main/java/com/raincat/common/bean/TxTransactionInfo.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.bean;
import com.raincat.common.enums.PropagationEnum;
@@ -22,37 +23,35 @@
import lombok.Getter;
/**
+ * TxTransactionInfo.
* @author xiaoyu
*/
@AllArgsConstructor
public class TxTransactionInfo {
/**
- * 补偿方法对象
+ * 补偿方法对象.
*/
@Getter
private TransactionInvocation invocation;
-
/**
- * 分布式事务组
+ * 分布式事务组.
*/
@Getter
private String txGroupId;
/**
- * 事务补偿id
+ * 事务补偿id.
*/
@Getter
private String compensationId;
-
/**
- * 事务等待时间
+ * 事务等待时间.
*/
@Getter
- private int waitMaxTime = 60;
-
+ private int waitMaxTime;
@Getter
private PropagationEnum propagationEnum;
diff --git a/raincat-common/src/main/java/com/raincat/common/bean/adapter/MongoAdapter.java b/raincat-common/src/main/java/com/raincat/common/bean/adapter/MongoAdapter.java
index a4d90636..ab46313e 100644
--- a/raincat-common/src/main/java/com/raincat/common/bean/adapter/MongoAdapter.java
+++ b/raincat-common/src/main/java/com/raincat/common/bean/adapter/MongoAdapter.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.bean.adapter;
import lombok.Data;
@@ -23,6 +24,7 @@
import java.io.Serializable;
/**
+ * MongoAdapter.
* @author xiaoyu
*/
@Data
diff --git a/raincat-common/src/main/java/com/raincat/common/bean/adapter/TransactionRecoverAdapter.java b/raincat-common/src/main/java/com/raincat/common/bean/adapter/TransactionRecoverAdapter.java
index 52db9873..9df5579f 100644
--- a/raincat-common/src/main/java/com/raincat/common/bean/adapter/TransactionRecoverAdapter.java
+++ b/raincat-common/src/main/java/com/raincat/common/bean/adapter/TransactionRecoverAdapter.java
@@ -24,73 +24,64 @@
import java.util.Date;
/**
- *
Description: .
- *
+ * TransactionRecoverAdapter.
* @author xiaoyu(Myth)
- * @version 1.0
- * @date 2017/10/30 10:39
- * @since JDK 1.8
*/
@Data
public class TransactionRecoverAdapter {
-
/**
- * 事务主键id
+ * 事务主键id.
*/
private String transId;
-
/**
- * 重试次数,
+ * 重试次数.
*/
- private int retriedCount = 0;
+ private int retriedCount;
/**
- * 创建时间
+ * 创建时间.
*/
private Date createTime = new Date();
-
/**
- * 创建时间
+ * 创建时间.
*/
private Date lastTime = new Date();
/**
- * 版本控制 防止并发问题
+ * 版本控制 防止并发问题.
*/
private int version = 1;
/**
- * 事务组id
+ * 事务组id.
*/
private String groupId;
/**
- * 任务id
+ * 任务id.
*/
private String taskId;
/**
- * 序列化后的二进制信息
+ * 序列化后的二进制信息.
*/
private byte[] contents;
/**
- * {@linkplain TransactionStatusEnum}
+ * 状态. {@linkplain TransactionStatusEnum}
*/
private int status;
-
/**
- * 调用接口名称
+ * 调用接口名称.
*/
private String targetClass;
-
/**
- * 调用方法名称
+ * 调用方法名称.
*/
private String targetMethod;
diff --git a/raincat-common/src/main/java/com/raincat/common/config/TxConfig.java b/raincat-common/src/main/java/com/raincat/common/config/TxConfig.java
index fd306590..b19a9212 100644
--- a/raincat-common/src/main/java/com/raincat/common/config/TxConfig.java
+++ b/raincat-common/src/main/java/com/raincat/common/config/TxConfig.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.config;
import com.raincat.common.enums.BlockingQueueTypeEnum;
@@ -24,132 +25,120 @@
import lombok.Data;
/**
+ * TxConfig.
* @author xiaoyu
*/
@Data
public class TxConfig {
/**
- * 提供不同的序列化对象 {@linkplain SerializeProtocolEnum}
+ * 提供不同的序列化对象. {@linkplain SerializeProtocolEnum}
*/
private String serializer = "kryo";
-
/**
- * netty 传输的序列化协议
+ * netty 传输的序列化协议.
*/
private String nettySerializer = "kryo";
-
/**
- * 延迟时间
+ * 延迟时间.
*/
private int delayTime = 30;
-
/**
- * 执行事务的线程数大小
+ * 执行事务的线程数大小.
*/
private int transactionThreadMax = Runtime.getRuntime().availableProcessors() << 1;
-
/**
- * netty 工作线程大小
+ * netty 工作线程大小.
*/
private int nettyThreadMax = Runtime.getRuntime().availableProcessors() << 1;
/**
- * 心跳时间 默认10秒
+ * 心跳时间 默认10秒.
*/
private int heartTime = 10;
-
/**
- * 线程池的拒绝策略 {@linkplain RejectedPolicyTypeEnum}
+ * 线程池的拒绝策略. {@linkplain RejectedPolicyTypeEnum}
*/
private String rejectPolicy = "Abort";
/**
- * 线程池的队列类型 {@linkplain BlockingQueueTypeEnum}
+ * 线程池的队列类型. {@linkplain BlockingQueueTypeEnum}
*/
private String blockingQueueType = "Linked";
/**
- * 是否需要补偿
+ * 是否需要补偿.
*/
private Boolean compensation = false;
/**
- * 补偿存储类型 {@linkplain CompensationCacheTypeEnum}
+ * 补偿存储类型. {@linkplain CompensationCacheTypeEnum}
*/
private String compensationCacheType;
-
/**
- * 回滚队列大小
+ * 回滚队列大小.
*/
private int compensationQueueMax = 5000;
+
/**
- * 监听回滚队列线程数
+ * 监听回滚队列线程数.
*/
private int compensationThreadMax = Runtime.getRuntime().availableProcessors() << 1;
-
/**
- * 补偿恢复时间 单位秒
+ * 补偿恢复时间 单位秒.
*/
private int compensationRecoverTime = 60;
-
/**
- * 更新tmInfo 的时间间隔
+ * 更新tmInfo 的时间间隔.
*/
private int refreshInterval = 60;
-
/**
- * 最大重试次数
+ * 最大重试次数.
*/
private int retryMax = 10;
-
/**
- * 事务恢复间隔时间 单位秒(注意 此时间表示本地事务创建的时间多少秒以后才会执行)
+ * 事务恢复间隔时间 单位秒(注意 此时间表示本地事务创建的时间多少秒以后才会执行).
*/
private int recoverDelayTime = 60;
-
/**
- * txManagerUrl服务地址
+ * txManagerUrl服务地址.
*/
private String txManagerUrl;
-
/**
- * db存储方式时候 数据库配置信息
+ * db存储方式时候 数据库配置信息.
*/
private TxDbConfig txDbConfig;
/**
- * mongo存储方式时候的 mongo配置信息
+ * mongo存储方式时候的 mongo配置信息.
*/
private TxMongoConfig txMongoConfig;
-
/**
- * redis存储方式时候的 redis配置信息
+ * redis存储方式时候的 redis配置信息.
*/
private TxRedisConfig txRedisConfig;
/**
- * 文件存储配置
+ * 文件存储配置.
*/
private TxFileConfig txFileConfig;
/**
- * zookeeper 存储的配置
+ * zookeeper 存储的配置.
*/
private TxZookeeperConfig txZookeeperConfig;
-
}
diff --git a/raincat-common/src/main/java/com/raincat/common/config/TxDbConfig.java b/raincat-common/src/main/java/com/raincat/common/config/TxDbConfig.java
index 91d937ea..585f6ef6 100644
--- a/raincat-common/src/main/java/com/raincat/common/config/TxDbConfig.java
+++ b/raincat-common/src/main/java/com/raincat/common/config/TxDbConfig.java
@@ -15,107 +15,98 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.config;
import lombok.Data;
/**
+ * TxDbConfig.
* @author xiaoyu
*/
@Data
public class TxDbConfig {
/**
- * Mysql 驱动
+ * Mysql 驱动.
*/
private String driverClassName = "com.mysql.jdbc.Driver";
/**
- * url
+ * url.
*/
private String url;
/**
- * 用户名
+ * 用户名.
*/
private String username;
/**
- * 密码
+ * 密码.
*/
private String password;
-
/**
- * 初始化时建立物理连接的个数。初始化发生在显示调用init方法,或者第一次getConnection时
+ * 初始化时建立物理连接的个数。初始化发生在显示调用init方法,或者第一次getConnection时.
*/
private int initialSize = 10;
-
/**
- * 最大连接池数量
+ * 最大连接池数量.
*/
private int maxActive = 100;
/**
- * 最小连接池数量
+ * 最小连接池数量.
*/
private int minIdle = 20;
-
/**
- * 配置获取连接等待超时的时间
+ * 配置获取连接等待超时的时间.
*/
private int maxWait = 60000;
-
/**
- * 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
+ * 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒.
*/
private int timeBetweenEvictionRunsMillis = 60000;
-
/**
- * 配置一个连接在池中最小生存的时间,单位是毫秒
+ * 配置一个连接在池中最小生存的时间,单位是毫秒.
*/
private int minEvictableIdleTimeMillis = 300000;
-
private String validationQuery = " SELECT 1 ";
-
/**
- * 申请连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能。
+ * 申请连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能.
*/
private Boolean testOnBorrow = false;
-
/**
- * 归还连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能。
+ * 归还连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能.
*/
private Boolean testOnReturn = false;
-
/**
* 建议配置为true,不影响性能,并且保证安全性。申请连接的时候检测,
* 如果空闲时间大于timeBetweenEvictionRunsMillis,
- * 执行validationQuery检测连接是否有效
+ * 执行validationQuery检测连接是否有效.
*/
private Boolean testWhileIdle = true;
-
/**
* 是否缓存preparedStatement,也就是PSCache。
- * PSCache对支持游标的数据库性能提升巨大,比如说oracle。在mysql下建议关闭
+ * PSCache对支持游标的数据库性能提升巨大,比如说oracle。在mysql下建议关闭.
*/
- private Boolean poolPreparedStatements=false;
-
+ private Boolean poolPreparedStatements = false;
/**
* 要启用PSCache,必须配置大于0,当大于0时,poolPreparedStatements自动触发修改为true。
* 在Druid中,
- * 不会存在Oracle下PSCache占用内存过多的问题,可以把这个数值配置大一些,比如说100
+ * 不会存在Oracle下PSCache占用内存过多的问题,可以把这个数值配置大一些,比如说100.
*/
- private int maxPoolPreparedStatementPerConnectionSize=100;
+ private int maxPoolPreparedStatementPerConnectionSize = 100;
}
diff --git a/raincat-common/src/main/java/com/raincat/common/config/TxFileConfig.java b/raincat-common/src/main/java/com/raincat/common/config/TxFileConfig.java
index bcf382e3..8e31434b 100644
--- a/raincat-common/src/main/java/com/raincat/common/config/TxFileConfig.java
+++ b/raincat-common/src/main/java/com/raincat/common/config/TxFileConfig.java
@@ -15,25 +15,26 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.config;
import lombok.Data;
/**
+ * TxFileConfig.
* @author xiaoyu
*/
@Data
public class TxFileConfig {
/**
- * 文件保存路径
+ * 文件保存路径.
*/
private String path;
/**
- * 文件前缀
+ * 文件前缀.
*/
private String prefix;
-
}
diff --git a/raincat-common/src/main/java/com/raincat/common/config/TxMongoConfig.java b/raincat-common/src/main/java/com/raincat/common/config/TxMongoConfig.java
index 6c3b166c..3d54c315 100644
--- a/raincat-common/src/main/java/com/raincat/common/config/TxMongoConfig.java
+++ b/raincat-common/src/main/java/com/raincat/common/config/TxMongoConfig.java
@@ -15,32 +15,35 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.config;
import lombok.Data;
/**
+ * TxMongoConfig.
* @author xiaoyu
*/
@Data
public class TxMongoConfig {
/**
- * mongo数据库设置
+ * mongo数据库设置.
*/
private String mongoDbName;
/**
- * mongo数据库URL
+ * mongo数据库URL.
*/
private String mongoDbUrl;
+
/**
- * mongo数据库用户名
+ * mongo数据库用户名.
*/
private String mongoUserName;
/**
- * mongo数据库密码
+ * mongo数据库密码.
*/
private String mongoUserPwd;
diff --git a/raincat-common/src/main/java/com/raincat/common/config/TxRedisConfig.java b/raincat-common/src/main/java/com/raincat/common/config/TxRedisConfig.java
index 173a8aff..108a334a 100644
--- a/raincat-common/src/main/java/com/raincat/common/config/TxRedisConfig.java
+++ b/raincat-common/src/main/java/com/raincat/common/config/TxRedisConfig.java
@@ -15,42 +15,60 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.config;
import lombok.Data;
/**
+ * TxRedisConfig.
* @author xiaoyu
*/
@Data
public class TxRedisConfig {
/**
- * 是否集群模式
+ * 是否集群模式.
*/
private Boolean cluster = false;
/**
- * 集群url ip:port;ip:port
+ * 集群url ip:port;ip:port.
*/
private String clusterUrl;
private String hostName;
+
private int port;
+
private String password;
+
private int maxTotal = 8;
+
private int maxIdle = 8;
- private int minIdle = 0;
+
+ private int minIdle;
+
private long maxWaitMillis = -1L;
+
private long minEvictableIdleTimeMillis = 1800000L;
+
private long softMinEvictableIdleTimeMillis = 1800000L;
+
private int numTestsPerEvictionRun = 3;
+
private Boolean testOnCreate = false;
+
private Boolean testOnBorrow = false;
+
private Boolean testOnReturn = false;
+
private Boolean testWhileIdle = false;
+
private long timeBetweenEvictionRunsMillis = -1L;
+
private Boolean blockWhenExhausted = true;
+
private int timeOut = 10000;
}
diff --git a/raincat-common/src/main/java/com/raincat/common/config/TxZookeeperConfig.java b/raincat-common/src/main/java/com/raincat/common/config/TxZookeeperConfig.java
index 0a47cf19..b430df99 100644
--- a/raincat-common/src/main/java/com/raincat/common/config/TxZookeeperConfig.java
+++ b/raincat-common/src/main/java/com/raincat/common/config/TxZookeeperConfig.java
@@ -15,11 +15,13 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.config;
import lombok.Data;
/**
+ * TxZookeeperConfig.
* @author xiaoyu
*/
@Data
diff --git a/raincat-common/src/main/java/com/raincat/common/constant/CommonConstant.java b/raincat-common/src/main/java/com/raincat/common/constant/CommonConstant.java
index 68006721..25f66101 100644
--- a/raincat-common/src/main/java/com/raincat/common/constant/CommonConstant.java
+++ b/raincat-common/src/main/java/com/raincat/common/constant/CommonConstant.java
@@ -19,21 +19,15 @@
package com.raincat.common.constant;
/**
- * Description: .
- *
+ * CommonConstant.
* @author xiaoyu(Myth)
- * @version 1.0
- * @date 2017/10/18 15:36
- * @since JDK 1.8
*/
public interface CommonConstant {
-
String REDIS_PRE_FIX = "transaction:group:%s";
String REDIS_KEYS = "transaction:group:*";
-
String REDIS_KEY_SET = "transaction:group";
double REDIS_SCOPE = 10.0;
@@ -44,7 +38,6 @@ public interface CommonConstant {
String RECOVER_REDIS_KEY_PRE = "transaction:recover:%s";
-
String DB_MYSQL = "mysql";
String DB_SQLSERVER = "sqlserver";
diff --git a/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServer.java b/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServer.java
index 6d06baf2..26ebfb71 100644
--- a/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServer.java
+++ b/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServer.java
@@ -15,25 +15,26 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.entity;
import lombok.Data;
/**
+ * TxManagerServer.
* @author xiaoyu
*/
@Data
public class TxManagerServer {
/**
- * TxManagerServer host
+ * TxManagerServer host.
*/
private String host;
/**
- * TxManagerServer port
+ * TxManagerServer port.
*/
private Integer port;
-
}
diff --git a/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServiceDTO.java b/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServiceDTO.java
index 4babe7d0..3b63bb11 100644
--- a/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServiceDTO.java
+++ b/raincat-common/src/main/java/com/raincat/common/entity/TxManagerServiceDTO.java
@@ -15,12 +15,13 @@
* along with this distribution; if not, see .
*
*/
-package com.raincat.common.entity;
+package com.raincat.common.entity;
import lombok.Data;
/**
+ * TxManagerServiceDTO.
* @author xiaoyu
*/
@Data
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/BlockingQueueTypeEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/BlockingQueueTypeEnum.java
index 2a4f1efc..1a397d59 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/BlockingQueueTypeEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/BlockingQueueTypeEnum.java
@@ -15,14 +15,13 @@
* along with this distribution; if not, see .
*
*/
-package com.raincat.common.enums;
+package com.raincat.common.enums;
import java.util.Arrays;
import java.util.Objects;
import java.util.Optional;
-
/**
* The enum Blocking queue type enum.
* @author xiaoyu
@@ -45,7 +44,7 @@ public enum BlockingQueueTypeEnum {
private String value;
- BlockingQueueTypeEnum(String value) {
+ BlockingQueueTypeEnum(final String value) {
this.value = value;
}
@@ -64,7 +63,7 @@ public String getValue() {
* @param value the value
* @return the blocking queue type enum
*/
- public static BlockingQueueTypeEnum fromString(String value) {
+ public static BlockingQueueTypeEnum fromString(final String value) {
Optional blockingQueueTypeEnum =
Arrays.stream(BlockingQueueTypeEnum.values())
.filter(v -> Objects.equals(v.getValue(), value))
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/CompensationActionEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/CompensationActionEnum.java
index fbe98607..8a8d81a0 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/CompensationActionEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/CompensationActionEnum.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.enums;
/**
@@ -26,32 +27,30 @@ public enum CompensationActionEnum {
/**
* Save compensate action enum.
*/
- SAVE(0,"保存"),
+ SAVE(0, "保存"),
/**
* Delete compensate action enum.
*/
- DELETE(1,"删除"),
+ DELETE(1, "删除"),
/**
* Update compensate action enum.
*/
- UPDATE(2,"更新"),
+ UPDATE(2, "更新"),
/**
* Compensate compensate action enum.
*/
- COMPENSATE(3,"补偿"),
-
- ;
+ COMPENSATE(3, "补偿");
private int code;
private String desc;
- CompensationActionEnum(int code,String desc){
- this.code=code;
- this.desc=desc;
+ CompensationActionEnum(final int code, final String desc) {
+ this.code = code;
+ this.desc = desc;
}
/**
@@ -68,7 +67,7 @@ public int getCode() {
*
* @param code the code
*/
- public void setCode(int code) {
+ public void setCode(final int code) {
this.code = code;
}
@@ -86,7 +85,7 @@ public String getDesc() {
*
* @param desc the desc
*/
- public void setDesc(String desc) {
+ public void setDesc(final String desc) {
this.desc = desc;
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/CompensationCacheTypeEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/CompensationCacheTypeEnum.java
index efc48c5c..67ddd431 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/CompensationCacheTypeEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/CompensationCacheTypeEnum.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.enums;
import java.util.Arrays;
@@ -22,6 +23,7 @@
import java.util.Optional;
/**
+ * CompensationCacheTypeEnum.
* @author xiaoyu
*/
public enum CompensationCacheTypeEnum {
@@ -53,7 +55,7 @@ public enum CompensationCacheTypeEnum {
private String compensationCacheType;
- CompensationCacheTypeEnum(String compensationCacheType) {
+ CompensationCacheTypeEnum(final String compensationCacheType) {
this.compensationCacheType = compensationCacheType;
}
@@ -63,7 +65,7 @@ public enum CompensationCacheTypeEnum {
* @param compensationCacheType the compensate cache type
* @return the compensate cache type enum
*/
- public static CompensationCacheTypeEnum acquireCompensationCacheType(String compensationCacheType) {
+ public static CompensationCacheTypeEnum acquireCompensationCacheType(final String compensationCacheType) {
Optional serializeProtocolEnum =
Arrays.stream(CompensationCacheTypeEnum.values())
.filter(v -> Objects.equals(v.getCompensationCacheType(), compensationCacheType))
@@ -85,7 +87,7 @@ public String getCompensationCacheType() {
*
* @param compensationCacheType the compensate cache type
*/
- public void setCompensationCacheType(String compensationCacheType) {
+ public void setCompensationCacheType(final String compensationCacheType) {
this.compensationCacheType = compensationCacheType;
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/NettyMessageActionEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/NettyMessageActionEnum.java
index 2ea245e7..3b473941 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/NettyMessageActionEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/NettyMessageActionEnum.java
@@ -15,15 +15,16 @@
* along with this distribution; if not, see .
*
*/
-package com.raincat.common.enums;
+package com.raincat.common.enums;
import java.util.Arrays;
import java.util.Objects;
import java.util.Optional;
-
/**
+ * NettyMessageActionEnum.
+ *
* @author xiaoyu
*/
public enum NettyMessageActionEnum {
@@ -33,7 +34,6 @@ public enum NettyMessageActionEnum {
*/
CREATE_GROUP(0, "创建事务组"),
-
/**
* Add transaction netty message action enum.
*/
@@ -49,7 +49,6 @@ public enum NettyMessageActionEnum {
*/
PRE_COMMIT(3, "预提交"),
-
/**
* Complete commit netty message action enum.
*/
@@ -72,33 +71,28 @@ public enum NettyMessageActionEnum {
/**
* Send netty message action enum.
*/
- SEND(8,"发送"),
+ SEND(8, "发送"),
/**
* Receive netty message action enum.
*/
- RECEIVE(9,"接收"),
-
+ RECEIVE(9, "接收"),
/**
* Get transaction group netty message action enum.
*/
- GET_TRANSACTION_GROUP_STATUS(10,"获取事务组状态"),
-
-
-
- FIND_TRANSACTION_GROUP_INFO(11,"获取事务组信息"),
-
-
-
+ GET_TRANSACTION_GROUP_STATUS(10, "获取事务组状态"),
+ /**
+ * Find transaction group info netty message action enum.
+ */
+ FIND_TRANSACTION_GROUP_INFO(11, "获取事务组信息");
- ;
private int code;
private String desc;
- NettyMessageActionEnum(int code, String desc) {
+ NettyMessageActionEnum(final int code, final String desc) {
this.code = code;
this.desc = desc;
}
@@ -110,13 +104,12 @@ public enum NettyMessageActionEnum {
* @param code the code
* @return the netty message action enum
*/
- public static NettyMessageActionEnum acquireByCode(int code) {
+ public static NettyMessageActionEnum acquireByCode(final int code) {
Optional actionEnum =
Arrays.stream(NettyMessageActionEnum.values())
.filter(v -> Objects.equals(v.getCode(), code))
.findFirst();
return actionEnum.orElse(NettyMessageActionEnum.HEART);
-
}
/**
@@ -133,7 +126,7 @@ public int getCode() {
*
* @param code the code
*/
- public void setCode(int code) {
+ public void setCode(final int code) {
this.code = code;
}
@@ -151,7 +144,7 @@ public String getDesc() {
*
* @param desc the desc
*/
- public void setDesc(String desc) {
+ public void setDesc(final String desc) {
this.desc = desc;
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/NettyResultEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/NettyResultEnum.java
index 3bb71228..dec2b49d 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/NettyResultEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/NettyResultEnum.java
@@ -15,15 +15,16 @@
* along with this distribution; if not, see .
*
*/
-package com.raincat.common.enums;
+package com.raincat.common.enums;
import java.util.Arrays;
import java.util.Objects;
import java.util.Optional;
-
/**
+ * NettyResultEnum.
+ *
* @author xiaoyu
*/
public enum NettyResultEnum {
@@ -33,25 +34,21 @@ public enum NettyResultEnum {
*/
SUCCESS(0, "成功"),
-
/**
* Fail netty result enum.
*/
FAIL(1, "失败"),
-
- TIME_OUT(-1,"tmManager未连接或者响应超时!"),
-
-
- ;
-
-
+ /**
+ * Time out netty result enum.
+ */
+ TIME_OUT(-1,"tmManager未连接或者响应超时!");
private int code;
private String desc;
- NettyResultEnum(int code, String desc) {
+ NettyResultEnum(final int code, final String desc) {
this.code = code;
this.desc = desc;
}
@@ -63,7 +60,7 @@ public enum NettyResultEnum {
* @param code the code
* @return the netty result enum
*/
- public static NettyResultEnum acquireByCode(int code) {
+ public static NettyResultEnum acquireByCode(final int code) {
Optional actionEnum =
Arrays.stream(NettyResultEnum.values())
.filter(v -> Objects.equals(v.getCode(), code))
@@ -86,7 +83,7 @@ public int getCode() {
*
* @param code the code
*/
- public void setCode(int code) {
+ public void setCode(final int code) {
this.code = code;
}
@@ -104,7 +101,7 @@ public String getDesc() {
*
* @param desc the desc
*/
- public void setDesc(String desc) {
+ public void setDesc(final String desc) {
this.desc = desc;
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/PropagationEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/PropagationEnum.java
index be0864fd..085f5f2c 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/PropagationEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/PropagationEnum.java
@@ -15,10 +15,11 @@
* along with this distribution; if not, see .
*
*/
-package com.raincat.common.enums;
+package com.raincat.common.enums;
/**
+ * PropagationEnum.
* @author xiaoyu
*/
public enum PropagationEnum {
@@ -61,7 +62,7 @@ public enum PropagationEnum {
private final int value;
- PropagationEnum(int value) {
+ PropagationEnum(final int value) {
this.value = value;
}
@@ -74,9 +75,4 @@ public int getValue() {
return this.value;
}
-
-
-
-
-
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/SerializeProtocolEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/SerializeProtocolEnum.java
index d68d5a06..e324c75b 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/SerializeProtocolEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/SerializeProtocolEnum.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.enums;
import java.util.Arrays;
@@ -22,9 +23,9 @@
import java.util.Optional;
/**
+ * SerializeProtocolEnum.
* @author xiaoyu
*/
-
public enum SerializeProtocolEnum {
/**
@@ -49,7 +50,7 @@ public enum SerializeProtocolEnum {
private String serializeProtocol;
- SerializeProtocolEnum(String serializeProtocol) {
+ SerializeProtocolEnum(final String serializeProtocol) {
this.serializeProtocol = serializeProtocol;
}
@@ -59,13 +60,12 @@ public enum SerializeProtocolEnum {
* @param serializeProtocol the serialize protocol
* @return the serialize protocol enum
*/
- public static SerializeProtocolEnum acquireSerializeProtocol(String serializeProtocol) {
+ public static SerializeProtocolEnum acquireSerializeProtocol(final String serializeProtocol) {
Optional serializeProtocolEnum =
Arrays.stream(SerializeProtocolEnum.values())
.filter(v -> Objects.equals(v.getSerializeProtocol(), serializeProtocol))
.findFirst();
return serializeProtocolEnum.orElse(SerializeProtocolEnum.KRYO);
-
}
/**
@@ -77,14 +77,4 @@ public String getSerializeProtocol() {
return serializeProtocol;
}
- /**
- * Sets serialize protocol.
- *
- * @param serializeProtocol the serialize protocol
- */
- public void setSerializeProtocol(String serializeProtocol) {
- this.serializeProtocol = serializeProtocol;
- }
-
-
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/TransactionRoleEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/TransactionRoleEnum.java
index 0502c389..b40e9e11 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/TransactionRoleEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/TransactionRoleEnum.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.enums;
import java.util.Arrays;
@@ -28,35 +29,31 @@
*/
public enum TransactionRoleEnum {
-
/**
* Start transaction role enum.
*/
START(0, "发起者"),
-
/**
* Actor transaction role enum.
*/
ACTOR(1, "参与者"),
/**
- * 事务组
+ * 事务组.
*/
- GROUP(2,"事务组")
- ;
-
+ GROUP(2, "事务组");
private int code;
private String desc;
- TransactionRoleEnum(int code, String desc) {
+ TransactionRoleEnum(final int code, final String desc) {
this.code = code;
this.desc = desc;
}
- public static TransactionRoleEnum acquireByCode(int code) {
+ public static TransactionRoleEnum acquireByCode(final int code) {
Optional roleEnum =
Arrays.stream(TransactionRoleEnum.values())
.filter(v -> Objects.equals(v.getCode(), code))
@@ -65,7 +62,7 @@ public static TransactionRoleEnum acquireByCode(int code) {
}
- public static String acquireDescByCode(int code) {
+ public static String acquireDescByCode(final int code) {
return acquireByCode(code).getDesc();
}
@@ -84,7 +81,7 @@ public int getCode() {
*
* @param code the code
*/
- public void setCode(int code) {
+ public void setCode(final int code) {
this.code = code;
}
@@ -102,7 +99,7 @@ public String getDesc() {
*
* @param desc the desc
*/
- public void setDesc(String desc) {
+ public void setDesc(final String desc) {
this.desc = desc;
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/TransactionStatusEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/TransactionStatusEnum.java
index d7525484..77e93363 100644
--- a/raincat-common/src/main/java/com/raincat/common/enums/TransactionStatusEnum.java
+++ b/raincat-common/src/main/java/com/raincat/common/enums/TransactionStatusEnum.java
@@ -15,6 +15,7 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.enums;
import java.util.Arrays;
@@ -22,9 +23,9 @@
import java.util.Optional;
/**
+ * TransactionStatusEnum.
* @author xiaoyu
*/
-
public enum TransactionStatusEnum {
/**
@@ -68,13 +69,12 @@ public enum TransactionStatusEnum {
private String desc;
- TransactionStatusEnum(int code, String desc) {
+ TransactionStatusEnum(final int code, final String desc) {
this.code = code;
this.desc = desc;
}
-
- public static TransactionStatusEnum acquireByCode(int code) {
+ public static TransactionStatusEnum acquireByCode(final int code) {
Optional transactionStatusEnum =
Arrays.stream(TransactionStatusEnum.values())
.filter(v -> Objects.equals(v.getCode(), code))
@@ -83,7 +83,7 @@ public static TransactionStatusEnum acquireByCode(int code) {
}
- public static String acquireDescByCode(int code) {
+ public static String acquireDescByCode(final int code) {
return acquireByCode(code).getDesc();
}
@@ -101,7 +101,7 @@ public int getCode() {
*
* @param code the code
*/
- public void setCode(int code) {
+ public void setCode(final int code) {
this.code = code;
}
@@ -119,7 +119,7 @@ public String getDesc() {
*
* @param desc the desc
*/
- public void setDesc(String desc) {
+ public void setDesc(final String desc) {
this.desc = desc;
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/enums/TransactionTypeEnum.java b/raincat-common/src/main/java/com/raincat/common/enums/TransactionTypeEnum.java
deleted file mode 100644
index 32b7d06d..00000000
--- a/raincat-common/src/main/java/com/raincat/common/enums/TransactionTypeEnum.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/*
- *
- * Copyright 2017-2018 549477611@qq.com(xiaoyu)
- *
- * This copyrighted material is made available to anyone wishing to use, modify,
- * copy, or redistribute it subject to the terms and conditions of the GNU
- * Lesser General Public License, as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
- * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
- * for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this distribution; if not, see .
- *
- */
-package com.raincat.common.enums;
-
-
-/**
- * The enum Transaction type enum.
- * @author xiaoyu
- */
-public enum TransactionTypeEnum {
-
- /**
- * Root transaction type enum.
- */
- ROOT(1),
- /**
- * Branch transaction type enum.
- */
- BRANCH(2);
-
- /**
- * The Id.
- */
- int id;
-
- TransactionTypeEnum(int id) {
- this.id = id;
- }
-
- /**
- * Gets id.
- *
- * @return the id
- */
- public int getId() {
- return id;
- }
-
- /**
- * Value of transaction type enum.
- *
- * @param id the id
- * @return the transaction type enum
- */
- public static TransactionTypeEnum valueOf(int id) {
- switch (id) {
- case 1:
- return ROOT;
- case 2:
- return BRANCH;
- default:
- return null;
- }
- }
-
-}
diff --git a/raincat-common/src/main/java/com/raincat/common/exception/TransactionException.java b/raincat-common/src/main/java/com/raincat/common/exception/TransactionException.java
index 704b6c4a..c9d34d84 100644
--- a/raincat-common/src/main/java/com/raincat/common/exception/TransactionException.java
+++ b/raincat-common/src/main/java/com/raincat/common/exception/TransactionException.java
@@ -15,9 +15,11 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.exception;
/**
+ * TransactionException.
* @author xiaoyu
*/
public class TransactionException extends Exception {
@@ -26,15 +28,15 @@ public class TransactionException extends Exception {
public TransactionException() {
}
- public TransactionException(String message) {
+ public TransactionException(final String message) {
super(message);
}
- public TransactionException(String message, Throwable cause) {
+ public TransactionException(final String message, final Throwable cause) {
super(message, cause);
}
- public TransactionException(Throwable cause) {
+ public TransactionException(final Throwable cause) {
super(cause);
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/exception/TransactionIoException.java b/raincat-common/src/main/java/com/raincat/common/exception/TransactionIoException.java
index 68c68b0a..2ab8f369 100644
--- a/raincat-common/src/main/java/com/raincat/common/exception/TransactionIoException.java
+++ b/raincat-common/src/main/java/com/raincat/common/exception/TransactionIoException.java
@@ -15,20 +15,22 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.exception;
/**
+ * TransactionIoException.
* @author xiaoyu
*/
public class TransactionIoException extends RuntimeException {
private static final long serialVersionUID = 6508064607297986329L;
- public TransactionIoException(String message) {
+ public TransactionIoException(final String message) {
super(message);
}
- public TransactionIoException(Throwable e) {
+ public TransactionIoException(final Throwable e) {
super(e);
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/exception/TransactionRuntimeException.java b/raincat-common/src/main/java/com/raincat/common/exception/TransactionRuntimeException.java
index ac227fe2..466e0154 100644
--- a/raincat-common/src/main/java/com/raincat/common/exception/TransactionRuntimeException.java
+++ b/raincat-common/src/main/java/com/raincat/common/exception/TransactionRuntimeException.java
@@ -15,9 +15,11 @@
* along with this distribution; if not, see .
*
*/
+
package com.raincat.common.exception;
/**
+ * TransactionRuntimeException.
* @author xiaoyu
*/
public class TransactionRuntimeException extends RuntimeException {
@@ -26,15 +28,15 @@ public class TransactionRuntimeException extends RuntimeException {
public TransactionRuntimeException() {
}
- public TransactionRuntimeException(String message) {
+ public TransactionRuntimeException(final String message) {
super(message);
}
- public TransactionRuntimeException(String message, Throwable cause) {
+ public TransactionRuntimeException(final String message, final Throwable cause) {
super(message, cause);
}
- public TransactionRuntimeException(Throwable cause) {
+ public TransactionRuntimeException(final Throwable cause) {
super(cause);
}
}
diff --git a/raincat-common/src/main/java/com/raincat/common/holder/Assert.java b/raincat-common/src/main/java/com/raincat/common/holder/Assert.java
index dc8aea13..d9d5454a 100644
--- a/raincat-common/src/main/java/com/raincat/common/holder/Assert.java
+++ b/raincat-common/src/main/java/com/raincat/common/holder/Assert.java
@@ -17,11 +17,10 @@
*/
package com.raincat.common.holder;
-
import com.raincat.common.exception.TransactionRuntimeException;
-
/**
+ * Assert.
* @author xiaoyu
*/
public class Assert {
diff --git a/raincat-common/src/main/java/com/raincat/common/holder/BeanMapUtils.java b/raincat-common/src/main/java/com/raincat/common/holder/BeanMapUtils.java
deleted file mode 100644
index a0a11438..00000000
--- a/raincat-common/src/main/java/com/raincat/common/holder/BeanMapUtils.java
+++ /dev/null
@@ -1,187 +0,0 @@
-/*
- *
- * Copyright 2017-2018 549477611@qq.com(xiaoyu)
- *
- * This copyrighted material is made available to anyone wishing to use, modify,
- * copy, or redistribute it subject to the terms and conditions of the GNU
- * Lesser General Public License, as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
- * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
- * for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this distribution; if not, see .
- *
- */
-package com.raincat.common.holder;
-
-import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
-import org.springframework.cglib.beans.BeanMap;
-
-import java.io.IOException;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-
-/**
- * @author xiaoyu
- */
-public class BeanMapUtils {
-
- /**
- * 将对象装换为map
- *
- * @param bean
- * @return
- */
- public static Map beanToMap(T bean) {
- Map map = Maps.newHashMap();
- if (bean != null) {
- BeanMap beanMap = BeanMap.create(bean);
- for (Object key : beanMap.keySet()) {
- if (Objects.nonNull(beanMap.get(key))) {
- map.put(key + "", beanMap.get(key));
- }
-
- }
- }
- return map;
- }
-
- /**
- * 将map装换为javabean对象
- *
- * @param map
- * @param bean
- * @return
- */
- public static T mapToBean(Map map, T bean) {
- BeanMap beanMap = BeanMap.create(bean);
- beanMap.putAll(map);
- return bean;
- }
-
-
- public static T objectMapToBean(Map