涓€銆佺畝浠媘ica-mqtt鏄竴涓熀浜巎avaaio鐨勭畝鍗曘€佷綆寤惰繜銆侀珮鎬ц兘鐨刴qtt鐗╄仈缃戝紑婧愮粍浠躲€俶ica-mqtt鏇村鏄撹瀺鍏ョ幇鏈夋湇鍔″拰浜屾寮€鍙戯紝闄嶄綆鑷爺鐗╄仈缃戝钩鍙扮殑寮€鍙戞垚鏈€?銆佸姛鑳芥敮鎸丮QTTv3.1銆乿3.1.1銆乿5.0鍗忚銆傛敮鎸亀ebsocketmqtt瀛愬崗璁紙鏀寔mqtt.js锛夈€傛敮鎸乭ttprestapi锛岃瑙乭ttpapi鏂囨。銆傛敮鎸丮QTT瀹㈡埛绔鎴风銆傛敮鎸丮QTT鏈嶅姟鍣ㄦ湇鍔″櫒銆傛敮鎸丮QTT閬楀槺娑堟伅銆傛敮鎸丮QTT淇濈暀娑堟伅銆傛敮鎸佽嚜瀹氫箟娑堟伅锛坢q锛夊鐞嗗拰杞彂锛屽疄鐜伴泦缇ゃ€侻QTT瀹㈡埛绔樋閲屼簯mqtt杩炴帴demo銆傛敮鎸佸皢GraalVM缂栬瘧涓烘湰鏈哄彲鎵ц鏂囦欢銆傛敮鎸佸揩閫熻闂甋pringBoot椤圭洰锛坢ica-mqtt-spring-boot-starter锛夈€俶ica-mqtt-spring-boot-starter鏀寔瀵规帴Prometheus+Grafana銆傚熀浜巖edispub/sub瀹炵幇闆嗙兢锛岃瑙乵ica-mqtt-broker妯″潡銆?.浣跨敤鍦烘櫙鐗╄仈缃戯紙浜戠mqttbroker锛夌墿鑱旂綉锛堣竟缂樻秷鎭€氫俊锛夌兢缁処M娑堟伅鎺ㄩ€佺畝鍗曟槗鐢ㄧ殑mqtt瀹㈡埛绔鎴风4.鏇存柊璁板綍v2.1.0-2023-03-05鉁ㄣ€愪笉鍏煎銆戣皟鏁存帴鍙ｅ弬鏁版柟渚夸娇鐢ㄢ湪銆愪笉鍏煎銆戝簳灞傞噸鏋勮皟鏁粹湪鍏煎鏇村Springboot鐗堟湰锛屾敮鎸?.1.0.RELEASE浠ヤ笂鐗堟湰銆傗湪ssl鏀寔鍙屽悜璁よ瘉gitee#I61AHJ鎰熻阿@DoubleH鍙嶉馃悰Fixwillmessagejudgmentgitee#I6BRBV鎰熻阿@tan90鍙嶉銆傪煇涗慨澶嶉敊鍒瓧gitee#I6F2PA鎰熻阿@hpz鍙嶉猬嗭笍渚濊禆鍗囩骇5.杩佺Щ鎸囧崡mica-mqtt-core鎷嗗垎涓簃ica-mqtt-client鍜宮ica-mqtt-server浠ラ伩鍏嶄竴浜涗緷璧栧紩鐢ㄩ棶棰樸€侶exUtil浠巒et.dreamlu.iot.mqtt.core.util.HexUtil绉诲姩鍒皁rg.tio.utils.mica.HexUtils銆?.1Client5.1.1璁㈤槄鍥炶皟鎺ュ彛璋冩暣娉ㄦ剰锛歮ica-mqtt-client-spring-boot-starter鍙互鐩存帴浣跨敤娉ㄨВ璁㈤槄杩涜鍗囩骇銆侷MqttClientMessageListener#onMessage(ChannelContextcontext,Stringtopic,MqttPublishMessagemessage,ByteBufferpayload)鏂规硶缁熶竴娣诲姞涓婁笅鏂囧拰娑堟伅鍙傛暟銆傞渶瑕佽皟鏁磋闃呯郴鍒楁柟娉曪細//娑堟伅璁㈤槄锛屾柟娉曠被浼約ubxxxclient.subQos0("/test/#",(context,topic,message,payload)->{logger.info(topic+'\t'+ByteBufferUtil.toString(payload));});5.1.2SSL鍙屽悜璁よ瘉鏀寔mica:ssl:enabled:false#鏄惁寮€鍚痵sl璁よ瘉锛?.1.0寮€濮嬫敮鎸佸弻鍚戣璇乲eystore-path:#鍙€夊弬鏁帮細ssl鍙屽悜璁よ瘉keystore鐩綍锛屾敮鎸乧lasspath:/璺緞銆俴eystore-pass:#鍙€夊弬鏁帮細ssl鍙屽悜璁よ瘉keystorepasswordtruststore-path:#鍙€夊弬鏁帮細ssl鍙屽悜璁よ瘉truststore鐩綍锛屾敮鎸乧lasspath:/璺緞銆倀ruststore-pass:#鍙€夊弬鏁帮細ssl鍙屽悜璁よ瘉truststore瀵嗙爜娉細鏈嶅姟绔紑鍚痵sl瀹㈡埛绔殑涓夌鎯呭喌ClientAuthisNONE锛堜笉闇€瑕佸鎴风璁よ瘉锛夊彧闇€瑕佸紑鍚痵sl锛屼笉閰嶇疆璇佷功ClientAuthisOPTIONAL锛堜笌瀹㈡埛绔崗鍟嗭級闇€瑕佸紑鍚痵sl骞堕厤缃畉ruststore璇佷功ClientAuthasREQUIRE锛堥渶瑕佸鎴风璁よ瘉锛夐渶瑕佸紑鍚痵sl骞堕厤缃畉ruststore锛宬eystore璇佷功topic銆乹oS銆乵essage鏀逛负鍘熸潵鐨凪qttPublishMessage锛岃繖鏍峰氨鍙互鑷繁鑾峰彇mqtt5.x鐨勫睘鎬с€?***鐩戝惉娑堟伅**@paramcontextChannelContext*@paramclientIdclientId*@paramtopictopic*@paramqoSMqttQoS*@parammessageMessage*/voidonMessage(ChannelContextcontext,StringclientId,Stringtopic,MqttQoSqoS,MqttPublishMessagemessage);5.1.2.2ssl鍙屽悜璁よ瘉鏀寔mica:ssl:#mqtttcpsslauthenticationenabled:false#鏄惁寮€鍚痵sl璁よ瘉锛?.1.0寮€濮嬫敮鎸佸弻鍚戣璇乲eystore-path:#蹇呭～鍙傛暟:sslkeystore鐩綍锛屾敮鎸乧lasspath:/璺緞銆俴eystore-pass:#寮哄埗鍙傛暟锛歴slkeystorepasswordtruststore-path:#鍙€夊弬鏁帮細ssl鍙屽悜璁よ瘉truststore鐩綍锛屾敮鎸乧lasspath:/璺緞銆倀ruststore-pass:#鍙€夊弬鏁帮細ssl鍙屽悜璁よ瘉truststorepasswordclient-auth:none#鏄惁闇€瑕佸鎴风璁よ瘉锛堝弻鍚戣璇侊級锛岄粯璁わ細NONE锛堜笉闇€瑕侊級6.浣跨敤鏂囨。鍜岀ず渚媘ica-mqtt-瀹㈡埛绔娇鐢ㄦ枃妗ica-mqtt-server浣跨敤鏂囨。mica-mqtt-client-spring-boot-starter浣跨敤鏂囨。mica-mqtt-server-spring-boot-starter浣跨敤鏂囨。mica-mqtthttpapi鏂囨。瑙乵ica-mqtt鍙戝竷鐗堟湰璁板綍
