MQTT的Erlang客戶端：emqttc

dc4g 9年前發布 | 13K 次閱讀 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).

項目主頁：http://www.baiduhome.net/lib/view/home/1439889401333

 本文由用戶 dc4g 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
 轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！