Spring事務監控(分佈式事務1)

先寫一個最最簡單的插入例子來探討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消息等等.