最近需要补的东西较多，疏于打理关于Monad的学习笔记，所以赶在到公历新年前，先整理出一部分，以备忘：
A monad is just a monoid in the category of endofunctors, what’s the problem?
单子 不过是一个自函子范畴上的半幺群
单子（monad，也译单体）是函数式编程中的一种抽象数据类型，其特别之处在于，它是用来表示计算而不是数据的。在以函数式风格编写的程序中，单子可以用来组织包含有序操作的过程，或者用来定义任意的控制流（比如处理并发、异常、延续）。
单子的构造包括定义两个操作return和b[……]
nightmare 是一个基于 electron 的自动化库（意思是说它自带浏览器），用于实现爬虫或自动化测试。相较于传统的爬虫框架（scrapy/pyspider），或者dom操作库（cheerio/jsdom），或者基于浏览器的自动化框架（selenium/phantomjs），他的优势在于提供了一个简洁有效 的编程模型。
来看官网给出的一个对比场景：
同样是实现一个向yahoo自动提交关键词并搜索的功能
1. PhantomJS实现
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
phantom.create(function (ph) { ph.createPage(function (page) { page.open('http://yahoo.com', function (status) { page.evaluate(function () { var el = document.querySelector('input[title="Search"]'); el.value = 'github nightmare'; }, function (result) { page.evaluate(function () { var el = document.querySelector('.searchsubmit'); var event = document.createEvent('MouseEvent'); event.initEvent('click', true, false); el.dispatchEvent(event); }, function (result) { ph.exit(); }); }); }); }); }); |
2. nightmare实现
[crayon-662af5e343[……]
Consul 是一个开源软件，用于实现分布式系统的服务发现与配置，内置如下功能：
目前实现最为完备的 Consul 客户端是 node-consul，看看它的功能点：
Too much，超出了需求范[……]
meta-programming（a.k.a.元编程） 中的这个 meta-词前缀源自希腊词，本意为“在…后，变换，以上”。经过几千年的演进，这个词前缀有了一种全新的意义：关于事物自身的事物。比如 meta-knowledge 就是“关于知识本身的知识”，meta-data 就是“关于数据的数据”，meta-language 就是“关于语言的语言”，而 meta-programming 也是由此而来，是“关于编程的编程”。
元编程算不上什么新鲜的概念，各种语言里早已有之：
[……]
准确来说，IO API 不算是 Akka Streams的内容，但它却是 Streaming IO (TCP) 的基础。
IO API 编程的第一步，是获取一个管理对象的引用。比如我们想针对TCP编程，可以这么获取 TCP Manager：
|
1 2 3 |
import akka.io.{ IO, Tcp } val manager = IO(Tcp) |
manager 是一个 actor 对象，用于处理底层 I/O资源和操作（诸如channels/selectors，或是workers的初始化），同时对于上层提供基于actor 模型的抽象
IO TCP 编程也是 CS 模型的，好处是不需要写繁琐的 S[……]
Akka Streams 为异步编程提供了管道和流式接口，但如果我们希望结合 actor 模型的消息机制呢？Akka Streams提供了如下解决方案：
Sink.actorRef 产生 ActorRef，做为下游结点接收管道里的流数据Source.actorRef 产生ActorRef，能被下游结点消费Source.ActorPublisher 产生ActorRef，用于实现Reactive Streams中的PublisherSink.ActorSubscriber 产生ActorRef，用于实现Reactive Streams中的Subscriber[……]Stage 是 Akka Streams 里的核心概念，它代表了在Graph里的单位，是如何定义输入端口（Inlet) / 输出端口(Outlet) 的；常用的基础形态有：
有了这些基础件，我们可以按需组合出各种拓扑的图来：
之前介绍过[……]
reactive streams 是一个异步流标准，Akka项目是这个标准最早的实现者之一。
标准定义了两个通道：
标准要求这两个通道间的通信是异步非阻塞的，并且是基于反压模式(back pressure)的——数据是从publisher流向subscriber的，但数据一次发送多少个elements是由subscriber通过request(n)来告诉上游的，这使得流可控。同时，这也使得流在处理过程中的合并与拆分成为可能：
akka-stream[……]
Akka 在容错方面有如下特点：
Akka 对于错误的观点值得称道：没有银弹，还是着眼于如何进行灾后重建吧 🙂
与传统应用将 业务逻辑和 try {} catch{}错误处理 绞在一起不同，Akka 的容错恢复是独立于业务逻辑的：Actors专注于自己的消息处理逻辑，而错误处理和策略设定，则由层 级结构里，它的监督者(父级Acto[……]
最近在学习 Akka，因为Scala的新版本已将Actors迁移到Akka [1]（教材就是那本烂到一定程度的 Akka in action，排版字体代码示例一如既往的Manning式的糟糕）——至于为什么要学习Actors，大概是因为 红宝书 里提出了一些对异步编程组合子的设计要求。
官方定义：
Akka is a toolkit and runtime for building highly concurrent, distributed, and resilient message-driven applications on the JVM.
做为一个消息驱[……]
RSS Feed