MQTT的Erlang客户端：emqttc
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). 本文由用户 dc4g 自行上传分享，仅供网友学习交流。所有权归原作者，若您的权利被侵害，请联系管理员。
转载本站原创文章，请注明出处，并保留原始链接、图片水印。
本站是一个以用户分享为主的开源技术平台，欢迎各类分享！