尚硅谷ActiveMQ学习笔记（3）-- JMS规范和落地产品

╰+攻爆jí腚メ 2022-10-22 07:31 161阅读 0赞

### 一、是什么 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70]

### 二、MQ中间件的其他落地产品 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 1]  
消息队列的详细对比  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 2]

### 三、JMS的组成和特点 ###

#### 1、JMS privider ####

实现JMS接口与规范的消息中间件，也就是我们的MQ服务器

#### 2、JMS producer ####

消息生产者，创建与发送JMS消息的客户端应用

#### 3、JMS consumer ####

消息的消费者，接受与处理JMS消息的客户端应用

#### 4、JMS message ####

##### ①、消息头 #####

JMSdesination：消息发送的目的地，主要是指Queue与Topic  
JMSDeliveryMode  
![在这里插入图片描述][20210404222120912.png]  
JMSExpiration  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 3]  
JMSPriority  
![在这里插入图片描述][20210404222328187.png]  
JMSMessageID：唯一识别每个消息的表示，由MQ产生

##### ②、消息体 #####

1、封装具体消息的数据  
2、五种消息体的格式  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 4]  
3、发送和接受的消息体类型必须是一致对应的

##### ③、消息属性 #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 5]

如果需要使用消息头以外的值，那么可以使用消息属性///一种加强型的api  
识别/去重/重点标注等操作非常有用的方法

### 四、JMS的可靠性 ###

#### 1、persistent：持久性 ####

##### ①、参数设置说明 #####

非持久  
![在这里插入图片描述][20210404223016457.png]  
持久  
![在这里插入图片描述][20210404223030665.png]  
默认是持久化的

##### ②、持久的queue #####

![在这里插入图片描述][20210404223050772.png]

##### ③、持久的topic #####

注意：先启动订阅再启动生产

持久的发布主题生产者

package com.atguigu.activemq.queue;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    
    import javax.jms.*;
    
    /** * @ClassName JmsProduce * @Description TODO * @Author DuanYueFeng * @Version 1.0 **/
    public class JmsProduce_Topic_p { 
        public static final String URL = "tcp://10.112.70.211:61616";
        public static final String topic_name = "topic_p";
    
        public static void main(String[] args) throws JMSException { 
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(URL);
            Connection connection = factory.createConnection();
    
            Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
            Topic topic = session.createTopic(topic_name);
            MessageProducer producer = session.createProducer(topic);
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);
            connection.start();
    
            for (int i = 1; i <=3; i++) { 
                TextMessage textMessage = session.createTextMessage("Topic mag..." + i);
                producer.send(textMessage);
            }
            producer.close();
            session.close();
            connection.close();
            System.out.println("完成....");
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 6]  
持久的订阅主题消费者

package com.atguigu.activemq.queue;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    import org.apache.camel.component.test.TestComponent;
    
    import javax.jms.*;
    import java.io.IOException;
    
    /** * @ClassName JmsConsumer * @Description TODO * @Author DuanYueFeng * @Version 1.0 **/
    public class JmsConsumer_Topic_p { 
        public static final String URL = "tcp://10.112.70.211:61616";
        public static final String topic_name = "topic_p";
    
        public static void main(String[] args) throws JMSException, IOException, InterruptedException { 
            System.out.println("我是3号消费者。。。");
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(URL);
            Connection connection = factory.createConnection();
            connection.setClientID("z3");
            Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
            Topic topic = session.createTopic(topic_name);
            TopicSubscriber durableSubscriber = session.createDurableSubscriber(topic, "remark..");
    
           
    
            Message message = durableSubscriber.receive();
    
            while (null!=message){ 
                TextMessage textMessage = (TextMessage)message;
                System.out.println("收到的持久化："+textMessage.getText());
                message = durableSubscriber.receive(1000L);
            }
    
            System.in.read();
    // Thread.sleep(1000);
            session.close();
            connection.close();
            System.out.println("完成....");
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 7]  
![在这里插入图片描述][20210404223249653.png]

类似微信公众号的订阅发布

测试先发送消息
    消费者关机，消费者启动之后可以收到之前发的消息
     
    测试先发送消息
    消费者关机，服务器宕机，消费者启动之后可以收到之前发的消息

##### ④、非持久的topic #####

没有意义，因为发布订阅模式是先启动订阅在启动生成，消息已经被消费了。如果先启动生产者后启动订阅者，消息会被当作废消息

#### 2、transaction:事务 ####

##### ①、producer提交时的事务 #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 8]

##### ②、事务偏生产者/签收偏消费者 #####

#### 3、Acknowledge:签收 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 9]

### 五、JMS的点对点模式总结 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 10]

### 六、JMS的发布订阅模式总结 ###

![在这里插入图片描述][20210404224805937.png]

#### 1、非持久订阅 ####

![在这里插入图片描述][2021040422513766.png]

#### 2、持久订阅 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 11]  
在发布端的持久化投递好像没有意义，注释之后，订阅者离线重上依然可以收到没有签收的消息。  
![在这里插入图片描述][20210404225213237.png]

#### 3、用哪个 ####

当所有消息必须被接受，则用持久订阅。当丢失消息能够被容忍，则用非持久订阅

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70]: /images/20221022/1650061e1b8242198a407fd328ee6b02.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 1]: /images/20221022/395398d8a5e1443ca5ed8da02e7f171d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 2]: /images/20221022/6fdbfccd169b46e79c29278841ebb589.png
[20210404222120912.png]: /images/20221022/7b82f895eb0447fa805abf72395f8e3a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 3]: /images/20221022/44a940a8e8584daf944182e29408e8d0.png
[20210404222328187.png]: /images/20221022/a8864859f26b43219bdc8bf383508fcd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 4]: /images/20221022/4ac7ae9de8824ea096ede05a1a17c36a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 5]: /images/20221022/6727f490f22746ffacf14ae5b18a410c.png
[20210404223016457.png]: /images/20221022/cd953bfc7e87470c830e0e97e9ff9307.png
[20210404223030665.png]: /images/20221022/6734c9cb7b9a4eb59b6ad1b737bbd235.png
[20210404223050772.png]: /images/20221022/7c0c2be007604518a85bf3beaeb12541.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 6]: /images/20221022/b5c0f06d8a9247b29276fc5eb262c119.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 7]: /images/20221022/aa4c4a8bc0a9426d900fcd8f31784b96.png
[20210404223249653.png]: /images/20221022/282bf4b7f99f40c68c6673d1f128405b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 8]: /images/20221022/96e8c4fec859436b841840d01858cabb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 9]: /images/20221022/231300043988407794822940c3902f4a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 10]: /images/20221022/710b620f54d1449b9befe0c3bb054524.png
[20210404224805937.png]: /images/20221022/b0922e731969402d8e5482af6a30fb8e.png
[2021040422513766.png]: /images/20221022/ebc24caa5cd6440cac4d80a877e2c794.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 11]: /images/20221022/8e22d8b23d9f4592bf1cca1160628a07.png
[20210404225213237.png]: /images/20221022/3a9158c32f6a4a38b9081ea67c095365.png