JAVA 实践项目 --- 树莓派信息自动化采集后入库项目 (三)

本贴最后更新于 2212 天前,其中的信息可能已经渤澥桑田

项目源代码可访问我的 github:https://github.com/Spacider/Gather-and-store
如果觉得好的话请给个 star 哦~

开发 IDE: IDEA 2018.03 JDK 1.8
开发环境: macOS 10.13.6 (如 windows 请对项目中部分路径进行改写)
数据库: Oracle 11g


第二阶段:数据的采集和写入日志文件

在 JAVA 实践项目---树莓派信息自动化采集后入库项目(二) 中我们从模拟的树莓派服务器上得到了我们需要采集的数据,接下来我们要干的事儿就是把得到的 XML 继续解析,等到相应的数据把其写入一个文件中!文件内容如下图所示:
imagepng


话不多说,开始编写代码:

  1. 在我们的 SAXReaderHelper 类中编写方法 InLogFile:将获取到数据写入到日志文件中。
public static void InLogFile(String str,String SensorAddress,String counter){
}

它由 3 个参数,分别是我们读取的 XML 文件(通过流实际上使用的是 String 来接收),由于 SensorAddresscounter 参数返回的 XML 文件中没有这两个参数,所以我们通过传参的方式把这两个参数传入!

这里我们又用到了 dom4j 技术对其进行解析:

 // 把客户端传过来的 xml 转化为字符串存储
String TotalStr = str.toString();
byte[] TotalBytes = TotalStr.getBytes();
// dom4j 构建对象内填入一个 byte 类型的数组
bais = new ByteArrayInputStream(TotalBytes);
SAXReader reader = new SAXReader();
Document document = null;

通过对象流的方式直接交给 dom4j:

try {
   document = reader.read(bais,"utf-8");
}

有了 document 对象以后我们就可以解析了,接下来我们用一个 StringBuilder 来对字符串进行拼接,拼接成上图我们讲过的样子。最后加上 "\r\n",这样最后写入文件的时候每一条数据会换行。

// 获取根节点
 Element Message = document.getRootElement();
 StringBuilder sb = new StringBuilder();
 // 拼接字符串
 sb.append(Message.element("SrcID").getText()+"|");
 sb.append(Message.element("DstID").getText()+"|");
 sb.append(Message.element("DevID").getText()+"|");
 sb.append(SensorAddress+"|");
 sb.append(counter+"|");
 sb.append(Message.element("Cmd").getText()+"|");
 sb.append(Message.element("Data").getText()+"|");
 sb.append(Message.element("Status").getText()+"|");
 sb.append(new Timestamp(System.currentTimeMillis()));
 sb.append("\r\n");

得到拼接好数据的字符串以后我们要做的就是写入文件了,这里用到了文件输出流,最后记得 flush 哦!刷一下内容才会进去
注意:请在 src 下先创建 radwtmp 文件,这里的 "/Users/wjh/Desktop/FirstProject/src/radwtmp" 路径为我电脑上路径,请改成你的路径!

File file = new File("/Users/wjh/Desktop/FirstProject/src/radwtmp");
if (!file.exists()){
  	file.createNewFile();
}
fos = new FileOutputStream(file,true);
fos.write(sb.toString().getBytes());
fos.flush();
  1. 封装好方法以后我们就可以调用它了,在 ClientReceiveHelperClientGetXml 方法最后加入这么一行:
// 根据 XML 文件解析,并将其写入文件中
SAXReaderHelper.InLogFile(sb.toString(), SensorAddress, counter + "");
  1. 编写客户端主程序:
    DataClient(温度湿度客户端),GuangClient(树莓派光照客户端),CarbonDioxideClient(二氧化碳客户端):
    传入 SensorAddress 为传感器 ID,16 表示温度湿度传感器,256 表示光照传感器,1280 表示二氧化碳传感器
 public static void DataGetObj(){
     ClientReceiveHelper.ClientGetXml("16",1);
 }
public static void guangGetObj(){
	ClientReceiveHelper.ClientGetXml("256",1);
}
public static void CarbonDioxideGetObj(){
     ClientReceiveHelper.ClientGetXml("1280",1);
}
  1. 为了方便操作,我们设立一个定时器,编写一个定时器类:
public final class TimerRunClient {

    public static void runClientMain() {
        // 构建定时器
        Timer timer = new Timer(false);

        /**
         * 第一个参数表示定时器执行的函数,第二个参数表示第一次定时器生效的时间,第三个参数表示每隔多长事件调用第一个参数所指向的方法
         * 第二个参数和第三个参数单位是毫秒
         */

        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                // 定时器调用的代码
                DataClient.DataGetObj();
                GuangClient.guangGetObj();
                CarbonDioxideClient.CarbonDioxideGetObj();
            }
        }, 0, 5000);
    }
    public static void main(String[] args) {
        runClientMain();
    }
}
  1. 运行定时器类(TimerRunClient)和树莓派系统数据模拟类(DataServer),看到 radwtmp 类中数据如下图所示即为成功!
    imagepng

本文中为代码详解,可能与源代码不一定相同,可以查看我的 github:https://github.com/Spacider/Gather-and-store 查看源代码与你的代码进行比对!如果觉得我写的好的话请给一个 star 哦!

  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3186 引用 • 8212 回帖
  • 实践项目
    6 引用

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...

