emqttcErlang 的 MQTT 客戶端

emqttc 是一個(gè) Erlang 的 MQTT 客戶端，支持 MQTT V3.1/V3.1.1 協(xié)議規(guī)范。支持并行連接和連接自動(dòng)恢復(fù)。要求 Erlang R17+.

特性：

• 支持 MQTT V3.1/V3.1.1 協(xié)議

• QoS0, QoS1, QoS2 發(fā)布和訂閱

• TCP/SSL Socket 支持

• 自動(dòng)重連

• 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).