事件生产和监听

2021-11-10 09:33:01 阅读：117 来源： 互联网

标签：EventBoat log batchNo eventBoat 监听事件生产 import public

事件的生产者

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;


@Component
@Slf4j
public class Sender {
    @Autowired
    private ApplicationContext applicationContext;

    /**
     * 发布事件
     * @param eventBoat 事件数据
     * @Return 调用结果
     */
    public boolean sendEvent(EventBoat eventBoat) {
        boolean flag = false;
        try {
            applicationContext.publishEvent(eventBoat);
            flag = true;
            log.info("发送事件成功");
        } catch (Exception e) {
            log.error("发送事件失败，eventBoat={}", JSON.toJSONString(eventBoat));
        }
        return flag;
    }
}

事件的监听者

@Component
@Slf4j
public class Listener {
    /**
     * 处理事件
     * @param eventBoat
     * @Return
     */
    @EventListener
    @Async
    public void handleEvent(EventBoat eventBoat){
        try {
            String batchNo = eventBoat.getBatchNo();
            log.info("事件接收成功：{}", batchNo);
            //业务处理
            ...........
        } catch (Exception e) {
            log.error("处理执行错误>>> {}", e);
        }
    }

}

实体类

@Data
public class EventBoat extends ApplicationEvent {
    /**
     * 批次号
     */
    private String batchNo;

    public EventBoat(Object source, String batchNo) {
        super(source);
        this.batchNo = batchNo;
    }
}

标签：EventBoat,log,batchNo,eventBoat,监听,事件,生产,import,public
来源： https://www.cnblogs.com/zhu12/p/15531991.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

事件生产和监听