event

此包中创建了三个事件

- ClearTenantEvent

- ReloadTenantEvent

- SetTenantEvent

请先阅读[《SpringBoot 事件与监听》](http://www.liyade.tech/project-18/doc-214/ "《SpringBoot 事件与监听》")

## 项目中的使用

本文只讲解 ClearTenantEvent 事件，其余两个事件同理

Spring Boot的事件处理机制主要涉及事件类、发布者和监听器三个角色：

### 事件类（Event）：

继承自ApplicationEvent类（从Spring Framework 4.2开始，事件类也可以是任意对象），用于封装事件数据。

> src/main/java/tech/liyade/starter/web/common/event/ClearTenantEvent.java

```
package tech.liyade.starter.web.common.event;

import org.springframework.context.ApplicationEvent;

public class ClearTenantEvent extends ApplicationEvent {

public ClearTenantEvent(Object source) {
        super(source);
    }

}
```

### 发布者（Publisher）：

注入ApplicationEventPublisher对象，使用publishEvent()方法发布事件。

> src/main/java/tech/liyade/starter/web/common/tenant/TenantContextHolder.java

```
package tech.liyade.starter.web.common.tenant;

import tech.liyade.starter.web.common.event.ClearTenantEvent;
import tech.liyade.starter.web.common.event.SetTenantEvent;
import tech.liyade.starter.web.common.utils.ApplicationUtil;

public class TenantContextHolder {

private static final ThreadLocal<Integer> TENANT_ID = new ThreadLocal<>();

public static void setTenantId(Integer tenantId) {
        if (tenantId == null) {
            throw new RuntimeException("tenantId不能为空！");
        }
        TENANT_ID.set(tenantId);

SetTenantEvent event = new SetTenantEvent(TenantContextHolder.class, tenantId);
        ApplicationUtil.publishEvent(event);
    }

public static Integer getTenantId() {
        return TENANT_ID.get();
    }

public static void clearTenantId() {
        TENANT_ID.remove();

ClearTenantEvent event = new ClearTenantEvent(TenantContextHolder.class);
        ApplicationUtil.publishEvent(event);
    }

}
```

因为 ApplicationUtil 继承了 ApplicationEventPublisher，所以本项目使用的是 `ApplicationUtil.publishEvent(event)`

![](/media/202501/2025-01-24_103420_8799440.34526724124838537.png)

### 监听器（Listener）：

实现ApplicationListener接口，重写onApplicationEvent()方法处理事件。监听器可以使用@Component注解注册为一个Bean，也可以使用@EventListener注解标注一个方法作为监听器。

> src/main/java/tech/liyade/starter/web/listeners/TenantListener.java

```
    public static class ClearTenantListener implements ApplicationListener<ClearTenantEvent> {

@Override
        public void onApplicationEvent(ClearTenantEvent event) {
            DynamicDataSourceContextHolder.clear();
        }
    }
```