使用mq保存数据

消息队列（Message Queue，简称 MQ）是一种用于在软件系统之间传递数据的中间件。它允许系统之间异步地交换数据，而无需使用直接连接或者共享内存。这使得各个系统可以更加松散地耦合，并且对于系统的扩展和故障恢复都更加方便。

使用 MQ 保存数据的方式通常是：将要保存的数据发送到 MQ 的一个队列中，然后由另一个应用程序从队列中接收数据并将其保存到持久存储中。这样，在数据保存过程中，原始应用程序就不需要等待数据保存完成，而是可以立即继续执行其他任务。

需要注意的是，使用 MQ 保存数据是有一定延迟的，因为数据需要经过网络传输和队列存储才能被保存。如果对数据实时性有很高要求，可能需要使用其他方案来保存数据。

1、默认提供的是持久化到文件的方式，即activemq.xml文件中的：

2. 步骤

本文重点接收的是持久化到MySQL中的配置方式：

2.1 添加MySQL驱动

首先需要把MySql的驱动放到ActiveMQ的Lib目录下，我用的文件名字是：mysql-connector-java-5.1.30-bin.jar

2.2 修改配置文件activemq.xml

将其中的这段配置：

修改为下面这段内容：

3、另外需要在节点的下面定义id为mysql-ds的bean，如下：

4、 新建数据库

从配置中可以看出数据库的名称是activemq，需要手动在MySql中新建一个activemq的空数据库。

此时，重新启动MQ，就会发现activemq库中多了三张表：activemq_acks，activemq_lock，activemq_msgs，OK,说明已经持久化成功啦！

先写数据。

正常设置过程是先写入数据库，发送MQ，缓存监听MQ更新缓存。

数据是科学实验、检验、统计等所获得的和用于科学研究、技术设计、查证、决策等的数值。

---