Need help with woker?
Click the “chat” button below for chat support from the developer who created it, or find similar developers for support.

About the developer

muyinchen
526 Stars 237 Forks 166 Commits 1 Opened issues

Services available

!
?

Need anything else?

Contributors list

# 77,822
HTML
Shell
webflux
nio
166 commits

SIMVISO 源码解读分享系列:

Java编程方法论-响应式篇-RxJava 分享视频 已完结

bilibili:https://www.bilibili.com/video/av34537840

油管:https://www.youtube.com/playlist?list=PL95Ey4rht798MMCusPzIW7VYD1xaKJVjc

Java编程方法论-响应式篇-Reactor 分享视频 已完结

B站:https://www.bilibili.com/video/av35326911

油管:https://www.youtube.com/playlist?list=PL95Ey4rht7980EH8yr7SLBvj9XSE1ggdy

Java编程方法论-响应式篇-Reactor-Netty 分享视频 在分享

相关博文:https://juejin.im/user/59c7640851882578e00ddf90/posts

视频分享:

B站:https://www.bilibili.com/video/av45556406/

油管:https://www.youtube.com/watch?v=6qLh2L75KdM&list=PL95Ey4rht79-ISlb_Yr9ToaEI0K8ARmH6

Java编程方法论-JDK 篇 之 NIO 分享视频 在分享

相关博文:https://juejin.im/user/59c7640851882578e00ddf90/posts

B站:https://www.bilibili.com/video/av43230997

油管:https://www.youtube.com/watch?v=ZZnCI8xaTRo&list=PL95Ey4rht799NVLgQiSV9skTqY6VuspIk

所有直播分享均在QQ群进行,同时也欢迎大家加群提出建议:

响应式编程交流QQ群: 523409180

应一些小伙伴的要求,加个赞赏途径,谢谢大家的支持(捐助请留言自己的昵称博客,我会在单独的一个页面内进行展示):

1552756959199

Java编程方法论-响应式 之 Rxjava篇

01 响应式入门:https://www.bilibili.com/video/av34537840/?p=1

02 Java9中的响应式编程:https://www.bilibili.com/video/av34537840/?p=2

03 Rxjava开篇:https://www.bilibili.com/video/av34537840/?p=3

04 Rxjava中create方法的设计思想:https://www.bilibili.com/video/av34537840/?p=4

05 Observables和Observable.cache():https://www.bilibili.com/video/av34537840/?p=5

06 无休止数据流与定时控制:https://www.bilibili.com/video/av34537840/?p=6

07 Demo的设计初衷:https://www.bilibili.com/video/av34537840/?p=7

08 Observable.cache()源码解读:https://www.bilibili.com/video/av34537840/?p=8

09 ConnectableObservable与publish().refCount()解读:https://www.bilibili.com/video/av34537840/?p=9

10 SubmissionPublisher 中订阅者状态的管理:https://www.bilibili.com/video/av34537840/?p=10

11 RxJava中Subject解读:https://www.bilibili.com/video/av34537840/?p=11

12 filter() map()深入解读与flatMap()初解:https://www.bilibili.com/video/av34537840/?p=12

13 flatMap()与scan()深入解读:https://www.bilibili.com/video/av34537840/?p=13

14 groupBy()进行分组:https://www.bilibili.com/video/av34537840/?p=14

15 merge()的源码解读 上:https://www.bilibili.com/video/av34537840/?p=15

16 merge()的源码解读 下:https://www.bilibili.com/video/av34537840/?p=16

17 zip()的源码解读:https://www.bilibili.com/video/av34537840/?p=17

18 combineLatest()的源码解读:https://www.bilibili.com/video/av34537840/?p=18

19 withLatestFrom() 源码解读:https://www.bilibili.com/video/av34537840/?p=19

20 amb() 操作源码解读:https://www.bilibili.com/video/av34537840/?p=20

21 scan()操作的2次深入:https://www.bilibili.com/video/av34537840/?p=21

22 reduce()源码解读:https://www.bilibili.com/video/av34537840/?p=22

23 collect() 源码解读:https://www.bilibili.com/video/av34537840/?p=23

24 distinct() distinctUntilChanged() compose() lift()及其他操作源码解读:https://www.bilibili.com/video/av34537840/?p=24

