java eventbus

// 引入必要的库
import org.greenrobot.eventbus.EventBus;
import org.greenrobot.eventbus.Subscribe;
import org.greenrobot.eventbus.ThreadMode;

public class EventBusExample {

    // 定义一个事件类
    public static class MessageEvent {
        private final String message;

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

        public String getMessage() {
            return message;
        }
    }

    // 订阅者类
    public static class Subscriber {

        @Subscribe(threadMode = ThreadMode.MAIN)
        public void onMessageEvent(MessageEvent event) {
            System.out.println("Received message: " + event.getMessage());
        }
    }

    public static void main(String[] args) {
        // 初始化EventBus实例
        EventBus eventBus = EventBus.getDefault();

        // 注册订阅者
        Subscriber subscriber = new Subscriber();
        eventBus.register(subscriber);

        // 发布事件
        eventBus.post(new MessageEvent("Hello, EventBus!"));

        // 取消注册订阅者（防止内存泄漏）
        eventBus.unregister(subscriber);
    }
}

解释说明

1. 引入库：我们使用了 org.greenrobot.eventbus 库来实现事件总线的功能。
2. 定义事件类：MessageEvent 类用于封装要传递的消息。
3. 订阅者类：Subscriber 类中定义了一个方法 onMessageEvent，该方法使用 @Subscribe 注解标记为事件处理方法，并且指定了线程模式为 ThreadMode.MAIN，表示该方法将在主线程中执行。
4. 初始化 EventBus 实例：通过 EventBus.getDefault() 获取默认的 EventBus 实例。
5. 注册订阅者：通过 eventBus.register(subscriber) 将订阅者注册到 EventBus 中。
6. 发布事件：通过 eventBus.post(new MessageEvent("Hello, EventBus!")) 发布一个事件。
7. 取消注册订阅者：在不再需要接收事件时，调用 eventBus.unregister(subscriber) 取消注册订阅者，以防止内存泄漏。

希望这个示例能帮助你理解如何使用 Java 的 EventBus。