我们在当前项目中使用了akka.net角色模型。我使用了一个实体actor来处理对它的插入、更新和删除操作。在搜索或获取的情况下，角色模型是否不适合？如果在UI中支持，如何获得结果(天气使用Ask函数)
使用akka.net参与者模型获取和查询数据不是很好的实践吗？
浏览 10提问于2017-03-16得票数 0
我试图让Akka.NET记录参与者接收到的所有消息，但无法使其正常工作。= DEBUG log-config-on-start = on actor { debug { receive = onPoisonPill lifecycle = on # log actor lifecycle changes event-stream = on # logto actors } }
浏览 2提问于2016-01-12得票数 11
回答已采纳
由于Akka.net系统只返回对Actor的引用(IActorRef)，而且您只能通过Tell()和Ask()与Actor交互，其中参数不是强类型的，只是类型为对象基.我脑子里有些问题。尽管松耦合很好，但"TellAnything“(一个对象契约)(在我看来)和MicrosoftOrleonor粒度(在我看来)的优点比它更适合这里，因为您可以有一个显式的接口。我是否错过了Akka.net提供的具有严肃合同的功能？;}
// <e
浏览 0提问于2016-06-03得票数 3
回答已采纳
1回答
我正在寻找一种在akka.net中锁定消息队列的方法。我有一个角色A，它向专职的角色发送消息。还有一个Actor B，他向专用actor发送消息，但使用其他逻辑、其他功能，但同样适用于此处，根据响应，发送特定的新请求。
但发送给专用Actor的消息不能混合。因此Actor A可以使用专用Actor，当完成时，Actor B可
浏览 6提问于2021-06-12得票数 0
我正在尝试测试我的Akka.NET演员，但是TestKit和理解它的工作原理有一些问题。由于Akka.NET中还没有用于单元测试的正式文档，所以我已经研究了Akka.NET回购(例如，代码)，但是这里使用的示例对我不起作用。我所引用的测试是和，因为它们与我试图在应用程序中测试的场景非常接近。if (msg.Message == "bye bye") Become(NotGreeted); }我想测试它
浏览 0提问于2015-06-09得票数 10
回答已采纳
我是Akka.NET的新手，我正在构建某种websockets，我想使用Akka.NET来处理(转换和转发)传入的流量，使用它的参与者系统。但我想知道怎样才是最好的办法。我有以下问题：
我是否应该在Actor之外创建主侦听器，并为每个传入的“侦听”客户端实例化一个参与者？或者我应该把我的主要听众也放在一个演员里面？我是否应该与“发送”websocket客户端一起创建转发和转换逻辑？或者我应该把我的客户放在演员之外，并把它放在Akka.NET消息中？
浏览 1提问于2017-10-10得票数 2
回答已采纳
在那里，你可以使用async，在actor内部等待你内心的渴望。
在我看来，我可以使用这种阻塞特性来强制Actor成为一种串行操作队列。是的，如果进程崩溃，入队的消息没有持久化，就会导致这些消息丢失。假设这是可以的，但是，在我的情况下，这是可取的。
浏览 53提问于2019-05-05得票数 0
回答已采纳
2回答
我知道，Akka.Net中的所有操作都是异步的，Context.Stop()只是向参与者发送一条Stop消息。这意味着，在它完全关闭之前，演员还会活着一段时间。下面是示例代码{}
actor = context.Chi
浏览 3提问于2017-01-06得票数 5
回答已采纳
2回答
我已经开始使用Akka.NET，并且能够在具有多个实例的远程系统上使用did自部署(使用具有5个实例的循环池路由器进行部署)。但是，现在我希望能够将多个服务器连接在一起。目前我有这样的工作：然而，我正试图做这样的事情：
/--->Remote Actor #1Remote Actor 1、2、或 3。这听起来更像是一个分散的网络，其中来自Main Actor
浏览 11提问于2022-01-05得票数 0
我是Akka.net的新手，我想要创建一个Active Objects模式TypedActor，在Active Objects代码和non-actor代码之间架起桥梁。我在上读了Java的文档Squarer mySquarer =有人能帮忙吗？非常感谢
浏览 4提问于2015-04-23得票数 2
回答已采纳
我们在akka.net上做POC来处理json文件。我正在为批处理JArray的最佳方法而奋斗。在我的实现中，akka协调员角色收到以下消息：public class ValidatedInputpublic JArray Data{ get; set; }我的协调器参与者可以像下面这样一次处理完整的JArray，但是我很难启动多个并行参与者，每个参与者都会处理来自JArray的50条记录。//coordinator act
浏览 6提问于2016-12-15得票数 2
回答已采纳
1回答
我们计划使用AKKA.NET开发一个审计服务web。
我们认为方法2是利用AKKA.NET的最佳方式。
浏览 3提问于2016-09-30得票数 1
回答已采纳
1回答
我在服务架构(ASP.NET核心)上有一个无状态服务，它将调用一个Actor，Actor也可以内部调用其他Actor和/或有状态服务，具体取决于场景。在我们早期的Akka.Net实现中，由于TCP/IP网络拥塞等原因，参与者有可能收到重复的请求，我们通过给每个消息一个唯一的相关Id来处理这个问题。有人知道这是否需要在Actor和/或Stateful服务中处理吗？
浏览 3提问于2018-06-28得票数 0
程序必须知道名称是否存在于给定的列表中。此外，如果列表中的一个元素是"James Christ"，并且我们搜索"James"，则程序应该返回true。我做了一半的节目。但是我的代码不执行额外的功能。我的代码是这样的：x=input("Enter the name to search : ")
return sea
浏览 4提问于2013-02-25得票数 2
1回答
我不确定这是否与akka.net或TPL更相关，但我将使用参与者作为我的例子来澄清这个问题。我现在用的是一台8核处理器的笔记本电脑。));然后我要向所有这些人传递一个信息：Console.WriteLine("sent message to actorDateTime.Now.TimeO
浏览 0提问于2016-02-22得票数 5
回答已采纳
我们正在开发一个带有Akka.net v1.4.38的集群，我们有使用Akka.IO.TCP与外部系统通信的种子节点，以及多个客户端节点，它们接收并向种子节点发送消息。我们创建了一个Actor，用于侦听AssociationErrorEvent和ThisActorSystemQuarantinedEvent，并在接收到此消息时重新启动系统。Sys.Terminate().Wait(10000))
Assert.Fail("Unable to terminate actor syst
浏览 9提问于2022-05-12得票数 0
回答已采纳
我想要构建一个查询，在三列上搜索名称和姓氏的列表。我要求用户输入一个名称，输出将是相应的行和一些列。我希望用户只输入一个名字或一个姓氏，甚至几个字母，不区分大小写。和"cuaron“匹配Alfonso Cuarón。import pandas as pd
def get_actordo a new search or find data?&
浏览 3提问于2022-04-01得票数 -2
回答已采纳
2回答
我开始研究Akka.Net框架中的新兵营。我无法理解域事件将如何被其他参与者发送和接收。仅限于一个本地部署的Actors和没有DI容器的系统，并使用c# /ASP.NET API，其中我将每个AgreegateRoot分离成自己的项目
ManagerActor将接收命令消息并通过验证过程，如果验证将发送给AggregateRoot Actor。发布的事件由处理程序(其他Actor )处理
浏览 1提问于2017-01-14得票数 1
回答已采纳
1回答
下面的代码显示了一个方法，我有一个hashmap缓冲区和一个队列，其中包含几个列表。当消息稳定时，我想搜索一条特定的消息以将其设置为真；消息可能位于缓冲区或队列中。或者是否有更好的方法来反映我的意图。 if (mBuffer.get(event_actor</
浏览 5提问于2022-03-23得票数 0
回答已采纳
我对类型记录和RxJ很陌生，并被分配了一个错误，在那里，我们的搜索常常在HTTP404状态下失败。特别是当用户从远程运行应用程序时。performSearch(pollingInterval: number, searchCriterias: string[], search: MalSokningDto[], actor: string=== 202) {
浏览 4提问于2021-04-27得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号