中介者模式在Java消息传递中的简化

中介者模式（Mediator Pattern）是一种行为设计模式，它通过定义一个中介对象来封装一组对象之间的交互。这样可以减少对象之间的直接依赖，降低耦合度，使得系统更加灵活和易于维护。在Java消息传递中，中介者模式可以简化消息处理流程，提高系统的可扩展性和可维护性。

在Java消息传递中，中介者模式通常包括以下几个角色：

1. 中介者（Mediator）：定义一个接口，用于协调各个组件之间的通信。
2. 具体中介者（ConcreteMediator）：实现中介者接口，负责处理组件之间的消息传递。
3. 抽象组件（Colleague）：定义一个接口，用于声明组件之间的通信方法。
4. 具体组件（ConcreteColleague）：实现抽象组件接口，与中介者进行交互，发送和接收消息。

下面是一个简单的Java消息传递中介者模式的示例：

// 中介者接口
public interface Mediator {
    void sendMessage(String message, Colleague colleague);
}

// 具体中介者
public class ConcreteMediator implements Mediator {
    private List<Colleague> colleagues = new ArrayList<>();

    public void registerColleague(Colleague colleague) {
        colleagues.add(colleague);
    }

    @Override
    public void sendMessage(String message, Colleague colleague) {
        for (Colleague c : colleagues) {
            if (c != colleague) {
                c.notify(message);
            }
        }
    }
}

// 抽象组件接口
public interface Colleague {
    void notify(String message);
}

// 具体组件
public class ConcreteColleagueA implements Colleague {
    private Mediator mediator;

    public ConcreteColleagueA(Mediator mediator) {
        this.mediator = mediator;
        mediator.registerColleague(this);
    }

    @Override
    public void notify(String message) {
        System.out.println("ConcreteColleagueA received message: " + message);
    }

    public void sendMessage(String message, Colleague colleague) {
        mediator.sendMessage(message, colleague);
    }
}

public class ConcreteColleagueB implements Colleague {
    private Mediator mediator;

    public ConcreteColleagueB(Mediator mediator) {
        this.mediator = mediator;
        mediator.registerColleague(this);
    }

    @Override
    public void notify(String message) {
        System.out.println("ConcreteColleagueB received message: " + message);
    }

    public void sendMessage(String message, Colleague colleague) {
        mediator.sendMessage(message, colleague);
    }
}

// 测试类
public class MediatorPatternDemo {
    public static void main(String[] args) {
        Mediator mediator = new ConcreteMediator();
        Colleague colleagueA = new ConcreteColleagueA(mediator);
        Colleague colleagueB = new ConcreteColleagueB(mediator);

        colleagueA.sendMessage("Hello!", colleagueB);
    }
}

在这个示例中，我们定义了一个简单的中介者模式，用于处理组件之间的消息传递。ConcreteColleagueA和ConcreteColleagueB是两个具体组件，它们通过中介者ConcreteMediator进行通信。通过这种方式，我们可以简化组件之间的直接依赖，降低耦合度，使得系统更加灵活和易于维护。