BeetlSQL 3.1.0 发布，spring saga 事务支持

本次发布增强了Saga在spring下的支持，使用kafka提供重试以及重试失败后放入丢弃队列里

Saga是用来在微服务中的长事务管理，具备ACID中的ACD，不具备I，隔离性。在一定业务条件下，可以使用Saga非常简单和方便的管理微服务事务。同理，也可以用于管理多库事务

Saga要求微服务提供回滚操作，然后如果需要回滚，有Saga编排调度各个微服务对应的回滚服务。BeetlSQL提供了SagaMapper,是的内置的操作都有对应的回滚操作，也提供@SagaSql，用户提供正向SQl，也提供回滚SQL。这样，在多库环境下，BeetlSQL能正确回滚数据而不依赖于数据库提供的事务

maven

1<dependency>
2  <groupId>com.ibeetl</groupId>
3  <artifactId>beetlsql</artifactId>
4  <version>3.1.0-RELEASE</version>
5</dependency>
6<dependency>
7  <groupId>com.ibeetl</groupId>
8  <artifactId>sql-saga-springkafa</artifactId>
9  <version>3.1.0-RELEASE</version>
10</dependency>
11
12
13@Transactional(propagation = Propagation.NEVER)
14public boolean normal(){
15	SagaContext sagaContext = SagaContext.sagaContextFactory.current();
16	try{
17		UserInfoInDs1 ds1 = new UserInfoInDs1();
18		ds1.setId(100);
19		ds1.setName("ces");
20
21		UserInfoInDs2 ds2 = new UserInfoInDs2();
22		ds2.setId(100);
23		ds2.setName("abs");
24		//俩个数据库
25		userInfoDs1Mapper.insert(ds1);
26		userInfoDs2Mapper.insert(ds2);
27		//模拟一个错误
28		int a = 1/0;
29	}catch(Exception ex){
30		sagaContext.rollback();
31		return false;
32	}
33	return true;
34}

需要配置重试队列和丢弃队列名字，以及重试次数，以及kafka序列化方式

1beetlsql-saga.kafka.retry-topic=retryTopic002
2beetlsql-saga.kafka.fail-topic=failTopic002
3
4
5spring.kafka.bootstrapServers=127.0.0.1:9092
6spring.kafka.consumer.group-id=saga
7spring.kafka.consumer.auto-offset-reset=latest
8spring.kafka.listener.type=single
9spring.kafka.listener.ack-mode=record
10
11spring.kafka.consumer.value-deserializer=org.beetl.sql.saga.kafka.JacksonDeserializer
12spring.kafka.producer.value-serializer=org.beetl.sql.saga.kafka.JacksonSerializer