Akka (Java)配置自定义ThreadFactory
Akka是一个用于构建高并发、分布式和可容错应用程序的开源工具包。它基于Actor模型，提供了一种并发编程模型，使得开发者可以更容易地编写可扩展和可靠的应用程序。
在Akka中，配置自定义ThreadFactory是为了控制线程的创建和管理。ThreadFactory是一个接口，用于创建新线程的工厂。通过自定义ThreadFactory，我们可以对线程进行更精细的控制，例如设置线程的名称、优先级、是否为守护线程等。
在Java中，配置自定义ThreadFactory可以通过以下步骤实现：
- 创建一个实现ThreadFactory接口的类，例如CustomThreadFactory。
- 在CustomThreadFactory类中实现newThread方法，该方法用于创建新线程，并可以在其中设置线程的属性。
- 在Akka的配置文件中，使用akka.actor.default-dispatcher.thread-factory配置项指定自定义的ThreadFactory类，例如akka.actor.default-dispatcher.thread-factory = "com.example.CustomThreadFactory"。
配置自定义ThreadFactory的优势在于可以根据应用程序的需求来定制线程的行为，从而提高应用程序的性能和可靠性。
Akka的应用场景包括但不限于：
- 分布式系统：Akka提供了分布式Actor模型的支持，可以轻松构建分布式系统。
- 高并发应用：Akka的Actor模型可以有效地处理大量并发请求，提高应用程序的吞吐量和响应速度。
- 可容错应用：Akka提供了容错机制，可以自动处理Actor的失败和恢复，提高应用程序的可靠性。
腾讯云提供了一系列与Akka相关的产品和服务，例如云服务器、容器服务、负载均衡等。您可以通过以下链接了解更多关于腾讯云的相关产品和服务：
请注意，以上答案仅供参考，具体的配置和推荐产品可能会因实际需求和环境而有所不同。
相关·内容
1回答
我目前正在尝试在一个使用LWJGL的应用程序中使用Scala和Akka。众所周知，您不能真正在应用程序的主线程之外发出OpenGL调用。如果我想要使用任何执行元进行渲染，这就会产生一个问题(要么是单个的主执行元，例如，耗尽渲染命令队列，要么是拥有多个可能随时发出任意OpenGL命令的执行元)，因为我还没有看到在特定线程上运行任何执行元的方法。通过将特定执行元固定到线程，或者指示执行元在某个特定线程上运行。(a la Objective-C's performSelectorOnMainThread)
有没有一种方法可以将一个“呈现”角色固定到主线程上，或者让任何角色在将来某个时候在主线
浏览 0提问于2013-09-30得票数 2
目前我们使用：
val simpleOps: ExecutionContext = Akka.system(app).dispatchers.lookup("akka.actor.simple-ops")
然后，当我们创建和构建我们的未来时，我们隐含地导入它。除此之外，我们目前不使用Akka。
有更简单的方法来获取ExecutionContext，但我不确定它是否会在Java Fork/Join Pool上运行，后者比常规的java ExecutorService性能更好一些。
Akka是获得FJP powered ExecutionContext的唯一方法吗？有没有其他方法可
浏览 0提问于2013-06-04得票数 2
回答已采纳
当我在Android上运行使用Akka的应用程序时，我会收到以下异常：
04-29 16:13:06.235: E/AndroidRuntime(8968): java.lang.RuntimeException: Unable to start activity ComponentInfo{com.myapp/com.myapp.MyActivity}: java.lang.NoSuchMethodException: <init> [interface com.typesafe.config.Config, interface akka.event.LoggingAdapter
浏览 9提问于2014-04-29得票数 2
回答已采纳
我在从线程记录RuntimeException时遇到了一些困难。我的系统是:Java7 (b118)，Spring3.0.5。线程不是手动创建的，而是通过Spring的@Async注释创建的，它在幕后创建自己的执行器，所以我实际上没有选择覆盖线程的任何方法，FutureTask或任何低级别的方法。所以我的问题是，Spring是否有任何支持，或者是否有任何处理(记录)这些类型的异常的最佳实践？如有任何建议，欢迎光临。谢谢。
浏览 5提问于2010-12-26得票数 4
TL;DR
我试图对akka库的一个版本进行阴影，并将其与我的应用程序捆绑在一起(以便能够在CDH 5.7版本的Spark 1.6上运行spray-can服务器)。阴影处理过程，在手动提供一个单独的版本的akka的reference.conf的阴影akka，它看起来仍然是混淆了一些。
阴影akka版本是否已知会导致问题？我做错了什么？
背景
我目前有一个Scala/Spark应用程序运行在Spark 1.6.1独立的平台上。应用程序使用spray 1.3.3运行 http服务器，这需要akka 2.3.9 (Spark 1.6.1独立包含兼容的akka 2.3.11)。
我正在尝试将应用程序迁
浏览 1提问于2016-11-21得票数 5
回答已采纳
我是新来的akka，并尝试学习akka的视频教程。
作者解释了代码，但没有解释任何关于配置的内容。
我的演员代码是
import akka.actor._
import akka.persistence.{PersistentActor, SnapshotOffer}
import Counter._
object Counter {
sealed trait Operation {
val count: Int
}
case class Increment(override val count: Int) extends Operation
case class
浏览 6提问于2018-01-14得票数 1
回答已采纳
2回答
我正试着像往常一样使用akka远程连接到一个演员，但我确定当我在android上使用akka时，我还需要做一些其他的事情，有人能帮我吗？
import akka.actor.Actor.remote
// Establish Connection to Remote Actor
val server = remote.actorFor(remoteActorID, rIP, rPort)
我按照堆栈跟踪得到了te：
04-28 09:57:13.114: ERROR/AndroidRuntime(18536): FATAL EXCEPTION: Thread-
浏览 3提问于2012-04-28得票数 5
使用Akka框架作为我的用例，我创建了一个SupervisorActor和两个子角色，现在我有令牌服务，它需要在到期前更新我的缓存，请找到代码：
public class TokenCacheService {
final Logger logger = LoggerFactory.getLogger(TokenCacheService.class);
private static final String KEY = "USER_TOKEN";
private LoadingCache<String, String> tokenCache;
浏览 0提问于2020-08-20得票数 0
我想使用slf4j进行日志记录，基于。这些配置应该在application.conf中更改
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
}
我用application.properties代替application.conf
akka.loggers[0]=akka.event.slf4j.Slf4jLogger
akka.logging-filter=akka.event.slf4j.Sl
浏览 1提问于2018-11-24得票数 3
4回答
我有一个使用Executor框架的Java应用程序，还有类似于这个protected ScheduledExecutorService scheduledExecutorService = new ScheduledThreadPoolExecutor(5)的代码
我的理解是，JVM内部将创建一个由5个线程组成的池。现在，当我在分析器中检查执行时，我得到了类似于thread-pool2,thread-pool3之类的内容。
Some of these thread pools are created by the server and some are created by me，我需要一种方
浏览 15提问于2011-04-21得票数 36
回答已采纳
的一个构造函数允许我将一个ThreadFactory传递给它。
这有点奇怪，因为我已经在处理线程池了！这意味着它知道如何管理线程生存期。
在我看来，这看起来像策略模式，允许我在维护所提供的调度服务的同时覆盖线程创建的逻辑。
我做得对吗？
在Java中内置的ThreadFactories是什么？
谢谢!
浏览 1提问于2012-08-06得票数 1
回答已采纳
我正在设置akka集群(使用akka库版本2.3.9 )，其中包含一个主角色和多个工作角色。Master Actor配置了池群集感知路由器。
部署形成4个集群节点的应用程序。最初，所有节点都正确地加入了集群，但几分钟后，节点就解除了与集群的关联，形成了自己的集群。
**Getting below warn message logged when enabling remote debug logging -**
**ERROR] []** [ClusterSystem-akka.remote.default-remote-dispatcher-23] [akka.tcp://ClusterS
浏览 20提问于2016-08-24得票数 2
1回答
我的应用程序使用一个库，该库在内部初始化参与者系统，如下所示 ActorSystem("MySys") 因此，MySys执行元系统使用默认调度程序。我想为这个特定的参与者系统使用一个自定义的分派器。如何在我的application.conf中重写这个库的执行元系统使用的调度程序 我已经试过这样做了 MySys {
akka {
actor {
default-dispatcher = "my-dispatcher"
}
my-dispatcher {
type = Dispatcher
exec
浏览 21提问于2019-06-24得票数 1
回答已采纳
2回答
在我的test.conf文件中，我有以下配置
akka {
actor {
provider = "akka.cluster.ClusterActorRefProvider"
serializers {
java = "akka.serialization.JavaSerializer"
}
serialization-bindings {
"java.io.Serializable" = "kyro"
}
}
}
我试图将此配置放在test.pro
浏览 7提问于2017-04-20得票数 0
回答已采纳
1回答
代码如下：
package com.packt.akka
import akka.actor.{Actor, ActorRef, ActorSystem, Props}
import com.typesafe.config.ConfigFactory
object MembersService {
val config = ConfigFactory.load.getConfig("MembersService")
val system = ActorSystem("MembersService", config)
val worker =
浏览 0提问于2016-04-05得票数 5
2回答
我使用的是Java 6和Junit 4.12。我试图在JUnit中检测线程是否是从类派生出来的。在我的课堂上，我像这样产生了线程。
final Thread deletethirdpartyClassThread = new Thread(new Runnable(){
@Override
public void run()
{
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
LOG.error(e.getMessag
浏览 4提问于2016-09-20得票数 0
回答已采纳
我使用了中给出的maven-shade-plugin，它创建了一个带阴影的jar，如maven build的以下输出所示：
[INFO] --- maven-shade-plugin:2.4.2:shade (default) @ remoting.example ---
[INFO] Including com.typesafe.akka:akka-remote_2.11:jar:2.4.8 in the shaded jar.
[INFO] Including org.scala-lang:scala-library:jar:2.11.8 in the shaded jar.
[INFO]
浏览 7提问于2016-08-04得票数 2
2回答
这可能是一个非常愚蠢的问题--
有没有可能定制Akka/Scala角色，让你控制角色所使用的线程？例如，您是否可以初始化自己的线程集以在线程池中使用，或者以其他方式控制/修改线程？
浏览 0提问于2011-07-28得票数 1
回答已采纳
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
解决这个问题，我有3个现金柜台服务的客户数量。除了第三个计数器外，每个计数器需要1秒来处理1个项目，而第三个计数器需要2秒来处理每个项目。(例如，在柜台1上有5件商品的客户A需要5秒才能完成)，在柜台C上有3件商品的客户B将需要6秒。每个顾客都有不同的排队时间。我使用ScheduledExecutorService创建了等同于现金计数器的线程数。
ScheduledExecutorService scheduledExecutorService =Executors.newScheduledThreadPool(3);
现在，我的runnable实现检查了项目的数量，并相应地运行循环。
我提交
浏览 0提问于2014-12-02得票数 1
我尝试了以下方法：
class ClientActor (stockActor: ActorSelection, paymentsActor: ActorSelection) extends PersistentActor
with AtLeastOnceDelivery with akka.actor.ActorLogging with RequiresMessageQueue[akka.custom.CustomMailbox]{
//actor implementation
}
我得到了错误：
illegal inheritance;
self-type Shoppin
浏览 0提问于2019-03-18得票数 0
我无法构建我的scala/play应用程序。
[error] a.i.TcpListener - Bind failed for TCP channel on endpoint [/0.0.0.0:9000]
java.net.BindException: Address already in use: bind
at sun.nio.ch.Net.bind0(Native Method)
at sun.nio.ch.Net.bind(Net.java:433)
at sun.nio.ch.Net.bind(Net.java:425)
at sun.nio.ch
浏览 22提问于2020-06-02得票数 1
回答已采纳
2回答
我正在学习本教程。
我一直在跟踪它，但我的程序没有运行，它会给我带来错误，我对这一行感到困惑：
val remote = context.actorFor("akka://HelloRemoteSystem@127.0.0.1:5150/user/RemoteActor")
我要写什么来代替“用户”？例如，当我写完完整的路径时：
val remote = context.actorFor("akka://HelloRemoteSystem@127.0.0.1:5150/sw/opt/programs/akka/akkaremoting/RemoteActor"
浏览 5提问于2014-10-27得票数 0
回答已采纳
1回答
我想在阿克卡为调度员使用一个定制的执行器。
具体来说，我想用我自己的(日志、调试等)包装一个现有的执行器。
我看过的相关部分
默认的dispatcher可以配置，默认情况下是带有“叉-连接-执行器”的Dispatcher，这在大多数情况下提供了出色的性能。
和
使用“叉-连接-执行器”、“线程池-执行器”或akka.dispatcher.ExecutorServiceConfigurator的FQCN指定使用“executor”。
(我不明白什么是FQCN。)
我该怎么做？
浏览 4提问于2014-07-30得票数 5
回答已采纳
我正在尝试使用Java的执行器来执行一个多线程程序。在执行时，java线程异常地终止。我通过try-catch捕获了异常，但是异常中没有消息(null)。
失败是随机的，但是我“怀疑”失败是在我在该线程中进行函数调用之后发生的。我尝试将线程堆栈大小增加到1024/2048，但结果保持不变。
有没有人可以指出这里要采用的调试方法。因为我没有关于异常的信息，所以我不能继续处理它。
我在Windows 64位环境中工作，使用的是java 1.6
浏览 0提问于2012-03-05得票数 0
回答已采纳
在将使用Akka + Akka集群分片的服务升级到新发布的Akka (2.5.0)之后，我们开始遇到在Docker + Alpine中启动系统的问题。根据我的推断，Akka集群切分被配置为使用Akka分布式数据(在2.5.0时不再是实验数据)，它使用的是LMDB (它需要GCC + glibc，在高寒Linux中是不可用的)。
我的问题如下：
1)是否有任何由Akka支持的标准替代方案，而不是LMDB？
( 2)有没有办法让LMDB在阿尔卑斯Linux下工作？
堆栈跟踪：
[ERROR] [04/20/2017 13:42:19.014] [lotus-akka.actor.default-d
浏览 0提问于2017-04-20得票数 1
回答已采纳
我对lagom、elasticsearch是新手，我使用的是lagom、elasticsearch、scala和cassandra.Everything，但是当我通过postman发布json数据时，数据会转到cassandra，而不是elasticsearch，我收到了一个错误警告，如下所示
12:22:10.688错误com.lightbend.lagom.internal.broker.kafka.KafkaSubscriberActor sourceThread=search-impl-application-akka.actor.default-dispatcher-5，akkaT
浏览 0提问于2019-02-26得票数 0
回答已采纳
我的spark程序在小数据集(大约400 to )上工作得很好。然而，当我将它扩展到大型数据集时。我开始收到错误java.lang.OutOfMemoryError: Java heap space或java.lang.OutOfMemoryError: Requested array size exceeds VM limit
我的程序如下所示: sc.textFile -> map -> filter -> groupBy -> saveAsObjectFile
groupBy生成类型为RDD[ (int，IteratableA )]的结果
出现saveAsObje
浏览 0提问于2015-07-03得票数 0
3回答
我在我的一个项目中使用了scala、spray和akka。在Intellij中，它运行得很好。当我构建项目并试图在命令行中运行它时，我得到了以下错误。
Caused by: com.typesafe.config.ConfigException$Missing: No configuration setting
found for key 'akka'
at com.typesafe.config.impl.SimpleConfig.findKey(SimpleConfig.java:124)
at com.typesafe.config.im
浏览 1提问于2015-02-06得票数 31
回答已采纳
在使用ExecutorService时，单元测试如何为可运行任务派生新线程？
基本上，我的应用程序有一个静态线程池。
public static final ExecutorService executorService = Executors.newCachedThreadPool();
我希望将这个线程池用于我的单元测试，而不是模拟一个线程池或注入一个新的线程池，因为不同的线程池可以极大地改变我的应用程序的行为(固定线程池、缓存线程池和调度线程池等等)；我希望确保使用其运行时线程池测试应用程序的行为。
缓存线程池似乎最适合我。问题是，由于它是静态的，并且线程被缓存了60秒，所以只有第一个测
浏览 1提问于2009-11-04得票数 8
回答已采纳
我使用JDK1.7编写了java代码，如下所示，它执行并行线程库实现
Executors.newFixedThreadPool(currentRecordSize)；ExecutorService = executorService executorService.execute(可运行的)；
在日志中，我得到的线程名如下
池-2-线程-1池-2线程-2池-1-线程-1-线程-2
我想用字符串作为后缀
浏览 2提问于2020-09-11得票数 1
回答已采纳
嗨，我遵循这个，我复制粘贴了代码，只是我把端口从5150更改为2552，我面临着HelloLocal项目错误。
[warn] there were 1 deprecation warning(s); re-run with -deprecation for details
[warn] one warning found
[info] Running HelloLocal
[INFO] [11/04/2014 22:37:50.707] [run-main-0] [Remoting] Starting remoting
[INFO] [11/04/2014 22:37:51.857] [r
浏览 2提问于2014-11-04得票数 0
回答已采纳
背景
试图创建Apache独立集群。
环境: AWS
职务经理：1
任务管理器：2
配置：
FLINK_PLUGINS_DIR : /usr/local/flink-1.9.1/plugins
io.tmp.dirs : /tmp/flink
jobmanager.execution.failover-strategy : region
jobmanager.heap.size : 1024m
jobmanager.rpc.address
浏览 6提问于2020-02-05得票数 0
1回答
我正在试着测试演员，那就是使用。这种情况是，数据库处于脱机状态，它应该向另一个参与者发送一个通知，说明数据库不可用。
在创建子参与者期间，它将数据持久化到数据库，它引发以下错误：
akka.actor.ActorInitializationException: akka://StoreTestOffline/user/OfflineStoreActor/StoreChilid: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:202)
浏览 0提问于2019-08-30得票数 0
1回答
我正在努力理解Camel是否能够在同一过程中优先执行一条路由。
例如，我们有：
from("cxfrs://restendpoint").routeId("HIGH").log("high priority");
和
from("file://filestore").routeId("LOW").log("low priority");
我希望这条高路线不要因低路线而减速。因此，当低路由正在处理一个巨大的文件，而rest呼叫到达高路由时，我希望CPU给高路由更多的时间。
我正在考虑通过将路由划分到两
浏览 5提问于2014-10-20得票数 3
回答已采纳
1回答
我正在阅读的一本手册中包含了这个示例，其中正在创建一个ScheduledExecutorService。但是，该接口显示ScheduledExecutorService是一个接口，而不是一个类。那么它是如何被实例化的呢？
下面是示例代码：
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledFuture;
import static java.util.concurrent.TimeUni
浏览 1提问于2014-12-06得票数 1
我正在尝试使用sbt将Scala/Play应用程序部署到Heroku，但是我一直收到以下错误：
remote: Downloaded https://repo1.maven.org/maven2/org/typelevel/machinist_sjs0.6_2.12/0.6.2/machinist_sjs0.6_2.12-0.6.2.jar
remote: [info] Compiling 626 Scala sources to /tmp/scala_buildpack_build_dir/shared/.js/target/scala-2.12/classes...
remo
浏览 7提问于2022-08-11得票数 0
回答已采纳
我正在尝试使用Java11中的HttpClient从Java API调用Scala服务。 在Java API上，代码如下所示： var client = HttpClient.newHttpClient();
var packagesCountUrl = getPackagesCountUrl();
var sessionUserToken = sessionUserHelper.getSessionUserToken();
var request = HttpRequest.newBuilder(URI.create(packagesCountUrl))
.GET()
.
浏览 39提问于2021-10-06得票数 0
4回答
我编写了一个JUnit (4.10)单元测试，它对com.google.appengine.api.ThreadManager进行以下调用
ThreadManager.currentRequestThreadFactory();
当此测试运行时，将从此NullPointerException方法中抛出一个currentRequestThreadFactory：
Caused by: java.lang.NullPointerException
at com.google.appengine.api.ThreadManager.currentRequestThreadFactory(Th
浏览 9提问于2013-02-04得票数 5
回答已采纳
刚开始了解akka的能力。我试图运行一个程序，使用akka路由器，基于一致哈希。
我的环境是: Java 7更新67，akka-actor_2.10版本2.3.7。
我的配置文件：
MyRouter{
akka.actor.deployment{
/exampleRouter {
router = consistent-hashing-pool
nr-of-instances = 5
}
}
}
Main.java：
public class Main {
public static
浏览 2提问于2014-12-01得票数 4
回答已采纳
我正在尝试运行一个akka流应用程序，但我得到了一个例外：
No configuration setting found for key 'akka.stream'
相关的代码片段是：
ConfigFactory.load()
implicit val system = ActorSystem("svc")
implicit val mat = ActorMaterializer()
我尝试这两个命令行：
java -jar ./myService.jar -Dconfig.resource=/opt/myservice/conf/application.con
浏览 4提问于2017-09-12得票数 5
回答已采纳
1回答
我正在开发一个支持多租户的应用程序。租户的unqiue标识符存储在本地线程中，可以通过某些服务访问。为了允许并行处理，我创建了一个可调用的包装器，设置了线程局部变量：
class TenantAwareCallable<T> implements Callable<T> {
private final String tenantName;
private final Callable<T> delegate;
TenantAwareCallable(Callable<T> delegate, String tenantName) {
浏览 1提问于2016-05-25得票数 1
回答已采纳
我在我们的项目中使用akka集群。
下面是阿克卡的配置-
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = "DEBUG"
logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
actor {
provider = "akka.cluster.ClusterActorRefProvider"
creation-tim
浏览 1提问于2019-09-16得票数 0
这与Flink 1.13.2一起运行在Amazon的环境中。
此应用程序运行在Kafka主题上。当主题具有较小的流量时，这个应用程序运行良好，如果有更大的卷，我就会得到这个错误。如何进行故障排除、调优和修复？
我看到类似的问题，但这显然是Flink：的旧版本中的一个单独的问题。
例外跟踪是：
2021-12-30 18:16:45
java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acqui
浏览 46提问于2021-12-31得票数 6
回答已采纳
有人问过一个，但我觉得它没有多大帮助。我将MyRepository注射到MyActor中。在启动时，我会得到以下例外：
[error] - akka.actor.OneForOneStrategy - Unable to provision, see the following errors:
1) Error injecting constructor, java.lang.RuntimeException: There is no started application
at infrastructure.repository.MyRepository.<init>(My
浏览 3提问于2016-01-13得票数 0
回答已采纳
我正在使用spark graphx在jobserver (v0.6.2 spark 1.6.1)上开发一个SparkJob，当我试图在Spark JobServer上启动我的工作时，我遇到了以下异常：
{
"status": "JOB LOADING FAILED",
"result": {
"errorClass": "java.lang.NoClassDefFoundError",
"cause": "org.apache.spark.graphx.Ver
浏览 20提问于2017-01-18得票数 0
2回答
我有下面的：
class ServiceKernel extends Bootable {
val system = ActorSystem("service-kernel")
def startup = {
system.actorOf(Props(new Boot(false))) ! Start
}
def shutdown = {
system.shutdown()
}
}
因为内核扩展了Bootable而不是App，所以我如何访问在启动内核时使用的命令行参数？例如，如果我使用start namespace.ServiceKer
浏览 9提问于2013-04-09得票数 5
8回答
我正试图通过maven编译使用lombok的项目，我得到了以下问题：
[INFO] ------------------------------------------------------------------------
[INFO] Building akka-calculator-lib 1.0-SNAPSHOT
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] --- maven-clean-plugin:2.5:clean (default-
浏览 0提问于2016-02-14得票数 24
回答已采纳
我在Jenkins中构建了一个Java/Scala/Akka项目。对于它，我得到了这个错误：
java.lang.unsupportedclassversionerror akka/actor/Actor: unsupported major.minor version 52.0
我查找了错误，例如这里的，原因是使用了旧版本的Java而不是Java8。
所以我添加了Jenkins configure JAVA_HOME=/my/path/to/jdk/1.8/exec。
但是，错误仍然存在。那么，原因可能是什么呢？
浏览 0提问于2017-02-10得票数 1
1回答
为使用存储的参与者设置有界邮箱
、、、、
我有个演员靠藏东西。存储需要UnboundedDequeBasedMailbox。是否可以将Bounded邮箱存储在一起？
正如阿诺所指出的，我的设置是：
Actor with UnrestrictedStash with RequiresMessageQueue[BoundedDequeBasedMessageQueueSemantics]
和配置：
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = INFO
daemonic = on
actor {
浏览 0提问于2013-12-06得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
