KO | EN

GitLite

Minimalist Open Source Repository Search Engine

gitlite — search

#dsh #dsh-plugin #typescript #ai-agent #developer-tools #claude-code #codex #deepseek-harness #ai-agents #react #mcp #rust

EventBusDemo

★ 64 Open GitHub ↗

EventBus基本的使用姿势

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# EventBus使用

开源地址：[https://github.com/greenrobot/EventBus](https://github.com/greenrobot/EventBus)

官方文档：[http://greenrobot.org/eventbus/documentation/](http://greenrobot.org/eventbus/documentation/)

## 使用步骤

### 1. 在Module的build.gradle添加依赖

compile 'org.greenrobot:eventbus:3.0.0'

### 2. 创建事件
	public class MyEvent {
	    public String msg;
	    public MyEvent(String msg) {
	        this.msg = msg;
	    }
	}

### 3. 注册和反注册EventBus
#### 在Activity中 ####
    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        //注册事件总线
        EventBus.getDefault().register(this);
    }

@Override
    protected void onDestroy() {
        super.onDestroy();
        //反注册事件总线
        EventBus.getDefault().unregister(this);
    }

#### 在Fragment中 ####
1. 在onCreate中注册，在onDestory中反注册
2. 在onCreateView中注册，在onDestoryView中反注册

#### 在自定义控件中 ####
在onAttachedToWindow中注册，在onDetachedFromWindow中反注册

#### 普通类 ####
在类中创建注册方法和反注册方法，在合适的时机调用

### 4. 监听事件
	
	/**
     * POSTING线程模型：在哪个线程发布事件，就在哪个线程执行onPostingEvent方法
     */
    @Subscribe(threadMode = ThreadMode.POSTING)
    public void onPostingEvent(MyEvent event) {
        Log.d(TAG, "onPostingEvent: " + Thread.currentThread().getName());
    }

/**
     * MAIN线程模型：不管是哪个线程发布事件，都在主线程执行onMainEvent方法
     */
    @Subscribe(threadMode = ThreadMode.MAIN)
    public void onMainEvent(MyEvent event) {
        Log.d(TAG, "onMainEvent: " + Thread.currentThread().getName());
    }

/**
     * BACKGROUND线程模型：事件如果是在子线程发布，onBackgroundEvent方法就在该子线程执行，事件如果是在
     * 主线程中发布，onBackgroundEvent方法就在EventBus内部的线程池中执行
     */
    @Subscribe(threadMode = ThreadMode.BACKGROUND)
    public void onBackgroundEvent(MyEvent event) {
        Log.d(TAG, "onBackgroundEvent: " + Thread.currentThread().getName());
    }

/**
     * ASYNC线程模型：不管事件在哪个线程发布，onAsyncEvent方法都在EventBus内部的线程池中执行
     */
    @Subscribe(threadMode = ThreadMode.ASYNC)
    public void onAsyncEvent(MyEvent event) {
        Log.d(TAG, "onAsyncEvent: " + Thread.currentThread().getName());
    }

### 5. 发布事件
    /**
     * 在主线程中发布事件
     * @param view
     */
    public void onPublishEventOnMainThread(View view) {
        MyEvent event = new MyEvent("msg from publisher main thread");
        EventBus.getDefault().post(event);
    }

/**
     * 在子线程中发送事件
     * @param view
     */
    public void onPublishEventOnBGThread(View view) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                MyEvent event = new MyEvent("msg from publisher bg thread");
                EventBus.getDefault().post(event);
            }
        }).start();
    }

