mqtt(mosquitto)环境搭建

《mqtt(mosquitto)环境搭建》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、MQTT（mosquitto）环境搭建一、下载mosquitto安装二、启动mosquittoC:ProgramFiles(x86)mosquitto>mosquitto.exe-cmosquitto.conf三、模拟订阅客户端org.fusesource.mqtt-clientmqtt-client1.0packagecom.suni

2、ng.ebuy.passbook;importjava.net.URISyntaxException;importorg.fusesource.mqtt.client.BlockingConnection;importorg.fusesource.mqtt.client.MQTT;importorg.fusesource.mqtt.client.Message;importorg.fusesource.mqtt.client.QoS;importorg.fusesource.mqtt.client.Topic;i

3、mportorg.slf4j.Logger;importorg.slf4j.LoggerFactory;/****使用Java为MQTelemetryTransport创建订户在此任务中，您将遵循教程来创建订户应用程序。订户将针对主题创建预订并接收该预订的发布。提供了一个示例订户应用程序Subscribe。Subscribe*将创建预订主题MQTTExamples，并等待获得该预订的发布，等待时间为30秒。订户可以创建预订并等待获得发布。它还可以接收发送至先前为同一客户机标识创建的预订的发布。**@authorl

4、onggangbai*/publicclassWSMQTTClientSubscribe{privatestaticfinalLoggerLOG=LoggerFactory.getLogger(WSMQTTClientSubscribe.class);privatefinalstaticStringCONNECTION_STRING="tcp://localhost:1883";privatefinalstaticbooleanCLEAN_START=true;privatefinalstaticshortKEE

5、P_ALIVE=30;//低耗网络，但是又需要及时获取数据，心跳30sprivatefinalstaticStringCLIENT_ID="publishService";publicstaticTopic[]topics1={newTopic("china/beijing",QoS.EXACTLY_ONCE),newTopic("china/tianjin",QoS.AT_LEAST_ONCE),newTopic("china/henan",QoS.AT_MOST_ONCE)};publicfinalstati

6、clongRECONNECTION_ATTEMPT_MAX=6;publicfinalstaticlongRECONNECTION_DELAY=2000;publicfinalstaticintSEND_BUFFER_SIZE=2*1024*1024;//发送最大缓冲为2Mpublicstaticvoidmain(String[]args){//创建MQTT对象MQTTmqtt=newMQTT();BlockingConnectionconnection=null;try{//设置mqttbroker的ip和端口

7、mqtt.setHost(CONNECTION_STRING);//连接前清空会话信息mqtt.setCleanSession(CLEAN_START);//设置重新连接的次数mqtt.setReconnectAttemptsMax(RECONNECTION_ATTEMPT_MAX);//设置重连的间隔时间mqtt.setReconnectDelay(RECONNECTION_DELAY);//设置心跳时间mqtt.setKeepAlive(KEEP_ALIVE);//设置缓冲的大小mqtt.setSendBuf

8、ferSize(SEND_BUFFER_SIZE);mqtt.setClientId("u2");//获取mqtt的连接对象BlockingConnectionconnection=mqtt.blockingConnection();//MQTT连接的创建connection.connect();//创建相关的MQTT的主题列表Topic[]topics={newTopi