Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/HasonHuang/distributed-transaction-process
/ functions
Functions
684 in github.com/HasonHuang/distributed-transaction-process
⨍
Functions
684
◇
Types & classes
195
↓ 40 callers
Method
notNull
(Object obj, String key, Object... args)
ms-core/src/main/java/com/hason/dtp/core/utils/CheckUtil.java:27
↓ 29 callers
Method
getXid
获取事务ID. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:108
↓ 27 callers
Method
newInstance
()
ms-core/src/main/java/com/hason/dtp/core/utils/result/ResultBuilder.java:14
↓ 25 callers
Method
toString
()
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:78
↓ 24 callers
Method
put
(K key, V value)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:87
↓ 20 callers
Method
get
获取用户 @param userId 用户id @return {@code Result<User>}
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/api/UserApi.java:36
↓ 18 callers
Method
save
保存用户 @param user 用户 @return {@code Result<User>}
tcc-transaction/tcc-account-api/src/main/java/com/hason/dtp/tcc/account/api/UserApi.java:26
↓ 15 callers
Method
equals
(Object other)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/FactoryBuilder.java:120
↓ 15 callers
Method
getGlobalTransactionId
获取 XID 的全局事务标识符部分作为字节数组。
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:65
↓ 14 callers
Method
getTransactionRepository
获取事务库. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/TransactionConfigurator.java:24
↓ 14 callers
Method
isNotEmpty
(String value)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/StringUtils.java:9
↓ 13 callers
Method
getMessage
()
ms-core/src/main/java/com/hason/dtp/core/exception/ErrorResult.java:33
↓ 13 callers
Method
getParameterTypes
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/InvocationContext.java:44
↓ 13 callers
Method
getStatus
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:112
↓ 13 callers
Method
success
()
ms-core/src/main/java/com/hason/dtp/core/utils/result/Result.java:22
↓ 12 callers
Method
getMessageId
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:64
↓ 12 callers
Method
getTransactionManager
获取事务管理器. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/TransactionConfigurator.java:18
↓ 11 callers
Method
getBranchQualifier
获取 XID 的事务分支标识符部分作为字节数组。
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:73
↓ 10 callers
Method
byteArrayToUUID
(byte[] bytes)
tcc-transaction/tcc-framework/tcc-transaction-api/src/main/java/org/mengyun/tcctransaction/api/TransactionXid.java:134
↓ 10 callers
Method
getArgs
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/InvocationContext.java:32
↓ 10 callers
Method
getId
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/common/TransactionType.java:26
↓ 10 callers
Method
getId
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:45
↓ 10 callers
Method
getName
()
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:551
↓ 9 callers
Method
delete
删除事务日志记录. @param transaction
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionRepository.java:31
↓ 8 callers
Method
equals
(Object o)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:67
↓ 8 callers
Method
getValue
()
tcc-transaction/tcc-integral-api/src/main/java/com/hason/dtp/tcc/integral/entity/Point.java:52
↓ 8 callers
Method
notFalse
(boolean condition, String key, Object... args)
ms-core/src/main/java/com/hason/dtp/core/utils/CheckUtil.java:21
↓ 8 callers
Method
register
注册用户 @param user 用户 @return User
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/service/UserService.java:21
↓ 8 callers
Method
setEditTime
(LocalDateTime editTime)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:156
↓ 8 callers
Method
size
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:99
↓ 8 callers
Method
toString
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:39
↓ 8 callers
Method
update
更新事务日志记录. @param transaction
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionRepository.java:25
↓ 7 callers
Method
getBytes
()
ms-core/src/main/java/com/hason/dtp/core/support/FormModelMethodArgumentResolver.java:576
↓ 7 callers
Method
getConsumerQueue
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:96
↓ 7 callers
Method
getError
()
ms-core/src/main/java/com/hason/dtp/core/utils/result/Result.java:34
↓ 7 callers
Method
getUsername
()
tcc-transaction/tcc-account/src/main/java/com/hason/dtp/tcc/account/config/properties/TccDataSourceProperties.java:61
↓ 7 callers
Method
getVersion
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:169
↓ 7 callers
Method
toJson
Object可以是POJO,也可以是Collection或数组。 如果对象为Null, 返回"null". 如果集合为空集合, 返回"[]".
ms-core/src/main/java/com/hason/dtp/core/utils/JsonMapper.java:85
↓ 7 callers
Method
valueOf
(int id)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/common/TransactionType.java:30
↓ 6 callers
Method
create
创建订单 @param entity 订单参数 @return {@code Result<CapitalAccount>}
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/api/OrderApi.java:30
↓ 6 callers
Method
directSendNotCheck
直接发送消息,不检查参数合法性 @param message 消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:204
↓ 6 callers
Method
execute
(JedisPool jedisPool, JedisCallback<T> callback)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/helper/RedisHelper.java:72
↓ 6 callers
Method
getBody
()
ms-core/src/main/java/com/hason/dtp/core/support/tcc/TransactionEntity.java:44
↓ 6 callers
Method
getCurrentTransaction
获取当前事务. @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionManager.java:106
↓ 6 callers
Method
getLastUpdateTime
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:181
↓ 6 callers
Method
getRetriedCount
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:150
↓ 6 callers
Method
getTransactionType
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:121
↓ 6 callers
Method
getUserId
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:53
↓ 6 callers
Method
getUserPointQueue
()
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/config/properties/QueueMessageProperties.java:52
↓ 6 callers
Method
getZk
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/ZooKeeperTransactionRepository.java:150
↓ 6 callers
Method
notEmpty
(String str, String key, Object... args)
ms-core/src/main/java/com/hason/dtp/core/utils/CheckUtil.java:33
↓ 6 callers
Method
setDead
(Boolean dead)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:108
↓ 6 callers
Method
toString
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:107
↓ 5 callers
Method
closeStatement
(Statement stmt)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:332
↓ 5 callers
Method
containsKey
(Object key)
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:55
↓ 5 callers
Method
deserialize
(ObjectSerializer serializer, byte[] value)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/helper/TransactionSerializer.java:32
↓ 5 callers
Method
entrySet
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:63
↓ 5 callers
Method
getAmount
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/entity/CapitalOrder.java:69
↓ 5 callers
Method
getConnection
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:314
↓ 5 callers
Method
getMessageRetryCount
()
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:88
↓ 5 callers
Method
getTableName
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:342
↓ 5 callers
Method
getTxidPath
(Xid xid)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/ZooKeeperTransactionRepository.java:177
↓ 5 callers
Method
releaseConnection
(Connection con)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/JdbcTransactionRepository.java:322
↓ 5 callers
Method
serialize
(ObjectSerializer serializer, Transaction transaction)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/helper/TransactionSerializer.java:16
↓ 5 callers
Method
setMessageRetryCount
(Integer messageRetryCount)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:92
↓ 4 callers
Method
bytesToLong
(byte[] bytes)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/ByteUtils.java:15
↓ 4 callers
Method
changeStatus
改变订单的状态 @param id 订单ID @param toStatus 新状态
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/service/OrderService.java:41
↓ 4 callers
Method
create
创建事务日志记录. @param transaction
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/TransactionRepository.java:19
↓ 4 callers
Method
deserialize
Deserialize an object from the given binary data. @param bytes object binary representation @return the equivalent object instance
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/serializer/ObjectSerializer.java:23
↓ 4 callers
Method
findByUserId
根据用户 ID,获取资金账户 @param userId 用户 ID @return CapitalAccount
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/dao/CapitalAccountRepository.java:21
↓ 4 callers
Method
getBean
根据 Class 对象获取对应的实例 @param var1 Class 对象 @param <T> Class 的类型 @return Class 对象的实例
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/support/BeanFactory.java:18
↓ 4 callers
Method
getCode
()
ms-core/src/main/java/com/hason/dtp/core/exception/ErrorCode.java:30
↓ 4 callers
Method
getContext
()
ms-core/src/main/java/com/hason/dtp/core/support/tcc/TransactionEntity.java:36
↓ 4 callers
Method
getData
()
tcc-transaction/tcc-capital-api/src/main/java/com/hason/dtp/tcc/capital/dto/CreateOrderDto.java:28
↓ 4 callers
Method
getId
()
tcc-transaction/tcc-integral-api/src/main/java/com/hason/dtp/tcc/integral/entity/Point.java:36
↓ 4 callers
Method
getRedisKey
(String keyPrefix, Xid xid)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/helper/RedisHelper.java:19
↓ 4 callers
Method
getUsername
()
reliable-message-transaction/rm-account-api/src/main/java/com/hason/dtp/account/entity/User.java:61
↓ 4 callers
Method
isEmpty
(Collection collection)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/CollectionUtils.java:15
↓ 4 callers
Method
putToCache
放入缓存. @param transaction
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/repository/CachableTransactionRepository.java:116
↓ 4 callers
Method
serialize
Serialize the given object to binary data. @param t object to serialize @return the equivalent binary data
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/serializer/ObjectSerializer.java:15
↓ 4 callers
Method
setConsumerQueue
(String consumerQueue)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:100
↓ 4 callers
Method
setMessageBody
(String messageBody)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:84
↓ 4 callers
Method
setMessageDataType
(MessageDataType messageDataType)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:76
↓ 4 callers
Method
setMessageId
(String messageId)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:68
↓ 4 callers
Method
setStatus
(MessageStatus status)
reliable-message-transaction/rm-message-api/src/main/java/com/hason/dtp/message/entity/Message.java:116
↓ 4 callers
Method
updateTime
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:193
↓ 4 callers
Method
updateVersion
()
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:173
↓ 4 callers
Method
values
()
ms-core/src/main/java/com/hason/dtp/core/utils/MapWapper.java:103
↓ 3 callers
Method
changeStatus
(TransactionStatus status)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:125
↓ 3 callers
Method
commit
提交参与者事务(在Participant中调用).
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Terminator.java:48
↓ 3 callers
Method
confirmAndSend
确认并发送消息.
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:24
↓ 3 callers
Method
create
创建订单 @param user 用户 @param amount 订单金额 @return CapitalOrder
tcc-transaction/tcc-capital/src/main/java/com/hason/dtp/tcc/capital/service/OrderService.java:25
↓ 3 callers
Method
deleteByMessageId
根据消息ID删除消息
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageService.java:59
↓ 3 callers
Method
enlistParticipant
招募参与者(加入参与者) @param participant
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/Transaction.java:100
↓ 3 callers
Method
fail
(String key, Object... args)
ms-core/src/main/java/com/hason/dtp/core/utils/CheckUtil.java:39
↓ 3 callers
Method
findByStatusAndCreateTime
根据状态、创建时间、是否死亡,分页查询记录 @param status 状态 @param dead 是否死亡 @param createTimeBefore 创建时间在 createTimeBefore 之前 @param pageable 分页参数 @return Page
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/dao/MessageRepository.java:50
↓ 3 callers
Method
findByUserId
根据用户ID,获取积分记录 @param userId 用户ID @return Point
tcc-transaction/tcc-integral/src/main/java/com/hason/dtp/tcc/integral/dao/PointRepository.java:21
↓ 3 callers
Method
getByMessageId
(String messageId)
reliable-message-transaction/rm-message/src/main/java/com/hason/dtp/message/service/MessageServiceImpl.java:146
↓ 3 callers
Method
getCompensable
根据切点,获取事务注解. @param pjp @return
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/interceptor/ResourceCoordinatorInterceptor.java:227
↓ 3 callers
Method
getDeclaringType
(Class aClass, String methodName, Class<?>[] parameterTypes)
tcc-transaction/tcc-framework/tcc-transaction-core/src/main/java/org/mengyun/tcctransaction/utils/ReflectionUtils.java:12
next →
1–100 of 684, ranked by callers