Java多线程通信：MessageQueue与Topic的区别示例

原创 ╰半橙微兮° 2024-10-11 05:39 20阅读 0赞

在Java中，多线程之间的通信主要通过Message Queue和Topic两种机制。以下是这两种机制的区别及一个简单示例：

1. Message Queue（队列）：
   - 线程发送消息后，消息将被放入队尾等待其他线程消费。
   - 消费方式是顺序消费，即一个接一个地处理消息。
   
2. Topic（主题）：
   - 线程发送的消息携带特定的主题标识，而不是直接发送消息内容。
   - 消费方式通常是多消费者并行消费，同一个主题可以被多个线程同时访问和处理。

示例代码：

```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class MQTopicExample {
    public static void main(String[] args) {
        // 创建ExecutorService服务
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 创建Message Queue（队列）
        String queueName = "myQueue";
        MessageQueueManager manager = new MessageQueueManager("ConnectionFactory");
        MessageQueue queue = manager.createMessageQueue(queueName);

// 创建Topic（主题）
        String topicName = "myTopic";
        Topic topic = new Topic(topicName, "ConnectionFactory"));

// 定义线程任务，将消息发送到队列或主题
        for (int i = 0; i < 10; i++) {
            final int msgIndex = i;
            executor.submit(() -> {
                // 发送消息到队列（模拟）
                if (msgIndex % 2 == 0) {
                    queue.put(new Message("Message " + msgIndex), null));
                }

// 或者发送消息到主题（模拟）
                else {
                    topic.send(new Message("Message " + msgIndex)), null);
                }
            }));
        }

// 关闭线程池
        executor.shutdown();

// 确保所有任务都已完成
        while (!executor.isTerminated())) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All tasks completed.");
    }
}
```

上述代码示例中，我们创建了一个线程池，模拟了发送消息到队列（Message Queue）或主题（Topic）的过程。最后关闭线程池并确保所有任务都已完成。