利用 NGINX Plus 在 EMQX 中实现 MQTT 粘性持久会话

在快速发展的物联网世界中，设备之间高效的通信能力至关重要。MQTT 是这个领域中轻量级消息传输协议的佼佼者。然而，随着部署规模的扩大，管理这些通信会变得越来越复杂。

粘性会话（Sticky Session）在物联网负载平衡中发挥着关键作用，确保客户端的后续连接路由到同一服务器 - 对于需要会话持久性的应用程序来说这是必须的。本文将深入探讨 NGINX Plus 和 EMQX Enterprise 共同提供的一种优化 MQTT 负载均衡的策略，介绍如何利用它们实现粘性会话，以及“Client ID”在其中的重要作用。

MQTT 是一种基于发布-订阅模式的消息传输协议。它适用于低带宽、高延迟或网络不稳定的环境，是物联网设备的理想选择。但是，当 MQTT 生态系统中的设备数量增加时，增长的流量会产生更大的压力，带来效率降低和数据丢失的风险。这就凸显了负载均衡的必要性。负载均衡是一种可以将 MQTT 流量均匀分配到多个 Broker 上的机制，避免单个服务器承受过大的压力。

NGINX Plus 中的 MQTT 功能

NGINX Plus (https://www.nginx.com/products/nginx/) 在 R29 版本中新增了对 MQTT 消息解析的原生支持。这不是一个简单的功能，而是一种革命性的能力。它可以创建粘性会话，从而提高数据流的效率，降低建立新连接的开销。

EMQX Enterprise：不只是 MQTT Broker

EMQX Enterprise 以其强大的性能和企业级功能在众多 MQTT Broker 中脱颖而出。它具有高度的可扩展性，可以处理亿级并发 MQTT 连接，是大规模物联网部署的优选方案。

它与 NGINX Plus 的兼容性进一步增强了其功能，为用户带来了流畅的体验。

准备工作

stream {
    mqtt_preread on;
    upstream emqx_backend {
        zone tcp_servers 64k;
        hash $mqtt_preread_clientid consistent;
        server 10.0.0.172:1883;
        server 10.0.0.174:1883;
    }
    server {
        listen 1880;
        status_zone tcp_server;
        proxy_pass emqx_backend;
        proxy_buffer_size 4k;
        proxy_protocol on;
    }
}

listeners.tcp.default {
  bind = "0.0.0.0:1883"
  proxy_protocol = true
}