介绍今天接上文，来实现一个Storm数据流处理综合案例的第二部分，Storm集群向Kafka集群源源不断读取数据，通过MyBatis写入到MySQL数据库，并部署为远程模式准备工作参考上文准备工作代码编写思路：Storm集群从Kafkatopic主题获取数据，解析后写入MySQL，注意我们使用MyBatis工具与数据库交互项目结构部署MySQL我们在服务器上部署一台MySQL数据库具体参考这篇文章数据库表结构如下： WordCountDao该类会获取SqlSessionConfig配置类的SqlSessionFactory和WordCountMapper的接口方法，生成具体与数据库交互的Session WordCountMapper.xml该文件为MyBatis编写与数据库交互的具体SQL代码的地方具体实现了全量查询和批量更新或插入的接口功能