文件名称:rocketmq_trans_message
文件大小:1.22MB
文件格式:ZIP
更新时间:2024-05-21 11:29:55
Java
rocketmq_trans_message 基于rocketmq上加入了基于数据库的事务消息的功能.官方的rocketmq阉割了此功能. 使用方法: 1.rocketmq配置文件中加入以下几个配置: jdbcURL=jdbc:mysql://xxxxx/xxxxx?useUnicode=true&characterEncoding=utf8&noAccessToProcedureBodies=true jdbcUser=xxxxx jdbcPassword=xxxxxx 2.打包 mvn -Dmaven.test.skip=true -Dcheckstyle.skip=true clean package install assembly:assembly -P release-all -U 3.example TransactionProducer 事务发送者 TransactionC