• 吴科🍀
    2018-12-24
    spark在1.6后,使用netty完全代替akka了。主要还是看业务场景吧

    作者回复: spark放弃akka,主要原因是当时akka不稳定,akka还是要持续改进呀。

    
     7
  • 老男孩
    2018-12-26
    使用akka实现传统的web应用功能用户注册,是否可以这样实现。首先通信方式是异步的,用户发起注册请求后,服务端收到请求后直接回复:已经受理了您的注册请求,稍后会将激活码下发邮箱或者手机。同时用户注册的actor就会把任务分解发给它的下一级actor处理,发给用户服务actor新增用户,发给积分兑换服务actor为新用户赠送注册积分和礼券。然后调用通知actor给用户的邮箱或者手机发送注册成功信息以及激活码等。感觉类似rabbitmq的消息队列也可以实现akka的异步和分布式通信。
    
     3
  • 足迹
    2018-12-23
    老师,面对这么多的技术,实际应用时时怎么选型的?比如流处理到底是用spark streaming还是storm或是flink?面对离线处理同样有不同的技术可选。你技术选型的主要依据是什么?有什么“套路”可套吗?谢谢!
    
     3
  • 冷锋
    2018-12-22
    相形见绌,拼音是xiāngxíngjiànchù

    作者回复: 谢谢指正

    
     3
  • gogo
    2018-12-24
    谢谢老师,平安夜快乐,圣诞节🎄快乐!
    
     2
  • gogo
    2018-12-24
    我根据自己理解的回复一下,老师可以看着答复一下哈:(/:抠鼻)

    1.Akka天生支持分布式(配置远程Ptops)、天生支持高并发(Actor之间使用MailBox队列实现、无需锁等待…)

    2.瞄了一眼GearPumps,感觉好厉害,四个节点,每秒可以处理1千8百万个长度为100byte的消息,仅有8ms延迟。那它们这个数据,貌似没说网络、机器配置是什么哇~

    可能说的不对……
    展开

    作者回复: 是的

    
     2
  • 纯洁的憎恶
    2018-12-22
    计算机产业变化太快了,我上学的时候还是过程化编程、模块化编程、面向对象的演进路线,这才没几年,已经又演化出新模式了——响应编程模式。
    
     2
  • Jun
    2020-01-05
    序列化和封装还是需要解决的,总不好只用纯文本传递数据。但这不是akka要解决的问题。akka感觉是简化版的面向消息的编程模型。我的主要问题是消息队列管理和scale,比如消息的一致性和大数据量下的响应和资源消耗。
    
    
  • 孔祥阳
    2019-03-19
    关于响应式有个小问题,如果 A通知 和 B通知同事修改一个数据怎么办?就像现实开发企业应用中,A领导拍了这个需求,B领导又出来指点一番,代码上是如何鉴定数据的理想性呢?

    作者回复: A和B如果同时修改一个数据,应该将修改消息发送给C,由C修改,而C的修改操作是串行的,即使A和B的消息同时发送给C,C也是一个消息一个消息轮流处理,不会出现并发同步问题。
    更多细节请参考Akka文档。

    
    
  • 周飞
    2019-01-18
    Akka的异步消息跟node.js有异曲同工之妙啊
    
    
  • Geek_89bbab
    2019-01-06
    老师,在你的回答中
    作为actor的b如果因为代码异常挂了,重启后会继续处理消息。如果是机器挂了,就没有了。

    机器挂了该怎么处理,是系统架构要考虑的。
    ———-
    A,b两个actor处于不同的进程中,a向b发信息,现在邮箱有未处理完的消息,b由于一些原因挂掉,重启为什么还可以继续处理邮箱的消息呢?难道消息持久化到文件中了吗?
    展开

    作者回复: 我说的是进程内actor因为代码执行异常挂了,重启是restart actor,不是重启进程。如果是进程挂了,等同于机器挂了,

    
    
  • Geek_89bbab
    2019-01-04
    老师,像akka中两个actor进行通信,它们在不同的进程中,如果actorA把消息发送到actorB的邮箱,B挂掉了。B的邮箱中还存在未处理的消息,重启后还可以重新处理吗?还是邮箱的存在内存中的,无法恢复?那如果B服务挂了,没有来得及处理A发送过去的消息,这该怎么办?

    作者回复: 作为actor的b如果因为代码异常挂了,重启后会继续处理消息。如果是机器挂了,就没有了。

    机器挂了该怎么处理,是系统架构要考虑的。

    
    
  • 白鸽
    2018-12-28
    web复杂请求(响应时间较长,10秒以上),服务器只做请求合法验证,只要验证通过,就返回请求正在处理提示,用户不用等待,想干啥干啥。等请求处理完后,服务器返回请求完成提示弹窗,用户点击查看即可。这种在web请求中很少见,很多就是显示进度条,是不合理吗?
    
    
  • 吴科🍀
    2018-12-24
    spark在1.6后,使用netty完全代替akka了。主要还是看业务场景吧
    
    
  • WolvesLeader
    2018-12-23
    老师请教一个问题 rdd.flatMap(x => x.split(" "))
    x.split(" ") 返回的是一个array[string]数组,但是rdd.flatMap需要的参数类型是TraversableOnce,为什么就不抱错误呢?是不是有隐式转换,我找了好久也没找到在哪里做的转换,谢谢啦
    
    
  • Riordon
    2018-12-22
    老师,Dew子项目sparklogparser中Matcher是否支持spark 1.6.x和2.x呢?看项目创建比较早期。

    作者回复: 应该是不支持了,不过解析策略应该还是有效,跑一下,如果log解析异常,改一下相关代码就可以。

    
    
  • Riordon
    2018-12-22
    老师,Dew子项目sparklogparser,Matcher中匹配的spark版本是否支持1.6.x和2.x呢?
    
    
我们在线,来聊聊吧