这期内容当中小编将会给大家带来有关如何理解storm与MySQL整合问题，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
南宁ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为创新互联公司的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：13518219792（备注：SSL证书合作）期待与您的合作！
首先说明下问题的情况，
1、我storm 环境已经搭建完成，在本地测试wordcount是没问题的，
2、我在wordcount中加入一个MysqlBolt，此Bolt只是简单的把 wordcount的结果存入mysql数据库中，在本地模式测试测试时，完全可以把结果插入指定表。
3、我的每个storm 节点都已经把mysql-connector-java-5.1.23.jar 放到storm的lib目录下。
4、每个节点均可以访问指定数据库，都已经开通相应权限
5、并且在远程模式下执行原始wordcount是没问题的
OK ！！！
问题是，在远程模式下运行整合mysql的wordcount时 就出错误了，异常为空指针，通过查找代码，发现在获得mysql 连接 时异常。
代码如下：标红处报异常
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();
}
问题原因：是使用maven打包时，没有包括第三方jar包
上述就是小编为大家分享的如何理解storm与mysql整合问题了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。
