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).
发布于 2015-11-09 05:52:12 | 244 次阅读
发布于 2015-10-23 00:29:42 | 168 次阅读
发布于 2015-10-15 00:18:18 | 138 次阅读
发布于 2015-10-09 00:48:17 | 174 次阅读
发布于 2015-09-27 00:54:53 | 234 次阅读
发布于 2015-09-18 17:52:26 | 276 次阅读
发布于 2015-08-31 00:30:14 | 193 次阅读
发布于 2015-08-20 04:22:30 | 420 次阅读
发布于 2015-08-17 07:23:14 | 229 次阅读
发布于 2015-07-09 09:00:51 | 236 次阅读
发布于 2015-05-31 00:02:31 | 430 次阅读