google guava的消息总线：EventBus，Java

Posted 2023-01-06 zhangphil

google guava的消息总线：EventBus，Java

pom.xml添加引用：

<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>31.1-jre</version>
</dependency>

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

public class MainClass 
    public static void main(String[] args) 
        AppEventListener appEventListener = new AppEventListener();

        EventBus eventBus = new EventBus();
        //支持异步操作
        //EventBus eventBus = new AsyncEventBus(Executors.newCachedThreadPool());
        eventBus.register(appEventListener);

        eventBus.post("1 zhang");
    

    @Subscribe
    private void receiver(String msg) 
        System.out.println(getClass().getName() + " 收到 " + msg);
    

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

public class AppEventListener 
    private EventBus eventBus;

    public AppEventListener() 
        MainClass mainClass = new MainClass();
        eventBus = new EventBus();
        eventBus.register(mainClass);
    

    @Subscribe
    private void receiver(String msg) 
        System.out.println(getClass().getName() + " 收到 " + msg);

        eventBus.post("2 phil");
    

输出：

test.AppEventListener 收到 1 zhang
test.MainClass 收到 2 phil

com.google.guava的maven仓库地址：

https://mvnrepository.com/artifact/com.google.guava/guavahttps://mvnrepository.com/artifact/com.google.guava/guava