消息队列的实现 - 实体类

**消息队列的实现**

在分布式系统中，消息队列是一种常见的设计模式，它允许不同组件之间异步通信。消息队列可以帮助减轻系统压力、提高可扩展性以及提供更好的容错能力。在本文中，我们将讨论如何实现一个基本的消息队列系统。

**实体类**

我们的消息队列系统将包含以下实体类：

1. **Message**: 消息实体类，代表一个待发送或已接收的消息。
2. **Producer**: 生产者实体类，负责向消息队列中发送消息。
3. **Consumer**: 消费者实体类，负责从消息队列中取出并处理消息。
4. **MessageQueue**: 消息队列实体类，负责存储和管理消息。

### Message 实体类

javapublic class Message {
 private String id;
 private String content;
 private long timestamp;

 public Message(String id, String content) {
 this.id = id;
 this.content = content;
 this.timestamp = System.currentTimeMillis();
 }

 public String getId() {
 return id;
 }

 public void setId(String id) {
 this.id = id;
 }

 public String getContent() {
 return content;
 }

 public void setContent(String content) {
 this.content = content;
 }

 public long getTimestamp() {
 return timestamp;
 }
}

javapublic class Producer {
 private MessageQueue messageQueue;

 public Producer(MessageQueue messageQueue) {
 this.messageQueue = messageQueue;
 }

 public void sendMessage(String id, String content) {
 Message message = new Message(id, content);
 messageQueue.addMessage(message);
 }
}

javapublic class Consumer {
 private MessageQueue messageQueue;

 public Consumer(MessageQueue messageQueue) {
 this.messageQueue = messageQueue;
 }

 public void consumeMessage() {
 Message message = messageQueue.getMessage();
 if (message != null) {
 System.out.println("Received message: " + message.getContent());
 messageQueue.removeMessage(message);
 }
 }
}

javaimport java.util.ArrayList;
import java.util.List;

public class MessageQueue {
 private List messages = new ArrayList<>();

 public void addMessage(Message message) {
 messages.add(message);
 }

 public Message getMessage() {
 if (!messages.isEmpty()) {
 return messages.remove(0);
 } else {
 return null;
 }
 }

 public void removeMessage(Message message) {
 messages.remove(message);
 }
}

javapublic class Main {
 public static void main(String[] args) {
 MessageQueue messageQueue = new MessageQueue();

 Producer producer = new Producer(messageQueue);
 Consumer consumer = new Consumer(messageQueue);

 producer.sendMessage("1", "Hello, world!");
 producer.sendMessage("2", "This is a test.");

 consumer.consumeMessage();
 consumer.consumeMessage();
 }
}