尚硅谷ActiveMQ学习笔记（5）-- ActiveMQ的消息存储与持久化

深碍√TFBOYSˉ_ 2022-11-18 01:26 255阅读 0赞

### 一、官网 ###

http://activemq.apache.org/persistence

### 二、是什么 ###

#### 1、面试题 ####

ActiveMQ持久化机制

#### 2、说明 ####

![在这里插入图片描述][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]

### 三、有哪些 ###

#### 1、KahaDB 消息存储（默认） ####

迷你版的文件数据库

##### ①、基于日志文件，从ActiveMQ5.4开始默认的持久化插件 #####

##### ②、官网 #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 2]  
kahaDB官网  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 3]

##### ③、验证 #####

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

##### ④、说明 #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 5]  
http://activemq.apache.org/kahadb

##### ⑤、kahaDB的存储原理 #####

#### 2、JDBC 消息存储 ####

消息基于JDBC存储的

#### 3、LevelDB消息存储（了解） ####

#### 4、JDBC Message store with ActiveMQ Journal ####

### 四、JDBC消息存储 ###

#### 1、MQ+Mysql ####

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

#### 2、添加mysql数据库的驱动包到lib文件夹 ####

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

#### 3、jdbcPersistanceAdapter配置 ####

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

#### 4、数据库连接池配置 ####

注意要和上面的引用ID一致

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

#### 5、建库建表说明 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 11]  
activemq\_msgs  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 12]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 13]  
activemq\_acks  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 14]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 15]  
activemq\_lock  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 16]

#### 6、代码运行验证 ####

##### ①、一定要开启持久化 #####

producer.setDeliveryMode(DeliveryMode.PERSISTENT);

##### ②、队列 #####

生产者

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 { 
        public static final String URL = "tcp://10.112.70.211:61616";
        public static final String queue_name = "topic_p_mysql";
    
        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);
            Queue queue = session.createQueue(queue_name);
            MessageProducer producer = session.createProducer(queue);
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);
            connection.start();
    
            for (int i = 1; i < 3; i++) { 
                TextMessage textMessage = session.createTextMessage("mag2..." + i);
                producer.send(textMessage);
            }
            producer.close();
    // session.commit();
            session.close();
            connection.close();
            System.out.println("....");
        }
    }

消费者

package com.atguigu.activemq.queue;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    
    import javax.jms.*;
    import java.io.IOException;
    
    /** * @ClassName JmsConsumer * @Description TODO * @Author DuanYueFeng * @Version 1.0 **/
    public class JmsConsumer { 
        public static final String URL = "tcp://10.112.70.211:61616";
        public static final String queue_name = "topic_p_mysql";
    
        public static void main(String[] args) throws JMSException, IOException, InterruptedException { 
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(URL);
            Connection connection = factory.createConnection();
            connection.start();
    
            Session session = connection.createSession(false,Session.DUPS_OK_ACKNOWLEDGE);
            Queue queue = session.createQueue(queue_name);
            MessageConsumer consumer = session.createConsumer(queue);
            while (true){ 
                TextMessage receive = (TextMessage) consumer.receive(1000);
                if (null != receive){ 
                    System.out.println("消息:"+receive.getText());
                }
                else { 
                    System.out.println("结束");
                    break;
                }
            }
    
    // System.in.read();
    // Thread.sleep(1000);
            consumer.close();
    // session.commit();
            session.close();
            connection.close();
            System.out.println("完成....");
        }
    }

##### ③、topic #####

生产者

package com.atguigu.activemq.topic;
    
    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_mysql";
    
        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 = 4; i <=6; i++) { 
                TextMessage textMessage = session.createTextMessage("Topic mag..." + i);
                producer.send(textMessage);
            }
            producer.close();
            session.close();
            connection.close();
            System.out.println("完成....");
        }
    }

消费者

package com.atguigu.activemq.topic;
    
    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_mysql";
    
        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..");
    
            connection.start();
    
            Message message = durableSubscriber.receive();
    
            while (null!=message){ 
                TextMessage textMessage = (TextMessage)message;
                System.out.println("收到的持久化："+textMessage.getText());
                message = durableSubscriber.receive(1000L);
            }
    
    // Thread.sleep(1000);
            session.close();
            connection.close();
            System.out.println("完成....");
        }
    }

#### 7、数据库情况 ####

#### 8、小总结 ####

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

#### 9、开发有坑 ####

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

### 五、JDBC Message store with ActiveMQ Journal ###

### 六、ActiveMQ持久化机制小总结 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 19]  
![在这里插入图片描述][20210412001357911.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70]: /images/20221022/a7e0c40c8f0841a695ff6f082f27258c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 1]: /images/20221022/72fc413f54c1462ba5603ad6c09861aa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 2]: /images/20221022/998d6f2664254d0592e9d0cca2b076c7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 3]: /images/20221022/5ed6168915fb4fc5a20d970b5e7ccd8e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 4]: /images/20221022/8604eb6a9267405c81550c0abcdb2be5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 5]: /images/20221022/5a10865f1dac4b059ac277c995a7f9f6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 6]: /images/20221022/b4704e40ac5b479ea45db39086c8d067.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 7]: /images/20221022/bc226b81316c41b4b56cf5ef3258d99c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 8]: /images/20221022/7703c79881864bd5970d3b5c35a8f56f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 9]: /images/20221022/576bb87b971c4bafaaca51d72321d9d0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 10]: /images/20221022/53fe85d5e3264dc98be4ec10c36111ea.png
[20210412000720609.png]: /images/20221022/f47296a2d2ee4c2cb37a766bb12aa497.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 11]: /images/20221022/a5aaebea9a9c4bb486336bf71f028e1b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 12]: /images/20221022/79cbfca828a148ceba46b67cb577b85e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 13]: /images/20221022/6a711fb330344bd2a1fca8b651851243.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 14]: /images/20221022/c506aa5a82ca4cb2a89682def0130e7b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 15]: /images/20221022/ae58a40341264ec8a7abae15463a002d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 16]: /images/20221022/330060d50abf4b05b4354e66231e9d5a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 17]: /images/20221022/25d995ec8a3b4e3cbdb964e4168669b1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 18]: /images/20221022/5f06d29fd71f4393a0910a1f8f1c56eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 19]: /images/20221022/c9e22380c5bc467d8d7dac85f0a4d28c.png
[20210412001357911.png]: /images/20221022/f3ea33c6b3e64a269111d1188b7da5b1.png