JMS|消息中间件(二)简单操作

JMS 入门小 Demo

点对点模式
　　点对点的模式主要建立在一个队列上面，当连接一个列队的时候，发送端不需要知道接
收端是否正在接收，可以直接向 ActiveMQ 发送消息，发送的消息，将会先进入队列中，如
果有接收端在监听，则会发向接收端，如果没有接收端接收，则会保存在 activemq 服务器，
直到接收端接收消息，点对点的消息模式可以有多个发送端，多个接收端，但是一条消息，
只会被一个接收端给接收到，哪个接收端先连上 ActiveMQ，则会先接收到，而后来的接收
端则接收不到那条消息。

１．引入依赖

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-client</artifactId>
    <version>5.13.4</version>
</dependency>

2.消息生产者

　　　　　// 1.1创建链接工厂对象
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.132:61616");
        // 1.2创建连接

        Connection connection = connectionFactory.createConnection();
        // 1.3开启连接
        connection.start();
        // 2.1获取 session (参数 1：是否启动事务,参数 2：消息确认模式)
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 2.2创建主题对象、订阅
        Topic topic = session.createTopic("my_topic");
        //2.2创建队列对象
        //Queue queue = session.createQueue("my_queue");

        // 2.3创建息生产者
        MessageProducer producer = session.createProducer(topic);
        //2.3创建消息生产者
        //MessageProducer producer = session.createProducer(queue); 


        // 2.4创建消息
        TextMessage textMessage = session.createTextMessage("欢迎订阅平邮购");
        // 3发送消息
        producer.send(textMessage);
        // 4关闭资源
        producer.close();
        session.close();
        connection.close();

上述代码创建 session 的两个参数：
第 1 个参数 是否使用事务
第 2 个参数 消息的确认模式：

- AUTO_ACKNOWLEDGE = 1 自动确认
- CLIENT_ACKNOWLEDGE = 2 客户端手动确认
- DUPS_OK_ACKNOWLEDGE = 3 自动批量确认
- SESSION_TRANSACTED = 0 事务提交并确认

3.消息的消费者

// 1.1创建连接工厂
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.132:61616");
        // 1.2创建连接
        Connection connection = connectionFactory.createConnection();
        // 1.3开启连接
        connection.start();
        // 2.1创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 2.2创建队列
        Topic topic = session.createTopic("my_topic");
        //2.2创建队列
        //Queue queue = session.createQueue("my_queue");


        // 2.3创建消息的消费者
        MessageConsumer consumer = session.createConsumer(topic);
        //2.3创建消息的消费者
        //MessageConsumer consumer = session.createConsumer(queue);


        // 3设置监听消息
        consumer.setMessageListener(new MessageListener() {
            // 消息监听器的方法
            @Override
            public void onMessage(Message message) {
                try {
                    TextMessage textMessage = (TextMessage)message;
                    System.out.println(textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });


        // 等待录入
        System.in.read();

        // 4关闭资源
        consumer.close();
        session.close();
        connection.close();

　　同时开启 2 个以上的消费者，再次运行生产者，观察每个消费者控制台的输出，会发现
每个消费者会接收到消息。