清除持久Akka日志中的消息
是指通过对Akka框架中的持久化日志进行清理和归档，以删除或移除不再需要的消息记录。这个过程通常由开发工程师或系统管理员执行，旨在减少磁盘空间占用、提高系统性能，以及确保日志的可用性和可靠性。
持久化日志是Akka框架中的一个关键组件，用于保证消息的可靠传递和持久化存储。当Akka系统接收到消息时，它会将消息写入持久化日志中，并通过这个日志实现消息的可靠传递和恢复。然而，由于系统运行时间的增加和消息数量的累积，持久化日志可能会变得庞大，占用大量磁盘空间，并对系统性能产生负面影响。
清除持久Akka日志中的消息的步骤如下：
- 确定清除策略：根据业务需求和系统性能要求，确定清除持久化日志的时间间隔和条件。可以根据消息的时间戳、存储时长或其他特定标识来确定需要清除的消息。
- 执行日志清除操作：根据确定的策略，执行清除操作。可以通过编写脚本或使用Akka框架提供的相关工具来执行清除操作。具体的操作包括扫描持久化日志，识别符合清除条件的消息记录，并将其删除或移动到归档存储中。
- 监控和维护：定期监控和维护持久化日志，确保清除操作的正确执行和系统的正常运行。可以通过设置警报机制来提醒管理员日志清除操作的状态，以便及时解决可能出现的问题。
清除持久Akka日志中的消息的优势包括：
- 节省磁盘空间：通过清除不再需要的消息记录，可以释放磁盘空间，减少存储成本。
- 提高系统性能：较小的持久化日志大小可以提高读写性能，减少磁盘IO操作的延迟。
- 保证日志可用性和可靠性：定期清除消息记录可以减少日志的膨胀，确保日志的可用性和可靠性。
清除持久Akka日志中的消息的应用场景包括：
- 高负载系统：在高并发和大规模消息传递的系统中，持久化日志可能会迅速增长，清除消息记录可以保持系统的正常运行。
- 长期运行系统：持久化日志在长时间运行的系统中可能会累积大量的消息记录，清除操作可以防止日志膨胀并减少系统资源的占用。
腾讯云相关产品和产品介绍链接地址：
腾讯云提供了一系列与云计算相关的产品和服务，以下是一些相关产品和链接地址的推荐：
- 云服务器 CVM（https://cloud.tencent.com/product/cvm）：腾讯云的弹性云服务器，提供灵活的计算资源和完善的网络环境。
- 云数据库 MySQL（https://cloud.tencent.com/product/cdb_mysql）：腾讯云的云数据库服务，可提供高性能、可扩展的 MySQL 数据库。
- 云原生应用管理平台 TKE（https://cloud.tencent.com/product/tke）：腾讯云的容器服务平台，支持应用的部署、管理和自动伸缩。
- 云媒体处理 MDP（https://cloud.tencent.com/product/mdp）：腾讯云的多媒体处理服务，提供音视频转码、编辑和实时转播等功能。
- 人工智能平台 AI Lab（https://cloud.tencent.com/product/ai）：腾讯云的人工智能平台，提供丰富的机器学习和深度学习工具和服务。
- 物联网套件 IoT Explorer（https://cloud.tencent.com/product/ioe）：腾讯云的物联网平台，提供设备接入、数据管理和远程控制等功能。
- 云存储 COS（https://cloud.tencent.com/product/cos）：腾讯云的对象存储服务，提供安全可靠的大规模存储和数据处理能力。
- 区块链服务 BaaS（https://cloud.tencent.com/product/baas）：腾讯云的区块链服务，可用于构建和部署区块链应用和智能合约。
- 云游戏平台 TCPS（https://cloud.tencent.com/product/tcps）：腾讯云的云游戏解决方案，提供高品质的游戏流媒体传输和云端渲染能力。
请注意，以上产品和链接仅作为示例，更详细和全面的腾讯云产品信息请访问腾讯云官方网站。
相关·内容
2回答
Akka持久性查询通过提供一个通用的基于异步流的查询接口来补充持久性，各个日志插件可以实现这个接口，以便公开它们的查询功能。
这是akka文档中对“akka持久性查询”的描述。我想知道，它是否只用于查询，换句话说，用于阅读端？
浏览 0提问于2018-01-24得票数 4
我正在使用Apache ignite构建Akka持久性插件，当涉及到事件标记时，我有一个问题，如果我禁用java序列化(a java-序列化= no)，标记类型无法正确序列化，因为我使用Protobuf来处理事件，是否有方法为事件标记包装配置特定的序列化，或者它需要在插件本身中处理？我的插件的GitHub：
我得到的例外是：
2018-11- 21 :20:48错误a.p.i.journal.IgniteWriteJournal -试图在禁用akka.actor.allow-java-serialization时使用akka.actor.allow-java-serialization序列化消
浏览 1提问于2018-11-21得票数 0
回答已采纳
1回答
我正在测试一个坚持不懈的Akka演员。为此，我使用了内存中的持久性。测试开始了，我看到参与者正在恢复持久化消息。我尝试了以下方法： 我向参与者发送一条消息，使其触发deleteMessages(LastMessage)。我希望这条消息会导致日志被清除。执行元似乎不会处理此消息，因为要恢复的消息以前曾遇到异常。因此，它抛出异常，不继续处理消息。 如何清除持久化的日志？ 我还认为内存中的持久性不会从日志中恢复以前的测试消息
浏览 20提问于2019-03-07得票数 0
回答已采纳
1回答
我尝试将Akka Persistence test Kit与Akka HTTP Test Kit一起使用，但我的内存日志在每次测试之前都不会被清除。 非常简单的持久化行为-只需放入字符串并获取所有存储的字符串： object MyStore {
def apply(): Behavior[Command] = EventSourcedBehavior[Command, Event, State](
persistenceId = PersistenceId.ofUniqueId("myId"),
emptyState = State(),
comm
浏览 33提问于2021-07-23得票数 1
回答已采纳
我编写了一个实现设备管理的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日志表中显示它
浏览 7提问于2021-11-27得票数 0
我有一个用例，我需要通过websocket将实时事件传递给客户端。我想用Kafka来解决这个问题。使用来自kafka的msg并通过websockets流传输。但是，当客户端断开连接时，他需要从中断的位置获取数据。因此，此查找必须与新的消费者一起完成，并且在该客户端的先前消息已被传递之前，公共消费者不应传递消息。所以我觉得卡夫卡不是最适合这种情况。因为可以有许多客户端从各种偏移量请求。 我也想使用Akka Actors。为每个客户端和消息创建的执行元将放入相应的执行元队列。但是，如果服务器在客户端断开连接后重新启动，这将不是持久的。 最终，我们需要一个队列，在该队列中，每个客户端数据将分别存储
浏览 15提问于2021-10-07得票数 0
当我正在使用最新版本的Akka时，我注意到耐用的邮箱现在已经从Akka移除了。
我需要确保我的消息在崩溃后重新启动时被恢复。是否有另一种不使用持久邮箱或其他人自定义实现的工作方式。
我也尝试过Akka持久化，但是它会重播这些消息，而且我不想在崩溃时发送两次相同的消息，因为所有消息的执行成本都很高。
浏览 5提问于2015-09-18得票数 10
回答已采纳
我正在尝试用Apache Ignite替换OpenDaylight中的默认LevelDB，但在对akka.conf文件进行更改并部署我在此处找到的akka-persistence-ignite jar之后，我无法做到这一点。
我正在浏览ODL源代码，并将一些Log.debug/print语句放入datastore模块的一些类中。
下面显示的是我将打印语句放入驻留在org/opendaylight/controller/config/yang/config/actor_system_provider/impl.中的类ActorSystemProviderImpl的构造函数后得到的结果的一部分我通
浏览 0提问于2018-07-04得票数 0
我有一个akka持久化应用程序(基于EventSourcedBehavior的演员，akka 2.6.13)，并使用akka- persistence -jdbc 3.5.3作为日志/快照插件以及一个蟑螂集群。一切都很好，但是最近我看到了很多事件持久化失败，但是错误日志没有显示问题的任何潜在原因--跟踪中根本没有SQL级别的异常。与此同时，我们通常会看到由于演员被恢复而导致的错误，以及日志再次抛出JournalFailureExceptions，但是没有根本的原因。
如果我看不到任何潜在的原因(日志显示的唯一东西是async write timed out after 5.00 s (这个超时
浏览 8提问于2022-11-01得票数 0
回答已采纳
全
是否可以将akka.net参与者收件箱消息存储在数据库中？如果主机与akka.net系统崩溃会发生什么？
浏览 0提问于2015-12-04得票数 3
回答已采纳
例如:我有演员X和Y。
Actor X将消息持久化到日志中，然后将消息发送给Y。Y接收消息，并向X发送确认消息，让X知道已收到消息。当X收到这个确认消息时，我希望它a)从日志中删除该消息，这样该消息在恢复时就不会被重播。(这部分似乎不太可能)。b)将消息标记为已完成(已送达)。我认为这一部分将通过日志(使用日志恢复)，或通过添加“标签”到日志(通过事件适配器，但我不确定这是否可能更新，如果它是一个可行的选择)。
这让我意识到，akka persistence实际上是如何工作的。如果执行元持久化所有消息，然后执行元出现故障并需要恢复，那么它不会恢复所有这些消息吗？我知道这是为了维护状态(所以对于
浏览 0提问于2019-12-16得票数 0
1回答
在这一刻，我只在一个节点上运行了这个参与者会话管理实现：
1)我有一个处理所有会话的SessionManager参与者
2) SessionManagerActor接收两条消息：CreateSesion(id)和ValidateSesion(id)
3)当SessionManagerActor接收到CreateSesion(id)消息时，它使用actorFor方法创建一个SessionActor，如下所示：
context.actorOf(Props(new SesionActor(expirationTime)), id)
4)当SessionManagerActor接收到ValidateS
浏览 3提问于2014-12-09得票数 0
1回答
我正在尝试为java项目中的消息传递系统选择什么样的解决方案。到目前为止，我的发现集中在、redis消息队列和java中的akka持久性。
案件：
系统接收来自另一个组件的同步请求。在此之后，系统负责将请求传递给异步处理程序( worker )，并在工人完成工作时返回ack。我考虑实现消息队列，它将对应于每个请求(任务)，或者使用akka持久化。
假设：
工人完成的任务相当繁重。
必须处理工人的故障。
发现：
Akka持久性通过akka持久化提供可靠的消息传递和故障处理。就我个人而言，我不喜欢akka的java代码，很多实例，强制转换等等，但是大多数事情都在引擎盖下面。
Red
浏览 1提问于2015-05-05得票数 2
1回答
在Akka流应用程序中，如果应用程序崩溃/节点崩溃，我就有丢失正在运行的消息的风险。
我们可以做些什么来确保我们不会丢失消息，并且一旦应用程序回来就会播放它们。
在我的应用程序中，mapAsyns执行IO调用和一些次要的CPU绑定任务。
在纯Akka应用程序中，我将选择持久队列或事件源。但是，如果是Akka流，因为我无法访问底层队列，我如何确保流中没有消息丢失？
浏览 0提问于2016-12-12得票数 1
回答已采纳
1回答
我有一些代码从另一个持久化事件处理程序中调用persist，如下所示：
persist(someClassInstance){ message =>
confirmDelivery(message.id)
//some code
start()
}
//Somewhere else in the code
def start(): Unit = {
log.info("Starting")
persist(someClassInstance){ message =>
deliver(destination, createMessage)
浏览 1提问于2015-07-06得票数 2
回答已采纳
1回答
我有一些消息传递应用程序，需要至少一次保证。正如我从文档中理解的: akka-persistence -是关于参与者状态的。它使用一些逐层的意识形态来处理这种状态。
在文档中，我发现一些似乎提出了这个保证。但现在我对这个概念有了一些怀疑：
我的演员是一个简单的发送者，我所需要的就是交付保证。因此，我实际上并不关心参与者的状态和所有这些消耗宝贵内存的分层。大量的期刊会成为问题的原因吗？
演员：
public class SafeSenderActor extends AbstractPersistentActorWithAtLeastOnceDelivery {
private Str
浏览 6提问于2017-07-06得票数 1
1回答
我使用StreamRefs在集群中的参与者之间建立流连接。目前，在写入节点中，我手动将传入的消息保存到日志文件中，但我想知道是否可以将其替换为用于写入的持久性Sink，以及用于从Akka日志中读取参与者启动时读取的持久Source。我一直在考虑用持久性参与者的persist { evt => ... }替换日志文件接收器，但是由于它异步执行，我将失去背压。那么，是否有可能将带背压的流数据写入Akka持久化日志，并在参与者恢复时以流式方式读取这些数据呢？
目前的执行情况：
object Writer {
case class WriteSinkRequest(userId: Strin
浏览 0提问于2018-05-08得票数 3
回答已采纳
1回答
我正在考虑如何正确使用Akka.Net的利弊。
我添加了Akka标签，因为底层的操作系统可能并不重要。
假设我有一个包含100.000个相对简单类型的10.000个对象的列表。
每个对象有一个字符串，2个整数和10个双精度。
我估计每个对象有100个字节。
所以完整的列表应该是大约的。1à10MB。
我更喜欢在一个消息中发送列表，但我读到这是错误的，在akka中的消息通常应该很小。
在akka中正确的方法是什么？
我真的应该发送100.000条10.000个字节的消息吗？
我应该发送每个100个对象的消息吗？
浏览 2提问于2017-10-31得票数 0
我使用的是SecureSocial 2.0.7，并且我实现了一个UserServicePlugin，用户可以登录。我可以停止并重新启动服务器(或重新编译或其他任何东西)，用户将保持登录状态。
自升级到2.0.12以来，登录会话在服务器重新启动后不会持续。
我已经为UserServicePlugin中的每个方法添加了调试日志。用户在登录时正在使用saved。但是，当服务器重新启动时，当我尝试以先前登录的用户身份访问页面时，我只在日志中看到：
[info] play - database [default] connected at jdbc:postgresql://localhost/xxxx
浏览 0提问于2013-05-18得票数 6
回答已采纳
1回答
我们正在使用Akka.NET创建一个新的系统，并且有一个基本的集群设置，包括切分和持久化。
我们已经使用了正式的文档和一些Petabridge文章来使切分工作正常。但是，我们遇到了一个问题，即碎片超出了Server连接池允许的最大连接数。因此，我们得到了以下信息..。
2017-04-20 14:04:31.433 +01:00警告“超时过期。超时时间在从池获得连接之前过去了。这可能是因为所有池连接都在使用，并且达到了最大池大小。”
我们认为，当碎片更新分片日志时，就会发生这种情况。
为什么切分模块不能正确地管理它的SQL连接？这里有配置问题吗？
当这种错误发生时，是否有可能让它重试？
浏览 2提问于2017-04-20得票数 7
1回答
在我们的集群中，我们有以下四个节点组合：
2个种子节点(后端)
1名工人
一个关于IIS的webapi
集群被加入、启动并运行；当我向webapi发送一个帖子时，：
IIS加入群集
API接收一个帖子并发送消息
消息被处理了两三次！
只发生在IIS连接时发送的消息，下面的消息运行良好
以下是我的IIS配置：
<akka>
<hocon>
<![CDATA[
akka.loglevel = INFO
akka.log-config-on-start = off
浏览 11提问于2017-07-15得票数 0
回答已采纳
执行元是否可以将其传出消息存储在本地中，直到其远程接收器执行元准备好在自己的持久收件箱中接收这些消息？换句话说，我可以使用Akka来执行类似于电子邮件的风格的消息吗？
浏览 0提问于2013-03-06得票数 6
回答已采纳
根据的说法，外部触发视图更新应该是这样的：
view ! Update(await = true|false)
然而，发送和等待似乎不起作用：
view ! Update(await = true) // repeat x times does not help either
Thread.sleep(2000)
val getState = view ? GetState
视图状态未被更新。
询问也不起作用-- Update没有答案，Await超时：
val getUpdate = v ? Update(await = true)
val updated = Await.result(get
浏览 3提问于2016-08-03得票数 0
回答已采纳
2回答
我正在对一个AKKA的持久性演员做一个性能测试，我想知道写日记的影响。
简单的问题，但我在文档中没有发现任何东西：
如何从配置文件中禁用日记？我在寻找类似模拟或空日志插件的东西。
有什么想法吗？
浏览 0提问于2019-06-24得票数 1
回答已采纳
Hono和Ditto成功连接了。但是当我试图从Hono发送数据时，我将得到503 -服务不可用的消息。
但当我检查Ditto日志的时候。我得到以下AMQP的上限超过了。
connectivity_1 | 2019-10-14 16:34:38,294 INFO [] o.e.d.s.c.m.ConnectionActor akka://ditto-
cluster/system/sharding/connection/6/hono-sandbox-connection-123/pa - Starting ClientActor for
connection <hono-sand
浏览 7提问于2019-10-14得票数 0
我脑子里乱七八糟的避免了中毒邮箱
然后，新的参与者继续处理其邮箱，这意味着重新启动在参与者自身之外是不可见的，但有一个明显的例外，即在此期间发生故障的消息没有被重新处理。
我的情况是:参与者接收运行smth的“命令”。演员试图到达远程服务。服务不可用。抛出异常。我想让演员继续联系远程服务器。我不想让演员跳过导致异常的输入命令。简历会帮助我强迫演员继续前进吗？
override val supervisorStrategy: SupervisorStrategy =
OneForOneStrategy(maxNrOfRetries = -1, withinTimeRange =
浏览 4提问于2017-04-20得票数 1
回答已采纳
1回答
我有一个演员，它接收消息，并通过httpclient下载文件。
代码示例：
@Override
public void onReceive(Object message) throws Exception {
HttpClient client = new DefaultHttpClient();
...
httpGet.releaseConnection()
...
}
几天后问题就出现了。
从日志中，它显示了httpclient请求中的执行元块。
块是可以的，但是看起来httpclient死锁了，actor不会进一步处理任何消息。
这是怎么发生的？
日志：
浏览 2提问于2014-12-09得票数 1
1回答
假设我想用Akka创建一个聊天系统。 在系统中，我可能会有一个UserActor来管理某个用户的所有消息。 如果我现在将其部署在Akka集群中，我如何确保actorOf为某个用户获得正确UserActor的(远程)引用？因此在不同的节点上不存在重复项...
浏览 9提问于2019-03-02得票数 2
当尝试对Akka.NET中的群集设置进行故障排除时，群集心跳消息将填充日志。
0011akka://mysystem/system/cluster/core/daemon#1680718572]初始化DEBUGThread接收Akka.Cluster.GossipStatus
是否有办法像那样有选择地防止此日志事件？
浏览 2提问于2016-08-09得票数 4
我目前喜欢在akka中使用redis，因为我可以通过查询redis来监视处理了哪些消息。Redis也存留到磁盘上。
阿克卡坚持与仅仅使用红宝石相比有何不同？
浏览 1提问于2015-11-09得票数 3
回答已采纳
Akka 2.1文档建议使用来保证消息递送，即一条消息只传递一次到接收方队列。为了确保消息在JVM崩溃的情况下不会丢失，我相信消息存储在持久队列中。
基本思想是，为了将消息M从参与者A发送到B，它将M发送给两个代理参与者P和E，其中P在A一侧，E在B一侧。请参阅
参与者P和E是否需要自己的持久队列？从A发送到B的消息在被持久化到B之前将被持久化在P的队列和E的队列中？
浏览 2提问于2013-01-31得票数 3
1回答
我在用Scala编写的应用程序中使用Akka持久性，并将LevelDB作为存储插件。在查询端，当前的实现使用PersistentView，它只知道参与者的标识符就可以从PersistentActor的日志中轮询消息。
现在，我已经了解到PersistentView是不受欢迎的，我们鼓励您使用持久查询。但是，我还没有找到任何关于如何通过使用PersistentView来调整代码以支持首选持久性查询实现的详细说明。
任何帮助都将不胜感激！
浏览 0提问于2017-09-15得票数 0
回答已采纳
1回答
以下资源指出，Lagom在生产中使用异步记录器。
但是，lagom也使用akka，并且akka建议您使用akka-way登录您的actors ->
akka日志记录方式(通过LoggingAdapter)基本上将所有日志消息转发给日志记录参与者。这样做是为了最小化日志记录对参与者的影响-->日志记录是由另一个参与者异步完成的。
这些组合导致了双重异步日志记录，我说的对吗？这是一个问题吗？slf4j的异步日志记录比akka日志记录方式更可取，还是相反？赞成的论点，反对的论点？
浏览 6提问于2018-01-10得票数 3
回答已采纳
2回答
我试图使用AKKA将20k记录插入到MySQL数据库中。我发现已插入19 994项记录，未插入其余6项记录。我读到AKKA并不保证消息传递。有什么办法解决这个问题吗？
浏览 4提问于2014-07-21得票数 6
在将使用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
回答已采纳
1回答
我对Akka非常陌生，对其各个模块的Maven坐标感到非常困惑。
，我想在被认为是最新的稳定的版本的Akka。，我不需要流血的边缘功能。我是全新的。
在我的build.gradle文件中我添加了：
dependencies {
compile 'org.codehaus.groovy:groovy-all:2.4.3'
compile 'com.typesafe.akka:akka-actor_2.10:2.3.12'
}
这就引入了各种二进制文件/依赖项，并允许我做一些简单的事情，比如创建UntypedActor子类、向它们传递消息等等。
我现
浏览 0提问于2015-08-24得票数 0
网络用户，
现在，我正在开发一个应用程序，它使用从ReceiveActor继承的Actors和从ReceivePersistentActor继承的Actors。
我正在使用Akka.Net，Akka.Persistence，Akka.TestKit版本1.3.1和Akka.Persistence.TestKit版本1.2.3.43-beta。
现在，我用ReceiveActor为NUnit编写了一个测试类，Akka.TestKit.NUnit运行得很好。但是我们也使用ReceivePersistentActors，而且在Akka.TestKit中显然没有对它们的支持。
有一个Akka.Pers
浏览 6提问于2017-09-22得票数 0
现在，我被要求在akka的演员中添加日志功能。
当收到消息时，在处理消息之前，应将此消息写入日志。在发送消息之前，应该先记录该消息。
我认为我应该重写Actor中的receive和send函数。假设我创建了一个特性actorlog，它扩展了Actor。类myActor扩展了actorlog。但是在myActor中，我需要重写receive函数(这里似乎会引起问题)。所以我搞不懂我该怎么做。
PS。我知道akka提供伐木。但是现在我需要自己来实现这个功能。
浏览 3提问于2013-11-07得票数 9
回答已采纳
我在Petabridge上读过，我觉得代码的这一部分有点让人困惑：
Recover<string>(str => _msgs.Add(str)); // from the journal
Recover<SnapshotOffer>(offer => {
var messages = offer.Snapshot as List<string>;
if(messages != null) // null check
_msgs = _msgs.Concat(messages)
浏览 3提问于2016-08-09得票数 3
回答已采纳
1回答
在每次重新启动服务3po3 shardinside AWS集群后，我们将得到一个异常，我们将使用NugetAkka1.4.16作为我们的.net服务，使用attaching，附加代码供您参考，如果我们遗漏了什么，请告诉我们。
当重播事件类型Akka时，ReceiveRecover中的异常。用于Cluster.Sharding.PersistentShardCoordinator+ShardHomeAllocated的序列号为26的persistenceId
原因: Shard 0已经在Akka.Cluster.Sharding.PersistentShardCoordinator.State.
浏览 7提问于2022-01-10得票数 0
我有一个Akka Persistence journal和几个数据库，为保存在日志中的数据提供不同的视图。大多数视图都包含多个实体( ->，多个持久化参与者)。
我知道我可以为一个参与者触发恢复，这将重建仅由该实体组成的视图，但如果我想重建所有视图，我该如何进行呢？
我可以启动所有现有的Actor (我需要知道所有的Actor)来触发整个系统的恢复，但是有没有一种方法可以给Actor系统一个日志，并基本上告诉它重播整个事件？
浏览 0提问于2016-04-24得票数 1
1回答
我有一个拉格姆微服务，运行在库伯内特斯与3个吊舱。它无法在启动时形成集群，并继续显示以下消息：
2019-07-12T19:29:27.310Z警告akka.cluster.sharding.ShardRegion -试图向[ActorSelectionAnchor(akka.tcp://microservice@10.233.101.14:10001/)，Path(/system/sharding/MicroserviceEventProcessorCoordinator/singleton/coordinator)]，的协调者注册，但没有确认。总共有1580条缓冲消息。[可以联系到协调员
浏览 0提问于2019-08-04得票数 0
回答已采纳
2回答
我想创建一个拥有1000名演员的Akka集群。每个演员都会收到一条消息，做一些计算，并将结果写成一个专门的Kafka主题。
它应该部署在集群中，例如Kubernetes。
我的理解是--如果不管是什么原因终止了参与者(JVM崩溃、重新部署或其他任何事情)，那么它的邮箱的内容以及当前正在处理的消息都会丢失！
在我的情况下，这是完全不能接受的，因此我希望实现一种具有持久性邮箱的方法。注意，参与者本身是无状态的，他们不需要重播消息或重建状态。如果参与者被终止，我所需要的就是不要丢失消息。
问题是：推荐的方法是什么？、和是他们推荐的实现持久参与者的方法。但就像我说的，我不需要坚持和恢复演员的任何状态。
浏览 0提问于2019-07-15得票数 2
回答已采纳
1回答
我正在尝试为我的akka演员系统设置一些基本的日志记录，但到目前为止，我只获取标准日志，而没有一个添加的日志或输出文件。我与一起跟踪并设置了以下内容：
我将这些依赖项添加到build.sbt文件中。
"com.typesafe.akka“%% "akka-slf4j”% "2.3.14“"ch.qos.logback”%“logback-经典”% "1.0.9“
我将其添加到application.conf fileakka {logger= "akka.event.slf4j.Slf4jLogger“日志级别=”调试“}中。
log
浏览 1提问于2016-01-19得票数 8
回答已采纳
1回答
我计划测试将Yugobyte DB ()用于Akka持久层的可行性。
来自：
为了帮助开发人员构建正确和高质量的存储插件，我们提供了一个技术兼容性工具包(简称 )。
TCK可以从Java和Scala项目中使用。对于Java，您需要包含akka-persistence-tck依赖项：
Akka文档的最新版本：没有提到Technology Compatibility Kit。Technology Compatibility Kit不再受支持吗？我的目标是使用Akka版本2.6.15
在中，最新的tck版本的日期为Jun, 2021，因此仍然支持tck。
如果Akka持久化支持Yugo字节，那么是
浏览 6提问于2021-07-13得票数 1
回答已采纳
我希望让运行在不同进程(或节点)上的参与者向其他运行在不同进程(或节点)之外的参与者发送消息，同时保持容错和负载平衡。我目前正在尝试使用Akka.群集的切分功能来完成这一任务。
但是，我不知道怎么做到这一点.
我有以下反映我的种子节点的代码：
let configurePort port =
let config = Configuration.parse ("""
akka {
actor {
provider = "Akka.Cluster.ClusterActorRefProvid
浏览 2提问于2017-03-15得票数 2
1回答
我要在日志里找个死信演员。伐木是水平信息。但我不知道sActor的哪种方法会给出一纸空文。下面是日志消息
akka.actor.DeadLetterActorRef - Message [scala.util.Right] from Actor[akka://marksun-app/user/marksun-api/sActor/$a#-396914220] to Actor[akka://marksun-app/deadLetters] was not delivered. [2] dead letters encountered. This logging can be turned o
浏览 4提问于2021-09-18得票数 2
我为编写了一个自定义记录器，将日志消息传递给远程系统。我有第二个记录器，它使用和作为后端打印到控制台和日志文件。
奇怪的是，我注意到一些消息没有被我的自定义记录器接收，但是slf4j记录器接收得很好。
例如，作为监督策略的一部分，由失败的子参与者生成的错误消息被记录：
[DEBUG][akka://Test/system/remote-deployment-watcher]: started (akka.remote.RemoteDeploymentWatcher@b342d63)
[DEBUG][akka://Test/system]: now supervising Actor[akka:
浏览 0提问于2014-09-03得票数 3
回答已采纳
您认为在事务性服务bean面前使用akka演员是个好主意吗？
参与者被客户端应用程序使用的外观唤醒，参与者使用消息来处理正确的服务调用。
这是一个很好的练习吗？
本文(http://honeysoft.wordpress.com/2012/08/05/akka-actor-dependency-injection-using-spring/)讨论的是与akka演员一起使用spring。但我看不到在(单例)春豆前使用演员的好处。
浏览 0提问于2013-02-11得票数 4
回答已采纳
如果您熟悉Trello，那么将整个Trello板存储为演员(具有akka持久性)是否是一个很好的用例？
特雷洛董事会由以下人员组成：
列表中的liststasks 每个任务都可以有注释和其他属性
在确定akka persistance是否是给定问题集的良好用例时，一般的最佳实践或考虑因素是什么？
浏览 3提问于2020-09-29得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
