消息队列体现了什么设计模式

消息队列是现代分布式系统架构中的重要组件之一，它可以帮助系统实现解耦、异步、缓冲、高可用等特点。在实现消息队列的过程中，我们可以使用一些经典的设计模式，来提高代码的可读性、可维护性和可扩展性。

以下是一些常用的设计模式：

1. 发布/订阅模式（Publish/Subscribe Pattern）

在消息队列中，发布/订阅模式是非常常见的一种模式。在这个模式中，消息的发布者将消息发送到一个主题（Topic）或者带有标签的消息队列，而订阅者则可以选择订阅他们感兴趣的消息类型，然后收到相应的消息。这个模式可以很好地解耦发布者和订阅者，使得系统更加灵活可扩展。

以下是一个简单的示例：

// 发布者
public class Publisher {
    private MessageQueue messageQueue;
    public Publisher(MessageQueue messageQueue) {
        this.messageQueue = messageQueue;
    }
    public void publish(String topic, String message) {
        messageQueue.addMessage(topic, message);
    }
}

// 订阅者
public class Subscriber {
    private MessageQueue messageQueue;
    private String topic;
    public Subscriber(MessageQueue messageQueue, String topic) {
        this.messageQueue = messageQueue;
        this.topic = topic;
    }
    public void subscribe() {
        while (true) {
            String message = messageQueue.getMessage(topic);
            // 处理消息
        }
    }
}

// 主题/消息队列
public class MessageQueue {
    private Map<String, Queue<String>> queueMap = new HashMap<>();
    public void addMessage(String topic, String message) {
        Queue<String> queue = queueMap.computeIfAbsent(topic, k -> new LinkedList<>());
        queue.add(message);
    }
    public String getMessage(String topic) {
        Queue<String> queue = queueMap.get(topic);
        if (queue == null) {
            return null;
        }
        return queue.poll();
    }
}

2. 管道模式（Pipeline Pattern）

在消息队列中，管道模式可以帮助我们将一个复杂的任务分解为多个阶段，并使用消息队列来传递各个阶段的结果。这个模式可以很好地实现任务的并行处理和分布式计算。

以下是一个示