功能Java示例 第5部分–将I / O移到外部

这是称为“ Functional Java by Example”的系列文章的第5部分。

在上一部分中,我们停止了对文档的变异,并返回了数据的副本。 现在,我们需要移走一些I / O。

如果您是第一次来,最好是从头开始阅读。 它有助于了解我们从何处开始以及如何在整个系列中继续前进。

这些都是这些部分:

  • 第1部分–从命令式到声明式
  • 第2部分–讲故事
  • 第3部分–不要使用异常来控制流程
  • 第4部分–首选不变性
  • 第5部分–将I / O移到外部
  • 第6部分–用作参数
  • 第7部分–将失败也视为数据
  • 第8部分–更多纯函数

我将在每篇文章发表时更新链接。 如果您通过内容联合组织来阅读本文,请查看我博客上的原始文章。

每次代码也被推送到这个GitHub项目 。

将I / O移到外面

还记得我们以前留下的东西吗?

class FeedHandler {Webservice webserviceDocumentDb documentDbvoid handle(List<Doc> changes) {changes.findAll { doc -> isImportant(doc) }.each { doc ->createResource(doc).thenAccept { resource ->documentDb.update(setToProcessed(doc, resource))}.exceptionally { e ->documentDb.update(setToFailed(doc, e))}}}private CompletableFuture<Resource> createResource(doc) {webservice.create(doc)}private boolean isImportant(doc) {doc.type == 'important'}private Doc setToProcessed(doc, resource) {doc.copyWith(status: 'processed',apiId: resource.id)}private Doc setToFailed(doc, e) {doc.copyWith(status: 'failed',error: e.message)}}

我在本系列的每个部分中发展的示例是某种“提要处理程序”,用于处理文档。

处理效果如何?

  1. 一份或多份文件进来
  2. 如果文档“很重要”,则将其保存到Web服务API中,该API将为其创建并返回资源
  3. 如果成功,则将文档标记为已处理
  4. 如果失败,则将文档标记为失败
  5. 最终,文档将在数据库中更新

Web服务可以是REST服务(因为我们在谈论资源 ),数据库可以是CouchDB或MongoDB的文档存储(因为我们在谈论文档 ),但这并不重要。

重要的是通常在任何系统中都涉及一些I / O(输入/输出)。 从文件系统读取信息,将信息存储到数据库中,在Web服务之间通过网络进行通信。

正如我们在上一期文章中所见,我们希望我们的功能尽可能纯净 ,没有任何副作用。 不幸的是,真正的系统必须与外界交互才能有意义。

我们还如何获取输入到系统中的信息,或向用户输出什么呢? I / O的一些示例是:

  • 文件系统访问
  • 网络插座
  • HTTP请求
  • JDBC操作
  • 启动线程
  • 系统时钟访问

我们已经通过setToProcessed / setToFailed方法摆脱了对数据库的访问,方法是将其上移到调用链上一步,但是它仍在FeedHandler

功能性Java

我们能做的最好的就是将I / O移到系统外部。

我们可以做的最明显的改变是完全摆脱数据库,而只是从handle()返回新的更新文档。

摆脱数据库

更改

.thenAccept { resource ->documentDb.update(setToProcessed(doc, resource))
}
.exceptionally { e ->documentDb.update(setToFailed(doc, e))
}

.thenApply { resource ->setToProcessed(doc, resource)
}
.exceptionally { e ->setToFailed(doc, e)
}

摆脱documentDb

我们只是在通话链的更远处返回所有修改过的文档。 这就是为什么我们还必须……

…摆脱虚无

从更改返回类型

void handle(...)

List<Doc> handle(...)

因此处理过的文档会一直返回到外部。

并不是说我们不再与任何数据库进行任何交互,而是不再需要我们的FeedHandler组件! 通过将任何I / O移至系统的外围,中间的所有内容都可以尽可能地纯净。

功能性Java

还记得Haskell,这是一种“纯”功能语言吗? 从“ 学到了伟大的Haskell” :

事实证明,Haskell实际上拥有一个非常聪明的系统来处理具有副作用的功能,这些功能将我们程序的纯净部分和不纯净的部分整齐地分开了,这就像在与之交谈一样,可以完成所有肮脏的工作。键盘和屏幕。 将这两个部分分开,我们仍然可以推理我们的纯程序,并利用纯净提供的所有功能,例如惰性,健壮性和模块化,同时与外界进行有效的通信。

当它在90年代被发明时,它引入了IO monad来处理I / O。 任何函数,例如从外部读取,都必须使用返回类型IO ,该类型实际上是由编译器检查的。

这有一些好处,例如Haskell编译器在重新排序所有非IO代码以进行优化方面具有一定的自由度。 从纯函数和I / O :

