// 假设我们有一个简单的消息接口
public interface Message<T> {
T getContent();
}
// 消息实现
public class SimpleMessage<T> implements Message<T> {
private T content;
public SimpleMessage(T content) {
this.content = content;
}
@Override
public T getContent() {
return content;
}
}
// 消息队列接口
public interface MessageQueue<T> {
void enqueue(Message<T> message);
Message<T> dequeue();
boolean isEmpty();
}
// 消息队列实现
public class SimpleMessageQueue<T> implements MessageQueue<T> {
private Queue<Message<T>> queue = new LinkedList<>();
@Override
public void enqueue(Message<T> message) {
queue.add(message);
}
@Override
public Message<T> dequeue() {
return queue.isEmpty() ? null : queue.poll();
}
@Override
public boolean isEmpty() {
return queue.isEmpty();
}
}
// 使用示例
public class MQExample {
public static void main(String[] args) {
MessageQueue<String> messageQueue = new SimpleMessageQueue<>();
// 入队消息
messageQueue.enqueue(new SimpleMessage<>("Hello"));
messageQueue.enqueue(new SimpleMessage<>("World"));
// 出队消息
while (!messageQueue.isEmpty()) {
Message<String> message = messageQueue.dequeue();
System.out.println(message.getContent());
}
}
}这个简单的例子展示了如何定义消息接口和消息队列接口，以及它们的基本实现。然后，我们创建了一个消息队列的使用示例，演示了如何使用这个消息队列来入队和出队消息。这个例子是消息队列概念的一个简化版本，用于教学展示。