• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:actor

actor

akka eventbus-消息保证-发布到总线保证

akka eventbus-消息保证-发布到总线保证
我到处都看过,无法真正获得信息,因此我可以基于此提供具体意见。 Akka eventbus只是一个“本地工具”(对于集群中的jvm / node),从我的阅读中可以知道:在同一个jvm中完成消息传递时要可靠得多。 因此,我有生产者A,B和C,以及消费者X,Y和Z,例如:如果我针对X正在收听的主题生成消息,则X是否一定会收到此消息(无论网络可靠性如何,如果我发……继续阅读 »

actor

Akka变成()和getSender()不兼容

Akka变成()和getSender()不兼容
我有一个与Java API中的Akka 2.0.1相关的问题。我有以下情况: 演员A:从UI接收请求。然后它将执行以下操作。 等待来自UI的消息发送消息到Actor B,以检索数据检索到演员B的答案后,请成为演员。 演员B: 等待演员A的消息。检索数据呼叫getSender().tell(xxx); 这是行不通的,并且演员A将不会收到答案。但是,如果Acto……继续阅读 »

actor

哪些设计决策会偏爱Scala的Actors而不是JMS?

哪些设计决策会偏爱Scala的Actors而不是JMS?
使用Scala Actors代替JMS有什么区别? 例如,从性能和可伸缩性的 Angular 来看,与JMS相比,Scala Actor模型增加了什么?在哪种情况下,使用Actor而不是JMS更有意义,即Actor解决了JMS无法解决的哪些问题? 解决方案如下: JMS和Scala参与者在理论上有相似之处,但他们认为它们并不一定在架构上解决相同的……继续阅读 »

actor

akka eventbus-消息保证-发布到总线保证

akka eventbus-消息保证-发布到总线保证
我到处都看过,无法真正获得信息,因此我可以基于此提供具体意见。 Akka eventbus只是一个“本地工具”(对于集群中的jvm / node),从我的阅读中可以知道:在同一个jvm中完成消息传递时要可靠得多。 因此,我有生产者A,B和C,以及消费者X,Y和Z,例如:如果我针对X正在收听的主题生成消息,则X是否一定会收到此消息(无论网络可靠性如何,如果我发……继续阅读 »

actor

具有TypedActor的基于事件的优先级调度程序

具有TypedActor的基于事件的优先级调度程序
是否可以(甚至建议)在Akka 1.3或2.0中使用带有TypedActor的PriorityExecutorBasedEventDrivenDispatcher?我希望为特定消息类型设置更高的优先级,这些优先级与TypedActor接口中公开的方法一对一对应。 例如,如果有方法a(),b()和c(),我希望对c()的调用具有比a()或b()调用更高的优先级……继续阅读 »

actor

JVM上的零拷贝消息传递

JVM上的零拷贝消息传递
对参与者传递消息的语义的忠实实现意味着,即使对于不可变的类型,也从逻辑的角度深度复制了消息内容。消息内容的深复制仍然是参与者模型幼稚实现的最大瓶颈之一,因此某些实现(例如Kilim)支持零复制消息传递。 我的问题是,如何在像JVM这样的共享内存平台中实现零拷贝消息传递(作为Actor library/framework的一部分)?我假设它仅适用于内容不可变的……继续阅读 »