因为纯函数代码就像代数,所以编译器可以将所有非IO函数视为数学方程式。 这有点类似于关系数据库如何优化查询。

在Java中,我们没有针对这些事情的特定编译器支持,但是有一些事情我们可以照顾好自己。

记住: void是一个沉Kong。 任何返回void方法要么没有意义,要么具有副作用,例如写入显示,网络,文件或数据库,即与外部系统的交互。 代替执行I / O作为副作用,而是向调用方返回一个值,以描述与外部系统的交互。

现在就这样!

翻译自: https://www.javacodegeeks.com/2018/11/functional-java-example-move-outside.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/344805.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

实现打包后修改服务器接口地址,vue打包之后生成一个配置文件修改接口

我们的vue代码打包上传到服务器之后&#xff0c;生成一个配置文件&#xff0c;里面可以配置域名或其它什么字段之类的&#xff0c;这样以后换了域名&#xff0c;只修改这个配置文件即可。第一步&#xff1a;安装generate-asset-webpack-plugin插件npm install --save-dev gener…

【渝粤教育】广东开放大学 javaweb 动态网站开发技术 形成性考核 (53)

选择题 题目&#xff1a;关于MVC模式说法正确的是_____ 题目&#xff1a;在MVC模式中&#xff0c;核心内容为_____ 题目&#xff1a;下面关于MVC的说法不正确的是_____ 题目&#xff1a;MVC设计模式将应用程序分为_____部分 题目&#xff1a;MVC中的M是指&#xff08;&#xff…

我的世界无人维护的服务器,我的世界:如何进入9年无人管理的2B2T?全球最大战争服务器!...

原标题&#xff1a;我的世界&#xff1a;如何进入9年无人管理的2B2T&#xff1f;全球最大战争服务器&#xff01;2b2t因混乱和9年无人管理而闻名于世&#xff0c;目前是全球最大的《我的世界》战争服务器&#xff0c;同时又是第二大Minecraft古老的服务器。​最近很多小伙伴都在…

【渝粤教育】广东开放大学 Python基础与应用 形成性考核 (21)

选择题 题目&#xff1a;Python语言语句块的标记是&#xff08; &#xff09; 题目&#xff1a;Python程序的文件扩展名是&#xff08; &#xff09; 题目&#xff1a;下列运算符中优先级最高的是&#xff08; &#xff09; 题目&#xff1a;Python不支持的数据类型…

带有AWS DynamoDB的反应式Spring Webflux

AWS已经发布了Java版本2的AWS开发工具包 &#xff0c;该开发工具包现在支持针对不同AWS服务的API调用的非阻塞IO。 在本文中&#xff0c;我将探讨如何使用AWS开发工具包2.x的DynamoDB API以及如何使用Spring Webflux堆栈公开响应式端点-这种方式&#xff0c;应用程序是端对端响…

【渝粤教育】广东开放大学 人工智能 形成性考核 (55)

选择题 题目&#xff1a;连接主义认为人工智能的研究方法应采用&#xff08;&#xff09;方法。 题目&#xff1a;图灵曾协助军方破解()的著名密码系统Enigma。 题目&#xff1a;由《大英百科全书》可知,围棋大约源起于公元前()年左右。 题目&#xff1a;下面属于常用的点角破空…

集团bim对集团项目服务器,BIM再添一员,五洋建设集团BIM项目组举行成立仪式

BIM项目组的成立&#xff0c;标志着五洋建设集团自此迈入了可视化数字建筑信息模型的阵营&#xff0c;掀开了五洋建设集团设计、施工一体化服务新的一页。随后&#xff0c;五洋建筑设计院院长金杭杭主持召开了工作会议。金杭杭院长在致辞中表示&#xff0c;由建设集团技术管理中…

java pojo使用_在POJO中使用ThreadLocal进行Java嵌套事务

java pojo使用大多数嵌套事务是使用EJB实现的&#xff0c;现在我们尝试在POJO上实现嵌套事务。 在这里&#xff0c;我们使用了ThreadLocal的功能。 了解嵌套事务 事务可以嵌套在另一个内部。 因此&#xff0c;内部事务或外部事务可以回滚或提交&#xff0c;而不会影响其他事务…

Java开发人员应该知道的5大Spring Boot功能

您可能已经听说过Spring Boot&#xff0c;这是用不到140个字符创建一个Spring Web应用程序的神奇力量&#xff0c;可以在一条推文中编写这些字符&#xff0c;但这到底意味着什么&#xff1f; 哪些功能可以使Spring Boot具有如此强大的功能并使Spring应用程序开发如此容易&#…

