EMQ 通过以下方式来保证消息不丢失：
- 消息持久化：EMQ 支持将消息持久化到硬盘上的数据库中，常用的选择是使用类似于 RabbitMQ、Apache Kafka 或者 Apache Cassandra 等高可靠性的数据库。当消息到达 EMQ 时，它会被存储在持久化介质上，以便在服务器重启或故障恢复后能够重新加载和传递。
- 发布确认机制：EMQ 使用 MQTT 协议的 QoS（Quality of Service）等级来确保消息的可靠传输。发送者可以选择 QoS 1（至少一次）或 QoS 2（恰好一次），在这些等级下，EMQ 将采取相应的机制来确保消息在传输过程中不丢失，如确认机制、重传机制等。
- 持久化会话：MQTT 协议中的客户端可以选择创建持久化会话，在客户端断开连接后，持久化会话将保留订阅信息和 QoS 级别为 1 或 2 的消息。当客户端重新连接时，EMQ 会重新传递未发送完成的消息，并恢复订阅状态，从而避免消息丢失。
- 数据备份和冗余：EMQ 支持集群部署，多个 EMQ 服务器组成的集群可以提供数据备份和冗余。如果一个服务器发生故障，其他服务器可以接管工作，并确保消息不丢失。
- 高可用性和故障恢复：EMQ 的集群部署模式可以提供故障转移和自动恢复能力。当某个节点发生故障时，集群中的其他节点可以继续处理消息，并在故障节点恢复后进行同步。
通过这些机制和策略，EMQ 可以有效地保证消息不丢失，并提供高可靠性的消息传递服务。但请注意，EMQ 也依赖于底层的硬件设施、网络连接和所选的持久化数据库等因素，因此在实际应用中仍需综合考虑系统设计和配置，以确保消息的完整传递。
