消息队列点对点与发布订阅

消息队列是一种流行的通信模式，它可以通过点对点或发布订阅的方式实现。这篇文章将深入探讨这两种模式以及它们在消息队列中的实现方式。

一、点对点模式

点对点模式是指消息的发送者和接收者是一对一的关系。在点对点模式中，发送者将消息发送到特定的队列中，而接收者则从该队列中接收消息。这种模式下没有多余的中介角色，消息发送者和接收者的关系是直接建立的。

点对点模式通常用于一些需要可靠的消息传递，而且每个消息只需要有一个消费者处理的场景，例如订单系统中的消息通知。

下面是点对点模式的实现示例：

消息发送者代码示例：

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class Sender {

    public static void main(String[] args) throws JMSException {
        // 连接工厂
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
        // 连接
        Connection connection = connectionFactory.createConnection();
        // 启动连接
        connection.start();
        // 创建Session
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 创建一个队列
        Queue queue = session.createQueue("queue");
        // 创建生产者
        MessageProducer producer = session.createProducer(queue);
        // 发送消息
        TextMessage message = session.createTextMessage("Hello, world!");
        producer.send(message);
        // 关闭资源
        producer.close();
        session.close();
        connection.close();
    }

}

消息接收者代码示例：

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class Receiver {

    public static void main(String[] args) throws JMSException {
        // 连接工厂
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
        // 连接
        Connection connection = connectionFactory.createConnection();
        // 启动连接
        connection.start();
        // 创建Session
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 创建一个队列
        Queue queue = session.createQueue("queue");
        // 创建消费者
        MessageConsumer consumer = session.createConsumer(queue);
        // 接收消息
        TextMessage message = (TextMessage) consumer.receive