25 Observable实战之Spring MVC返回值的响应式化改造:https://www.bilibili.com/video/av34537840/?p=25

26 汇率查询的小服务及对于返回值处理抽取的前置知识讲解:https://www.bilibili.com/video/av34537840/?p=26

27 写一个SpringMVC的响应式返回值处理组件springboot-starter:https://www.bilibili.com/video/av34537840/?p=27

28 RxJava2中的多线程操作中调度器的引入:https://www.bilibili.com/video/av34537840/?p=28

29 subscribeOn() observeOn() unsubscribeOn()操作源码解读:https://www.bilibili.com/video/av34537840/?p=29

30 调度器Scheduler源码设计思路解读:https://www.bilibili.com/video/av34537840/?p=30

31 调度器Scheduler源码解读补充1:https://www.bilibili.com/video/av34537840/?p=31

32 调度器Scheduler源码解读补充2:https://www.bilibili.com/video/av34537840/?p=32

33 调度器Scheduler源码解读补充3:https://www.bilibili.com/video/av34537840/?p=33

34 背压回顾以及一些探究:https://www.bilibili.com/video/av34537840/?p=34

35 rxjava中SpscLinkedArrayQueue无界队列的实现解读:https://www.bilibili.com/video/av34537840/?p=35

36 从Observable到 Flowable 的设计思路 及Flowable.create() 中背压设计的解读:https://www.bilibili.com/video/av34537840/?p=36

37 onBackpressureXXX()操作与Flowable.generate()解读:https://www.bilibili.com/video/av34537840/?p=37

38 关于Rxjava解读简短的结束语:https://www.bilibili.com/video/av34537840/?p=38

Java编程方法论-响应式 之 Reactor篇

Spring官方以及龙之春力荐

01 Reactor开篇:https://www.bilibili.com/video/av35326911/?p=1

02 subscribe方法解读及原子类AtomicXxxFieldUpdater的技法解读及应用:https://www.bilibili.com/video/av35326911/?p=2

03 Flux.create解读及AtomicXxxFieldUpdater部分细节讲解修正及背压策略的具体实现细节解读:https://www.bilibili.com/video/av35326911/?p=3

04 Flux.Create回顾 BaseSubscriber与几个Flux源的快速包装方法源码细节解读:https://www.bilibili.com/video/av35326911/?p=4

05 结合Spring Cloud Function来讲函数式的诸多好处:https://www.bilibili.com/video/av35326911/?p=5

06 通过函数式来进行方法级别的类接口设计:https://www.bilibili.com/video/av35326911/?p=6

07 Flux.generate方法解读及使用其一个方法来对数据库事务实现进行拓展:https://www.bilibili.com/video/av35326911/?p=7

08 针对上一节末尾的口误的修正:https://www.bilibili.com/video/av35326911/?p=8

09 Reactor中无界队列的源码解读 :https://www.bilibili.com/video/av35326911/?p=9

10 Flux.generate中程序健壮性所涉及的error日志的触发演示及原理解读:https://www.bilibili.com/video/av35326911/?p=10

11 通过Reactor中Flux.generate的相关实现来fix Rxjava中generate源码中的bug(基于最新的2.2.3的发行版):https://www.bilibili.com/video/av35326911/?p=11

12 QueueSubscription蛇形走位的解读以及publishOn的详解1: https://www.bilibili.com/video/av35326911/?p=12

13 publishOn的详解2:https://www.bilibili.com/video/av35326911/?p=13

14 publishOn的详解3:https://www.bilibili.com/video/av35326911/?p=14

15 publishOn的详解4:https://www.bilibili.com/video/av35326911/?p=15

16 通过一个redis与数据库双写的场景来讲述Reactor中我们可以借鉴与对业务改造的思路1:https://www.bilibili.com/video/av35326911/?p=16

17 通过一个redis与数据库双写的场景来讲述Reactor中我们可以借鉴与对业务改造的思路2:https://www.bilibili.com/video/av35326911/?p=17

18 通过一个redis与数据库双写的场景来讲述Reactor中我们可以借鉴与对业务改造的思路3:https://www.bilibili.com/video/av35326911/?p=18

19 将常见的监听器改造成响应式结构:https://www.bilibili.com/video/av35326911/?p=19

