亚洲va在线va天堂xxxx中文 ,女子奶水太多喂老头中文字幕,亚洲性啪啪无码av天堂,无码H肉动漫在线观看免费中文

TransactionalEventListener，事務(wù)事件監(jiān)聽(tīng)，可監(jiān)聽(tīng)事務(wù)提交前、提交后、事務(wù)回滾、事務(wù)完成（成功或失?。?

(資料圖片)

一、介紹

Spring內(nèi)置了簡(jiǎn)便的事件機(jī)制，可以非常方便的實(shí)現(xiàn)事件驅(qū)動(dòng)，核心類(lèi)包括

1、定義發(fā)送事件對(duì)象

public class UserEntity {    private long id;    private String name;    private String msg;}

2、定義事件監(jiān)聽(tīng)器

可以添加條件condition，限制監(jiān)聽(tīng)具體的事件

@Slf4j@Componentpublic class RegisterListener {    @EventListener(condition = "#entity.id != null and #entity.async==false ")    public void handlerEvent(UserEntity entity) {        try {            // 休眠5秒            TimeUnit.SECONDS.sleep(5);        } catch (InterruptedException e) {            e.printStackTrace();        }        log.info("handlerEvent: {}", entity);    }}

3、定義發(fā)送接口以及實(shí)現(xiàn)類(lèi)

public interface IRegisterService {    public void register(String name);}

@Servicepublic class RegisterServiceImpl implements IRegisterService {    @Resource    private ApplicationEventPublisher applicationEventPublisher;    @Override    public void register(String name) {        UserEntity entity = new UserEntity();        entity.setName(name);        entity.setId(1L);        entity.setMsg("新用戶注冊(cè)同步調(diào)用");        applicationEventPublisher.publishEvent(entity);    }}

4、測(cè)試Controller類(lèi)，進(jìn)行測(cè)試

@Slf4j@Controllerpublic class TestController {    @Resource    private IRegisterService registerService;    @RequestMapping("test")    @ResponseBody    public void test1(String name) {        registerService.register(name);        log.info("執(zhí)行同步調(diào)用結(jié)束");    }}

在瀏覽器中輸入地址：http://localhost/test?name=nik

控制臺(tái)輸出：

handlerEvent: UserEntity(id=1, name=nik, msg=新用戶注冊(cè)同步調(diào)用)執(zhí)行同步調(diào)用結(jié)束

三、使用示例：異步發(fā)布

1、在啟動(dòng)類(lèi)添加異步注解@EnableAsync

2、在監(jiān)聽(tīng)方法上添加注解@Async

@Async@EventListener(condition = "#entity.name != null and #entity.async ")public void handlerEventAsync(UserEntity entity) {    try {        TimeUnit.SECONDS.sleep(5);    } catch (InterruptedException e) {        e.printStackTrace();    }    log.info("handlerEventAsync: {}", entity);}

3、在service中添加異步發(fā)送方法

@Overridepublic void registerAsyn(String name) {    UserEntity entity = new UserEntity();    entity.setName(name);    entity.setId(1L);    entity.setMsg("新用戶注冊(cè)異步調(diào)用");    entity.setAsync(true);    applicationEventPublisher.publishEvent(entity);}

3、測(cè)試

@RequestMapping("test")@ResponseBodypublic void test(String name) {    registerService.registerAsyn(name);    log.info("執(zhí)行異步調(diào)用結(jié)束");}

控制臺(tái)輸出：

執(zhí)行異步調(diào)用結(jié)束handlerEventAsync: UserEntity(id=1, name=nik, msg=新用戶注冊(cè)異步調(diào)用)

四、使用示例：在事務(wù)提交后發(fā)布事件

比如，用戶注冊(cè)成功后給用戶發(fā)送成功短信，那么注冊(cè)成功必然是注冊(cè)方法事務(wù)提交成功后才代表成功。

Spring提供了注解@TransactionalEventListener監(jiān)聽(tīng)事務(wù)事件，在@EventListener基礎(chǔ)上增加了屬性phase，包含以下四個(gè)值：

1、自定義事務(wù)處理事件

public class RegisterCommitEvent extends ApplicationEvent {    @Getter    @Setter    private String msg;    @Getter    @Setter    private String name;    public RegisterCommitEvent(UserEntity source) {        super(source);        this.msg = source.getMsg();        this.name = source.getName();    }}

2、在處理方法上添加事務(wù)注解，@Transactional

@Override@Transactionalpublic void registerCommit(String name) {    UserEntity entity = new UserEntity();    entity.setName(name);    entity.setMsg("新用戶注冊(cè)事務(wù)提交事件");    RegisterCommitEvent registerEvent = new RegisterCommitEvent(entity);    userDao.save(entity);    // 發(fā)送事件    applicationEventPublisher.publishEvent(registerEvent);}

3、添加事務(wù)事件監(jiān)聽(tīng)

@Async@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)public void handlerEventCmmit(RegisterCommitEvent event) {    try {        TimeUnit.SECONDS.sleep(5);    } catch (InterruptedException e) {        e.printStackTrace();    }    log.info("handlerEventCmmit: {}", event);}

4、測(cè)試

@RequestMapping("test")@ResponseBodypublic void test(String name) {    registerService.registerCommit(name);    log.info("執(zhí)行事務(wù)調(diào)用結(jié)束");}

控制臺(tái)輸出：

執(zhí)行事務(wù)調(diào)用結(jié)束handlerEventCmmit: RegisterCommitEvent[source=UserEntity(id=0, name=nik, msg=新用戶注冊(cè)事務(wù)提交事件)]

總結(jié)

Spring ApplicationEvent事件處理機(jī)制使用起來(lái)簡(jiǎn)單方便，可以對(duì)程序進(jìn)行有效解耦。

雖然可以發(fā)送任意類(lèi)型的對(duì)象，但是在實(shí)際業(yè)務(wù)中容易產(chǎn)生混亂，建議根據(jù)實(shí)際業(yè)務(wù)，定義好各類(lèi)事件，并在監(jiān)聽(tīng)方法中實(shí)現(xiàn)異步處理。

關(guān)鍵詞：