Modelo de programación que se distingue por la comunicación asincrónica ubicua.

Más sobre actor...

¿Existe una diferencia de idioma entre F # y C # que bloquea el uso de Microsoft Coyote del código F #? Debido a que OnEventDoActionAttribute se define en el tipo heredado Microsoft.Coyote.Actors.Actor con un modificador de acceso protegido, parece que todavía es accesible en los tipos de actores he....
9 may. 2020 a las 11:47
Una de las mayores ventajas del modelo de actor es la eliminación del bloqueo (los actores operan de forma independiente y en serie). ¿Significa esto que no podemos tener ningún estado compartido / global en absoluto en un sistema de actores (porque acceder / actualizar eso traerá bloqueos)? En térm....
2 mar. 2020 a las 11:01
De la documentación de akka: A diferencia de los objetos, los actores encapsulan no solo su estado sino también su ejecución. La comunicación con los actores no se realiza mediante llamadas a métodos, sino pasando mensajes. Si bien esta diferencia puede parecer menor, en realidad es lo que nos permi....
30 ene. 2020 a las 15:01
Los actores se envían mensajes entre ellos. Si las colas son limitadas, ¿qué sucede en los intentos de escritura / envío a colas completas? ¿Bloqueo o caída? Si no están limitados, es posible un bloqueo de memoria. ¿Cuánto es configurable?....
Tengo una tabla de base de datos donde cada fila representa un trabajo por hacer. Esta tabla se llena / recibe trabajo a través de una API de descanso. Además de un servicio de descanso que realiza el trabajo, tengo otro servicio que utiliza actores para procesar este trabajo. Necesito sugerencias p....
26 dic. 2019 a las 15:34
Ahora estamos en el proceso de refactorizar nuestra aplicación de mensajería escrita en Vert.x. La aplicación procesa los mensajes entrantes de los usuarios. Inicialmente, se implementó para que haya una única instancia de vertical que escuche una sola cola en el bus de eventos y procese todos los m....
18 dic. 2019 a las 14:46
Estoy investigando la conversión de mi aplicación de estructura de servicio a kubernetes. Un área con la que estoy luchando, ¿cuál es el equivalente de los actores de la estructura de servicio en kubernetes? Utilizo principalmente actores recordatorios en la aplicación, ¿hay un equivalente en kubern....
10 dic. 2019 a las 20:17
Estoy tratando de emular un lenguaje funcional simple usando actores. Los sistemas de actores hoy en día se utilizan básicamente para acelerar todo tipo de cosas evitando bloqueos del sistema operativo y subprocesos estancados o hace que los microservicios sean menos dolorosos, pero inicialmente s....
¿Es posible verificar si un actor existe en ActorSystem? Simplemente no quiero pasar la referencia IActorRef a cada constructor de actores y me gustaría tener algo como el método GetOrCreate para crear instancias del actor requerido. Por lo tanto, podría ser como un actor único que usaría en todo e....
30 ago. 2019 a las 09:59
Quiero crear un Akka Cluster con miles de actores. Cada actor recibe un mensaje, hace algunos cálculos y escribe el resultado en un tema dedicado de Kafka. Debe implementarse en un clúster, por ejemplo, Kubernetes. Según tengo entendido, si, sea cual sea el motivo por el que se termina el actor (blo....
15 jul. 2019 a las 16:07
Estamos considerando usar un intermediario de mensajes para lograr un patrón de comunicación de publicación-suscripción basado en mensajes. ¿Necesita utilizar Actor-model para poder tener comunicaciones pub / sub basadas en mensajes entre sus microservicios?....
Estoy escribiendo una clase ALadder de C ++ inspirada en el tutorial de Alan Noon https://www.youtube .com / watch? v = axuwbkDWI5U. Actualmente la clase es muy sencilla: Ladder.h #pragma once #include "GameFramework/Actor.h" #include "Ladder.generated.h" class UPaperSprite; UCLASS() class ALa....
20 mar. 2019 a las 00:41
Estoy desarrollando una aplicación que crea algunos actores de Akka para administrar y procesar mensajes provenientes de un tema de Kafka. Los mensajes con la misma clave son procesados por el mismo actor. También uso la tecla de mensaje para nombrar al actor correspondiente. Cuando se lee un nuevo ....
18 mar. 2019 a las 23:15
Estoy usando la entidad permanente de Lagom y leo el soporte de Cassandra para implementar, guardar el estado para las consultas del lado de lectura. Entonces, tratando de entender, ¿las entidades persistentes también son actores? lo que significa que solo se manejará un evento / comando a la vez? ¿....
31 ago. 2018 a las 09:46
Estoy probando un actor que usa una API asincrónica basada en el futuro. El actor usa el patrón de tubería para enviarse un mensaje a sí mismo cuando se completa un futuro: import akka.pattern.pipe // ... // somewhere in the actor's receive method futureBasedApi.doSomething().pipeTo(self) En mi pr....
9 jul. 2018 a las 11:26
Tengo un sistema akka que es básicamente dos actores productores que envían mensajes a un actor consumidor. En una forma simplificada tengo algo como esto: class ProducerA extends Actor { def receive = { case Produce => Consumer ! generateMessageA() } ... more code ... } class ....
7 jul. 2018 a las 01:35
Soy nuevo en el marco de Akka y estoy creando una aplicación de chat grupal con él. Mi aplicación puede tener 10 millones de instancias de actor (una instancia de actor para cada chat grupal) del mismo tipo, solo el 5% de las cuales son muy activas y el 60% de las cuales pueden estar inactivas (sin ....
21 may. 2018 a las 08:59
Pregunta de novato: estoy tratando de tener un solo administrador de caché que se encuentre entre varios usuarios de la caché (= ascendente) y el cliente Redis (descendente), por lo que: Client A -----> | | Cache Manager <=====> Redis Connection --(tcp)-- Client B ....
20 may. 2018 a las 19:35
Tengo la siguiente implementación para el método de recepción en la implementación del actor Akka. override def receive: Receive = { case SetRequest(key, value) =>{ log.info("Received SetRequest - key:{} ,value:{}", key,value) map.put(key,value) sender() ! Status.Success } case Get....
20 may. 2018 a las 07:02
De la documentación de Akka: Los actores se implementan extendiendo el rasgo base Actor e implementando el método receive. El método receive debe definir una serie de declaraciones de casos (que tienen el tipo PartialFunction[Any, Unit]) que definen qué mensajes puede manejar su Actor, usando la coi....
13 may. 2018 a las 16:25
Estoy tratando de modelar un proceso de creación de cuenta de usuario mediante el cual un administrador crea una nueva cuenta de usuario. ¿Es aceptable tener actores que sean de un tipo diferente en un diagrama BPMN / Swim Lane? Entonces, por ejemplo, los Actores en este caso son 'Administrador de c....
9 abr. 2018 a las 04:36
Estoy pensando en crear un sistema que requiera que los actores creen una suscripción a un tema de Azure Service Bus con un filtro específico para la instancia de Actor. Mi pregunta es, si el Actor (que tiene la suscripción al Tema) se ha desactivado en Service Fabric, ¿será (re) activado por un nue....
Sé que los actores dentro de Service Fabric son de un solo subproceso. Pero supongamos que empiezo un nuevo hilo dentro de un método actor, ¿qué pasará entonces? ¿Se desactivará un actor aunque el hilo generado todavía se esté ejecutando? De acuerdo con la documentación, un actor se desactiva cuando....
Suponiendo que tengo un actor UserActor que sabe cómo trabajar con mensajes entrantes y cómo enviar mensajes nuevos, quiero manejar los sockets web dentro de Akka-Http, así que creo Flow[Message, Message, NotUsed]. Aquí obtenemos nuevos mensajes como JSON y los enviamos a UserActor. Cuando se comple....
13 feb. 2018 a las 15:19
Quiero etiquetar ciertas pruebas para (no) ejecutarlas en ciertos escenarios. (Por ejemplo, slow que solo debería ejecutarse durante la compilación, pero no durante el desarrollo). En Scala usando FlatSpec de ScalaTest, sé que puedo usar taggedAs y Tag de scalatest. Sin embargo, no sé cómo lograr lo....
11 dic. 2017 a las 17:24