spring-integration-eventbus:基于 Spring Integration 框架的以解耦方式连接事件发布 代码

以下是使用 Spring Integration 实现的事件总线示例代码：

首先，定义一个事件类：

public class MyEvent {
    private String message;

    public MyEvent(String message) {
        this.message = message;
    }

    public String getMessage() {
        return message;
    }
}

然后，定义一个事件发布器：

public class MyEventPublisher {
    private ApplicationEventPublisher publisher;

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

    public void publishEvent(String message) {
        MyEvent event = new MyEvent(message);
        publisher.publishEvent(event);
    }
}

在 Spring 配置文件中，需要配置一个 `ApplicationEventMulticaster` 和一个 `MyEventPublisher`：

<bean id="applicationEventMulticaster" class="org.springframework.context.event.SimpleApplicationEventMulticaster">
    <property name="taskExecutor">
        <bean class="org.springframework.core.task.SimpleAsyncTaskExecutor"/>
    </property>
</bean>

<bean id="myEventPublisher" class="com.example.MyEventPublisher">
    <constructor-arg ref="applicationEventPublisher"/>
</bean>

最后，在需要使用事件总线的地方，可以注入 `MyEventPublisher` 并发布事件：

@Autowired
private MyEventPublisher myEventPublisher;

public void doSomething() {
    myEventPublisher.publishEvent("Hello world!");
}

通过上述配置和代码，我们就可以实现基于 Spring Integration 框架的事件总线了。