20 Flux.push特殊使用场景及细节探索:https://www.bilibili.com/video/av35326911/?p=20

21 Flux.handle 解读:https://www.bilibili.com/video/av35326911/?p=21

22 Schedulers.elastic深入理解1:https://www.bilibili.com/video/av35326911/?p=22

23 Schedulers.elastic深入理解2:https://www.bilibili.com/video/av35326911/?p=23

24 Schedulers.elastic深入理解3:https://www.bilibili.com/video/av35326911/?p=24

25 Reactor中ElasticScheduler与Rxjava2的IoScheduler实现的优劣对比:https://www.bilibili.com/video/av35326911/?p=25

26 Flux.subscribeOn 深入解读1:https://www.bilibili.com/video/av35326911/?p=26

27 Flux.subscribeOn 深入解读2:https://www.bilibili.com/video/av35326911/?p=27

28 subscribeOn与publishOn默认使用上小bug解读:https://www.bilibili.com/video/av35326911/?p=28

29 Flux.parallel源码解读1:https://www.bilibili.com/video/av35326911/?p=29

30 Flux.parallel源码解读2:https://www.bilibili.com/video/av35326911/?p=30

31 ParallelFlux.runOn源码解读:https://www.bilibili.com/video/av35326911/?p=31

32 Flux.filter操作源码解读:https://www.bilibili.com/video/av35326911/?p=32

33 transform与compose 操作解读:https://www.bilibili.com/video/av35326911/?p=33

34 buffer 操作源码解读:https://www.bilibili.com/video/av35326911/?p=34

35 window操作源码解读:https://www.bilibili.com/video/av35326911/?p=35

36 Flux.groupBy 操作源码深入解读:https://www.bilibili.com/video/av35326911/?p=36

37 Flux.merge源码解读1:https://www.bilibili.com/video/av35326911/?p=37

38 Flux.merge源码解读2:https://www.bilibili.com/video/av35326911/?p=38

39 Flux.mergeSequential操作源码解读:https://www.bilibili.com/video/av35326911/?p=39

40 Flux.flatMap源码深入解读:https://www.bilibili.com/video/av35326911/?p=40

41 Flux.concatMap源码深入解读1:https://www.bilibili.com/video/av35326911/?p=41

42 Flux.concatMap源码深入解读2:https://www.bilibili.com/video/av35326911/?p=42

43 Flux.combineLatest 操作源码深入解读:https://www.bilibili.com/video/av35326911/?p=43

44 Flux.publish及 Flux.replay 操作源码深入解读1:https://www.bilibili.com/video/av35326911/?p=44

45 Flux.publish及 Flux.replay 操作源码深入解读2:https://www.bilibili.com/video/av35326911/?p=45

46 Flux.publish及 Flux.replay 操作源码深入解读3:https://www.bilibili.com/video/av35326911/?p=46

47 Flux.publish及 Flux.replay 操作源码深入解读4:https://www.bilibili.com/video/av35326911/?p=47

48 UnicastProcessor详解:https://www.bilibili.com/video/av35326911/?p=48

49 DirectProcessor详解:https://www.bilibili.com/video/av35326911/?p=49

50 EmitterProcessor详解:https://www.bilibili.com/video/av35326911/?p=50

51 ReplayProcessor详解:https://www.bilibili.com/video/av35326911/?p=51

52 TopicProcessor初探:https://www.bilibili.com/video/av35326911/?p=52

53 TopicProcessor及reactor中借鉴disruptor匹配实现 1:https://www.bilibili.com/video/av35326911/?p=53

54 TopicProcessor及reactor中借鉴disruptor匹配实现 2 之WaitStrategy解读:https://www.bilibili.com/video/av35326911/?p=54

55 TopicProcessor及reactor中借鉴disruptor匹配实现 3 之subscribe方法的深度解读上:https://www.bilibili.com/video/av35326911/?p=55

56 TopicProcessor及reactor中借鉴disruptor匹配实现 4 之subscribe方法的深度解读下:https://www.bilibili.com/video/av35326911/?p=56

57 WorkQueueProcessor解读:https://www.bilibili.com/video/av35326911/?p=57

58 WorkQueueProcessor解读细节补充:https://www.bilibili.com/video/av35326911/?p=58

59 Hot 还是 Cold :https://www.bilibili.com/video/av35326911/?p=59