推荐标签 标签

  • FlowUs

    FlowUs.息流 个人及团队的新一代生产力工具。

    让复杂的信息管理更轻松、自由、充满创意。

    1 引用
  • jsDelivr

    jsDelivr 是一个开源的 CDN 服务,可为 npm 包、GitHub 仓库提供免费、快速并且可靠的全球 CDN 加速服务。

    5 引用 • 31 回帖 • 53 关注
  • SSL

    SSL(Secure Sockets Layer 安全套接层),及其继任者传输层安全(Transport Layer Security,TLS)是为网络通信提供安全及数据完整性的一种安全协议。TLS 与 SSL 在传输层对网络连接进行加密。

    70 引用 • 193 回帖 • 437 关注
  • Kafka

    Kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是现代系统中许多功能的基础。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。

    36 引用 • 35 回帖 • 2 关注
  • 开源中国

    开源中国是目前中国最大的开源技术社区。传播开源的理念,推广开源项目,为 IT 开发者提供了一个发现、使用、并交流开源技术的平台。目前开源中国社区已收录超过两万款开源软件。

    7 引用 • 86 回帖
  • Q&A

    提问之前请先看《提问的智慧》,好的问题比好的答案更有价值。

    7932 引用 • 36284 回帖 • 169 关注
  • abitmean

    有点意思就行了

    30 关注
  • 又拍云

    又拍云是国内领先的 CDN 服务提供商,国家工信部认证通过的“可信云”,乌云众测平台认证的“安全云”,为移动时代的创业者提供新一代的 CDN 加速服务。

    21 引用 • 37 回帖 • 541 关注
  • Kubernetes

    Kubernetes 是 Google 开源的一个容器编排引擎,它支持自动化部署、大规模可伸缩、应用容器化管理。

    110 引用 • 54 回帖 • 3 关注
  • Solidity

    Solidity 是一种智能合约高级语言,运行在 [以太坊] 虚拟机(EVM)之上。它的语法接近于 JavaScript,是一种面向对象的语言。

    3 引用 • 18 回帖 • 383 关注
  • 反馈

    Communication channel for makers and users.

    123 引用 • 911 回帖 • 237 关注
  • CAP

    CAP 指的是在一个分布式系统中, Consistency(一致性)、 Availability(可用性)、Partition tolerance(分区容错性),三者不可兼得。

    11 引用 • 5 回帖 • 606 关注
  • 外包

    有空闲时间是接外包好呢还是学习好呢?

    26 引用 • 232 回帖 • 3 关注
  • TensorFlow

    TensorFlow 是一个采用数据流图(data flow graphs),用于数值计算的开源软件库。节点(Nodes)在图中表示数学操作,图中的线(edges)则表示在节点间相互联系的多维数据数组,即张量(tensor)。

    20 引用 • 19 回帖
  • 钉钉

    钉钉,专为中国企业打造的免费沟通协同多端平台, 阿里巴巴出品。

    15 引用 • 67 回帖 • 337 关注
  • 招聘

    哪里都缺人,哪里都不缺人。

    190 引用 • 1057 回帖 • 1 关注
  • danl
    128 关注
  • 运维

    互联网运维工作,以服务为中心,以稳定、安全、高效为三个基本点,确保公司的互联网业务能够 7×24 小时为用户提供高质量的服务。

    148 引用 • 257 回帖
  • 生活

    生活是指人类生存过程中的各项活动的总和,范畴较广,一般指为幸福的意义而存在。生活实际上是对人生的一种诠释。生活包括人类在社会中与自己息息相关的日常活动和心理影射。

    230 引用 • 1454 回帖
  • 微软

    微软是一家美国跨国科技公司,也是世界 PC 软件开发的先导,由比尔·盖茨与保罗·艾伦创办于 1975 年,公司总部设立在华盛顿州的雷德蒙德(Redmond,邻近西雅图)。以研发、制造、授权和提供广泛的电脑软件服务业务为主。

    8 引用 • 44 回帖 • 1 关注
  • FreeMarker

    FreeMarker 是一款好用且功能强大的 Java 模版引擎。

    23 引用 • 20 回帖 • 461 关注
  • Angular

    AngularAngularJS 的新版本。

    26 引用 • 66 回帖 • 533 关注
  • 宕机

    宕机,多指一些网站、游戏、网络应用等服务器一种区别于正常运行的状态,也叫“Down 机”、“当机”或“死机”。宕机状态不仅仅是指服务器“挂掉了”、“死机了”状态,也包括服务器假死、停用、关闭等一些原因而导致出现的不能够正常运行的状态。

    13 引用 • 82 回帖 • 53 关注
  • 强迫症

    强迫症(OCD)属于焦虑障碍的一种类型,是一组以强迫思维和强迫行为为主要临床表现的神经精神疾病,其特点为有意识的强迫和反强迫并存,一些毫无意义、甚至违背自己意愿的想法或冲动反反复复侵入患者的日常生活。

    15 引用 • 161 回帖 • 1 关注
  • HHKB

    HHKB 是富士通的 Happy Hacking 系列电容键盘。电容键盘即无接点静电电容式键盘(Capacitive Keyboard)。

    5 引用 • 74 回帖 • 465 关注
  • IDEA

    IDEA 全称 IntelliJ IDEA,是一款 Java 语言开发的集成环境,在业界被公认为最好的 Java 开发工具之一。IDEA 是 JetBrains 公司的产品,这家公司总部位于捷克共和国的首都布拉格,开发人员以严谨著称的东欧程序员为主。

    180 引用 • 400 回帖 • 2 关注
  • 周末

    星期六到星期天晚,实行五天工作制后,指每周的最后两天。再过几年可能就是三天了。

    14 引用 • 297 回帖