为EventBus发送的消息添加ID，以区分消息

2024-02-14 11:34:48

在小型项目中，集成EventBus作为一种解耦方式颇具吸引力。这种集成方式可以很好地避免编写多余的接口代码。发送方只需发送消息，而无需关注消息类型对应的接收方将如何处理这些消息。然而，在使用过程中，不可避免地会遇到一些不适用的特性。例如，EventBus可以使用@Subscribe注解来声明接收方，以便接收和处理特定类型的消息。但是，这种方式可能会导致订阅相同类型的消息的接收方数量过多，从而增加消息处理的复杂性。

为了解决这个问题，一种可行的方法是在发送消息时为其分配一个唯一的ID。通过这种方式，可以轻松地将消息与特定的处理程序相关联，而无需依赖@Subscribe注解。这种方法有助于提高代码的可读性和可维护性，尤其是在大型项目中。

下面提供了一个实现此功能的示例：

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

public class MessageWithIdExample {

    private EventBus eventBus;

    public MessageWithIdExample() {
        this.eventBus = new EventBus();
    }

    // 发送带ID的消息
    public void sendMessage(String message, long id) {
        this.eventBus.post(new MessageWithId(message, id));
    }

    // 接收带ID的消息
    @Subscribe
    public void receiveMessage(MessageWithId message) {
        System.out.println("Received message: " + message.getMessage() + " with ID: " + message.getId());
    }

    public static void main(String[] args) {
        MessageWithIdExample example = new MessageWithIdExample();
        example.sendMessage("Hello, world!", 1L);
        example.sendMessage("This is a test message.", 2L);
    }

    // 带ID的消息类
    public static class MessageWithId {
        private String message;
        private long id;

        public MessageWithId(String message, long id) {
            this.message = message;
            this.id = id;
        }

        public String getMessage() {
            return message;
        }

        public long getId() {
            return id;
        }
    }
}