emqttc是一个Erlag的MQTT客户端,支持MQTTV3.1/V3.1.1协议规范。支持并行连接和连接自动恢复。要求ErlagR17+.
特性:
支持MQTTV3.1/V3.1.1协议
QoS0,QoS1,QoS2发布和订阅
TCP/SSLSocket支持
自动重连
Keepalive和pig/pog
示例:
%% coect to broker{ok, C} = emqttc:start_lik([{host, "localhost"}, {cliet_id, <<"simpleCliet">>}]),%% subscribeemqttc:subscribe(C, <<"TopicA">>, qos0),%% publishemqttc:publish(C, <<"TopicA">>, <<"Payload...">>),%% receive messagereceive {publish, Topic, Payload} -> io:format("Message Received from ~s: ~p~", [Topic, Payload])after 1000 -> io:format("Error: receive timeout!~")ed,%% discoect from brokeremqttc:discoect(C).
评论