真正

logMonitor

storm部分

-------------

       通过Maven构建，生成一个包含依赖的single jar文件（不要把Storm的依赖包添加进去）

       1、修改storm的main入口　　2、修改MessageFilterBolt

       3、添加<scope>provided</scope>

        <dependency>
            <groupId>org.apache.storm</groupId>
            <artifactId>storm-core</artifactId>
            <version>0.9.5</version>
            <scope>provided</scope>
        </dependency>

　　storm命令行客户端，运行类的指定参数的main方法：

　　storm jar 20180111.jar logMonitor.LogMonitorTopologyMain kafka4storm

转储部分

------------

　　打包成runnable.jar包

　　

jedis 与 mysql 的连接都要写192.168.223.201 而不是127.0.0.1

6、storm连接mysql数据库报异常

连接远程mysql数据库时报如下错误：

1	message from server:"Host FILTER" is not allowed to connect to this MySQL server

问题分析：可能是没有给其IP访问Mysql数据库权限导致

问题解决：登录mysql数据库，执行如下命令：

1	grant all on *.* to root@'%' identified by "123456";

此操作是给任意IP地址赋予访问权限（命令中*.*是通配任何IP，可指定IP 用户名：root 密码：123456）