coltzhao等scala党说说streaming吧# Programming - 葵花宝典
q*d
1 楼
有在Samsung R&D - Cambridge, Massachusetts 工作的DXJM吗?
求Refer!!!
Thanks a lot!!!
求Refer!!!
Thanks a lot!!!
E*a
2 楼
那么久我们赌气不联系对方，我以为永远也不会再见到你了。那时我跟自己说，没有关
系，我们在一起笑过，快乐过，天下没有不散的宴席，有过那些美好的回忆和经历，也
是好的，我不要难过。每次想哭的时候，我就跟自己这样重复。
所以你可以想象，再见的时候，我是多么的欣喜。出发以前，你问我可不可以穿裙子，
因为你喜欢我穿裙子的样子。我说好。我从寒冷的地方来，带了裙子丝袜和高跟鞋在机
场换上。出了安检，你笑着迎上来，说嗨，然后紧紧抱住我。你的拥抱和吻，都有一丝
陌生的感觉。恍惚间觉得已经隔世，其实才几个月而已。
接下来的几天我们寸步不离，即使走在山上的小路上，你也在前面牵着我的手。上到山
顶，明媚阳光下有一个小亭子，一个女孩在桌子上洒满的红色的玫瑰花瓣，旁着一个精
美的竹编午餐篮子，坐在那里等人。我看着她，她就抬头对我笑了一下。我无声地说，
good luck。希望这个眼睛亮亮的女孩，和她等的人，有一段甜蜜的时光。
晚上我们去downtown散步，在人山人海里慢慢走过，我知道你不喜欢人太多的地方，可
是那天，你没有抱怨，还陪我一起排长长的买爆米花的队。买到了就坐在草地边，你躺
在我的腿上，看着小朋友们在坡地上滚下爬上地玩。你说，你要不要去滚一下？我会在
下面接你，可是不保证接到噢。
晚上懒懒地躺在你的怀抱里聊天，电视在那里开着讲一些奇怪的世界末日的事，我讲起
不开心的事情就踢你一下。你说你现在是一个很好的kicker了啊。渐渐地困了，就在你
的怀里睡着，半夜醒来还枕着你的胳膊。我摸摸你的脸，闭上眼睛再慢慢睡着，心安地
睡到天亮。
你先起来准备早饭，我听到厨房的声音，起来帮忙。和以往一样，还是几乎帮倒忙。我
说也不知道怎么搞的，我用东西就是坏得很快啊。你就嘴角上扬，坏笑着说，”你确定
只是东西被你用坏的快？not people? are you sure? “ 我哈哈大笑，把厨房丢给也
不会做饭的你。结果你真的做出了不算难吃的东西。
You always amaze me.
系，我们在一起笑过，快乐过，天下没有不散的宴席，有过那些美好的回忆和经历，也
是好的，我不要难过。每次想哭的时候，我就跟自己这样重复。
所以你可以想象，再见的时候，我是多么的欣喜。出发以前，你问我可不可以穿裙子，
因为你喜欢我穿裙子的样子。我说好。我从寒冷的地方来，带了裙子丝袜和高跟鞋在机
场换上。出了安检，你笑着迎上来，说嗨，然后紧紧抱住我。你的拥抱和吻，都有一丝
陌生的感觉。恍惚间觉得已经隔世，其实才几个月而已。
接下来的几天我们寸步不离，即使走在山上的小路上，你也在前面牵着我的手。上到山
顶，明媚阳光下有一个小亭子，一个女孩在桌子上洒满的红色的玫瑰花瓣，旁着一个精
美的竹编午餐篮子，坐在那里等人。我看着她，她就抬头对我笑了一下。我无声地说，
good luck。希望这个眼睛亮亮的女孩，和她等的人，有一段甜蜜的时光。
晚上我们去downtown散步，在人山人海里慢慢走过，我知道你不喜欢人太多的地方，可
是那天，你没有抱怨，还陪我一起排长长的买爆米花的队。买到了就坐在草地边，你躺
在我的腿上，看着小朋友们在坡地上滚下爬上地玩。你说，你要不要去滚一下？我会在
下面接你，可是不保证接到噢。
晚上懒懒地躺在你的怀抱里聊天，电视在那里开着讲一些奇怪的世界末日的事，我讲起
不开心的事情就踢你一下。你说你现在是一个很好的kicker了啊。渐渐地困了，就在你
的怀里睡着，半夜醒来还枕着你的胳膊。我摸摸你的脸，闭上眼睛再慢慢睡着，心安地
睡到天亮。
你先起来准备早饭，我听到厨房的声音，起来帮忙。和以往一样，还是几乎帮倒忙。我
说也不知道怎么搞的，我用东西就是坏得很快啊。你就嘴角上扬，坏笑着说，”你确定
只是东西被你用坏的快？not people? are you sure? “ 我哈哈大笑，把厨房丢给也
不会做饭的你。结果你真的做出了不算难吃的东西。
You always amaze me.
z*e
3 楼
看了看其他语言，没啥意思，都是老东西
streaming貌似很火？我看vert.x这块还是experimental
说说有啥搞头？难点在哪？
streaming貌似很火？我看vert.x这块还是experimental
说说有啥搞头？难点在哪？
e*a
4 楼
真浪漫，真美好
【在 E***a 的大作中提到】
: 那么久我们赌气不联系对方，我以为永远也不会再见到你了。那时我跟自己说，没有关
: 系，我们在一起笑过，快乐过，天下没有不散的宴席，有过那些美好的回忆和经历，也
: 是好的，我不要难过。每次想哭的时候，我就跟自己这样重复。
: 所以你可以想象，再见的时候，我是多么的欣喜。出发以前，你问我可不可以穿裙子，
: 因为你喜欢我穿裙子的样子。我说好。我从寒冷的地方来，带了裙子丝袜和高跟鞋在机
: 场换上。出了安检，你笑着迎上来，说嗨，然后紧紧抱住我。你的拥抱和吻，都有一丝
: 陌生的感觉。恍惚间觉得已经隔世，其实才几个月而已。
: 接下来的几天我们寸步不离，即使走在山上的小路上，你也在前面牵着我的手。上到山
: 顶，明媚阳光下有一个小亭子，一个女孩在桌子上洒满的红色的玫瑰花瓣，旁着一个精
: 美的竹编午餐篮子，坐在那里等人。我看着她，她就抬头对我笑了一下。我无声地说，
【在 E***a 的大作中提到】
: 那么久我们赌气不联系对方，我以为永远也不会再见到你了。那时我跟自己说，没有关
: 系，我们在一起笑过，快乐过，天下没有不散的宴席，有过那些美好的回忆和经历，也
: 是好的，我不要难过。每次想哭的时候，我就跟自己这样重复。
: 所以你可以想象，再见的时候，我是多么的欣喜。出发以前，你问我可不可以穿裙子，
: 因为你喜欢我穿裙子的样子。我说好。我从寒冷的地方来，带了裙子丝袜和高跟鞋在机
: 场换上。出了安检，你笑着迎上来，说嗨，然后紧紧抱住我。你的拥抱和吻，都有一丝
: 陌生的感觉。恍惚间觉得已经隔世，其实才几个月而已。
: 接下来的几天我们寸步不离，即使走在山上的小路上，你也在前面牵着我的手。上到山
: 顶，明媚阳光下有一个小亭子，一个女孩在桌子上洒满的红色的玫瑰花瓣，旁着一个精
: 美的竹编午餐篮子，坐在那里等人。我看着她，她就抬头对我笑了一下。我无声地说，
l*n
5 楼
不就是个pub/sub pattern吗？
m*l
6 楼
暖暖的，甜甜的，美好的，温馨的，赞美文。
【在 E***a 的大作中提到】
: 那么久我们赌气不联系对方，我以为永远也不会再见到你了。那时我跟自己说，没有关
: 系，我们在一起笑过，快乐过，天下没有不散的宴席，有过那些美好的回忆和经历，也
: 是好的，我不要难过。每次想哭的时候，我就跟自己这样重复。
: 所以你可以想象，再见的时候，我是多么的欣喜。出发以前，你问我可不可以穿裙子，
: 因为你喜欢我穿裙子的样子。我说好。我从寒冷的地方来，带了裙子丝袜和高跟鞋在机
: 场换上。出了安检，你笑着迎上来，说嗨，然后紧紧抱住我。你的拥抱和吻，都有一丝
: 陌生的感觉。恍惚间觉得已经隔世，其实才几个月而已。
: 接下来的几天我们寸步不离，即使走在山上的小路上，你也在前面牵着我的手。上到山
: 顶，明媚阳光下有一个小亭子，一个女孩在桌子上洒满的红色的玫瑰花瓣，旁着一个精
: 美的竹编午餐篮子，坐在那里等人。我看着她，她就抬头对我笑了一下。我无声地说，
【在 E***a 的大作中提到】
: 那么久我们赌气不联系对方，我以为永远也不会再见到你了。那时我跟自己说，没有关
: 系，我们在一起笑过，快乐过，天下没有不散的宴席，有过那些美好的回忆和经历，也
: 是好的，我不要难过。每次想哭的时候，我就跟自己这样重复。
: 所以你可以想象，再见的时候，我是多么的欣喜。出发以前，你问我可不可以穿裙子，
: 因为你喜欢我穿裙子的样子。我说好。我从寒冷的地方来，带了裙子丝袜和高跟鞋在机
: 场换上。出了安检，你笑着迎上来，说嗨，然后紧紧抱住我。你的拥抱和吻，都有一丝
: 陌生的感觉。恍惚间觉得已经隔世，其实才几个月而已。
: 接下来的几天我们寸步不离，即使走在山上的小路上，你也在前面牵着我的手。上到山
: 顶，明媚阳光下有一个小亭子，一个女孩在桌子上洒满的红色的玫瑰花瓣，旁着一个精
: 美的竹编午餐篮子，坐在那里等人。我看着她，她就抬头对我笑了一下。我无声地说，
z*e
7 楼
那是message吧，这个还有啥好做的
我看不像啊，感觉akka里面这块很高大上的样子
想看看里面有啥神秘的地方
【在 l**********n 的大作中提到】
: 不就是个pub/sub pattern吗？
我看不像啊，感觉akka里面这块很高大上的样子
想看看里面有啥神秘的地方
【在 l**********n 的大作中提到】
: 不就是个pub/sub pattern吗？
c*e
8 楼
温馨 ：）
z*e
9 楼
我觉得你说得不对
我看了下介绍
streaming最麻烦得不是什么sub
而是如何push back
整个系统就像是一个比较流动的一个东西
如果不加以控制，极端情况很快就会把所有内存consume掉
彻底爆掉内存
【在 l**********n 的大作中提到】
: 不就是个pub/sub pattern吗？
我看了下介绍
streaming最麻烦得不是什么sub
而是如何push back
整个系统就像是一个比较流动的一个东西
如果不加以控制，极端情况很快就会把所有内存consume掉
彻底爆掉内存
【在 l**********n 的大作中提到】
: 不就是个pub/sub pattern吗？
l*n
10 楼
就是akka替你管理线程了。其实你用Java Future一样能实现。
【在 z****e 的大作中提到】
: 那是message吧，这个还有啥好做的
: 我看不像啊，感觉akka里面这块很高大上的样子
: 想看看里面有啥神秘的地方
【在 z****e 的大作中提到】
: 那是message吧，这个还有啥好做的
: 我看不像啊，感觉akka里面这块很高大上的样子
: 想看看里面有啥神秘的地方
l*n
11 楼
java future怎么处理exception？
z*e
12 楼
错了吧
这个应该是data的stream
难点是pump back
【在 l**********n 的大作中提到】
: 就是akka替你管理线程了。其实你用Java Future一样能实现。
这个应该是data的stream
难点是pump back
【在 l**********n 的大作中提到】
: 就是akka替你管理线程了。其实你用Java Future一样能实现。
z*e
13 楼
monad方式处理
顺便
http://vert-x3.github.io/docs/vertx-reactive-streams/java/index
上次说rxjava的时候不是说没有pump嘛
现在有了
【在 l**********n 的大作中提到】
: java future怎么处理exception？
顺便
http://vert-x3.github.io/docs/vertx-reactive-streams/java/index
上次说rxjava的时候不是说没有pump嘛
现在有了
【在 l**********n 的大作中提到】
: java future怎么处理exception？
l*n
14 楼
push back不是streaming， 是Web Socket。 protocol范畴了。
【在 z****e 的大作中提到】
: 我觉得你说得不对
: 我看了下介绍
: streaming最麻烦得不是什么sub
: 而是如何push back
: 整个系统就像是一个比较流动的一个东西
: 如果不加以控制，极端情况很快就会把所有内存consume掉
: 彻底爆掉内存
【在 z****e 的大作中提到】
: 我觉得你说得不对
: 我看了下介绍
: streaming最麻烦得不是什么sub
: 而是如何push back
: 整个系统就像是一个比较流动的一个东西
: 如果不加以控制，极端情况很快就会把所有内存consume掉
: 彻底爆掉内存
z*e
15 楼
直接写web socket太蛋疼了
还是找个wrapper上了
http://vert-x3.github.io/docs/vertx-reactive-streams/java/index
【在 l**********n 的大作中提到】
: push back不是streaming， 是Web Socket。 protocol范畴了。
还是找个wrapper上了
http://vert-x3.github.io/docs/vertx-reactive-streams/java/index
【在 l**********n 的大作中提到】
: push back不是streaming， 是Web Socket。 protocol范畴了。
l*n
16 楼
你这个还是基于TCP的吧？
【在 z****e 的大作中提到】
: 直接写web socket太蛋疼了
: 还是找个wrapper上了
: http://vert-x3.github.io/docs/vertx-reactive-streams/java/index
【在 z****e 的大作中提到】
: 直接写web socket太蛋疼了
: 还是找个wrapper上了
: http://vert-x3.github.io/docs/vertx-reactive-streams/java/index
z*e
17 楼
streaming这种还用http吗？
感觉有些作死啊
【在 l**********n 的大作中提到】
: 你这个还是基于TCP的吧？
感觉有些作死啊
【在 l**********n 的大作中提到】
: 你这个还是基于TCP的吧？
p*2
18 楼
Spark streaming
Akka streams
个人推荐Spark。
【在 z****e 的大作中提到】
: 看了看其他语言，没啥意思，都是老东西
: streaming貌似很火？我看vert.x这块还是experimental
: 说说有啥搞头？难点在哪？
l*n
19 楼
那你说用啥？
【在 z****e 的大作中提到】
: streaming这种还用http吗？
: 感觉有些作死啊
【在 z****e 的大作中提到】
: streaming这种还用http吗？
: 感觉有些作死啊
z*e
20 楼
tcp
【在 l**********n 的大作中提到】
: 那你说用啥？
【在 l**********n 的大作中提到】
: 那你说用啥？
l*n
21 楼
akka一点也没啥。
l*n
22 楼
总而言之，像scala这种语言，就是把事情搞复杂了。
z*e
23 楼
所以vert.x把他们变简单
【在 l**********n 的大作中提到】
: 总而言之，像scala这种语言，就是把事情搞复杂了。
【在 l**********n 的大作中提到】
: 总而言之，像scala这种语言，就是把事情搞复杂了。
l*n
24 楼
不错。
【在 z****e 的大作中提到】
: 所以vert.x把他们变简单
【在 z****e 的大作中提到】
: 所以vert.x把他们变简单
z*e
25 楼
除了spark能用，其他都用不了
或者感觉很怪异，如果稍微加点修改的话
akka那种方式才是王道
况且我需要在actor之间做streaming，而不是仅仅跟spark搞
【在 p*****2 的大作中提到】
:
: Spark streaming
: Akka streams
: 个人推荐Spark。
c*o
26 楼
Streaming 只是一个概念。
用真实世界来说，就是吧你的感觉（Input)和行动(Output)
看成是一个无始无终的事件序列，而且这个序列由于时间的单向性，历史是不能改变的
（immutable), 未来是不知道的（lazy loading), 你可以用历史来处理现在，来影响
未来。
rx的observer, scala的stream, java的stream都是这个概念的一种理解和实现。
spark 的 stream也是这个概念的一种理解和实现，不过实在软件结构而不是语言上了。
用真实世界来说，就是吧你的感觉（Input)和行动(Output)
看成是一个无始无终的事件序列，而且这个序列由于时间的单向性，历史是不能改变的
（immutable), 未来是不知道的（lazy loading), 你可以用历史来处理现在，来影响
未来。
rx的observer, scala的stream, java的stream都是这个概念的一种理解和实现。
spark 的 stream也是这个概念的一种理解和实现，不过实在软件结构而不是语言上了。
c*o
27 楼
现在的趋势就是用functional combinator:
map/fold/reduce/zip等等来做 streaming transformation.
map/fold/reduce/zip等等来做 streaming transformation.
z*e
28 楼
那pump啥时候用？
【在 c******o 的大作中提到】
: 现在的趋势就是用functional combinator:
: map/fold/reduce/zip等等来做 streaming transformation.
【在 c******o 的大作中提到】
: 现在的趋势就是用functional combinator:
: map/fold/reduce/zip等等来做 streaming transformation.
H*S
29 楼
早就说过scalaz-stream，天生克服back pressure。基本原理fpis最后一章就是。
【在 z****e 的大作中提到】
: 看了看其他语言，没啥意思，都是老东西
: streaming貌似很火？我看vert.x这块还是experimental
: 说说有啥搞头？难点在哪？
【在 z****e 的大作中提到】
: 看了看其他语言，没啥意思，都是老东西
: streaming貌似很火？我看vert.x这块还是experimental
: 说说有啥搞头？难点在哪？
g*g
30 楼
任何系统publisher比subscriber快就会有back pressure的问题，我不觉得有什么语言
能够天生客服，这个不符合物理。
【在 H****S 的大作中提到】
: 早就说过scalaz-stream，天生克服back pressure。基本原理fpis最后一章就是。
能够天生客服，这个不符合物理。
【在 H****S 的大作中提到】
: 早就说过scalaz-stream，天生克服back pressure。基本原理fpis最后一章就是。
H*S
31 楼
【在 g*****g 的大作中提到】
: 任何系统publisher比subscriber快就会有back pressure的问题，我不觉得有什么语言
: 能够天生客服，这个不符合物理。
相关阅读
现在还有谁敢说goodbug C*及格？傻逼太监懂个屁C＊nickmit你过来版主求你把那个spammer屏蔽掉把说同步比异步快的根本不懂网站老魏，你的message queue的概念是十年前j2ee的概念座位优化有多难？难于上青天？c++的一个诡异问题，高手请进呵呵，goodbug这个喷子在这打赌啊！重新贴一次goodbug的要求其实你们吵了半天，12306就靠”彩色动态验证码“就杜绝了大部分抢票软件用脚趾头想，message queue有次序的，分布出去能收回来么？老姜应该把计数器和超级网卡给加上去你们一般都用什么json的lib？machine leaning, natural language processing 这些有码农在搞么？修正一下 Wei 的测试程序，结果腰斩再腰斩没干过大数据云计算的不用琢磨12306了做Java的来说说我不知道你们加不加入工会你们比谁牛谁水的亮一亮blog/stackoverflow账号什么的