## 优先级和事件取消 ##
[Priorities and Even Cancellation](http://greenrobot.org/eventbus/documentation/priorities-and-event-cancellation/)

## 粘性事件 ##
[Sticky Events](http://greenrobot.org/eventbus/documentation/configuration/sticky-events/)

## 订阅者索引 ##
[Subscriber Index](http://greenrobot.org/eventbus/documentation/subscriber-index/)

## EventBus源码分析 ##

### 单例模式 ###

//简单单例，当多线程时，还是会创建多个示例
    public static EventBus getDefault() {
        if (defaultInstance == null) {
            defaultInstance = new EventBus();
        }
        return defaultInstance;
    }

//加锁单例，每次调用都检查是否加锁
    public static synchronized EventBus getDefault() {
        if (defaultInstance == null) {
            defaultInstance = new EventBus();
        }
        return defaultInstance;
    }

//两个非空，一个加锁
    public static EventBus getDefault() {
        if (defaultInstance == null) {
            synchronized (EventBus.class) {
                if (defaultInstance == null) {
                    defaultInstance = new EventBus();
                }
            }
        }
        return defaultInstance;
    }

### 注册 ###

public void register(Object subscriber) {
        Class<?> subscriberClass = subscriber.getClass();
		//找到订阅者中所有的订阅方法
        List<SubscriberMethod> subscriberMethods = subscriberMethodFinder.findSubscriberMethods(subscriberClass);
        synchronized (this) {
            for (SubscriberMethod subscriberMethod : subscriberMethods) {
				//将订阅方法记录下来保存到对应事件的订阅列表中
				//Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType
                subscribe(subscriber, subscriberMethod);
            }
        }
    }

### 发布事件 ###

public void post(Object event) {
        PostingThreadState postingState = currentPostingThreadState.get();
        List<Object> eventQueue = postingState.eventQueue;
        eventQueue.add(event);.//添加到事件队列

if (!postingState.isPosting) {
            postingState.isMainThread = Looper.getMainLooper() == Looper.myLooper();
            postingState.isPosting = true;
            if (postingState.canceled) {
                throw new EventBusException("Internal error. Abort state was not reset");
            }
            try {
                while (!eventQueue.isEmpty()) {
					//发布的单个事件
                    postSingleEvent(eventQueue.remove(0), postingState);
                }
            } finally {
                postingState.isPosting = false;
                postingState.isMainThread = false;
            }
        }
    }

private void postSingleEvent(Object event, PostingThreadState postingState) throws Error {
        Class<?> eventClass = event.getClass();
        boolean subscriptionFound = false;
        if (eventInheritance) {
			........
        } else {
			//发布对应事件类型的事件
            subscriptionFound = postSingleEventForEventType(event, postingState, eventClass);
        }
		.........
    }

private boolean postSingleEventForEventType(Object event, PostingThreadState postingState, Class<?> eventClass) {
        CopyOnWriteArrayList<Subscription> subscriptions;
        synchronized (this) {
            subscriptions = subscriptionsByEventType.get(eventClass);//获取对应事件的订阅列表
        }
        if (subscriptions != null && !subscriptions.isEmpty()) {
			//遍历订阅列表
            for (Subscription subscription : subscriptions) {
                postingState.event = event;
                postingState.subscription = subscription;
                boolean aborted = false;
                try {
					//发布事件到一个订阅
                    postToSubscription(subscription, event, postingState.isMainThread);
                    aborted = postingState.canceled;
                }
				........
            }
            return true;
        }
		......
    }

private void postToSubscription(Subscription subscription, Object event, boolean isMainThread) {
		//判断订阅方法的线程模型
        switch (subscription.subscriberMethod.threadMode) {
            case POSTING:
				//POSTING线程模型下，直接反射调用订阅方法
                invokeSubscriber(subscription, event);
                break;
            case MAIN:
				//MAIN线程模型
                if (isMainThread) {
					//如果当前是主线程，则直接反射调用订阅方法
                    invokeSubscriber(subscription, event);
                } else {
					//如果当前不是主线程，则使用绑定主线程Looper的Handler在主线程调用订阅方法
                    mainThreadPoster.enqueue(subscription, event);
                }
                break;
            case BACKGROUND:
				//BACKGROUND线程模型
                if (isMainThread) {
					//如果当前是主线程，则在EventBus内部的线程池中执行
                    backgroundPoster.enqueue(subscription, event);
                } else {
					//如果当前是子线程，则直接在该子线程反射调用订阅方法
                    invokeSubscriber(subscription, event);
                }
                break;
            case ASYNC:
				//ASYNC线程模型
				//直接在EventBus的线程池中执行
                asyncPoster.enqueue(subscription, event);
                break;
            default:
                throw new IllegalStateException("Unknown thread mode: " + subscription.subscriberMethod.threadMode);
        }
    }

EventBusDemo

Explore Similar Repositories

Was this content helpful?

Recent Feedback

Download README