在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
开源软件名称:JFinal-mqtt开源软件地址:https://gitee.com/code_redrain/JFinal-mqtt开源软件介绍:#JFinal-mqtt插件说明坚持努力学习JFinal一直坚持的一切从简的光荣传统,为JFinal的为发展壮大提供绵薄之力。 ###插件在JFinal中的使用说明 public void configPlugin(Plugins me) { //使用配置文件 me.add(new MqttPlugin("mqtt.properties")); //不使用配置文件 //MqttPlugin plugin = new MqttPlugin("tcp://127.0.0.1:1883", "clientId"); //plugin.setAutomaticReconnection(true); //plugin.setCleanSession(true); //plugin.setConnectionTimeout(10); //plugin.setKeepAliveInterval(10); //plugin.setManualAcks(true); //plugin.setMaxConnections(20); //plugin.setUserName("test"); //plugin.setPassword("test"); //plugin.setVersion("3.1.1"); //plugin.setReConnectionTimeInterval(10); //me.add(plugin);}public void afterJFinalStart() { try { //订阅消息 MqttKit.sub("/hello", MqttKit.QOS_AT_LEAST_ONCE, new IMqttMessageListener() { public void messageArrived(String topic, MqttMessage message) throws Exception { System.out.println("主题:"+topic+"\t"+new String(message.getPayload())); } }); //发布消息 MqttKit.pub("/hello", "world".getBytes(), MqttKit.QOS_AT_LEAST_ONCE, false); //取消订阅 MqttKit.unSub("/hello"); } catch (MqttException e1) { e1.printStackTrace(); } catch (Exception e) { e.printStackTrace(); }} ###mqtt插件配置文件说明 #JFinal-mqtt插件配置文件#MQTT Broker连接地址 默认地址:tcp://127.0.0.1:1883mqtt.brokerURL=tcp://127.0.0.1:1883#MQTT ClientId 默认值:"jf_mq_p_"+System.nanoTime()mqtt.clientId=#MQTT Client连接MQTT Broker时使用的用户名,密码 默认不设置mqtt.userName=mqtt.password=#是否手动发送消息应答 该设置只在Qos=1有效 默认falsemqtt.manualAcks=false#是否自动重连 默认falsemqtt.automaticReconnection=false#自动检测连接重连时间 默认5s 该参数只在mqtt.automaticReconnection=生效mqtt.reConnectionTimeInterval=5#是否清理session,false时可接收离线消息 true忽略离线消息 默认truemqtt.cleanSession=true#连接MQTT Broker超时时间 默认:30smqtt.connectionTimeout=60#MQTT 心跳时间间隔 默认60smqtt.keepAliveInterval=60#使用MQTT协议的版本 默认3.1.1mqtt.version=3.1.1#MQTT最大连接数 默认:10"mqtt.maxConnections=10#MQTT SSL配置文件地址mqtt.sslProperties=#MQTT 消息保存方式 如果不设置,默认保存在内存中,设置了则保存着指定的目录下mqtt.stroageDir= |
请发表评论