如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析-創(chuàng)新互聯(lián)

如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析,相信很多沒有經(jīng)驗(yàn)的人對(duì)此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個(gè)問題。

創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù),包含不限于成都做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)、防城網(wǎng)絡(luò)推廣、微信小程序開發(fā)、防城網(wǎng)絡(luò)營銷、防城企業(yè)策劃、防城品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營等,從售前售中售后,我們都將竭誠為您服務(wù),您的肯定,是我們大的嘉獎(jiǎng);創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供防城建站搭建服務(wù),24小時(shí)服務(wù)熱線:028-86922220,官方網(wǎng)址:muchs.cn

mqtt協(xié)議的broker有很多,但是java的支持集群的并不多,之前調(diào)研過一番,發(fā)現(xiàn)moqutte基本滿足需求,就想著基于這個(gè)在自己做二次開發(fā)。
github地址:https://github.com/andsel/moquette
一。將代碼倒入idea
找到啟動(dòng)類
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析
啟動(dòng)報(bào)錯(cuò),是因?yàn)檎也坏絤oquette的配置文件
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析
跟蹤源碼moquette的配置文件地址是config/moquette.conf
因?yàn)樵蹅兪侵苯訂?dòng)的Server類里面的main方法,而不是通過assebely打包的jar包,所有這個(gè)位置是沒有配置文件的,但是moquette支持通過啟動(dòng)參數(shù)指定配置文件的位置
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析
那就簡(jiǎn)單了,把啟動(dòng)需要的配置文件放到本地的某個(gè)地方,再通過啟動(dòng)參數(shù)指定就行了,在idea里面指定
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析
我是放在/data/moquette目錄下
另外idea啟動(dòng)需要的配置文件再,broker模塊下的config包里面,或者distribution/src/main/resources
加入之后啟動(dòng)成功
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析

二。配置文件講解
moqutte的配置文件有五個(gè),下面分別講解一個(gè)有什么作用
1.moquette.conf   主配置文件,moquette啟動(dòng)需要的主要配置都在這里,包括端口號(hào),認(rèn)證鑒權(quán),存儲(chǔ)等,后面講解源碼的時(shí)候會(huì)詳細(xì)講解各個(gè)參數(shù)的意義
2.hazelcast.xml moquette的集群是通過.hazelcast來實(shí)現(xiàn)的,不了解的同學(xué)可以自行g(shù)oogle一下,這里就不詳細(xì)講了
3.password_file.conf 這里配置的是連接是需要的密碼
4.acl.conf  這里是各個(gè)client對(duì)topic的讀寫權(quán)限
5.log4j.properties 日志文件,不多說了

三??蛻舳诉x擇,本人選擇的是eclipse的paha,github地址https://github.com/eclipse/paho.mqtt.java
倒入idea之后找到如下的測(cè)試類
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析

在moquette的io.moquette.server.netty.NettyMQTTHandler類上的打斷點(diǎn),重新啟動(dòng)

啟動(dòng)paha的測(cè)試類,開始測(cè)試
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析

發(fā)現(xiàn)moquette的斷點(diǎn)進(jìn)來了,說明client到broker的鏈路走通了,后面就可以跟蹤源碼了
如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析
之所以在這打斷點(diǎn)是因?yàn)檫@是netty與其他應(yīng)用的接入點(diǎn),對(duì)netty了解的同學(xué)應(yīng)該知道,應(yīng)用其實(shí)只需要實(shí)現(xiàn)一個(gè)handler,當(dāng)有數(shù)據(jù)流的時(shí)候,由netty負(fù)責(zé)回調(diào)你的handler。

看完上述內(nèi)容,你們掌握如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注創(chuàng)新互聯(lián)網(wǎng)站制作公司行業(yè)資訊頻道,感謝各位的閱讀!

創(chuàng)新互聯(lián)www.cdcxhl.cn,專業(yè)提供香港、美國云服務(wù)器,動(dòng)態(tài)BGP最優(yōu)骨干路由自動(dòng)選擇,持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證, 機(jī)房獨(dú)有T級(jí)流量清洗系統(tǒng)配攻擊溯源,準(zhǔn)確進(jìn)行流量調(diào)度,確保服務(wù)器高可用性。佳節(jié)活動(dòng)現(xiàn)已開啟,新人活動(dòng)云服務(wù)器買多久送多久。

本文標(biāo)題:如何進(jìn)行mqtt協(xié)議中broker的moqutte源碼分析-創(chuàng)新互聯(lián)
URL鏈接:http://muchs.cn/article16/deipdg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供外貿(mào)建站、靜態(tài)網(wǎng)站、網(wǎng)站排名、面包屑導(dǎo)航、響應(yīng)式網(wǎng)站、品牌網(wǎng)站設(shè)計(jì)

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)

h5響應(yīng)式網(wǎng)站建設(shè)