Guava事件总线-EventBus
Guava事件总线-EventBus
Kevin-air 发表于2年前
Guava事件总线-EventBus
  • 发表于 2年前
  • 阅读 37
  • 收藏 1
  • 点赞 0
  • 评论 0

【腾讯云】买域名送云解析+SSL证书+建站!>>>   

摘要: EventBus是Guava的事件处理机制,是设计模式中的观察者模式(生产/消费者编程模型)的优雅实现。对于事件监听和发布订阅模式,EventBus是一个非常优雅和简单解决方案,我们不用创建复杂的类和接口层次结构。

EventBus基本用法:

  使用Guava之后, 如果要订阅消息, 就不用再继承指定的接口, 只需要在指定的方法上加上@Subscribe注解即可。

import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
import org.junit.Test;

/**
 * @author Kevin
 * @description
 * @date 2016/8/5
 */
public class EventBusTest {
    @Test
    public void testReceiveEvent() throws Exception {

        EventBus eventBus = new EventBus("test");
        EventListener listener = new EventListener();

        eventBus.register(listener);

        eventBus.post(new TestEvent(200));
        eventBus.post(new TestEvent(300));
        eventBus.post(new TestEvent(400));

        System.out.println("LastMessage:" + listener.getLastMessage());
    }
}

class EventListener {
    public int lastMessage = 0;

    @Subscribe
    public void listen(TestEvent event) {
        lastMessage = event.getMessage();
        System.out.println("Message:" + lastMessage);
    }

    public int getLastMessage() {
        return lastMessage;
    }
}

class TestEvent {
    int message;

    public TestEvent(int message) {
        this.message = message;
    }

    public int getMessage() {
        return message;
    }

    public void setMessage(int message) {
        this.message = message;
    }
}

多listener与event继承的示例

import com.google.common.eventbus.EventBus;
import com.google.common.eventbus.Subscribe;
import org.junit.Test;

/**
 * @author Kevin
 * @description
 * @date 2016/8/5
 */
public class MultiEventBusTest {

    @Test
    public void multiEventBusTest() {
        EventBus eventBus = new EventBus("multiEventListener");
        eventBus.register(new MultiEventListener());

        eventBus.post(100);
        eventBus.post(200L);
        eventBus.post("Kevin");
    }
}

class MultiEventListener {
    // Number是Integer和Long的父类,可以收到事件
    @Subscribe
    public void numberEvent(Number event) {
        System.out.println("numbereger event = " + event);
    }

    @Subscribe
    public void integerEvent(Integer event) {
        System.out.println("integer event = " + event);
    }

    @Subscribe
    public void longEvent(Long event) {
        System.out.println("long event = " + event);
    }

    @Subscribe
    public void stringEvent(String event){
        System.out.println("String event = " + event);
    }
}

 

  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 13
博文 73
码字总数 26587
×
Kevin-air
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: