您好,我正在学习使用Akka.net,我想要做的是,创建一个简单的TCP服务器,它将定期向tcp连接发送数据。(然后将由processingjs客户端获取并显示在输出中) 不知道我错过了什么。你们中的任何一位专家能对这个问题做一些解释吗? 下面是我的演员: using Akka.Actor;
using Akka.IO;
using System;
using System.Text;
using System.Threading.Tasks;
namespace ActorTcpProcessing
{
public class ProcessingServer : Receiv
我刚接触akka,看着现有的代码,看到一个演员从别人那里得到Message1,然后把Message2发送给自己。我知道发送消息比方法调用的优势是akka中的关键。但是,我看不出向getSelf()发送消息有什么好处。我看到的代码如下所示: import java.util.Date;
import akka.actor.AbstractLoggingActor;
import akka.actor.Props;
public class myActor extends AbstractLoggingActor {
public static class Message1 {
我们使用Akka HTTP来使用akka streams API来处理我们的网络套接字连接。我们使用的是一个流,它将传入的消息传输到“连接参与者”。代码片段如下:
val connection = system.actorOf(ConnectionActor.props())
val in = Flow[Message]
.to(Sink.actorRef[Message](connection, WebSocketClosed))
val out = Source
.actorRef[Message](500, OverflowStrategy.fail)
.mapMater
我目前使用的是play框架(2.0.1版)。我的应用程序需要监听udp广播消息。所以我需要一个新的线程来监控套接字并接收所需的字节。所以我实现了一个新的后台akka任务来读取我的套接字。见下文。我遇到的问题是当我关闭服务器时。但随后就挂起了,而且从来没有关闭过我的后台线程。
public running = false;
public void onReceive(Object message) {
if (message instanceof SystemConfiguration) {
try {
InetAddress group = In
我读了Akka文档,但我不明白:
class MyActor extends Actor {
private var _state = 0
override def receive: Receive = {
case x: Int =>
if (x != _state) {
println(s"---------> fail: ${x} and ${_state}")
}
_state = x + 1
}
}
implicit val system = ActorSystem("m
我试图编译这段代码,以了解角色的实际工作方式,但它给了我一条错误消息: value actorOf不是object akka.actor.Actor的成员
我是akka的新手,实际上不能理解如何开始和了解实现整个定义的结构,比如每个类的接收方法。另外,ActorLogging的实际工作是什么?有谁能帮帮忙吗?谢谢。
import akka.actor.Actor
case object Start
object Main {
def main(args: Array[String]): Unit = {
println("Start");
val ech
aktor path = akka://SchedulerAutoAction/user/TaskScheduleraktor
[INFO][7/1/2019 5:22:32 AM][Thread 0007][akka://SchedulerAutoAction/user/TaskScheduleraktor/$a] Message Messages from akka://SchedulerAutoAction/deadLetters to akka://SchedulerAutoAction/user/TaskScheduleraktor/$a was not delivered. 1 d
我正在尝试通过以下方式运行AKKA远程示例
1. Running the remote actor in a machine with IP 192.168.1.7
2. Running the local from my machine
远程执行元在机器中启动( ip地址为192.168.1.7);但是当我从我的机器启动本地执行元时,它无法连接到远程执行元。请查找本地和远程执行元系统配置:
本地:
akka {
//loglevel = "INFO"
actor {
provider = "akka.remote.RemoteActorRefProvi
我编写了一个实现设备管理的Akka应用程序。每个设备都是一个Akka Actor,我实现了Akka有限状态机来控制设备的生命周期,比如FUNCTIONAL,BROKEN,IN_REPAIRS,RETIRED,etc...and I Persistence the Device with Akka Persistence to Cassandra。
每件事都像一个梦,但我有两难的境地,我想问一下处理Akka的模式是什么。
我将有近1,000,000个设备,Akka是管理这些单个实例的理想选择,但我如何实现,如果用户一个看到所有设备系统并选择一个,更改它是状态...
我不能从Akka日志表中显示它
我的应用程序需要能够创建参与者的树形结构。我认为实现这一点的标准方法是将实例化代码放在actors中,这样它们就可以实例化自己的子对象。我更希望的方法是能够在给定的路径上实例化一个参与者。例如在mySystem中创建角色A,然后能够直接创建akka://mySystem/A/B和其他角色。这样的功能是否存在?这将大大简化我的代码。
编辑:现在我不在手机上了,让我来详细说明。
假设我有一节课
class myActor extends actor
我需要把它们做成一个n-way树。而不是让代码在接收函数中实例化它们自己的子级所需的代码
case Create(n:Int) => {}
我希
基于这个问题,,我实现了一个简单的akka层次结构,以便在两个参与者之间共享数据:
package playground
import akka.actor.{Actor, ActorRef, ActorSystem, Props}
case object GetFromDb
case object GetList
case object ProcessList
class ParentActor extends Actor {
var fromDb: List[Int] = List()
def receive = {
case GetFromDb =>
我正在尝试将SWT的使用与Akka结合起来。SWT widget之一是Browser,它嵌入了一个web浏览器,并允许JS代码通过BrowserFunction对象中的回调函数调用JVM虚拟机代码。
我有以下代码:
import org.eclipse.swt.widgets.Composite
import org.eclipse.swt.browser._
import akka.actor.Actor
class MyActor(parentComposite: Composite) extends Actor {
private var mutableContent: Any =
我尝试移植从Scala角色向Akka角色发送"Ping“和"Pong”的,但我一直收到错误,我想知道这只是一个简单的错误还是一些根本的错误。
考虑下面的代码:
import akka.actor.Actor._
import akka.actor.Actor
case class Message(text: String)
class PingPongActor(name: String) extends Actor {
def receive = {
case Message(msg) =>
println("receive
当我通过TCP套接字从非akka客户端收到一条消息时,我需要回复三条消息。在下面给出的示例中,只有第一个正确通过发送方(非AKKA的TCP客户端)。剩下的两个都成了死信。有什么想法吗?提前谢谢。
object TcpExample {
def main(args: Array[String]): Unit = {
val system = ActorSystem("some-system")
val tcpConsumer = system.actorOf(Props[TcpConsumer])
}
class TcpConsumer extends C