EMQ是一個開源的MQTT消息服務器，它支持高并發和分布式部署。可以輕松地使用EMQ來處理大規模的MQTT消息。本文將介紹EMQ如何把消息寫入到MySQL中。

1. 安裝MySQL驅動
在EMQ中使用MySQL，需要安裝相應的MySQL驅動。可以在EMQ的插件市場中下載并安裝MySQL驅動。

2. 配置MySQL的參數
在EMQ的配置文件中，需要添加MySQL的參數。例如：
emq.emqtt.db.username = root
emq.emqtt.db.password = 123456
emq.emqtt.db.host = localhost
emq.emqtt.db.port = 3306
emq.emqtt.db.database = emq

3. 創建MySQL的表
在MySQL中創建一個用于存儲EMQ消息的表。可以使用以下DDL語句：
CREATE TABLE emq_message (
id VARCHAR(36) NOT NULL,
topic VARCHAR(255) NOT NULL,
payload BLOB NOT NULL,
qos SMALLINT NOT NULL,
retain TINYINT NOT NULL,
ts BIGINT NOT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

4. 配置EMQ的持久化參數
在EMQ的配置文件中，需要添加相應的持久化參數。例如：
emq.persistence.client.use_storage = true
emq.persistence.client.storage_type = sql
emq.persistence.client.sql.driver = mysql
emq.persistence.client.sql.database = emq
emq.persistence.client.sql.username = root
emq.persistence.client.sql.password = 123456
emq.persistence.client.sql.host = localhost
emq.persistence.client.sql.port = 3306

5. 重啟EMQ
修改了配置文件之后，需要重啟EMQ服務，以使配置生效。

6. 查看MySQL中的數據
當MQTT客戶端發送消息給EMQ時，EMQ會把消息寫入到MySQL中。可以使用以下SQL語句來查看寫入的數據：
SELECT * FROM emq_message;

以上就是EMQ如何把消息寫入到MySQL中的詳細介紹。通過以上操作，可以輕松地將EMQ中的消息存儲到MySQL中，實現消息的持久化。