60 Hot 还是 Cold 总结补充:https://www.bilibili.com/video/av35326911/?p=60

61 Reactor特供的Context:https://www.bilibili.com/video/av35326911/?p=61

62 Reactor中的测试源码解读与实战 1:https://www.bilibili.com/video/av35326911/?p=62

63 Reactor中的测试源码解读与实战 2 操作时间测试:https://www.bilibili.com/video/av35326911/?p=63

64 Reactor中的测试源码解读与实战 3 使用 StepVerifier 进行后置校验:https://www.bilibili.com/video/av35326911/?p=64

65 Reactor中的测试源码解读与实战 4 关于Context的测试 上:https://www.bilibili.com/video/av35326911/?p=65

66 Reactor中的测试源码解读与实战 4 关于Context的测试 下:https://www.bilibili.com/video/av35326911/?p=66

67 Reactor中的测试源码解读与实战 5 使用TestPublisher对自定义中间操作测试:https://www.bilibili.com/video/av35326911/?p=67

68 Reactor中的测试源码解读与实战 5 使用TestPublisher对自定义中间操作测试 补充1:https://www.bilibili.com/video/av35326911/?p=68

69 Reactor中的测试源码解读与实战 5 使用TestPublisher对自定义中间操作测试 补充2:https://www.bilibili.com/video/av35326911/?p=69

70 Reactor中的测试 6 使用PublisherProbe检查执行路径:https://www.bilibili.com/video/av35326911/?p=70

71 Reactor中的调试 之 启用调试模式:https://www.bilibili.com/video/av35326911/?p=71

72 Reactor中 在调试模式下读取堆栈跟踪信息 及 通过checkpoint()方式进行调试 与 记录订阅关系下操作流程的日志:https://www.bilibili.com/video/av35326911/?p=72

Java编程方法论-响应式 之 Reactor-Netty篇

01 reactor-netty解读之HttpServer配置设定设计:https://www.bilibili.com/video/av45556406/?p=1

02 Reactor-netty与Reactor中设计思路对比:https://www.bilibili.com/video/av45556406/?p=2

03 HttpServer中bind设定的设计思路解读1:https://www.bilibili.com/video/av45556406/?p=3

04 HttpServer中bind设定的设计思路解读2:https://www.bilibili.com/video/av45556406/?p=4

05 reactor-netty中针对netty中EventLoopGroup的封装:https://www.bilibili.com/video/av45556406/?p=5

06 reactor-netty中 DisposableServer 的设计实现1:https://www.bilibili.com/video/av45556406/?p=6

07 DisposableServer 的设计实现2及相关技巧在SpringcloudFunction的使用:https://www.bilibili.com/video/av45556406/?p=7

待续...

Java编程方法论-JDK 篇 之 NIO 分享

01 ServerSocket中bind与accept解读 :https://www.bilibili.com/video/av43230997/?p=1

02 对示例Demo进行实现accept与read的非阻塞改造:https://www.bilibili.com/video/av43230997/?p=2

03 赋予Channel异步可中断的能力:https://www.bilibili.com/video/av43230997/?p=3

04 赋予Channel可被多路复用的能力:https://www.bilibili.com/video/av43230997/?p=4

05 赋予Channel支持网络socket的能力之bind解读:https://www.bilibili.com/video/av43230997/?p=5

06 赋予Channel支持网络socket的能力之accept解读:https://www.bilibili.com/video/av43230997/?p=6

07 赋予Channel支持网络socket的能力之setOption实现:https://www.bilibili.com/video/av43230997/?p=7

08 ServerSocketChannel与ServerSocket在bind处的异同:https://www.bilibili.com/video/av43230997/?p=8

09 ServerSocketChannel的socket方法延伸:https://www.bilibili.com/video/av43230997/?p=9

10 SocketAdaptor解读:https://www.bilibili.com/video/av43230997/?p=10

11 针对SocketChannel中finishConnect方法设定的目的:https://www.bilibili.com/video/av43230997/?p=11

12 理解netty前置之手把手带你写一个nio服务器V1版:https://www.bilibili.com/video/av43230997/?p=12

待续...

We use cookies. If you continue to browse the site, you agree to the use of cookies. For more information on our use of cookies please see our Privacy Policy.