---
title: 协议支持总览
---

# 协议支持总览

FlowMQ 原生支持多种标准消息协议，在同一套集群与权限体系下提供一致的发布/订阅与流式处理能力。

## MQTT

FlowMQ 提供完整的 MQTT 3.1.1 与 MQTT 5.0 支持：

- 实时 Pub/Sub
- QoS 0 / 1 / 2
- 遗嘱消息（LWT）、保留消息（Retained）
- MQTT 5.0 属性（Properties）、用户属性（User Properties）
- 主题通配符订阅（`+` / `#`）
- TLS/SSL 加密传输

默认端口：`1883`（TCP）/ `8883`（TLS）

关于如何使用 MQTT 协议访问 FlowMQ, 参考[MQTT 协议](./mqtt)

## Kafka

FlowMQ 提供完整的 Kafka 协议兼容，可直接使用标准 Kafka 客户端接入：

- 高吞吐生产与消费
- Topic / Partition
- 幂等 Producer
- Consumer Group 以及 偏移量（Offset）提交与管理
- SASL/TLS 安全认证

默认端口：`9092`

关于如何使用 Kafka 客户端访问 FlowMQ, 参考 [Kafka 协议](./kafka)

## AMQP（开发中）

FlowMQ 对 AMQP 0-9-1 和 AMQP 1.0 支持还处在开发阶段，功能尚未完全可用。

- 交换机（Exchange）类型：Direct / Topic / Fanout
- 队列（Queue）声明与绑定（Binding）
- 持久化队列、消息确认（ACK）
- 消息属性与 TTL

默认端口：`5672`

详见：[AMQP 协议](./amqp)
