EventBus应用

Posted 2020-10-27 binfoo

EventBus作为消息总线，通过解耦发布者和订阅者简化事件传递

本文实现一个handler演示如何使用EventBus

定义消息类型对象EventMsg

package com.binfoo.observer.event;

/**
 * 定义消息类型对象
 */
public class EventMsg {
    private String msg;

    public EventMsg(){
    }

    public EventMsg(String msg){
        this.msg = msg;
    }

    public String getMsg() {
        return msg;
    }

    @Override
    public String toString() {
        return "EventMsg{" +
                "msg=‘" + msg + ‘\‘‘ +
                ‘}‘;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }


}

• 实现Runnable接口的EventHandler，含有成员EventBus，当线程启动时候，进行注册线程本身

package com.binfoo.observer.event;

import com.google.common.eventbus.AllowConcurrentEvents;
import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;

public class EventHandler implements Runnable{
    public EventBus getEventBus() {
        return eventBus;
    }

    public void setEventBus(EventBus eventBus) {
        this.eventBus = eventBus;
    }

    private EventBus eventBus;

    public EventHandler(EventBus eventBus){
        this.eventBus = eventBus;

    }


    @Subscribe
    @AllowConcurrentEvents
    public void handler(EventMsg eventMsg){

        System.out.println("线程： " + Thread.currentThread().getName()+ " 处理得到消息： " + eventMsg.toString());

    }

    @Override
    public void run() {
        eventBus.register(this);
        System.out.println(Thread.currentThread().getName());
    }
}

• 进行测试，交替发送不同的消息

package com.binfoo.observer.event;

import com.google.common.eventbus.EventBus;

public class EventHandlerTest {
    public static void main(String[] args) {


        EventMsg msg1 = new EventMsg("中国人民共和国万岁！");
        EventMsg msg2 = new EventMsg("世界人民大团结万岁！");
        EventMsg msg3= new EventMsg("!!!!!!!!！");
        EventHandler eventHandler = new EventHandler(new EventBus());
        new Thread(eventHandler).start();

        for (int j =0; j<10;j++){

            try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                if (j%2==0){
                    System.out.println("------" + j);
                    eventHandler.getEventBus().post(msg1);
                }else if (j%2==1){
                    System.out.println("======" + j);
                    eventHandler.getEventBus().post(msg2);
                }else {
                    System.out.println("......." + j);
                    eventHandler.getEventBus().post(msg3);
                }
            }

        }

    }

• 我们看到结果

• Thread-1
  ------0
  线程： main 处理得到消息： EventMsg{msg=‘中国人民共和国万岁！‘}
  ======1
  线程： main 处理得到消息： EventMsg{msg=‘世界人民大团结万岁！‘}
  ------2
  线程： main 处理得到消息： EventMsg{msg=‘中国人民共和国万岁！‘}
  ======3
  线程： main 处理得到消息： EventMsg{msg=‘世界人民大团结万岁！‘}
  ------4
  线程： main 处理得到消息： EventMsg{msg=‘中国人民共和国万岁！‘}
  ======5
  线程： main 处理得到消息： EventMsg{msg=‘世界人民大团结万岁！‘}
  ------6
  线程： main 处理得到消息： EventMsg{msg=‘中国人民共和国万岁！‘}
  ======7
  线程： main 处理得到消息： EventMsg{msg=‘世界人民大团结万岁！‘}
  ------8
  线程： main 处理得到消息： EventMsg{msg=‘中国人民共和国万岁！‘}
  ======9
  线程： main 处理得到消息： EventMsg{msg=‘世界人民大团结万岁！‘}
  
  Process finished with exit code 0