TransactionOptions options = TransactionOptions.defaults()
//参与事务的Redis主服务器与其从服务器之间的同步数据超时。
//默认值为5000毫秒
options.syncSlavesTimeout(5, TimeUnit.SECONDS);
//响应超时
//默认值为3000毫秒
options.responseTimeout(3, TimeUnit.SECONDS);
//定义每次尝试发送事务的时间间隔（如果尚未发送）。
//默认值为1500毫秒
options.retryInterval(2, TimeUnit.SECONDS)//定义发送事务的尝试次数（如果尚未发送）。
//默认为3次尝试
options.retryAttempts(3)
//如果事务尚未在超时内提交，它将自动回滚。
//默认值为5000毫秒
options.timeout(5, TimeUnit.SECONDS);复制代码

@Configuration
@EnableTransactionManagementpublic
public class RedissonTransactionContextConfig {@Bean public TransactionalBean transactionBean() {return new TransactionalBean(); } @Bean public RedissonTransactionManager transactionManager(RedissonClient redisson) { return new RedissonTransactionManager(redisson); } @Bean public RedissonClient redisson() { return BaseTest.createInstance(); }@PreDestroypublic void destroy() { redisson().shutdown(); }
}
public class TransactionalBean { @Autowired private RedissonTransactionManager transactionManager; @Transactional public void commitData() { RTransaction transaction = transactionManager.getCurrentTransaction(); RMap map = transaction.getMap("test1"); map.put("1", "2"); }
}复制代码

// 从JTA兼容事务管理器获取的事务
Transaction globalTransaction = transactionManager.getTransaction();
RXAResource xaResource = redisson.getXAResource();
globalTransaction.enlistResource(xaResource);
RTransaction transaction = xaResource.getTransaction();
RBucket<String> bucket = transaction.getBucket("myBucket");
bucket.set("simple");
RMap<String, String> map = transaction.getMap("myMap");
map.put("myKey", "myValue");
transactionManager.commit();复制代码