Flux 和 Mono 是 Reactor 中的两个基本概念。Flux 表示的是包含 0 到 N 个元素的异步序列。在该序列中可以包含三种不同类型的消息通知：正常的包含元素的消息、序列结束的消息和序列出错的消息。当消息通知产生时，订阅者中对应的方法 onNext(), onComplete()和 o ...
分类：
其他好文 时间：
2019-09-19 22:02:04
阅读次数：
786
[TOC] 一、前言 关于 响应式 Reactive，前面的两篇文章谈了不少概念，基本都离不开下面两点： 响应式编程是面向流的、异步化的开发方式 响应式是非常通用的概念，无论在前端领域、还是实时流、离线处理场景中都是适用的。 有兴趣的朋友可以看看这两篇文章： "Reactive(1) 从响应式编程到 ...
分类：
编程语言 时间：
2019-09-12 23:35:09
阅读次数：
596
通读本文，你会了解到1.netty如何接受新的请求2.netty如何给新请求分配reactor线程3.netty如何给每个新连接增加ChannelHandler netty中的reactor线程 netty中最核心的东西莫过于两种类型的reactor线程，可以看作netty中两种类型的发动机，驱动着 ...
分类：
Web程序 时间：
2019-09-11 12:05:26
阅读次数：
113
twistedtwisted管理了所有的异步任务Twisted的主线程是单线程的，即reactor线程；而这些io耗时操作会在线程池中运行，不再twisted主线程中运行，即通过线程池来执行异步任务即twisted通过事件循环(reactor)+线程池来实现异步 IO 的效果线程池大小默认是10，即... ...
分类：
其他好文 时间：
2019-09-09 14:34:47
阅读次数：
78
from twisted.internet import reactor # 事件循环（终止条件，所有的socket都已经移除） from twisted.web.client import getPage # socket对象（如果下载完成，自动从时间循环中移除...） from twisted. ...
分类：
其他好文 时间：
2019-09-01 18:34:23
阅读次数：
83
crawl与twisted原理一样 from twisted.internet import defer from twisted.web.client import getPage from twisted.internet import reactor def download(*args,** ...
分类：
其他好文 时间：
2019-08-31 19:49:17
阅读次数：
103
isinstance(result,types.GeneratorType) 判断是否生成器 队列为空会等，block=False 不等会报错 reactor.callLater(0,self.next_request) from twisted.internet import reactor # ...
分类：
其他好文 时间：
2019-08-31 19:44:31
阅读次数：
88
from twisted.internet import reactor # 事件循环（终止条件，所有的socket都已经移除） from twisted.web.client import getPage # socket对象（如果下载完成，自动从时间循环中移除...） from twisted. ...
分类：
其他好文 时间：
2019-08-31 18:58:52
阅读次数：
75
gevent:mokey.path_all （找到所有socket，进行异步IO） gevent+requests=》grequests Twisted: reactor.run() 死循环 Tornado =》gevent > Twisted > Tornado > asyncio www.cnb ...
分类：
其他好文 时间：
2019-08-25 01:19:14
阅读次数：
65
