HBase 的 MemStore 详解

1. 定义事件类

/*
* 1. 定义事件类
* 首先，我们创建一个自定义事件 UserRegisteredEvent，用于表示用户注册事件。
* */
public class UserRegisteredEvent extends ApplicationEvent {
    private final String email;

    public UserRegisteredEvent(Object source, String email) {
        super(source);
        this.email = email;
    }

    public String getEmail() {
        return email;
    }
}

2. 创建事件发布器

@Service
public class UserService {
    private final ApplicationEventPublisher publisher;

    public UserService(ApplicationEventPublisher publisher) {
        this.publisher = publisher;
    }

    public void registerUser(String email) {
        // 这里可以添加用户注册逻辑，比如保存到数据库
        System.out.println("User registered: " + email);

        /*
        * 2. 创建事件发布器
        * 我们创建一个服务类 UserService，
        * 在用户注册时发布 UserRegisteredEvent。
        * */

        // 发布用户注册事件
        publisher.publishEvent(new UserRegisteredEvent(this, email));
    }
}

3. 创建事件监听器

/*
* 3. 创建事件监听器
* 然后，我们创建一个监听器 EmailService，在收到 UserRegisteredEvent 时发送欢迎邮件。
* */
@Component
public class EmailService {
    @EventListener
    public void onUserRegistered(UserRegisteredEvent event) {
        String email = event.getEmail();
        // 这里模拟发送邮件
        System.out.println("Sending welcome email to: " + email);
    }
}

4、启动类

@SpringBootApplication
public class MytestApplication implements CommandLineRunner {

    @Autowired
    private UserService userService;

    public static void main(String[] args) {
        SpringApplication.run(MytestApplication.class, args);
    }

    @Override
    public void run(String... args) {
        // 模拟用户注册
        userService.registerUser("user@example.com");
    }
}