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

本贴最后更新于 2471 天前,其中的信息可能已经沧海桑田

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

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


上节完毕项目主体已经基本开发完成,下列进行一系列优化操作:

1.备份模块:
先编写一个接口:

/** * 备份模块 * 1. 客户端发送集合没有发送出去或连不上服务器需要备份 * 2. 服务端接收了集合对象写入数据库出错,对集合进行备份 */ public interface BackUp extends WossModel{ /** * 将集合保存到文件中 * @param coll 需要备份的集合 */ void storeEnvs(Collection<Environment> coll ); /** * 将集合从文件中读取 * @return */ Collection<Environment> loadEnvs(); }

具体实现:
通过对象流套文件流的形式把对象存入备份文件中:

@Override public void storeEnvs(Collection<Environment> coll) { File file = new File(path); FileOutputStream fos = null; ObjectOutputStream oos = null; try { if (!file.exists()) { file.createNewFile(); } fos = new FileOutputStream(file,true); oos = new ObjectOutputStream(fos); oos.writeObject(coll); oos.flush(); System.out.println("已经存入备份文件中 ,path:" +path); } catch (IOException e) { e.printStackTrace(); } finally { IOUtil.close(fos,oos); } }

从备份文件中取出相应对象!

@Override public Collection <Environment> loadEnvs() { FileInputStream fis = null; ObjectInputStream ois = null; Object backupObject = null; try { fis = new FileInputStream(path); ois = new ObjectInputStream(fis); backupObject = ois.readObject(); // System.out.println("已经从 path:" + path + "取出备份文件"); log.info("从 path:" + path + "取出备份文件中..."); } catch (IOException | ClassNotFoundException e) { e.printStackTrace(); } return (Collection <Environment>) backupObject; }

2.日志模块
先编写一个接口叫 Log,里边封装了日志的四种级别:

public interface Log extends WossModel{ /** * 输出 debug 级别的日志 * @param msg */ void debug(String msg); /** * 输出 info 级别的日志 * @param msg */ void info(String msg); /** * 输出 warn 级别的日志 * @param msg */ void warn(String msg); /** * 输出 error 级别的日志 * @param msg */ void error(String msg); }

日志模块的实现就是调用 log4j 的日志配置,然后做对应的输出:

private Logger LOGGER = Logger.getLogger(LogImpl.class); public LogImpl() { PropertyConfigurator.configure("/Users/wjh/Desktop/FirstProject/src/main/resources/log4j.properties"); } @Override public void debug(String msg) { LOGGER.debug(msg); } @Override public void info(String msg) { LOGGER.info(msg); } @Override public void warn(String msg) { LOGGER.warn(msg); } @Override public void error(String msg) { LOGGER.error(msg); } @Override public void init(Properties properties) { }

3.配置模块
首先配置一个接口为 WossModel,里面有一个方法,有了这个方法之后当一个类如果实现了这个接口,我们就可以把 Properties 文件传给它,在 Properties 文件中我们又可以传入相应的参数,这样做可以灵活替换类中的可变参,让整个程序变得灵活起来!

/** * 初始化配置参数 */ public interface WossModel { void init(Properties properties); }

再定义一个接口为 Configuration,在这个接口的实现中会通过反射去获取各个类(又可以说是一个模块)的对象,保证了对象的唯一性!这一部分又可以看做是一个注入过程,让对象的创建变得灵活,变得安全!

/** * 获取各个配置模块对象 * 对所有对象进行管理 */ public interface Configuration { /** * 获取采集模块对象 */ Gather getGather(); /** * 获取客户端模块对象 */ EnvClient getClient(); /** * 获取服务器端对象 */ EnvServer getServer(); /** * 获取入库模块对象 */ DBStore getDBStore(); /** * 获取日志模块对象 */ Log getLog(); /** * 获取备份模块对象 */ BackUp getBackUp(); }

最后一个接口是 ConfigurationAware,这个接口的主要用途就是当遇到一个模块对象调用到另一个模块对象时间,就可以把刚才写的 Configuration 整个注入进去,有了这个 Configuration 对象就相当于可以获取到了其他所有配置模块的对象,这样你就可以灵活去获取到你需要的对象并且调用其内的方法了!

public interface ConfigurationAware { void SetConfiguration(Configuration conf); }

具体实施

讲了这么多,具体咋实施呢:
给你需要的类上接口!
例如:
客户端的类:
让接口实现 WossModel 接口,那么子实现就默认也实现了这个接口!
由于在客户端类中

public interface EnvClient extends WossModel { } public class EnvClientImpl implements EnvClient , ConfigurationAware { }

当继承了 WossModel 接口之后我们就可以实现其方法来接入 Properties 文件:

public void init(Properties properties) { port = Integer.parseInt(properties.getProperty("port")); }

这样我们就可以替换掉 port 属性,等会有写怎样去通过写入 XML 文件的形式读取到这个 port 属性!

最后是重头戏,实现 Configuration 类,编写 ConfigurationImpl 类:
按照如下形式去

<?xml version="1.0" encoding="UTF-8" ?> <EMS> <Log class="com.briup.util.Impl.LogImpl"> </Log> <gather class="com.briup.Client.Impl.GatherImpl"> <logFile>/Users/wjh/Desktop/FirstProject/src/radwtmp</logFile> <positionFile>/Users/wjh/Desktop/FirstProject/src/main/resources/FilePostion.properties</positionFile> </gather> <EnvClient class = "com.briup.Client.Impl.EnvClientImpl"> <host>127.0.0.1</host> <port>9999</port> <path>/Users/wjh/Desktop/FirstProject/src/BackUptmp</path> </EnvClient> <EnvServer class="com.briup.Server.Impl.EnvServerImpl"> <port>9999</port> </EnvServer> <BackUp class="com.briup.util.Impl.BackUpImpl"> <BackUppath>/Users/wjh/Desktop/FirstProject/src/BackUptmp</BackUppath> </BackUp> <DBStore class="com.briup.Server.Impl.DBStoreImpl"> </DBStore> </EMS>

<对象名 class="对象的全限定名"> <需要替换的属性名>属性值</需要替换的属性名> </对象名>

来进行编写

ConfigurationImpl 的构造器中,编写对 XML 文件进行解析的代码!
这里还是用之前用到的 Dom4j,先获取到根节点,然后获取最大的子节点,也就是对象名

fis = new FileInputStream("/Users/wjh/Desktop/FirstProject/src/main/resources/EMS.xml"); document = saxReader.read(fis); EMS = document.getRootElement(); List<Element> EMSlist = EMS.elements();

使用一个 map 集合来存储我们得到的对象:

// 使用 Map 集合来存放 模块名-对象 private Map<String,WossModel> ObjectMap = new HashMap <>();

再遍历对象名的时候,获取对象名的 class 属性,也就是全限定名,通过 Class.forName() 来获取到的对应的对象,然后存入 map 集合中,然后继续遍历下一层,碰到有需要可变参数的模块的时候把可变参数提取出来,交给 Properties,等待对象成功创建以后通过其中的 init 方法把 Properties 对象传入,最后如果遇到了类继承了 ConfigurationAware 接口(也就是说这个类会调用其他类的对象),就调用 SetConfiguration 方法把 Configuration 对象传入!这样就可以在一个类中去调用其他类的对象了:

for (Element element : EMSlist){ //gather -- EnvClient -- EnvServer -- BackUp -- DBStore -- String elementName = element.getName(); String elementClass = element.attribute("class").getText(); WossModel obj = (WossModel) Class.forName(elementClass).newInstance(); if (obj instanceof ConfigurationAware){ ((ConfigurationAware) obj).SetConfiguration(this); } // 遍历子节点,为应该赋值的变量赋值 List<Element> ChildEMSList = element.elements(); Properties properties =new Properties(); for (Element element1 : ChildEMSList){ properties.setProperty(element1.getName(),element1.getText()); } // 调用其 init 方法,对变量进行赋值 obj.init(properties); ObjectMap.put(elementName,obj); }

当做完了这一切,对象的创建变得异常简单:

@Override public Gather getGather() { return (Gather) ObjectMap.get("gather"); } @Override public EnvClient getClient() { return (EnvClient) ObjectMap.get("EnvClient"); } @Override public EnvServer getServer() { return (EnvServer) ObjectMap.get("EnvServer"); } @Override public DBStore getDBStore() { return (DBStore) ObjectMap.get("DBStore"); } @Override public Log getLog() { return (Log) ObjectMap.get("Log"); } @Override public BackUp getBackUp() { return (BackUp) ObjectMap.get("BackUp"); }

在配置模块之后,就可以通过这样来创造一个新的对象:

ConfigurationImpl configuration = new ConfigurationImpl(); Gather gather = configuration.getGather();

而在继承了 ConfigurationAware 接口的类中,可以通过

private Configuration configuration; private Log logger; @Override public void SetConfiguration(Configuration conf) { this.configuration = conf; logger = configuration.getLog(); }

日志也变得如此简单:

logger.info("插入数据库成功:" + count + "数据"); logger.error("插入数据库失败");

项目的说明就此结束,项目的说明中的代码不一定完整,完整代码在 https://github.com/Spacider/Gather-and-store

这是一个练手项目,通过这个项目你可以对 java 基础有更深层次的了解,其中运用了注入,模块分割等常用的方法,使你之后对 spring 等框架的理解更深一个层次!
本人语言沟通能力尚缺,可能讲的地方会出问题,请指教!希望能和大家一起学习,一起进步!

个人网站:http://www.spacider.com/
CSDN:https://blog.csdn.net/qq_37163479
联系 QQ:729215049

  • 实践项目
    6 引用
  • Java

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

    3203 引用 • 8217 回帖 • 2 关注

相关帖子

欢迎来到这里!

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

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

推荐标签 标签

  • RYMCU

    RYMCU 致力于打造一个即严谨又活泼、专业又不失有趣,为数百万人服务的开源嵌入式知识学习交流平台。

    4 引用 • 6 回帖 • 61 关注
  • ngrok

    ngrok 是一个反向代理,通过在公共的端点和本地运行的 Web 服务器之间建立一个安全的通道。

    7 引用 • 63 回帖 • 656 关注
  • BAE

    百度应用引擎(Baidu App Engine)提供了 PHP、Java、Python 的执行环境,以及云存储、消息服务、云数据库等全面的云服务。它可以让开发者实现自动地部署和管理应用,并且提供动态扩容和负载均衡的运行环境,让开发者不用考虑高成本的运维工作,只需专注于业务逻辑,大大降低了开发者学习和迁移的成本。

    19 引用 • 75 回帖 • 683 关注
  • 大疆创新

    深圳市大疆创新科技有限公司(DJI-Innovations,简称 DJI),成立于 2006 年,是全球领先的无人飞行器控制系统及无人机解决方案的研发和生产商,客户遍布全球 100 多个国家。通过持续的创新,大疆致力于为无人机工业、行业用户以及专业航拍应用提供性能最强、体验最佳的革命性智能飞控产品和解决方案。

    2 引用 • 14 回帖
  • CentOS

    CentOS(Community Enterprise Operating System)是 Linux 发行版之一,它是来自于 Red Hat Enterprise Linux 依照开放源代码规定释出的源代码所编译而成。由于出自同样的源代码,因此有些要求高度稳定的服务器以 CentOS 替代商业版的 Red Hat Enterprise Linux 使用。两者的不同在于 CentOS 并不包含封闭源代码软件。

    240 引用 • 224 回帖
  • JetBrains

    JetBrains 是一家捷克的软件开发公司,该公司位于捷克的布拉格,并在俄国的圣彼得堡及美国麻州波士顿都设有办公室,该公司最为人所熟知的产品是 Java 编程语言开发撰写时所用的集成开发环境:IntelliJ IDEA

    18 引用 • 54 回帖
  • 负能量

    上帝为你关上了一扇门,然后就去睡觉了....努力不一定能成功,但不努力一定很轻松 (° ー °〃)

    89 引用 • 1251 回帖 • 391 关注
  • Log4j

    Log4j 是 Apache 开源的一款使用广泛的 Java 日志组件。

    20 引用 • 18 回帖 • 38 关注
  • 爬虫

    网络爬虫(Spider、Crawler),是一种按照一定的规则,自动地抓取万维网信息的程序。

    106 引用 • 275 回帖 • 1 关注
  • 黑曜石

    黑曜石是一款强大的知识库工具,支持本地 Markdown 文件编辑,支持双向链接和关系图。

    A second brain, for you, forever.

    25 引用 • 254 回帖 • 2 关注
  • Hprose

    Hprose 是一款先进的轻量级、跨语言、跨平台、无侵入式、高性能动态远程对象调用引擎库。它不仅简单易用,而且功能强大。你无需专门学习,只需看上几眼,就能用它轻松构建分布式应用系统。

    9 引用 • 17 回帖 • 638 关注
  • OneDrive
    2 引用
  • LeetCode

    LeetCode(力扣)是一个全球极客挚爱的高质量技术成长平台,想要学习和提升专业能力从这里开始,充足技术干货等你来啃,轻松拿下 Dream Offer!

    209 引用 • 72 回帖
  • Q&A

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

    10207 引用 • 46388 回帖 • 63 关注
  • Caddy

    Caddy 是一款默认自动启用 HTTPS 的 HTTP/2 Web 服务器。

    10 引用 • 54 回帖 • 179 关注
  • Rust

    Rust 是一门赋予每个人构建可靠且高效软件能力的语言。Rust 由 Mozilla 开发,最早发布于 2014 年 9 月。

    59 引用 • 22 回帖 • 8 关注
  • 职场

    找到自己的位置,萌新烦恼少。

    127 引用 • 1708 回帖 • 1 关注
  • Sphinx

    Sphinx 是一个基于 SQL 的全文检索引擎,可以结合 MySQL、PostgreSQL 做全文搜索,它可以提供比数据库本身更专业的搜索功能,使得应用程序更容易实现专业化的全文检索。

    1 引用 • 223 关注
  • sts
    2 引用 • 2 回帖 • 247 关注
  • IBM

    IBM(国际商业机器公司)或万国商业机器公司,简称 IBM(International Business Machines Corporation),总公司在纽约州阿蒙克市。1911 年托马斯·沃森创立于美国,是全球最大的信息技术和业务解决方案公司,拥有全球雇员 30 多万人,业务遍及 160 多个国家和地区。

    17 引用 • 53 回帖 • 144 关注
  • InfluxDB

    InfluxDB 是一个开源的没有外部依赖的时间序列数据库。适用于记录度量,事件及实时分析。

    2 引用 • 106 关注
  • 尊园地产

    昆明尊园房地产经纪有限公司,即:Kunming Zunyuan Property Agency Company Limited(简称“尊园地产”)于 2007 年 6 月开始筹备,2007 年 8 月 18 日正式成立,注册资本 200 万元,公司性质为股份经纪有限公司,主营业务为:代租、代售、代办产权过户、办理银行按揭、担保、抵押、评估等。

    1 引用 • 22 回帖 • 800 关注
  • Swift

    Swift 是苹果于 2014 年 WWDC(苹果开发者大会)发布的开发语言,可与 Objective-C 共同运行于 Mac OS 和 iOS 平台,用于搭建基于苹果平台的应用程序。

    34 引用 • 37 回帖 • 557 关注
  • LaTeX

    LaTeX(音译“拉泰赫”)是一种基于 ΤΕΧ 的排版系统,由美国计算机学家莱斯利·兰伯特(Leslie Lamport)在 20 世纪 80 年代初期开发,利用这种格式,即使使用者没有排版和程序设计的知识也可以充分发挥由 TeX 所提供的强大功能,能在几天,甚至几小时内生成很多具有书籍质量的印刷品。对于生成复杂表格和数学公式,这一点表现得尤为突出。因此它非常适用于生成高印刷质量的科技和数学类文档。

    12 引用 • 59 回帖
  • IPFS

    IPFS(InterPlanetary File System,星际文件系统)是永久的、去中心化保存和共享文件的方法,这是一种内容可寻址、版本化、点对点超媒体的分布式协议。请浏览 IPFS 入门笔记了解更多细节。

    20 引用 • 245 回帖 • 236 关注
  • PWA

    PWA(Progressive Web App)是 Google 在 2015 年提出、2016 年 6 月开始推广的项目。它结合了一系列现代 Web 技术,在网页应用中实现和原生应用相近的用户体验。

    14 引用 • 69 回帖 • 185 关注
  • Kotlin

    Kotlin 是一种在 Java 虚拟机上运行的静态类型编程语言,由 JetBrains 设计开发并开源。Kotlin 可以编译成 Java 字节码,也可以编译成 JavaScript,方便在没有 JVM 的设备上运行。在 Google I/O 2017 中,Google 宣布 Kotlin 成为 Android 官方开发语言。

    19 引用 • 33 回帖 • 90 关注