java 使用本机代理_Java与本机代理–他们所做的强大功能

java 使用本机代理在安装代理之前应了解的内容及其对代码的影响 在构建可伸缩的服务器端应用程序时&#xff0c;我们花费大量时间思考如何在生产中监视&#xff0c;操作和更新代码。 已经开发出一种新的工具来帮助Java和Scala开发人员做到这一点。 它们中的许多都是建立在最强大…

【渝粤教育】广东开放大学 企业会计准则应用实务形成性考核 (41)

选择题 题目&#xff1a;当非货币性资产交换同时满足“交换具有商业实质”和“换入资产或换出资产的公允价值能够可靠地计量”两个条件时&#xff0c;应当以公允价值和应支付的相关税费作为换入资产的成本&#xff0c;公允价值与换出资产账面价值的差额计入当期损益。 答案&…

在任何无法理解的情况下,请编写脚本

脚本编写是使您的应用程序在运行时就可以根据客户需求进行调整的最流行的方法之一。 与往常一样&#xff0c;此方法不仅带来好处&#xff0c;例如&#xff0c;在灵活性和可管理性之间存在众所周知的折衷方案。 本文不是从理论上讨论优缺点的文章之一&#xff0c;而是从实践上展…

【渝粤教育】广东开放大学 公共关系实务 形成性考核 (37)

选择题 题目&#xff1a; 请指出以下哪些言论具有公共关系意识&#xff08; &#xff09; 选择一项或多项&#xff1a; 答案&#xff1a;看左侧 题目&#xff1a; 公共关系传播媒介&#xff0c;从其物质形式看有&#xff08; &#xff09; 选择一项或多项&#xff1a; 答案&a…

【渝粤教育】广东开放大学 地基与基础 形成性考核 (27)

选择题 题目&#xff1a;土的三相比例指标包括&#xff1a;土粒比重、含水量、密度、孔隙比、孔隙率和饱和度&#xff0c;其中为实测指标。 答案&#xff1a;看左侧 题目&#xff1a;条形均布荷载中心线下&#xff0c;附加应力随深度减小&#xff0c;其衰减速度与基础的宽度b有…

【渝粤教育】广东开放大学 社会调查与方法 形成性考核 (35)

选择题 题目&#xff1a;社会调查的本质是&#xff08; &#xff09; 题目&#xff1a;从所研究的总体屮&#xff0c;按照一定的方式选取一部分个体进行调查&#xff0c;并将在这部分个体中所得到的调查结果推广到总体中去&#xff0c;这种调查是&#xff08; &#xff09;…

下载anaconda时出现“Please make sure you are connected to the internet”警告

如题&#xff0c;在anaconda下载过程中下载VScode时出现下图的警告。 百度翻译&#xff1a; 顺着图中指定文件路径&#xff0c;找到vscode_inst.py.log文件&#xff08;注&#xff1a;有些人ProgramData文件夹可能找不到&#xff0c;打开任意文件夹&#xff0c;点击查看&…

【渝粤教育】广东开放大学 Linux操作系统 形成性考核 (55)

选择题 题目&#xff1a; 以下哪个不属于操作系统&#xff1f; 答案&#xff1a;看左侧 题目&#xff1a; 以下描述正确的是&#xff1f; 答案&#xff1a;看左侧 题目&#xff1a; 使用gcc编译后的目标文件一般以什么名称结尾&#xff1f; 答案&#xff1a;看左侧 题目&#x…

多个公证员提高网络吞吐量

您是否需要非常高吞吐量的Corda网络&#xff1f; 网络的吞吐量是否稳定&#xff1f; 您是否已经从其他领域挤出了所有可能的表现&#xff1f; 如果您对这些问题的回答是“是”&#xff0c;那么我可能会为您提供一些有用的信息。 我列出了这些问题&#xff0c;以减少您过早优化C…

初识FPGA(搬运)

原文链接1原文链接2 fpga简介 FPGA&#xff08;Field&#xff0d;Programmable Gate Array&#xff09;&#xff0c; 即现场可编程门阵列&#xff0c;它是在PAL&#xff08;可编程阵列逻辑&#xff09;、GAL&#xff08;通用阵列逻辑器件&#xff09;、CPL&#xff08;复杂可…

【渝粤教育】广东开放大学 会展营销 形成性考核 (56)

选择题 题目&#xff1a;以下哪一个选项不属于市场定位的内容&#xff1f; 答案&#xff1a;看左侧 题目&#xff1a;以下哪一个选项不是会展营销调研的程序&#xff1f; 答案&#xff1a;看左侧 题目&#xff1a;以下哪一个选项不是市场定位的原则&#xff1f; 答案&#xff1…