MQTT 消息持久化
前提条件：服务器（EMQX）& 生产者 都正常工作--消费者正常或者非正常掉线，一段时间过后，消费者重新上线，如何保证接收掉线时间内的离线消息？
一、持久化会话
当消费者连接服务器时，通过关键字段告知服务器需要持久化会话。服务器记住该消费者-客户端，并保留持久化会话信息。
当该消费者重新上线时，无需重新订阅topic，直接消费消息（包括离线消息）。
客户端和服务端可以保存会话状态，以支持跨网络连接的可靠消息传输。清理会话标志位：Clean Session用于控制会话状态的生存时间
/* 情形一 */
conn_opts.cleansession = 1;
/* 情形二 */
conn_opts.cleansession = 0;