首页下载资源行业研究该框架是基于消息队列的分布式事务解决方案.zip

ZIP该框架是基于消息队列的分布式事务解决方案.zip

rita_0567251.92KB需要积分:1

资源文件列表:

该框架是基于消息队列的分布式事务解决方案（ReliableMessageDistributedTransaction），框架.zip 大约有220个文件
  1. rmdt-master/LICENSE 11.08KB
  2. rmdt-master/rmdt-dubbo/target/classes/org/rmdt/dubbo/proxy/RmdtProxyFactory.class 1.39KB
  3. rmdt-master/rmdt-dubbo/target/classes/org/rmdt/dubbo/proxy/RmdtInvokerInvocationHandler.class 6.38KB
  4. rmdt-master/rmdt-dubbo/target/classes/org/rmdt/dubbo/service/DubboApplicationService.class 1009B
  5. rmdt-master/rmdt-dubbo/target/classes/org/rmdt/dubbo/interceptor/DubboRmdtTransactionInterceptor.class 2.89KB
  6. rmdt-master/rmdt-dubbo/target/classes/org/rmdt/dubbo/interceptor/DubboRmdtTransactionAspect.class 839B
  7. rmdt-master/rmdt-dubbo/target/classes/META-INF/dubbo/com.alibaba.dubbo.rpc.ProxyFactory 54B
  8. rmdt-master/rmdt-dubbo/pom.xml 808B
  9. rmdt-master/rmdt-dubbo/src/main/resources/META-INF/dubbo/com.alibaba.dubbo.rpc.ProxyFactory 54B
  10. rmdt-master/rmdt-dubbo/src/main/java/org/rmdt/dubbo/proxy/RmdtProxyFactory.java 1.71KB
  11. rmdt-master/rmdt-dubbo/src/main/java/org/rmdt/dubbo/proxy/RmdtInvokerInvocationHandler.java 6.66KB
  12. rmdt-master/rmdt-dubbo/src/main/java/org/rmdt/dubbo/service/DubboApplicationService.java 705B
  13. rmdt-master/rmdt-dubbo/src/main/java/org/rmdt/dubbo/interceptor/DubboRmdtTransactionInterceptor.java 2.39KB
  14. rmdt-master/rmdt-dubbo/src/main/java/org/rmdt/dubbo/interceptor/DubboRmdtTransactionAspect.java 568B
  15. rmdt-master/pom.xml 3.37KB
  16. rmdt-master/README.md 16.77KB
  17. rmdt-master/rmdt-common/target/classes/org/rmdt/common/context/RmdtTransactionContext.class 1.09KB
  18. rmdt-master/rmdt-common/target/classes/org/rmdt/common/config/RmdtConfig.class 2.56KB
  19. rmdt-master/rmdt-common/target/classes/org/rmdt/common/config/repository/JdbcRepositoryConfig.class 4.08KB
  20. rmdt-master/rmdt-common/target/classes/org/rmdt/common/config/repository/BaseRepositoryConfig.class 650B
  21. rmdt-master/rmdt-common/target/classes/org/rmdt/common/config/repository/RedisRepositoryConfig.class 1017B
  22. rmdt-master/rmdt-common/target/classes/org/rmdt/common/config/message/ActivemqMessageConfig.class 1005B
  23. rmdt-master/rmdt-common/target/classes/org/rmdt/common/config/message/BaseMessageConfig.class 338B
  24. rmdt-master/rmdt-common/target/classes/org/rmdt/common/enums/MessageEnum.class 1.51KB
  25. rmdt-master/rmdt-common/target/classes/org/rmdt/common/enums/TransactionRoleEnum.class 1.64KB
  26. rmdt-master/rmdt-common/target/classes/org/rmdt/common/enums/TransactionStatusEnum.class 1.78KB
  27. rmdt-master/rmdt-common/target/classes/org/rmdt/common/enums/TransactionEventEnum.class 1.56KB
  28. rmdt-master/rmdt-common/target/classes/org/rmdt/common/constant/RmdtConstant.class 800B
  29. rmdt-master/rmdt-common/target/classes/org/rmdt/common/thread/RmdtTransactionThreadFactory.class 1.14KB
  30. rmdt-master/rmdt-common/target/classes/org/rmdt/common/thread/RmdtTransactionThreadLocal.class 974B
  31. rmdt-master/rmdt-common/target/classes/org/rmdt/common/domain/RPCErrorInfo.class 894B
  32. rmdt-master/rmdt-common/target/classes/org/rmdt/common/domain/Transaction.class 3.22KB
  33. rmdt-master/rmdt-common/target/classes/org/rmdt/common/domain/Participant.class 2.09KB
  34. rmdt-master/rmdt-common/pom.xml 488B
  35. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/context/RmdtTransactionContext.java 519B
  36. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/config/repository/RedisRepositoryConfig.java 323B
  37. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/config/repository/BaseRepositoryConfig.java 617B
  38. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/config/repository/JdbcRepositoryConfig.java 930B
  39. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/config/RmdtConfig.java 1.09KB
  40. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/config/message/BaseMessageConfig.java 166B
  41. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/config/message/ActivemqMessageConfig.java 278B
  42. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/enums/MessageEnum.java 1.14KB
  43. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/enums/TransactionRoleEnum.java 409B
  44. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/enums/TransactionStatusEnum.java 473B
  45. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/enums/TransactionEventEnum.java 1.14KB
  46. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/constant/RmdtConstant.java 710B
  47. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/thread/RmdtTransactionThreadLocal.java 817B
  48. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/thread/RmdtTransactionThreadFactory.java 685B
  49. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/domain/Participant.java 832B
  50. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/domain/RPCErrorInfo.java 258B
  51. rmdt-master/rmdt-common/src/main/java/org/rmdt/common/domain/Transaction.java 1.03KB
  52. rmdt-master/rmdt-annotation/rmdt-annotation.iml 80B
  53. rmdt-master/rmdt-annotation/target/classes/org/rmdt/annotation/Rmdt.class 577B
  54. rmdt-master/rmdt-annotation/target/classes/org/rmdt/annotation/Listener.class 585B
  55. rmdt-master/rmdt-annotation/pom.xml 661B
  56. rmdt-master/rmdt-annotation/src/main/java/org/rmdt/annotation/Rmdt.java 676B
  57. rmdt-master/rmdt-annotation/src/main/java/org/rmdt/annotation/Listener.java 515B
  58. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/org/rmdt/demo/config/GoodsServerConfig.class 1.82KB
  59. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/org/rmdt/demo/mapper/InventoryMapper.class 556B
  60. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/org/rmdt/demo/message/GoodsMessageListener.class 576B
  61. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/org/rmdt/demo/service/impl/InventoryServiceImpl.class 2.01KB
  62. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/org/rmdt/demo/GoodsApp.class 862B
  63. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/generatorConfig.xml 4.48KB
  64. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/mapper/InventoryMapper.xml 2.39KB
  65. rmdt-master/rmdt-demo/rmdt-demo-goods-server/target/classes/application.yml 750B
  66. rmdt-master/rmdt-demo/rmdt-demo-goods-server/pom.xml 2.24KB
  67. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/resources/generatorConfig.xml 4.48KB
  68. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/resources/mapper/InventoryMapper.xml 2.39KB
  69. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/resources/application.yml 750B
  70. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/java/org/rmdt/demo/config/GoodsServerConfig.java 1.62KB
  71. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/java/org/rmdt/demo/GoodsApp.java 490B
  72. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/java/org/rmdt/demo/mapper/InventoryMapper.java 425B
  73. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/java/org/rmdt/demo/message/GoodsMessageListener.java 295B
  74. rmdt-master/rmdt-demo/rmdt-demo-goods-server/src/main/java/org/rmdt/demo/service/impl/InventoryServiceImpl.java 1.32KB
  75. rmdt-master/rmdt-demo/rmdt-demo-goods-api/target/classes/org/rmdt/demo/vo/InventoryVo.class 827B
  76. rmdt-master/rmdt-demo/rmdt-demo-goods-api/target/classes/org/rmdt/demo/service/InventoryService.class 373B
  77. rmdt-master/rmdt-demo/rmdt-demo-goods-api/target/classes/org/rmdt/demo/domain/Inventory.class 1.45KB
  78. rmdt-master/rmdt-demo/rmdt-demo-goods-api/pom.xml 675B
  79. rmdt-master/rmdt-demo/rmdt-demo-goods-api/src/main/java/org/rmdt/demo/vo/InventoryVo.java 239B
  80. rmdt-master/rmdt-demo/rmdt-demo-goods-api/src/main/java/org/rmdt/demo/service/InventoryService.java 318B
  81. rmdt-master/rmdt-demo/rmdt-demo-goods-api/src/main/java/org/rmdt/demo/domain/Inventory.java 342B
  82. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/org/rmdt/demo/config/MemberServerConfig.class 1.82KB
  83. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/org/rmdt/demo/MemberApp.class 865B
  84. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/org/rmdt/demo/mapper/UserAccountMapper.class 562B
  85. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/org/rmdt/demo/message/MemberMessageListener.class 579B
  86. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/org/rmdt/demo/service/impl/UserAccountServiceImpl.class 2.07KB
  87. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/generatorConfig.xml 4.49KB
  88. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/mapper/UserAccountMapper.xml 2.3KB
  89. rmdt-master/rmdt-demo/rmdt-demo-member-server/target/classes/application.yml 752B
  90. rmdt-master/rmdt-demo/rmdt-demo-member-server/pom.xml 2.24KB
  91. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/resources/generatorConfig.xml 4.49KB
  92. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/resources/mapper/UserAccountMapper.xml 2.3KB
  93. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/resources/application.yml 752B
  94. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/java/org/rmdt/demo/config/MemberServerConfig.java 1.63KB
  95. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/java/org/rmdt/demo/MemberApp.java 492B
  96. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/java/org/rmdt/demo/mapper/UserAccountMapper.java 433B
  97. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/java/org/rmdt/demo/message/MemberMessageListener.java 296B
  98. rmdt-master/rmdt-demo/rmdt-demo-member-server/src/main/java/org/rmdt/demo/service/impl/UserAccountServiceImpl.java 1.36KB
  99. rmdt-master/rmdt-demo/rmdt-demo-member-api/target/classes/org/rmdt/demo/vo/UserAccountVo.class 851B
  100. rmdt-master/rmdt-demo/rmdt-demo-member-api/target/classes/org/rmdt/demo/service/UserAccountService.class 377B
  101. rmdt-master/rmdt-demo/rmdt-demo-member-api/target/classes/org/rmdt/demo/domain/UserAccount.class 1.43KB
  102. rmdt-master/rmdt-demo/rmdt-demo-member-api/pom.xml 676B
  103. rmdt-master/rmdt-demo/rmdt-demo-member-api/src/main/java/org/rmdt/demo/vo/UserAccountVo.java 276B
  104. rmdt-master/rmdt-demo/rmdt-demo-member-api/src/main/java/org/rmdt/demo/service/UserAccountService.java 321B
  105. rmdt-master/rmdt-demo/rmdt-demo-member-api/src/main/java/org/rmdt/demo/domain/UserAccount.java 367B
  106. rmdt-master/rmdt-demo/mvnw.cmd 5.67KB
  107. rmdt-master/rmdt-demo/rmdt-demo-order-api/target/classes/org/rmdt/demo/service/OrderInfoService.class 364B
  108. rmdt-master/rmdt-demo/rmdt-demo-order-api/target/classes/org/rmdt/demo/domain/OrderInfo.class 1.92KB
  109. rmdt-master/rmdt-demo/rmdt-demo-order-api/pom.xml 956B
  110. rmdt-master/rmdt-demo/rmdt-demo-order-api/src/main/java/org/rmdt/demo/service/OrderInfoService.java 464B
  111. rmdt-master/rmdt-demo/rmdt-demo-order-api/src/main/java/org/rmdt/demo/domain/OrderInfo.java 421B
  112. rmdt-master/rmdt-demo/pom.xml 1.88KB
  113. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/org/rmdt/demo/OrderApp.class 862B
  114. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/org/rmdt/demo/config/OrderServerConfig.class 1.82KB
  115. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/org/rmdt/demo/enums/OrderStatusEnum.class 1.7KB
  116. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/org/rmdt/demo/mapper/OrderInfoMapper.class 465B
  117. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/org/rmdt/demo/service/impl/OrderInfoServiceImpl.class 3.28KB
  118. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/generatorConfig.xml 4.48KB
  119. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/mapper/OrderInfoMapper.xml 2.16KB
  120. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/META-INF/services/org.wolfcode.rmdt.core.repository.RmdtTransactionRepository
  121. rmdt-master/rmdt-demo/rmdt-demo-order-server/target/classes/application.yml 750B
  122. rmdt-master/rmdt-demo/rmdt-demo-order-server/pom.xml 2.24KB
  123. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/resources/generatorConfig.xml 4.48KB
  124. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/resources/mapper/OrderInfoMapper.xml 2.16KB
  125. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/resources/META-INF/services/org.wolfcode.rmdt.core.repository.RmdtTransactionRepository
  126. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/resources/application.yml 750B
  127. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/java/org/rmdt/demo/OrderApp.java 490B
  128. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/java/org/rmdt/demo/config/OrderServerConfig.java 1.62KB
  129. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/java/org/rmdt/demo/enums/OrderStatusEnum.java 416B
  130. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/java/org/rmdt/demo/mapper/OrderInfoMapper.java 327B
  131. rmdt-master/rmdt-demo/rmdt-demo-order-server/src/main/java/org/rmdt/demo/service/impl/OrderInfoServiceImpl.java 2.88KB
  132. rmdt-master/rmdt-demo/rmdt-demo-client/target/classes/org/rmdt/demo/ClientApp.class 777B
  133. rmdt-master/rmdt-demo/rmdt-demo-client/target/classes/org/rmdt/demo/controller/OrderController.class 1.21KB
  134. rmdt-master/rmdt-demo/rmdt-demo-client/target/classes/application.yml 318B
  135. rmdt-master/rmdt-demo/rmdt-demo-client/pom.xml 1.24KB
  136. rmdt-master/rmdt-demo/rmdt-demo-client/src/main/resources/application.yml 318B
  137. rmdt-master/rmdt-demo/rmdt-demo-client/src/main/java/org/rmdt/demo/controller/OrderController.java 784B
  138. rmdt-master/rmdt-demo/rmdt-demo-client/src/main/java/org/rmdt/demo/ClientApp.java 407B
  139. rmdt-master/rmdt-demo/rmdt-demo-goods.sql 969B
  140. rmdt-master/rmdt-demo/.gitignore 268B
  141. rmdt-master/rmdt-demo/.mvn/wrapper/maven-wrapper.properties 116B
  142. rmdt-master/rmdt-demo/.mvn/wrapper/maven-wrapper.jar 47.2KB
  143. rmdt-master/rmdt-demo/rmdt-demo-member.sql 987B
  144. rmdt-master/rmdt-demo/mvnw 8.9KB
  145. rmdt-master/rmdt-demo/rmdt-demo-order.sql 896B
  146. rmdt-master/rmdt-core/target/classes/org/rmdt/core/repository/impl/RedisTransactionRepository.class 1.82KB
  147. rmdt-master/rmdt-core/target/classes/org/rmdt/core/repository/impl/JdbcTransactionRepository.class 13.22KB
  148. rmdt-master/rmdt-core/target/classes/org/rmdt/core/repository/RmdtTransactionRepository.class 704B
  149. rmdt-master/rmdt-core/target/classes/org/rmdt/core/coordinator/RmdtTransactionCoordinatorSupport.class 6.78KB
  150. rmdt-master/rmdt-core/target/classes/org/rmdt/core/coordinator/RmdtTransactionCoordinator.class 408B
  151. rmdt-master/rmdt-core/target/classes/org/rmdt/core/coordinator/StartTransactionCoordinator.class 2.51KB
  152. rmdt-master/rmdt-core/target/classes/org/rmdt/core/coordinator/ActorTransactionCoordinator.class 2.57KB
  153. rmdt-master/rmdt-core/target/classes/org/rmdt/core/coordinator/LocalTransactionCoordinator.class 1.42KB
  154. rmdt-master/rmdt-core/target/classes/org/rmdt/core/bootstrap/RmdtBootstrapSupport.class 5.21KB
  155. rmdt-master/rmdt-core/target/classes/org/rmdt/core/bootstrap/RmdtBootstrap.class 1.5KB
  156. rmdt-master/rmdt-core/target/classes/org/rmdt/core/bootstrap/ApplicationContextHolder.class 1.64KB
  157. rmdt-master/rmdt-core/target/classes/org/rmdt/core/serialize/impl/JavaSerializer.class 3.27KB
  158. rmdt-master/rmdt-core/target/classes/org/rmdt/core/serialize/ObjectSerializer.class 378B
  159. rmdt-master/rmdt-core/target/classes/org/rmdt/core/message/impl/KafkaTransactionMessage.class 1.52KB
  160. rmdt-master/rmdt-core/target/classes/org/rmdt/core/message/impl/ActivemqTransactionMessage.class 7.04KB
  161. rmdt-master/rmdt-core/target/classes/org/rmdt/core/message/RmdtTransactionMessage.class 586B
  162. rmdt-master/rmdt-core/target/classes/org/rmdt/core/disruptor/RmdtTransactionEventExceptionHandler.class 1.47KB
  163. rmdt-master/rmdt-core/target/classes/org/rmdt/core/disruptor/RmdtTransactionEvent.class 951B
  164. rmdt-master/rmdt-core/target/classes/org/rmdt/core/disruptor/RmdtTransactionEventConsumer.class 1.83KB
  165. rmdt-master/rmdt-core/target/classes/org/rmdt/core/disruptor/RmdtTransactionEventTranslator.class 1.37KB
  166. rmdt-master/rmdt-core/target/classes/org/rmdt/core/disruptor/RmdtTransactionEventProducer.class 2.61KB
  167. rmdt-master/rmdt-core/target/classes/org/rmdt/core/disruptor/RmdtTransactionEventFactory.class 793B
  168. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/impl/RmdtSchedulerRecoverServiceImpl.class 4.79KB
  169. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/impl/RmdtRepositoryServiceImpl.class 2.65KB
  170. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/impl/RmdtCoordinatorServiceImpl.class 1.71KB
  171. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/impl/RmdtInvocationServiceImpl.class 5.51KB
  172. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/impl/RmdtMQServiceImpl.class 4.33KB
  173. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/RmdtRepositoryService.class 545B
  174. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/RmdtInvocationService.class 269B
  175. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/RmdtCoordinatorService.class 283B
  176. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/RmdtSchedulerRecoverService.class 236B
  177. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/RmdtApplicationService.class 188B
  178. rmdt-master/rmdt-core/target/classes/org/rmdt/core/service/RmdtMQService.class 250B
  179. rmdt-master/rmdt-core/target/classes/org/rmdt/core/interceptor/AbstractRmdtTransactionAspect.class 1.36KB
  180. rmdt-master/rmdt-core/target/classes/org/rmdt/core/interceptor/RmdtTransactionInterceptor.class 290B
  181. rmdt-master/rmdt-core/target/classes/META-INF/services/org.rmdt.core.repository.RmdtTransactionRepository 112B
  182. rmdt-master/rmdt-core/target/classes/META-INF/services/org.rmdt.core.message.RmdtTransactionMessage 104B
  183. rmdt-master/rmdt-core/pom.xml 1.33KB
  184. rmdt-master/rmdt-core/src/main/resources/META-INF/services/org.rmdt.core.repository.RmdtTransactionRepository 112B
  185. rmdt-master/rmdt-core/src/main/resources/META-INF/services/org.rmdt.core.message.RmdtTransactionMessage 104B
  186. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/repository/impl/RedisTransactionRepository.java 1.02KB
  187. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/repository/impl/JdbcTransactionRepository.java 9.82KB
  188. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/repository/RmdtTransactionRepository.java 1.3KB
  189. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/coordinator/RmdtTransactionCoordinatorSupport.java 6.6KB
  190. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/coordinator/ActorTransactionCoordinator.java 2.35KB
  191. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/coordinator/LocalTransactionCoordinator.java 1.08KB
  192. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/coordinator/StartTransactionCoordinator.java 2.14KB
  193. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/coordinator/RmdtTransactionCoordinator.java 823B
  194. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/bootstrap/RmdtBootstrapSupport.java 4.7KB
  195. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/bootstrap/RmdtBootstrap.java 1.44KB
  196. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/bootstrap/ApplicationContextHolder.java 972B
  197. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/serialize/impl/JavaSerializer.java 1.97KB
  198. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/serialize/ObjectSerializer.java 1.02KB
  199. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/message/impl/ActivemqTransactionMessage.java 5.92KB
  200. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/message/impl/KafkaTransactionMessage.java 983B
  201. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/message/RmdtTransactionMessage.java 1.5KB
  202. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/disruptor/RmdtTransactionEventTranslator.java 959B
  203. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/disruptor/RmdtTransactionEventExceptionHandler.java 884B
  204. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/disruptor/RmdtTransactionEventConsumer.java 1.29KB
  205. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/disruptor/RmdtTransactionEventFactory.java 336B
  206. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/disruptor/RmdtTransactionEvent.java 369B
  207. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/disruptor/RmdtTransactionEventProducer.java 3.54KB
  208. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/impl/RmdtCoordinatorServiceImpl.java 1.74KB
  209. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/impl/RmdtInvocationServiceImpl.java 7.77KB
  210. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/impl/RmdtSchedulerRecoverServiceImpl.java 2.57KB
  211. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/impl/RmdtMQServiceImpl.java 1.75KB
  212. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/impl/RmdtRepositoryServiceImpl.java 2KB
  213. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/RmdtRepositoryService.java 905B
  214. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/RmdtMQService.java 485B
  215. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/RmdtCoordinatorService.java 485B
  216. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/RmdtApplicationService.java 236B
  217. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/RmdtInvocationService.java 797B
  218. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/service/RmdtSchedulerRecoverService.java 216B
  219. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/interceptor/AbstractRmdtTransactionAspect.java 1.3KB
  220. rmdt-master/rmdt-core/src/main/java/org/rmdt/core/interceptor/RmdtTransactionInterceptor.java 318B

