RoudnRobinGroup在Akka中的简单示例
RoudnRobinGroup是Akka框架中的一个简单示例，用于实现轮询分组的消息路由。在Akka中，消息路由是一种将消息从发送者传递给接收者的机制。RoudnRobinGroup是其中一种路由策略，它将消息按照轮询的方式分发给多个接收者。
RoudnRobinGroup的主要特点和优势包括：
- 均衡负载：RoudnRobinGroup能够将消息均匀地分发给多个接收者，确保每个接收者都能够处理相同数量的消息，实现负载均衡。
- 高可用性：当某个接收者出现故障或不可用时，RoudnRobinGroup能够自动将消息路由到其他可用的接收者，提高系统的可用性。
- 简单易用：RoudnRobinGroup的使用非常简单，只需要在Akka配置文件中定义路由策略为RoudnRobinGroup，并指定接收者的地址即可。
RoudnRobinGroup的应用场景包括：
- 并行处理：当需要将大量的任务分发给多个工作节点进行并行处理时，RoudnRobinGroup可以实现任务的均衡分配，提高处理效率。
- 负载均衡：在分布式系统中，RoudnRobinGroup可以将请求均匀地分发给多个服务器，实现负载均衡，提高系统的性能和稳定性。
腾讯云提供了一系列与Akka相关的产品和服务，可以用于支持RoudnRobinGroup的实现，包括：
- 云服务器CVM：提供高性能的虚拟服务器，可以作为Akka集群的节点使用。链接地址：https://cloud.tencent.com/product/cvm
- 云数据库CDB：提供可靠的数据库服务，可以用于存储和管理Akka应用程序的数据。链接地址：https://cloud.tencent.com/product/cdb
- 云原生容器服务TKE：提供容器化部署和管理的平台，可以用于部署和运行Akka应用程序。链接地址：https://cloud.tencent.com/product/tke
请注意，以上仅为腾讯云的相关产品示例，其他云计算品牌商也提供类似的产品和服务，具体选择应根据实际需求和预算进行评估。
相关·内容
我试图在linux集群机器上运行一个基于scala/akka的程序。我正在跟踪教程链接(这是我能找到的唯一示例)：
它说要使用命令获得akka库: git克隆git://github.com/akka/akka.git
但按照本教程的规定，它里面没有任何jars文件。
我无法让一个基本的组合在linux上工作。所以在这方面的任何帮助都是非常感谢的。我不知道(无法找到任何明确的源代码)在使用或不使用SBT时编译/执行所需的命令。
Java版本："1.8.0_31“Scala版本："2.11.5”Akka:我不确定，我做了git克隆，相信它是最新的SBT: 0.13.9
Java，
浏览 4提问于2015-10-30得票数 1
回答已采纳
1回答
我只是在尝试这个样本流，它当前只有一个TextMessage作为源： // print each incoming strict text message
val printSink: Sink[Message, Future[Done]] =
Sink.foreach {
case message: TextMessage.Strict =>
println(message.text)
case _ =>
// ignore other message types
}
浏览 8提问于2021-10-13得票数 0
回答已采纳
1回答
有件事我不明白。
工作原理：echo "akka" | cat
但这不会在控制台上产生"akka“：echo "akka" > cat
这甚至不起作用：cat < echo "akka"
对我来说应该是一样的。但这3条命令似乎不一样
浏览 2提问于2021-01-25得票数 1
回答已采纳
我正在尝试使用akka-http中的json对象流。( akka http版本"10.0.9"，akka-http-play-json版本1.10.1)
我在web上使用示例，但是，对于字符串，我得到了：
could not find implicit value for parameter um: akka.http.scaladsl.unmarshalling.FromByteStringUnmarshaller[String]
对于我的用户定义的Foo case类(我为其提供了json协议)：
could not find implicit value for param
浏览 6提问于2018-01-19得票数 0
1回答
我尝试使用akka.net做一个简单的集群。
目标是让服务器接收请求并通过集群进行akka.net处理。
为了测试和学习，我创建了一个简单的WCF服务，它接收一个数学方程，并且我希望将这个等式发送到求解。
我有一个项目服务器和另一个客户端。
服务器端的配置是：
<![CDATA[
akka {
actor {
provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
debug {
浏览 2提问于2017-03-22得票数 1
回答已采纳
1回答
在向我无法控制的第三方服务发出请求时，我在日志中遇到了以下异常：
2017-10-25 17:08:45 [main-actor-system-akka.actor.default-dispatcher-16] ERROR akka.actor.RepointableActorRef - Error in stage [akka.http.impl.engine.client.OutgoingConnectionBlueprint$PrepareResponse@7feef72e]: Illegal response status code: 920
akka.http.scaladsl.mo
浏览 1提问于2017-10-25得票数 0
回答已采纳
在BroadcastHub的例子中，可以动态地产生监听同一个生产者的工作者。但这种派生必须在代码中显式完成。我想知道它是否可以被编码为流中事件的反应。
在下面的示例中，我想在收到spawns流中的“产卵”消息后再产生2个工作进程。有可能吗？
package com.example
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{BroadcastHub, Flow, Keep, Sink, Source}
import scala.concurre
浏览 1提问于2017-02-10得票数 0
回答已采纳
我尝试使用flatMapConcat，如下所示： Source.empty
.flatMapConcat {
Source.fromFuture(Future("hello"))
}
.runWith(Sink.foreach(println))
.onComplete {
case Success(_) =>
println()
case Failure(e) =>
println(s"Thrown ${e.getMes
浏览 29提问于2019-04-23得票数 0
回答已采纳
我正在尝试使用默认的Kafka配置设置，但我不确定${akka.kafka.consumer}是如何设置的。阅读我定义了以下内容：
在application.conf中，我定义：
our-kafka-consumer: ${akka.kafka.consumer} {
kafka-clients {
bootstrap.servers = "kafka-host:9092"
}
}
但是，当我启动Akka集群时，接收错误：
Could not resolve substitution to a value: ${akka.kafka.consumer}
${ak
浏览 18提问于2022-02-28得票数 0
回答已采纳
假设我有一个actor类，在Akka Actor中有一个方法： class SecureActor extends Actor{
def methodWithThread(): Unit={
} 是否可以在此方法中运行新线程？Akka自己的线程不会有问题吗？ class ThreadExample extends Thread{
override def run(){
println("Thread is running...");
} def methodWithThread(): Unit={
var t = new ThreadE
浏览 19提问于2021-01-19得票数 0
回答已采纳
我和Akka和Spring一起工作。
我有一个演员系统，它运行在一个卡夫卡流上(使用akka-stream-kafka_2.12)，参与者在内存中保存一些数据，并使用akka-persistence保存他们的状态。
我想知道的是，我可以创建一个REST端点，它可以与我的Actor-System交互，以提供一些数据或向我的参与者发送消息。
我的问题是，怎样才能达到这个目标？
浏览 2提问于2019-12-04得票数 1
回答已采纳
我必须对似乎没有经过验证的SSL证书的api进行https调用。我仍然希望使用akka-http的Http().singleRequest方法来调用api。
然而，当我进行调用时，我得到了以下错误：
javax.net.ssl.SSLHandshakeException: General SSLEngine problem
当我使用curl进行呼叫时，我得到
curl failed to verify the legitimacy of the server and therefore could not
establish a secure connection to it.
但是，如果我有
浏览 11提问于2019-08-02得票数 2
回答已采纳
1回答
节点试图加入群集时失败。
、、、、
我有前端和后端服务器。
前端运行！2.5和akka 2.4.11后端运行akka 2.4.11
它们都在运行kamon 0.6.3，并具有以下依赖关系：
"io.kamon" %% "kamon-akka" % Version.kamon,
"io.kamon" %% "kamon-log-reporter" % Version.kamon,
"io.kamon" %% "kamon-system-metrics" % Version.kamon,
"io.kamon" %%
浏览 4提问于2016-10-23得票数 0
回答已采纳
1回答
我需要发展以下几点：
游戏框架应用程序
akka http
共享库
剧本和akka应用程序都需要3号共享库。
是否可以在单个sbt项目中创建两个不同的构建？
因此，当我运行play构建时，它将不包括akka，而当我运行akka构建时，它将不包括play代码。
我只想避免打开和管理两个不同的项目。
浏览 4提问于2017-01-07得票数 1
1回答
当试图配置路由器时，我发现自己缺少了一些配置。
例外：
Caused by: akka.ConfigurationException: Configuration missing for router [akka://UPS/user/sqs-poller-2/router1] in 'akka.actor.deployment' section.
at akka.routing.FromConfig.verifyConfig(RouterConfig.scala:320)
at akka.routing.RoutedActorRef.<init>(RoutedAc
浏览 2提问于2017-04-10得票数 0
回答已采纳
我想知道有没有可能创造akka演员
在eclipse java项目中通过导入
akka jar文件。
有谁能告诉我这是怎么做到的。
例如，首先在eclipse中创建一个新项目，然后
在项目中创建akka actor对象或类
如果不可能的话，还有其他的选择吗？
用于在eclipse java项目中创建akka参与者。
感谢所有人
浏览 2提问于2012-09-22得票数 3
回答已采纳
1回答
Akka和节流
、、、
我是Akka的新手，我想用它来限制消息。我想使用Akka java库，我正在查看2.4.2版的以下示例，但不幸的是，它现在已经过时，不支持
对于最新版本(2.5.3) -我在节流迁移指南中找到了以下内容
谁能提供一个关于如何使用Java框架在Akka 2.5.3中处理节流的指导性示例？
谢谢
浏览 2提问于2017-07-13得票数 0
我使用的是.sbt构建定义文件，并且定义了许多共享相同版本号的相关依赖项，例如：
libraryDependencies ++= Seq(
"com.typesafe.akka" % "akka-actor" % "2.0.3",
"com.typesafe.akka" % "akka-slf4j" % "2.0.3",
...
"com.typesafe.akka" % "akka-testkit" % "2.0.3"
浏览 3提问于2012-09-17得票数 5
回答已采纳
1回答
在一个简单的测试中，我期望流程生成并打印数字一秒。我想测试处理背压的流操作，需要一个不尊重背压的Source。
... with FreeSpec ... {
implicit val system = ActorSystem(this.getClass.getSimpleName)
private val matSettings: ActorMaterializerSettings =
ActorMaterializerSettings(system).withDebugLogging(true).withFuzzing(true)
implicit val mat = Act
浏览 2提问于2017-05-28得票数 1
回答已采纳
我是akka的新手，我想用akka远程连接两台PC，只是为了在两个角色中运行一些代码。我在中试过这个例子。但是我真正要做的是将2个IP地址添加到配置文件中，我总是会收到这个错误吗？
第一台机器给我这个错误：
信息11/20/2018 13:58:48.833 akka.remote.artery.Association(akka://ClusterSystem)出站控制流到akka://集群系统@192.168.1.2:2552失败。重新启动。与akka://ClusterSystem@192.168.1.2:2552握手没有在20000 ms内完成(akka.remote.artery.O
浏览 0提问于2018-11-20得票数 0
回答已采纳
我需要在Kubernetes中使用DNS解析器设置一个Akka集群(使用Akka Classic)。我已经创建了一个无头服务，它能够为我的Akka应用程序的各种pod解析地址。在DNS解析之后，我能够获得各种pod的地址。现在我的Akka-Management通过Https运行， 因此，当一个pod尝试连接到各种其他pod的管理端点时，它需要使用"HTTPS“而不是"http”，但Akka默认使用"HTTP“。有没有办法在Java中修改这种行为？
浏览 33提问于2021-05-10得票数 0
回答已采纳
我有一个class A(httpClient: HttpExt)(implicit val system: ActorSystem, materializer: ActorMaterializer)，它有一个名为extractInfo (res: Future[HttpResponse]): Int的方法，该方法接受未来的响应，并从响应实体中提取一个int值。
我想为这个方法编写一个单元测试，并且在我的单元规范类中包含以下内容：
class ASpec extends UnitSpec with MockFactory {
"An A" - {
implicit v
浏览 0提问于2017-09-29得票数 2
我有一个用Java编写并由Maven管理的遗留应用程序。
最近，我想修改代码，使应用程序能够在由多台机器组成的集群上运行。我想从activator的akka示例集群Scala模板开始，这个模板是用Scala编写的，由SBT管理。
我的问题是:如何将这两个项目合并在一起，这样我就可以在akka示例集群scala项目中访问我的Java类，或者将代码从akka示例集群scala项目复制到我的Java项目并使其工作。
浏览 6提问于2016-05-26得票数 2
回答已采纳
假设下面的图片。每个Docker容器都属于一个Akka集群"foo"，每个容器都运行一个集群节点。Docker分配的IP地址(容器内部)是绿色的。所有内部端口都是9090，但都映射到主机上的各种外部端口。
假设Docker 5中的节点的Akka URI是什么？是akka.tcp://foo@10.0.0.195:9101
我读过一些关于Akka和Docker的博客，涉及链接，但这似乎不可行(?)对于多节点部署，我不知道如何将规模与1000节点连接起来。
我需要一些方法让Akka知道它的集群的地址。如果留给自己的设备，Docker 5可能会决定它可以在akka.tcp:
浏览 4提问于2014-12-16得票数 5
回答已采纳
我在谷歌上搜索一个适合我的用例的例子，但到目前为止我还没有找到。
我正在编写一个Akka WebService，它应该处理一个可能很大的纯文本请求体，将每一行发送到参与者的传入消息队列。
你们中有谁可以在这里写一些代码，或者直接转到一个示例页面？
我实际上不知道从哪里开始:对我来说最大的问题是处理流(在我的例子中，我想使用Akka流媒体库)
浏览 10提问于2017-07-16得票数 1
回答已采纳
我的sbt文件使用akka-sbt-plugin在target/<project>-dist目录中创建Akka微内核。该目录有子目录bin、config、deploy和lib.
我想把那个目录压缩成一个tarball。
我试图将sbt-native-packager与Universal目标一起使用，但我不明白如何使mappings工作。
sbt-native-packager是该走的路吗？如何引用akka-sbt-plugin创建的目录？有更好的方法压缩目录吗？
更新-添加更多信息
除其他外，我的plugins.sbt有：
addSbtPlugin("com.typesaf
浏览 1提问于2014-01-30得票数 0
回答已采纳
我尝试使用和 (我自己编写了specs2测试；参见下面)来测试乒乓示例(来自激活器的specs2 )。
最容易被刮伤的总是过去。但是，specs2测试并不总是通过(也就是说，如果我多次重新运行相同的测试)。当它失败时，它有以下输出：
[info] PingPongActorSpecs2
[info]
[info] A Ping actor in specs2 should should
[error] ! send back a ping on a pong
[error] assertion failed: expected PingMessage(
浏览 3提问于2016-01-08得票数 0
回答已采纳
1回答
我正在尝试从命令行运行一个可运行的jar，其中嵌入了几个akka进程。尽管我不是该应用程序的原始作者，但我知道代码在eclipse中确实运行得相当愉快。但是，当我尝试导出然后作为runnable Jar运行时，它会在一段时间后崩溃，这就是它开始启动akka进程的时候。我正在使用Java 8运行它
java -jar something.jar {options}
错误：
at akka.actor.ActorInitializationException$.apply(Actor.scala:174)
at akka.actor.ActorCell.create(ActorCel
浏览 2提问于2017-09-12得票数 2
我有一个Akka消息引擎，可以在一天中发送数百万条消息，包括短信和电子邮件。我需要介绍一种新的消息传递类型(PushNotification)，它包括让每个请求使用一个REST API (它还将处理数百万个请求)。我认为使用Webservice是一个阻塞操作，所以从我所读到的内容来看，我需要为这个新的Actor添加一个单独的分派器，我的问题是，它一定要像这里提到的那样是具有固定池大小的线程池执行器吗？(参见https://doc.akka.io/docs/akka-http/current/handling-blocking-operations-in-akka-http-routes.ht
浏览 21提问于2019-06-14得票数 1
1回答
给定以下appliction.conf：
akka {
loglevel = debug
actor {
provider = cluster
serialization-bindings {
"sample.cluster.CborSerializable" = jackson-cbor
}
}
remote {
artery {
canonical.hostname = "127.0.0.1"
canonical.port = 0
}
}
cluster {
浏览 7提问于2021-06-07得票数 1
回答已采纳
我正在阅读Akka streams的文档，我遇到了mapConcat操作符，它类似于flatMap (至少在概念层面上)。
下面是一个简单的例子：
scala> val src = Source.fromFuture(Future.successful(1 to 10))
src: akka.stream.scaladsl.Source[scala.collection.immutable.Range.Inclusive,akka.NotUsed] = Source(SourceShape(FutureSource.out(51943878)))
我所期望的源类型是：
akka.stre
浏览 1提问于2018-01-04得票数 4
回答已采纳
1回答
我正在使用Akka集群来实现一些冗余，并删除我的java应用程序中的单个故障点。但是，在将消息从一台计算机发送到另一台计算机时，我在序列化消息时遇到了一些问题。
我正在发送一个不实现Serializable的java对象。因此，我需要使用自己的序列化程序，幸运的是，该对象提供了一个使用Kryo的序列化方法。因此，在这个之后，我创建了自己的akka序列化程序，扩展了JSerializer
import akka.serialization.JSerializer;
public class MyObjectClusterSerializer extends JSerializer {
浏览 0提问于2014-08-04得票数 2
回答已采纳
1回答
以官方示例为例进行演示：
首先，启动前端节点
sbt 'runMain sample.cluster.factorial.FactorialFrontendMain'
启动两个后端节点，这两个后端节点分别是种子节点
sbt 'runMain sample.cluster.factorial.FactorialBackendMain 2551'
sbt 'runMain sample.cluster.factorial.FactorialBackendMain 2551'
现在一切都应该没问题了。
[info] [INFO] [05/11/2017
浏览 2提问于2017-05-11得票数 0
在Akka文档中，它说：
弃用警告-聚合器已被废弃，并计划在下一个主要版本中删除。请随意将源代码复制到您的项目中，或者在Akka之外创建一个单独的库。
但它并没有说什么(如果有的话)将取代它。
那么，Akka聚合器有哪些替代方案呢？
浏览 5提问于2017-03-12得票数 0
我是一名Ruby开发人员，而不是Java开发人员，所以我正在努力寻找在JRuby中使用Scala Akka库的最新示例，但结果并不理想。
我已经准备好了以下代码...
require "java"
[
"akka-2.3.8/lib/scala-library-2.11.4.jar",
"akka-2.3.8/lib/akka/akka-actor_2.11-2.3.8.jar",
"akka-2.3.8/lib/akka/config-1.2.1.jar"
].each { |lib| $C
浏览 2提问于2015-01-11得票数 0
若要向远程参与者发送受歧视的联合字段，我将使用Hyperion作为序列化程序，但它似乎只序列化第一个字段，但不序列化联合的其余部分。示例代码如下：
Server.fsx
#r "nuget: Akka.FSharp"
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"
#r "nuget: Akka.Serialization.Hyperion"
#load "Message.fsx"
open Message
open System
open Akka.FShar
浏览 4提问于2020-12-02得票数 0
回答已采纳
现在，我尝试在一个非常简单的用例中使用Akka。我想要一个特定的Actor来处理通过TCP获得的消息，但是我无法做到这一点，而且文档看起来还不够清楚。我现在拥有的是：
Application.conf:
akka {
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
remote {
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = "127.0.0.1
浏览 0提问于2014-07-22得票数 1
回答已采纳
2回答
我试图在Apache中配置Akka框架。我使用了以下步骤：
我已经在我的项目包中包含了下面的bundle jar文件
- akka-actor\_2.11-2.4.11\_1.0.0.jar
- akka-cluster-tools\_2.11-2.4.11\_1.0.0.jar
- akka-stream\_2.11-2.4.11\_1.0.0.jar
- config-1.3.0.jar
- scala-library-2.11.8.jar
下面是我在Activator中用来创建ActorSystem的源代码：
公共类激活器扩展DependencyActivatorBa
浏览 2提问于2016-11-30得票数 1
我试图用日记持久性将Akka.Net配置为MongoDb，但它正在抛出一个我无法完全弄清楚的异常。是否有一个我可以查看的参考示例，以了解它应该如何工作？，我本来希望单元测试中的示例能够满足我的这一需求，但是持久性的MongoDb实现缺少测试。:(
下面是我遇到的错误：
Akka.Actor.ActorInitializationException : Exception during creation --->
System.TypeLoadException : Method 'ReplayMessagesAsync' in type
'Akka.Persi
浏览 1提问于2016-04-15得票数 0
1回答
我目前使用的是Play 2.4.2，并且已经使用以下内容成功创建了线程池：
package threads
import scala.concurrent.ExecutionContext
import play.api.libs.concurrent.Akka
import play.api.Play.current
object Contexts {
implicit val db: ExecutionContext = Akka.system.dispatchers.lookup("contexts.db-context")
implicit val pdf:
浏览 1提问于2016-09-28得票数 1
我想知道Akka的用途是什么。
我从互联网上读到了它，并且知道它是一个工具箱，使用的是Actor模型系统。在此之后，我研究了Actor模型系统，在这个系统中，有不同的参与者可以相互传递信息并发起行动。
我还知道Akka帮助提供并发性，并避免了锁定机制。但是，即使在阅读了所有这些之后，我仍然无法准确地总结出Akka是什么，以及我们为什么使用它？还有，它是如何使用的？
有人能用简单的话向我解释一下吗？谢谢。
浏览 7提问于2014-07-09得票数 16
回答已采纳
1回答
我意识到在反应式编程中阻止它是不可取的.但是，我有一个简单的用例。我有一个生产者比能生产的要快得多的消费者。对于这个现实世界的例子，我估计我只需要一个生产者和4到10个消费者(最多)。
我想使用一个有限制的邮箱，这样我的(快速)生产者就不会比它(慢的)用户走得太远。在我以前的(非Akka)实现中，我使用了一个Java BlockingQueue。
case object Start
case object End
case class Work(msg: String)
trait Constant {
val loop = 1000000
}
class SlowConsumerA
浏览 0提问于2019-09-01得票数 2
回答已采纳
1回答
我有一个带有application.conf的akka集群，如下所示：
remote { // Remote configuration for this seed node
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = ""
port = 2555
}
}
cluster {
seed-nodes = [
"akka.tcp://automation-akka-http@10.0.0.4:2555",
浏览 1提问于2017-06-19得票数 0
回答已采纳
1回答
好的，按照使用Java 8的先决条件和说明，项目创建工作。
sbt new akka/akka-grpc-quickstart-java.g8
然后继续使用
./gradlew compileJava也能工作。
但是，./gradlew --info runServer失败了，出现了折叠错误/问题：
Task ':runServer' is not up-to-date because:
Task has not declared any outputs.
和
Error: Main method not found in class com.example.helloworl
浏览 9提问于2020-02-11得票数 1
回答已采纳
代码来自以下存储库：
➜ akka-sample-distributed-data-scala git:(2.5) ✗ sbt run
[info] Loading project definition from /Volumes/Macintosh HD/github/akka-samples/akka-sample-distributed-data-scala/project
[info] Set current project to akka-sample-distributed-data-scala (in build file:/Volumes/Macintosh%20HD/gi
浏览 2提问于2018-05-27得票数 1
我正试图按照这里的指南运行Akka分布式工人项目，
在运行时，它会出现一系列错误消息失败。第一个引起我注意的是：
14:42:36.747 [ClusterSystem-akka.actor.default-dispatcher-4] ERROR akka.cluster.ClusterActorRefProvider - No root guardian at [akka.tcp://ClusterSystem@127.0.0.1:2554]
java.lang.IllegalArgumentException: Wrong protocol of [akka.tcp://ClusterSy
浏览 5提问于2019-11-20得票数 1
回答已采纳
我对java和AKKA工具包很陌生。我已经创建了一个JAVA项目，并试图包含以下代码
package com.postgresqltutorial;
import akka.actor.ActorSystem;
public class App {
public static void main(String[] args) {
final ActorSystem system = ActorSystem.create("QuickStart");
}
}
我在引用的库中使用了A
浏览 3提问于2022-03-04得票数 0
1回答
我是测试Akka的新手，当从akka.contrib.pattern.DistributedPubSubMediator向Akka中介者发送publish消息时，我一直在尝试简单地验证消息是否发送给订阅者。在我进入验证实际业务逻辑之前，我想了解如何让他工作。
import akka.actor.{ ActorRef, Actor }
import akka.contrib.pattern.DistributedPubSubExtension
import akka.contrib.pattern.DistributedPubSubMediator.{ Subscribe, Publish }
浏览 3提问于2015-02-18得票数 1
我正在使用jruby 1.7.12 (1.9.3p392)，我想利用Scala库。我知道Mikka宝石，但我想手动做。
我从下载了Akka库" 2.3.8“(特别是链接”Akka2.3.8发行版的Scala2.11“)。
下面是文件结构(一个app.rb JRuby文件，其余是下载的Akka库).
├── akka-2.3.8
| ├── bin
| ├── config
| ├── deploy
| ├── doc
│ ├── lib
│ │ ├── akka
│ │ │ ├── akka-actor_2.11-2.3.8.jar
│ │
浏览 2提问于2015-01-11得票数 1
回答已采纳
我正在尝试将一个现有的(演示)项目从Akka.Net 1.0.8升级到最近的项目(1.3.2或其他什么)。
我被困在让SQL服务器持久性加载上。我采取了以下步骤：
创建了一个空白项目，并包含了Akka.Persistence.SqlServer包及其所有依赖项。
从：复制HOCON配置示例
将DB连接字符串更改为现有的DB。
将自动初始化设置为“on”。
修正了akka.persistence.journal-store.sql-server.plugin-dispatcher中的双引号问题
创建了一个演员系统
检查SQL server配置是否存在
浏览 2提问于2018-02-21得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
