emqttcErlang 的 MQTT 客户端
emqttc 是一个 Erlang 的 MQTT 客户端，支持 MQTT V3.1/V3.1.1 协议规范。支持并行连接和连接自动恢复。要求 Erlang R17+.
特性：
支持 MQTT V3.1/V3.1.1 协议
QoS0, QoS1, QoS2 发布和订阅
TCP/SSL Socket 支持
自动重连
Keepalive 和 ping/pong
示例：
%% connect to broker
{ok, C} = emqttc:start_link([{host, "localhost"}, {client_id, <<"simpleClient">>}]),
%% subscribe
emqttc:subscribe(C, <<"TopicA">>, qos0),
%% publish
emqttc:publish(C, <<"TopicA">>, <<"Payload...">>),
%% receive message
receive
{publish, Topic, Payload} ->
io:format("Message Received from ~s: ~p~n", [Topic, Payload])
after
1000 ->
io:format("Error: receive timeout!~n")
end,
%% disconnect from broker
emqttc:disconnect(C).评论