我想通过websockets向客户端发送通知。此通知是由actor生成的，因此我尝试在服务器启动时创建actor的消息流，并订阅到此流的websockect连接(仅发送订阅后发出的通知)但是如果已经实现了，我如何订阅(akka<
浏览 3提问于2017-02-07得票数 0
1回答
阅读akka的文档，我不太清楚消息的顺序，以及是否可以强制执行。让我用我为聊天服务器编写的一小部分代码来设置我问题的上下文。merge ~> channelActorSink
}[INFO] [11&#
浏览 4提问于2017-11-11得票数 0
回答已采纳
我已经添加了最新的akka-http到我的项目，但这包括非常老的2.4.19版本的akka-演员。因此，我还在依赖项中添加了akka-参与者版本2.5.4。我的maven配置如下： <dependency> <a
浏览 1提问于2017-08-27得票数 2
回答已采纳
我正在组织一个小的SBT项目，并学习如何使用akka演员。我能够得到一个简单的示例，只使用akka，但是一旦我使用外部库，就会停止工作。External projects like Alpakka, Persistence plugins or Akka HTTP etc. have their own version numbers(Lscala/Function2;)Lakka/act
浏览 2提问于2018-01-21得票数 4
这个想法是让通道保持打开状态，以便以后使用。在playframework 2.5.x中，文档说您必须使用akka streams，但没有说明如何实现此示例。有人能帮帮我吗？
浏览 0提问于2016-03-15得票数 8
2回答
我正在使用Typesafe/，并创建了一个带有“”的项目。然后，我将akka版本从2.3.11改为2.4.2 (当前稳定版本)。现在，我想添加最新的稳定Akka-HTTP和Akka流到我的项目。
浏览 5提问于2016-03-21得票数 2
回答已采纳
我正在尝试在我们的应用程序中使用akka pub。我有一个播放应用程序，它是akka集群的一部分。我想使用akka集群-客户端使这个应用程序监听/订阅主题和消息将从其他应用程序发布。Play应用程序中的集群/订阅方代码 import DistributedPub
浏览 0提问于2013-11-06得票数 0
回答已采纳
3回答
我正在尝试使用sbt的scala -akka。我的sbt文件如下所示：name := "hello"scala
浏览 1提问于2013-05-23得票数 8
回答已采纳
1回答
在我们的项目中，我们将消息发布到JMS代理或从JMS代理消费消息。我们有一个PL/SOL生产者和一个Java消费者。但问题是，生产者的速度是消费者的10倍。因此，在读取和处理消息时，我们希望将使用者更改为使用多线程。
但是我们也需要保持消息的顺序。也就是说，消息应该按照它们发布到jms代理的顺序发送到目标系统。我是Akka</e
浏览 0提问于2015-10-26得票数 0
6回答
在Play提供的功能中，是广告宣传最多的部分之一。与之相比，又如何呢？有很多重叠吗？同时使用它们实用吗？
浏览 14提问于2012-04-22得票数 25
回答已采纳
1回答
使用Akka和Actors实现以下内容的正确方法是什么？
我需要调用远程REST服务并传递一组参数和一个特定的日期。但我的应用程序正在获取一组输入参数和一个日期范围。因此，如果日期范围是365天，app需要对远程服务进行365次调用，然后处理所有输出数据(范围内的所有天)，并将处理结果保存到数据库中。对REST服务的初始调用不会立即返回结果，而是返回一些“请求id”。App将需要调用另一个REST API来检查请求状
浏览 2提问于2014-10-15得票数 1
1回答
我在用可重新启动的源和接收器处理akka流中的错误。newVal + " sink") newVal }}
我是打破源和下沉分别与不同的情况我首先断开接收器，希望接收器重新启动，并一次又一次地重新处理newVal == 3消息。但是似乎接收器中的错误被抛出了，只有源失败被重新尝试，所以源最终被重新
浏览 8提问于2022-01-10得票数 1
回答已采纳
我试图使用Scala2.12.3、SBT0.13.6和build.sbt文件中的以下库依赖项构建一个项目： "com.typesafe.akka" %% "akka-actor" % "2.5.4",
"com.typesafe.akka" %% "akka-stream" % "
浏览 4提问于2017-08-29得票数 4
回答已采纳
._import akka.stream._import akka.actor.Actorimport akka.actor.ActorRefimpo
浏览 3提问于2016-06-13得票数 1
假设我有一些通过ZeroMQ套接字进行会话的服务，并且我想向一个单页面web应用程序提供对该服务的访问。我希望web应用程序与一个提供REST API (用于控制和查询)和WebSockets (用于监控)的服务对话，它通过与第一个服务对话ZeroMQ来实现这一点。我想用Scala写这篇文章。我可以使用哪些选项来构建第二个服务？
浏览 0提问于2012-10-06得票数 1
回答已采纳
1回答
我是测试Akka的新手，当从akka.contrib.pattern.DistributedPubSubMediator向Akka中介者发送publish消息时，我一直在尝试简单地验证消息是否发送给订阅者在我进入验证实际业务逻辑之前，我想了解如何让他工作。import akka.actor.{ ActorRef, Actor }
import akka.contrib.patter
浏览 3提问于2015-02-18得票数 1
4回答
我正在尝试使用Play和akka流为Websocket连接创建一个简单的代理。.toMat(serverIncoming)(Keep.both) // also keep the Future[Done]// status code 101 (Switching Protocols) indicat
浏览 9提问于2017-04-12得票数 6
回答已采纳
1回答
._import javax.inject.Injectimportimport akka.Doneimport akka.stream.ActorMaterializer
import akka.stream.scaladsl._
浏览 15提问于2020-06-03得票数 0
回答已采纳
1回答
我正在尝试用Akka集群创建一个公共类型的应用程序。我正在阅读关于pubsub的文章，并且正在尝试运行他们的例子。运行订阅者(谁将成为主导者/领导者)。所有订阅者都将收到此消息)。Subscriber.scala
import akka.actor.，当我试图发布到“内容”主题时，它会挂起，而订阅者不会收到消息
浏览 8提问于2016-12-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
