首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Spring事务监控(分布式事务1) 顶

Spring事务监控(分布式事务1) 顶

作者头像
算法之名
发布2019-08-21 17:13:35
6030
发布2019-08-21 17:13:35
举报
文章被收录于专栏:算法之名算法之名

先写一个最最简单的插入例子来探讨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消息等等.

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档