先写一个最最简单的插入例子来探讨Spring事务监控.

model

@Data
public class User implements Serializable {

private long id;
private String name;
private int age;

}
dao(此处数据库有一个user表,3个字段,id自增)

@Mapper
public interface UserDao {

@Options(useGeneratedKeys = true, keyProperty = "id")
@Insert("insert into user (name,age) values (#{name},#{age})")
void insert(User user);

}
service

public interface UserService {

public void insert(User user);

}
@Transactional
@Service
public class UserServiceImpl implements UserService {

@Autowired
private ApplicationEventPublisher publisher;
@Autowired
private UserDao userDao;
@Override
public void insert(User user) {
    userDao.insert(user);
    //重点在于此处对事务进行侦听
    publisher.publishEvent(user);
}

}
listener(对Spring事务侦听,并进行处理)

@Component
public class UserTransactionEventListener {

@TransactionalEventListener(phase = TransactionPhase.BEFORE_COMMIT)
public void beforeCommit(PayloadApplicationEvent<User> event) {
    System.out.println("before commit, id: " + event.getPayload().getId());
}

@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void afterCommit(PayloadApplicationEvent<User> event) {
    System.out.println("after commit, id: " + event.getPayload().getId());
}

@TransactionalEventListener(phase = TransactionPhase.AFTER_COMPLETION)
public void afterCompletion(PayloadApplicationEvent<User> event) {
    System.out.println("after completion, id: " + event.getPayload().getId());
}

@TransactionalEventListener(phase = TransactionPhase.AFTER_ROLLBACK)
public void afterRollback(PayloadApplicationEvent<User> event) {
    System.out.println("after rollback, id: " + event.getPayload().getId());
}

}
controller

@RestController
public class UserController {

@Autowired
private UserService userService;

@PostMapping("/save")
public Map<String,Object> save(@RequestBody User user) {
    Map<String,Object> result = new HashMap();
    userService.insert(user);
    result.put("code","200");
    result.put("body",user);
    result.put("msg","success");
    return result;
}

}
运行结果

{

"msg": "success",
"code": "200",
"body": {
    "id": 1,
    "name": "miky",
    "age": 21
}

}

日志片段

2018-09-17 14:42:44.384 INFO 10696 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8080 (http) with context path ''
2018-09-17 14:42:44.387 INFO 10696 --- [ main] com.guanjian.TransactionApplication : Started TransactionApplication in 3.987 seconds (JVM running for 5.122)
2018-09-17 14:45:46.915 INFO 10696 --- [nio-8080-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring FrameworkServlet 'dispatcherServlet'
2018-09-17 14:45:46.915 INFO 10696 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet : FrameworkServlet 'dispatcherServlet': initialization started
2018-09-17 14:45:46.930 INFO 10696 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet : FrameworkServlet 'dispatcherServlet': initialization completed in 15 ms
2018-09-17 14:45:47.047 INFO 10696 --- [nio-8080-exec-1] com.alibaba.druid.pool.DruidDataSource : {dataSource-1} inited
before commit, id: 1
after commit, id: 1
after completion, id: 1

说明侦听成功,可以进行分布式事务的下一步处理,发送MQ消息等等.