侧边栏壁纸
博主头像
实习两年半

基础不牢,地动山摇。

  • 累计撰写 43 篇文章
  • 累计创建 40 个标签
  • 累计收到 4 条评论

目 录CONTENT

文章目录

SpringBoot Event 事件机制

实习两年半
2024-01-17 / 0 评论 / 0 点赞 / 907 阅读 / 355 字
温馨提示:
本文最后更新于 2024-01-17,若内容或图片失效,请留言反馈。部分素材来自网络,若不小心影响到您的利益,请联系我们删除。

创建一个事件

自定义一个kafka消费结束的事件,其中CompositeBuilder是一个组合多个数据的内部静态类。

package cn.unuuc.springboot.study.event;


import lombok.Builder;
import lombok.Data;
import org.springframework.context.ApplicationEvent;

import java.time.LocalDateTime;
import java.util.List;


/**
 * 自定义消费者结束事件
 */
public class KafkaConsumerEndEvent extends ApplicationEvent {

    private CompositeBuilder compositeBuilder;

    public KafkaConsumerEndEvent(Object source, CompositeBuilder compositeBuilder) {
        super(source);
        this.compositeBuilder = compositeBuilder;
    }

    public CompositeBuilder getCompositeBuilder() {
        return compositeBuilder;
    }

    @Builder
    @Data
    public static class CompositeBuilder {
        // 这里是组装的对象,大概示意一下
        private String topic;
        private LocalDateTime time;
        private List<String> snapImgList;
        // ........
    }
}

事件发布者

package cn.unuuc.springboot.study.event;

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * kafka消费结束事件发布者
 */
@Component
public class KafkaConsumerPublisher {

    @Resource
    private ApplicationEventPublisher applicationEventPublisher;

    public void publishEvent(KafkaConsumerEndEvent.CompositeBuilder compositeBuilder) {
        applicationEventPublisher.publishEvent(compositeBuilder);
    }


}

在kafka消费结束时发布

package cn.unuuc.springboot.study.service;

import cn.unuuc.springboot.study.event.KafkaConsumerEndEvent;
import cn.unuuc.springboot.study.event.KafkaConsumerPublisher;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.ArrayList;


@Service
public class KafkaService {
    @Resource
    KafkaConsumerPublisher kafkaConsumerPublisher;

    public void kafkaTask() {
        System.out.println("kafka开始执行");
        System.out.println("kafka执行中");
        System.out.println("kafka结束了,发布一个结束的事件");
        KafkaConsumerEndEvent.CompositeBuilder build = KafkaConsumerEndEvent.CompositeBuilder.builder().time(LocalDateTime.now()).topic("hello-world").snapImgList(new ArrayList<>()).build();
        kafkaConsumerPublisher.publishEvent(build);
    }
}

事件监听者

package cn.unuuc.springboot.study.event;

import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaTaskEndListener {


    @EventListener
    public void handleUserLoginEvent(KafkaConsumerEndEvent.CompositeBuilder compositeBuilder) {

        System.out.println("监听到kafka结束事件");
        System.out.println(compositeBuilder.toString());
    }

}

测试结果

image-1705472561787

0

评论区