资源介绍:

该框架是基于消息队列的分布式事务解决方案.zip
## 概述   该框架是基于消息队列的分布式事务解决方案（Reliable Message Distributed Transaction），框架名简称为RMDT。主要是为了解决分布式应用服务化后，事务不能保持一致性的问题。框架详情和架构设计可查看我的个人博客： > http://blog.iloveyoubaby.online/space/java?currentPage=1&tag=%E5%88%86%E5%B8%83%E5%BC%8F%E4%BA%8B%E5%8A%A1 或者简书账号：LuoHaiPeng 码云地址：luohiapeng/rmdt ## 技术选型 **开发工具** - IDEA - Maven - Git **框架** - SpringBoot - Dubbo - Mybatis **中间件** - MySQL - Zookeeper - ActiveMQ **其他工具** - Lombok - Disruptor **补充说明**   对于技术选型有几点需要说明的，第一点是：该框架直接使用Springboot构建，简化了我们构建项目和开发过程。同时使用了Spring IOC，并没有自己实现IOC，虽然这样会对Spring框架强依赖，但是我们要关注的核心是分布式事务，而不是IOC。     第二点是：我们知道，市面上流行的分布式应用框架有很多，比如Dubbo、SpringCloud、Motan等，不同的框架有不同的实现细节，要让我们这个分布式事务框架支持市面上流行的分布式应用框架，那就必须做很多对应的适配工作，而我们时间有限，第一个版本先支持Dubbo，后续有时间再做扩展，或者大家可以贡献适配的代码。   第三点是：Mybatis和Zookeeper并不是框架本身使用的，而是Demo项目使用的，框架本身操作关系型数据库没有依赖任何第三方ORM框架，而是直接使用JDBC操作。至于Zookeeper，就是Demo项目使用Dubbo搭建的一个分布式应用，服务的发现和注册使用Zookeeper中间件。   第四点是：框架本身需要MySQL和ActiveMQ中间件支持，MySQL用于存储事务日志数据，ActiveMQ用于发送事务消息，但是框架内部并没有使用硬编码的方式集成这两个中间件，而是支持动态扩展，换句话说就是：存储事务日志的中间件可以通过配置的方式，切换为任意的存储技术，比如可以切换为Redis、MangoDB等。同理，消息中间件也是可以通过配置切换为常用的RabbitMQ、RocketMQ、Kafka等。具体如何配置看下文。 ## 模块说明   整个项目包含以下几个子模块：rmdt-core，rmdt-common， rmdt-annotation，rmdt-dubbo，rmdt-demo。 ![项目模块](https://upload-images.jianshu.io/upload_images/10574922-135075f68fe9027f.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240) 我们来看看每个模块的作用： - rmdt-core 顾名思义，它就是存放核心代码的模块，整个项目所有处理流程和逻辑类都放到这里。 - rmdt-common 存放一些各个子模块有可能会用到的公共文件，公共类和公共的配置。 - rmdt-annotation 存放注解的模块，我们之前说了，要让别人用起来简单，最好贴个注解就能有对应的功能，所以我们涉及到的注解的定义都放到这里。但实际上，整个项目肯定不可能有很多注解，把这为数不多的注解放到一个模块中，最主要的目的是，别人在使用框架时，可以导入最少依赖。什么意思呢？举个例子：如果是使用Dubbo作为分布式框架，那么肯定会有API这样的子项目，API项目中放的是对外提供服务的接口类，那就有可能我们的注解就需要贴在这些接口类的抽象方法上，而这种API项目是不会有具体实现逻辑的，所以它能用的上的就只有注解，不会使用我们的core、common，这些模块中的类，那这样的话，这个API项目就只导入annotation这个模块的依赖就行了。所以，这就是为什么几个注解类，也要单独放一个模块。 - rmdt-dubbo 我们在之前的设计稿中可以知道，调用远程RPC方法前，需要给RPC地址添加参数，但是每种具体的分布式应用框架传参都是不一样的，比如Dubbo和SpringCloud就有很大的区别，SpringCloud相对来说要简单很多，因为它就是一个RESTful资源路径而已，往该资源路径再追加一个参数很简单，而如果大家对Dubbo的源码有了解的话，就知道往RPC地址加参数，需要做比较多的事情。所以，为了后面框架的扩展，每一种分布式应用框架的支持，都单独创建一个模块，比如，现在我们框架需要支持Dubbo，那么就创建一个rmdt-dubbo的模块，用户存放处理远程方法调用和参数传递的类和文件。同理，如果对框架扩展，让它也能支持SpringCloud，就需要再创建一个rmdt-springcloud的模块。 - rmdt-demo 该模块主要是用于方便测试功能的，其实就是我们经常说的业务项目了，它不是框架的一部分，但为了能让自己开发方便，和别人测试使用方便，就把demo放到了框架中。其中，我们可以看到，rmdt-demo模块下多了7个子模块，对Dubbo项目比较熟悉的小伙伴，应该不用过多的解析了，这7个模块都是业务类的项目，他们分别为： - rmdt-demo-client 作为服务消费者项目，也就是我们说的客户端。 - rmdt-demo-goods-api和rmdt-demo-goods-server 共同构成商品系统项目，其中api为对外提供的服务接口，server为具体的服务实现。 - rmdt-demo-member-api和rmdt-demo-member-server 共同构成会员系统项目，其中api为对外提供的服务接口，server为具体的服务实现。 - rmdt-demo-order-api和rmdt-demo-order-server 共同构成订单系统项目，其中api为对外提供的服务接口，server为具体的服务实现。 ## 功能演示说明   我们可以运行框架中的demo项目，了解框架的功能效果。但在运行前，先简单解析一下这个demo项目的业务（注意：demo只是模拟业务需求，并发真实逻辑）：*客户端发起RPC请求，调用远程订单系统中的付款方法makePayment。在makePayment方法中有两个操作：分别是发送两个RPC请求，调用远程会员系统的付款方法payment，和远程商品系统的扣库存方法decrease*，在这个模拟的业务需求中，我们可以测试出分布式事务的问题，因为payment和decrease分别做付款和扣库存的操作，这两个操作是同一个事务的，要么两个都成功，要么两个都失败，但是由于现在的架构是分布式应用，他们各自都运行在自己的JVM中，这就不能确保事务一致性了。而使用了RMDT框架后，就能确保分布式事务的一致性了，**实现原理在之前的分析文章中已经讲过了，这里就不再提及**。那么接下来，我们来启动demo项目。 - 1、导入代码 把GitHub上的该项目clone下来，导入到IDEA或者Eclipse（推荐使用IDEA），稍等片刻，让开发工具把环境build好。 - 2、导入测试数据 项目clone下来后，在rmdt-demo模块中下有3个SQL文件： ![](https://upload-images.jianshu.io/upload_images/10574922-9266fe706c909670.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240) 在自己本地MySQL服务创建3个数据库rmdt-demo-goods，rmdt-demo-member，rmdt-demo-order，分别是给商品系统，会员系统和订单系统使用，创建好这3个数据库后，把这3个SQL文件分别导入到以上3个数据库中： ![](https://upload-images.jianshu.io/upload_images/10574922-b3f16dbdf7f8f45d.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240) - 3、启动zookeeper 由于使用到了zookeeper作为服务发现和注册中心，而配置文件中，连接的zookeeper地址是本地，所以需要在自己本地电脑启动zookeeper服务 ![](https://upload-images.jianshu.io/upload_images/10574922-40a70c334d332878.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240) - 4、启动ActiveMQ ActiveMQ用于发送事务消息，给框架�
100+评论
captcha

    相关资源

    1. iFRPFILE AIO v2.8.6.zip

      qq_21051503#前端ZIP39.27MB5月前
      资源摘要:iFRPFILE AIO v2.8.6.zip

    2. 梦幻西游道人j20240924

      m0_72280720#后端ZIP54.78MB5月前
      资源摘要:梦幻西游道人是梦幻西游里面的一个NPC，主要是刷全服最实惠的高级兽决和其他很好用的比较贵的东西，在长安城、傲来国、长寿村中的任意一个场景出现，一般会出现30分钟，不过东西一般都被秒刷。梦幻西游道人出现时间解析如下：1.梦幻西游道人出现时间一直都保持着一年出现两次的规律，即2、3月份的元宵节期间来一次，9月份的教师节期间出现一次。2.云游道人每个整点(0:00至7:00不出现)会在长安城、傲来国、长寿村中的任意一个场景出现,每次出现后停留时间为30分钟。

    3. 数据结构C语言版PPT-230901.zip

      2401_83428938#行业研究ZIP37.3MB5月前
      资源摘要:数据结构C语言版PPT-230901.zip

    4. 模仿大富翁游戏，使用JavaSwing(GUI)实现的单机游戏，遵循MVC设计模式 CreatedinJava.Usi.zip

      pingguocu3#后端ZIP13.39MB5月前
      资源摘要:模仿大富翁游戏，使用JavaSwing(GUI)实现的单机游戏，遵循MVC设计模式。CreatedinJava.Usi.zip

    5. 基于领域驱动设计模式，开发一个售后补偿微服务.zip

      rita_0567#行业研究ZIP117.36KB5月前
      资源摘要:基于领域驱动设计模式，开发一个售后补偿微服务。

    6. 33种设计模式实现(C、C++).zip

      rita_0567#行业研究ZIP488.78KB5月前
      资源摘要:33种设计模式实现(C、C++)

    7. 常见的设计模式Django撰写.zip

      rita_0567#行业研究ZIP13.13KB5月前
      资源摘要:常见的设计模式Django撰写

    8. （2015）（Python）24种设计模式.zip

      rita_0567#行业研究ZIP41.99KB5月前
      资源摘要:（2015）（Python）24种设计模式
    站长QQ:九六九五七三七