這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)如何理解storm與MySQL整合問(wèn)題，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

南寧ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景，ssl證書未來(lái)市場(chǎng)廣闊！成為創(chuàng)新互聯(lián)公司的ssl證書銷售渠道，可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：13518219792（備注：SSL證書合作）期待與您的合作！

首先說(shuō)明下問(wèn)題的情況，

1、我storm 環(huán)境已經(jīng)搭建完成，在本地測(cè)試wordcount是沒(méi)問(wèn)題的，

2、我在wordcount中加入一個(gè)MysqlBolt，此Bolt只是簡(jiǎn)單的把 wordcount的結(jié)果存入mysql數(shù)據(jù)庫(kù)中，在本地模式測(cè)試測(cè)試時(shí)，完全可以把結(jié)果插入指定表。

3、我的每個(gè)storm 節(jié)點(diǎn)都已經(jīng)把mysql-connector-java-5.1.23.jar 放到storm的lib目錄下。

4、每個(gè)節(jié)點(diǎn)均可以訪問(wèn)指定數(shù)據(jù)庫(kù)，都已經(jīng)開通相應(yīng)權(quán)限

5、并且在遠(yuǎn)程模式下執(zhí)行原始wordcount是沒(méi)問(wèn)題的

OK ！！！

問(wèn)題是，在遠(yuǎn)程模式下運(yùn)行整合mysql的wordcount時(shí) 就出錯(cuò)誤了，異常為空指針，通過(guò)查找代碼，發(fā)現(xiàn)在獲得mysql 連接 時(shí)異常。

代碼如下：標(biāo)紅處報(bào)異常

String host_port = "slaver1:3306";
 String database = "test";
 String username = "root";
 String password = "hello";
 String url = "jdbc:mysql://" + host_port + "/" + database;
 Connection conn = null;
 try {
 Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection(url, username, password);
 } catch (ClassNotFoundException e) {
 e.printStackTrace();
 } catch (SQLException e) {
 e.printStackTrace();
 }
問(wèn)題原因：是使用maven打包時(shí)，沒(méi)有包括第三方j(luò)ar包

上述就是小編為大家分享的如何理解storm與mysql整合問(wèn)題了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

網(wǎng)頁(yè)題目：如何理解storm與mysql整合問(wèn)題
文章轉(zhuǎn)載：http://vcdvsql.cn/article10/pdehgo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)、小程序開發(fā)、品牌網(wǎng)站設(shè)計(jì)、自適應(yīng)網(wǎng)站、響應(yīng)式網(wǎng)站、商城網(wǎng)站

廣告

聲明：本網(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í)需注明來(lái)源： 創(chuàng)新互聯(lián)