• 灵
    2019-08-06
    请问actor模型与reactor模型有什么关联和区别吗?

    作者回复: 雷锋和雷峰塔的关系

    
     40
  • QQ怪
    2019-06-04
    老师,actor模式具体实现的产品有哪些?想知道这些更加理解actor

    作者回复: spark,flink,play应该都用到了,我也不会scala,如果想深入理解只能先把scala学了😂😂

    
     5
  • 兔斯基
    2019-06-04
    这种并发模型现实应用多么?系统往往很少有可以接受丢失消息的吧?

    作者回复: 线程池也一样会丢数据,现在基本上都是靠数据库,mq这些支持事务的存储来搞定安全的异步处理

     2
     5
  • 翡冷翠
    2019-07-01
    累加器这个例子里只是启动了四个线程去发送消息,实际累加只是在一个线程(actor)里进行的
    
     3
  • 晓杰
    2019-06-05
    请问老师actor模型的效率是不是会比较低

    作者回复: 不会

     1
     2
  • aoe
    2019-11-22
    感兴趣的可以看看《响应式架构 消息模式Actor实现与Scala.Akka应用集成》

    作者回复: 这本书也不错

    
     1
  • 军
    2019-10-29
    这里的Actor工作方式很像游戏里的角色Actor,ActorSystem就是游戏里的World
     1
     1
  • cricket1981
    2019-06-05
    "也不保证消息送达的顺序和发送的顺序是一致的" …… 想问下什么情况下会发生这种情形?MailBox不是类似Queue一样FIFO结构吗?

    作者回复: 理论模型没这要求,并发情况下严格实现fifo很影响性能

    
     1
  • Liam
    2019-06-05
    actor,看erlang
    
     1
  • 潭州太守
    2019-06-04
    请问老师,Actor是不是不适合低延迟场景,或者有没有策略保证低延迟。

    作者回复: 也不是,erlang就有这方面的应用

    
     1
  • 有铭
    2019-06-04
    Actor模型的最佳实践目前还是erlang,Java的akka有些不伦不类
    
     1
  • 周治慧
    2019-06-04
    万物皆是面向对象 早上好
    
     1
  • Cv
    2020-01-08
    我理解示例中的累加器只是用了4个线程把累计动作丢到队列里, 累加器还是单线程消费队列的, 实际效率并不高
    
    
  • DFighting
    2019-10-16
    Actor读起来好像流数据处理模型中的Operator,不过Flink解决一致性语义(exactly-once)使用的是轻量级一致性快照,即在每个节点内部缓存当前整个系统执行到何处的状态,不过代价就是需要在计算拓扑中传递状态,算是一种内存换一致性吧,不过现在存储愈发可得,这个代价应该也是可以接受的。

    作者回复: 👍

    
    
  • 张三丰
    2019-10-14
    很长一段时间里,我都以为对象方法是面向对象理论中消息的一种实现,直到接触到 Actor 模型,才明白消息压根不是这个实现法。


    老师是认为面向对象调用方法不叫消息?那么面向对象调用方法这种数据传递方式叫什么?

    作者回复: 方法参数😂

    
    
  • helloworld
    2019-09-23
    老师说Actor模型并不能保证消息100%可达,也不能保证100%能被处理,可见Actor模式适用的情形还是受限狭窄的
     1
    
  • 机遇号
    2019-06-11
    老师您好,能不能在继承UntypedActor这个类里将消息保存到数据库?具体怎么实现?能不能指点一下
     2
    
  • 峰
    2019-06-04
    感觉核心就是通过消息对列实现消息的暂存,然后actor就可以一个接一个单线程处理消息。有点像redis,但不同的是不同actor的调用线程可能不一样,只要保证同一时刻最多只有一个线程处理某个actor就行,并且actor直接可以消息通信,意味着可以用多个actor去组织起来完成一次请求。
    
    
  • 明天更美好
    2019-06-04
    遇到一个线程问题,我们有个业务要通过mq去通知第三方,但是第三方能力比较差,我们同步的时候mq堆积很多。后来改成用woker-thread模式,队列设置了2000线程用了64个机器是64核的,拒绝策论是当前线程执行该任务。结果发现队列很快就被放满了,一段时间后mq又堆积了。因为客户端没有及时签收消息,导致broker限流了直接不销费了,这种问题老师您有什么好的建议吗?

    作者回复: 可以试试异步处理,暂存本地数据库,另起进程发mq

     1
    
  • 往事随风,顺其自然
    2019-06-04
    Scala 编写spark 内部实现也是用这个通信机制
    
    
我们在线,来聊聊吧