akka持久化回调参数是否与持久化事件的意图相同
，取决于具体的应用场景和设计需求。在Akka持久化中，回调参数和持久化事件的意图可以是相同的，也可以是不同的。
Akka是一个基于Actor模型的并发编程框架，它提供了持久化机制来保证Actor系统的可靠性和数据一致性。在Akka持久化中，持久化事件是指将Actor的状态变化记录下来，以便在系统故障或重启后能够恢复到之前的状态。而回调参数是指在持久化事件成功或失败后，系统可以执行的回调函数。
在某些情况下，回调参数可以与持久化事件的意图相同。例如，当我们需要在持久化事件成功后执行某些操作时，可以将这些操作作为回调参数传递给持久化框架。这样，当持久化事件成功后，系统就可以根据回调参数执行相应的操作，以实现业务逻辑的完整性。
然而，在其他情况下，回调参数可能与持久化事件的意图不同。例如，当我们需要在持久化事件失败后执行某些补偿操作时，可以将这些补偿操作作为回调参数传递给持久化框架。这样，当持久化事件失败后，系统就可以根据回调参数执行相应的补偿操作，以保证数据的一致性和完整性。
总之，akka持久化回调参数是否与持久化事件的意图相同，取决于具体的应用场景和设计需求。在实际应用中，我们需要根据业务需求来确定回调参数的内容，并确保回调参数的执行与持久化事件的意图相符。腾讯云提供了云原生应用开发平台Tencent Cloud Native，可以帮助开发者构建和管理基于云原生架构的应用，更多详情请参考：https://cloud.tencent.com/product/tke
相关·内容
由于ActorPublisher不支持GraphStage，看来我不得不放弃我的参与者管理的状态，转而使用GraphStateLogic。但是，对于参与者管理的状态，我可以通过向我的参与者发送任意消息来改变状态，而对于GraphStateLogic，我不知道如何做到这一点。
因此，以前，如果我想创建一个源代码来公开通过HTTP /response提供的数据，那么通过ActorPublisher请求通过Request消息传递给我的参与者，我可以通过在后台启动一个HTTP请求并向我的参与者发送响应，从而将其内容发送到下游。
如果我不能向GraphStageLogic实例发送任意消息，那么如何使用它
浏览 1提问于2017-08-27得票数 0
2回答
Akka持久性查询通过提供一个通用的基于异步流的查询接口来补充持久性，各个日志插件可以实现这个接口，以便公开它们的查询功能。
这是akka文档中对“akka持久性查询”的描述。我想知道，它是否只用于查询，换句话说，用于阅读端？
浏览 0提问于2018-01-24得票数 4
我目前喜欢在akka中使用redis，因为我可以通过查询redis来监视处理了哪些消息。Redis也存留到磁盘上。
阿克卡坚持与仅仅使用红宝石相比有何不同？
浏览 1提问于2015-11-09得票数 3
回答已采纳
2回答
我的项目使用play框架2.3，需要每10分钟计算一次用户在市场上列出的商品的实时价格(商品的价格根据销售数量而变化，类似于股票)。我用演员做到了这一点。然而，我有一个问题
如何在项目开始时启动作业，并且还可以在代码中停止作业？
Akka.system.scheduler.schedule(0.microseconds, 10.minutes, tickActor, "job")
package job.scheduledJobs
import akka.actor.Actor
class JobModule extends Actor {
override d
浏览 0提问于2017-05-03得票数 0
如果您熟悉Trello，那么将整个Trello板存储为演员(具有akka持久性)是否是一个很好的用例？
特雷洛董事会由以下人员组成：
列表中的liststasks 每个任务都可以有注释和其他属性
在确定akka persistance是否是给定问题集的良好用例时，一般的最佳实践或考虑因素是什么？
浏览 3提问于2020-09-29得票数 0
当我正在使用最新版本的Akka时，我注意到耐用的邮箱现在已经从Akka移除了。
我需要确保我的消息在崩溃后重新启动时被恢复。是否有另一种不使用持久邮箱或其他人自定义实现的工作方式。
我也尝试过Akka持久化，但是它会重播这些消息，而且我不想在崩溃时发送两次相同的消息，因为所有消息的执行成本都很高。
浏览 5提问于2015-09-18得票数 10
回答已采纳
我编写了一个实现设备管理的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
我使用sqlserver作为后端，在akka.net中使用持久性角色。
有没有可能用sqlserver持久化配置Akka.net，使其持久化使用文本有效负载，而不是现在的varbinary？
浏览 4提问于2016-07-13得票数 2
网络用户，
现在，我正在开发一个应用程序，它使用从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
的ZK文档有两个EventListeners状态：
订阅此事件队列的同步或异步侦听器。同步侦听器的工作方式与普通事件侦听器相同，而异步侦听器则在工作线程中异步执行。
但是，他们给出的代码示例似乎根本不支持同步侦听器：
eq.subscribe(
new EventListener() {
public void onEvent(Event evt) {
// asynchronous
}
},
new EventListener() {
public void onEvent(Event e
浏览 4提问于2015-08-18得票数 0
我一直在阅读和研究Akka.NET，我觉得它非常适合我将要开发的一个非常基本的在线多人游戏。
我对Akka.NET中的Persistence模块特别感兴趣，我想要做的是在任何时间点对我的整个Actor系统进行快照，并在我选择的时间恢复快照(本质上是游戏状态的保存/加载机制)。Actor持久性的保存和加载似乎是自动发生的，而我希望手动快照系统的当前状态，并在我选择的时间进行恢复。
使用Akka.NET持久化可以实现这种情况吗？
浏览 9提问于2017-10-25得票数 0
1回答
我们正在使用Akka.NET创建一个新的系统，并且有一个基本的集群设置，包括切分和持久化。
我们已经使用了正式的文档和一些Petabridge文章来使切分工作正常。但是，我们遇到了一个问题，即碎片超出了Server连接池允许的最大连接数。因此，我们得到了以下信息..。
2017-04-20 14:04:31.433 +01:00警告“超时过期。超时时间在从池获得连接之前过去了。这可能是因为所有池连接都在使用，并且达到了最大池大小。”
我们认为，当碎片更新分片日志时，就会发生这种情况。
为什么切分模块不能正确地管理它的SQL连接？这里有配置问题吗？
当这种错误发生时，是否有可能让它重试？
浏览 2提问于2017-04-20得票数 7
清楚地表明，不能有多个具有相同PersistenceId的参与者：
PersistenceId字段很重要-它唯一地标识了一个使用Akka.Persistence持久化其状态的实体，并且对于单个PersistenceId，在任何给定时间都应该有一个持久性参与者。
..。因此，想象一下，如果有两个角色具有相同的PersistenceId，但不同的序列号写入同一个商店。这将是一场混乱，并且不可避免地会出错--所以这就是为什么在你的PersistenceId中，每个ActorSystem必须是全局唯一的(至少对于所有写信给该商店的参与者来说都是如此)。
我可以想到一个场景，您将有两个独立的参与
浏览 3提问于2016-08-29得票数 0
回答已采纳
1回答
在我的应用程序中，我有一个服务，可以发送电子邮件来响应各种用户事件。有一个正在进行的问题，其中电子邮件发送将由于某种原因而失败，因此我们丢弃消息，不尝试重试它。此故障模型中包括正在关闭的JVM。规则是不应该发生重复的电子邮件，不发送电子邮件是非常不受欢迎的，但可以接受。基本上，我们应该能够重试，而不用担心重复。
Akko-Persistence将出现在表面上来解决上述问题，然而，它似乎是为了存储所有消息，然后重放它们的子集来恢复。
所需的行为是在参与者恢复时重播任何未处理的消息(包括发生故障时正在处理的消息)。此外，如果系统被退回，则会发送所有挂起的电子邮件。
有没有我遗漏的Akka文档中的某
浏览 19提问于2016-07-27得票数 2
回答已采纳
2回答
下面两个调用之间有区别吗？
$.ajax({
type: 'POST',
url: someApiUrl,
contentType: 'application/json; charset=utf-8',
data: someData
}).success(function (payload, status, xhr) {
//success code
});
$.ajax({
type: 'POST',
浏览 5提问于2017-10-03得票数 0
回答已采纳
在当前v.1.0版本的Akka.NET中，不可能将有限状态机方法与F#应用编程接口中的持久性结合起来。我想知道是否有可能使用像这样的函数式方法，同时挂钩到的prestart方法。如果可以在prestart方法执行期间从持久存储中读取，那么这将是实现某种“自定义”持久性的一种方式。
关于如何使用自定义持久解决方案的任何其他建议都非常受欢迎。
浏览 0提问于2015-04-12得票数 0
1回答
我使用以下代码：
trait ScanList[E] {
sealed trait Event
case class Added(item: E) extends Event
case class Requeued(item: E) extends Event
case class Processed(item: E, at: DateTime) extends Event
case class Dequeued(item: E) extends Event
// some unimplemented methods here..
}
object Character
浏览 1提问于2014-07-31得票数 1
回答已采纳
我正在尝试激活一个函数调用并传递一个文件选择事件。以下非JQuery运行正常：
class AddBTS
constructor: () ->
document.getElementById('upload_JSON').addEventListener('change', @select_json_changehandler, false)
select_json_changehandler: (evt) =>
console.log 'evt = ', evt
我尝试了以下方法，它执行函数调用，但ev
浏览 0提问于2013-02-27得票数 1
回答已采纳
我正在构建一个简单的REST，用于生成一些必须创建并定期从API中发送的对象。对象的性质并不重要，支持REST接口的框架也不重要(喷雾、播放框架等等)。我的问题是，使用Akka的这个系统有什么好的可伸缩的演员设计呢？假设服务崩溃，或者是迁移了，或者任何导致停止它的原因。为了恢复关于必须发送哪些对象以及何时发送的任务的描述，akka持久化是一个很好的方法吗？还是在传统数据库中保留这样的东西更好呢？
谢谢。
注意:我也想知道，假设有一个演员自己不是有状态的，但创造了很多的儿童演员，如果是一个好的做法，使用阿克卡-坚持，以重播信息，使这个演员再次创造他的孩子(孩子也是无状态的)。
浏览 5提问于2014-12-15得票数 0
回答已采纳
这里是Akka 。我有两个演员，Parent和Child，前者是后者的父亲。如果Child抛出一个特定的异常(例如，一个UnrulyTeenagerExcepton)，那么我要寻找的行为如下：
Parent保存对Child在抛出异常时正在处理的消息的引用；然后
重新启动Child，并将持久化消息“回放”到Child；但是
如果这个保存->重启->重播周期发生三次，而Child抛出UnrulyTeenagerException三次，那么我们就SupervisorStrategy.escalate()
到目前为止，我最大的努力是：
// Groovy pseudo-
浏览 3提问于2015-08-25得票数 0
回答已采纳
你能帮忙吗？当保存一两次时，效果很好。三个或更多，我得到了这个：
[INFO][11/28/2017 2:57:27 PM][Thread 0005][[akka://ECHO3DEV/user/api-master/PortfolioCoordinator/TK#425630680]] Portfolio Actor: TK completely recovered. Current Positions: ......
11/28/2017 9:57:27 AM portfolio- Actor started...
[ERROR][11/28/2017 2:57:27 PM][Th
浏览 3提问于2017-11-28得票数 1
回答已采纳
全
是否可以将akka.net参与者收件箱消息存储在数据库中？如果主机与akka.net系统崩溃会发生什么？
浏览 0提问于2015-12-04得票数 3
回答已采纳
我读过关于生命周期事件的文档，以及关于在生命周期事件期间更改或持久化新实体的几个问题。打电话给EnitityManager::flush()似乎是个问题。
好的，但是，有一个代码示例，其中的字段在postPersist中被更改，但是没有被调用。
我检查了它，建议的更改是而不是写入DB的。只有被持久化的对象才会收到更改。
<?php
/** @Entity @HasLifecycleCallbacks */
class User
{
// ...
/**
* @Column(type="string", length=255)
*/
浏览 1提问于2018-09-22得票数 5
回答已采纳
2回答
在实现事件源的不同选择中，Kafka似乎是“外部”的一个非常合理的选择：
它有一个伟大的生态系统
它有很好的记录。
它自然支持流和侦听器。
然而，从Akka持久化的角度来看，Kafka杂志似乎只能通过社区提供的一揽子方案来支持，而在过去的两年中，该方案一直没有被修改过。卡夫卡不是一个好的选择，有没有更好的选择，如果它是最好的选择，人们如何使用它与阿克卡坚持？
浏览 4提问于2017-10-17得票数 7
当与事件源相结合时，是否有一个很好的方法来进行CQRS？
我想到的一种方法是在命令处理程序(持久化Actor的命令处理程序)中这样做，一旦命令变成事件并持久化到事件日志(这些事件代表写模型)，我将使用事件总线将事件发送给感兴趣的订阅查询参与者，以便他们能够更新其查询模型。
我的另一种想法(只要日志支持它)是使用持久化查询(通过Akka )，比如allPersistenceIds或currentPersistenceIds，而查询端(可能的查询参与者)可以定期执行这一操作。
我在正确的道路上吗？有更好的方法吗？
浏览 4提问于2016-04-27得票数 4
回答已采纳
2回答
我正在编写一个应用程序，通过WiFi和MQTT协议控制一群机器人。我已经做了一些测试来测量它对我的应用来说是否足够快。我希望有一个控制回路(一条信息从个人电脑发送到机器人和返回)，平均不超过25-30毫秒。
我使用Paho Java客户端编写了一个在两台机器上运行的应用程序。当在topic1上收到消息时，它会发布到topic2。Topic2由第二台机器订阅，然后发布到topic1。
topic1 topic1
M1---------> broker ---------> M2
topic2 topic2
M1 <-
浏览 1提问于2015-07-14得票数 2
2回答
我使用来自战车解决方案的phonegap-nfc插件。在应用程序运行时读取NFC标记是没有问题的。我注册了该应用程序的意图，所以它开始时，应用程序是在背景和标签被读取。但是NdefListener没有被解雇。有人知道如何在应用程序启动时获得标签信息吗？
浏览 9提问于2014-04-14得票数 0
回答已采纳
1回答
我有以下单元测试：
it should "return xml" in new TestScope {
val testProbe: TestProbe = TestProbe()
val someActor = system.actorOf(Props[SomeActor])
testProbe.send(someActor, MakeXmlApiCall())
testProbe.expectMsgPF() {
case Success(message) => {
assert(message == &
浏览 2提问于2016-12-15得票数 1
回答已采纳
我从最近几天开始学习。我已经建立了一个小应用程序。我试图将数据发送回API，并更新了对新闻对象的喜欢。
以下是“新闻项目”组件的代码。
import React, { Component} from 'react';
import { connect } from 'react-redux'
import { bindActionCreators } from 'redux';
import { updateArticleLikes } from '../../actions/updateNews';
class NewsIte
浏览 2提问于2017-09-07得票数 1
回答已采纳
1回答
我使用Akka集群(版本2.4.10)，很少有节点指定为“前端”角色，很少有其他节点指定为“工作者”。工人们在远程机器上工作。输入的工作由前端参与者通过循环路由分配给工作人员。问题是把“工人”的回应发回给前端演员。我看到工人们正在完成这项工作。但是工人们发送到前端的信息并没有到达，最终以死信的形式结束。我在日志中看到了下面的错误。
[Cluster-akka.actor.default-dispatcher-21] [akka://Cluster/deadLetters] Message [scala.collection.immutable.$colon$colon] from Actor[
浏览 0提问于2016-10-06得票数 0
回答已采纳
1回答
阿卡持久战滥用？
、、
使用akka持久性作为本地数据库是个好主意吗？如果服务器无法访问，我需要在本地存储数据，而我的应用程序构建在akka之上，因此使用akka-persistence听起来是最简单的方法。
数据中填充的速率约为每10秒一个记录的avg。不过，鉴于akka-持久性是为一些不同的东西而设计的，这听起来像是一种滥用。有什么问题我应该知道吗？
浏览 2提问于2016-01-26得票数 2
回答已采纳
1回答
假设您使用的是第三方Java，该API通过回调异步地流数据。--如果我们在Scala中使用这样的API，我们有什么(基本的)设计选项？，我是这种语言的新手。以下是我的想法：
从野外提供一个Scala函数作为回调(例如，创建一些包含回调函数的object )
我们可以选择让这个对象向Akka演员发送消息(传递数据)。这样，我们就可以用输入数据为参与者系统提供燃料。
数据打包--一个案例类..。但是请记住，数据来自Java函数。我们唯一的选择是Scala回调在打包一个case类实例之前使用多个参数(字符串、ints、doubles)接收原始数据吗？
浏览 3提问于2017-02-03得票数 2
回答已采纳
像AKKA.net这样的参与者模型给表带来了许多好处，比如可伸缩性、响应性、内存缓存等.当我试图将AKKA与进行比较时，除了内存中缓存的好处之外，我在Azure中也看到了几乎相同的主要好处。
在生产环境中，AKKA需要具有更多内存、处理能力的多个VM来处理内存中的数百万参与者。对于Azure服务总线队列，不需要强大的主机。即使我们使用演员模型，也不需要进行监督，也不需要创建演员系统来管理数百万演员。使用Azure服务总线可自动实现可伸缩性。
从长远来看，我认为Azure服务巴士排队是符合成本效益的。随着负载的增加，不需要IT管理来管理它。也不需要有多核的强大系统。
AKKA的演员模型是否适合于
浏览 5提问于2015-05-20得票数 5
回答已采纳
1回答
在阅读这篇文章之前，请注意，我想知道是否有人想出了更好的方法来组织oauth登录和api授权。我的oauths都工作得很好，但在我添加更多API之前，我想知道是否有人可以帮助我组织起来。我知道这不是一个简单的问题，因为你没有看我的目录和代码，但我希望有人遇到了这个组织问题。因为回调urls需要在根目录中，所以它会变得混乱。
我的网站目前有以下oauth登录: T，Y!，G，FB -所有工作正常。我的根目录中有一堆回调文件，这些文件需要在根目录中才能正常工作，比如: login-twitter.php、login-fb.php等。这些文件也有相关的文件，比如kill-session.php和co
浏览 1提问于2011-11-11得票数 0
回答已采纳
1回答
我正在用Akka.Net实现CQRS/ES解决方案，用Server实现Akka.Net.Persistence。到目前为止，使用默认的sql-server插件似乎一切都很好。
最后要验证的是能够从特定的AR重新加载/重播事件，例如重建读取模型或为读取模型填充新实现的投影。我这样做的方法是读取DB中的事件，并将它们放在事件总线上，或者直接放到“投影参与者”的邮箱中。
我似乎找不到任何手动重新加载事件的例子，除了自己查询Journal表(执行sql查询)和使用内置序列化程序之外，我基本上还坚持这样做。
有没有人想或多或少做同样的事？
浏览 1提问于2016-02-16得票数 0
回答已采纳
我是斯威夫特大学的新手，自从我想学习以来，我一直在研究如何回答这个问题，但我完全不知所措。
我有一个从服务器请求数据的函数，在接收到数据之后，执行一个完成处理程序来解析数据。在前面提到的完成处理程序中，调用另一个函数，它将传递完成处理程序本身。
由于某种原因，函数中的函数调用将被跳过，并在第一个完成处理程序完全执行之后完成。对于下面的代码来说，这可能更有意义：
func loadSites(forceDownload: Bool){
self.inspectionSites = MyData.getLocallyStoredInspectionSites()
if self.i
浏览 1提问于2016-03-23得票数 0
回答已采纳
1回答
我不明白为什么不需要将参数name传递给addEventListener中的匿名函数。为什么你需要通过e，而不是name。我指的是行尾的第6行，function(e)
let btn = document.querySelector(".test-btn");
function firstFunction(e,name){
e.preventDefault();
btn.innerHTML = name;
}
btn.addEventListener("click",function(e){
firstFunction(e,
浏览 0提问于2020-12-28得票数 2
回答已采纳
我使用Node.js已经有一段时间了，我认为自己对Java很在行。但我刚刚发现了Akka，并立即对它的角色模式感兴趣(据我所知)。
现在，假设我的JavaScript技能与Scala/Java技能相当，我想把重点放在这两个系统的实用性上。尤其是在web服务方面。
据我所知，Node在处理许多并发操作方面表现出色。我设想一个用于资产管理系统的好的Node web服务将擅长处理同时提交更改的多个用户(在大型、高流量的应用程序中)。
但在阅读了Akka的演员之后，它似乎会在同样的事情上表现出色。我喜欢将工作减少到一口大小的想法。另外，几年前我涉足了Erlang，并爱上了它使用的消息传递系统。
我在许
浏览 45提问于2012-12-13得票数 99
回答已采纳
2回答
FB.Event.subscribe('auth.authResponseChange', function(response)
{
if (response.status === 'connected')
{
document.getElementById("message").innerHTML += "<br>Connected to Facebook";
//SUCCESS
}
else if (response.status === 'not_authorized&#
浏览 2提问于2013-12-29得票数 0
回答已采纳
1回答
嗨，我和Kafka和Akka Streams一起工作。在Kafka中，对于主题MyTestTopic，我有3个分区，数据在高度并发的情况下被推入主题，大致上是1000 QPS，它只会比这个更高。
下面是我为Akka Stream Kafka使用者编写的代码：
final ConsumerSettings<String, byte[]> consumerSettings =
ConsumerSettings.create(kafkaConfig, new StringDeserializer(), new ByteArrayDeserializer())
浏览 5提问于2019-12-09得票数 0
在play 2.1中，我可以使用Akka异步执行一段代码，如下所示：
Promise<Integer> promiseOfInt = Akka.future(
new Callable<Integer>() {
public Integer call() {
return intensiveComputation();
}
}
);
如何获取此操作的状态？例如:已启动、已执行、已完成等？
浏览 4提问于2013-03-25得票数 1
回答已采纳
有许多bootstrap选项卡，每个选项卡都有包含大量"td“元素的示例表。我们在活动选项卡的td上绑定一个单击事件。为了提高性能，我们希望在每次用户更改选项卡时解除绑定前一个选项卡的单击事件。
下面是演示：
(“已显示”事件是在所有转换完成后发生的)
$('a[data-toggle="tab"]').on('shown', function (e) {
var newt = $(e.target).attr("href"),
prevt = $(e.relatedTarget).attr(&#
浏览 1提问于2013-04-02得票数 0
回答已采纳
3回答
我有一个关于jQuery bind..Whenever的工作的问题，我们在任何元素上使用bind方法并编写一些回调代码，这些完整的代码是“每次”在bind事件上执行还是jQuery只记住该代码的输出/结果并只执行该结果。
另外，我们可以在回调代码中生成另一个事件吗？
比如它到底是怎么工作的。
浏览 2提问于2011-08-24得票数 1
回答已采纳
我有两个模型: UserNotification和进度表。创建计划时，将创建一种类型的用户通知(代码的第一行)。更新计划时，将创建另一种类型的用户通知(第二行代码)。由于某些原因，after_update是在保存之后发生的(我只希望在更新后才发生)。下面是代码中的代码：
class Schedule < ActiveRecord::Base
after_save 'UserNotification.schedule_created(@user)'
after_update 'UserNotification.schedule_updated(@user
浏览 2提问于2013-12-12得票数 10
回答已采纳
1回答
我有一个实体如下：
@Entity
public class Order {
@Id
private String orderId;
@Temporal(TemporalType.TIMESTAMP)
@Column(name = "created_at", nullable = false)
private Date created;
@Temporal(TemporalType.TIMESTAMP)
@Column(name = "updated_at", nullable = false)
private Date u
浏览 0提问于2019-01-17得票数 2
回答已采纳
正如akka博士所描述的，akka会发送信息-忘了-。
但是在ask模式中，如果typekey不存在，我仍然需要等待响应使用超时。
在向不存在的typekey发送消息时，是否有一种立即失败的方法？
浏览 7提问于2022-11-25得票数 1
回答已采纳
我在我的akka应用程序中得到以下运行时错误(使用akka类型化和经典)
Actorakka://my-classic-actor-system/user/ChatServer#1583147696.外部对ActorContext的不支持访问 java.lang.UnsupportedOperationException当前参与者没有处理任何消息，但是Threadmy-classic-actor-system-akka.actor.default-dispatcher-5,5，运行主组-0调用了ActorContext。
def main(args: Array[String]): Unit
浏览 5提问于2022-01-14得票数 1
回答已采纳
我已经阅读了Akka.NET的在线文档。 我看到持久性插件可以使用事件源模式来存储参与者的状态。 但是我没有在邮箱中找到任何关于邮件的具体信息。 当一个进程死亡或重新启动时，参与者的邮箱会恢复消息吗？
浏览 32提问于2019-05-22得票数 2
回答已采纳
1回答
我正在使用jquery jqGrid插件，我需要在网格初始化时触发事件。我测试了gridComplete和loadComplete事件，但是这些事件是在每个服务器请求之后引发的。我需要一个只在网格初始化一次之后引发的事件。我读过，但没有看到任何与我的需求相关的事件。有办法吗？感谢您的关注。
更新：
感谢奥列格的回答。我使用的是jqGrid 4.6，并使用了@Oleg建议的具有以下模式的事件：
$('#grid1').jqGrid('setGridParam', {
onSelectRow: function(id) {
浏览 10提问于2015-02-28得票数 1
回答已采纳
对于CQRS/EventSourcing应用程序，我们使用来自akka-persistence 2.6.15的EventSourcedBehavior，使用akka-persistence-JDBC4.0.0在PostgreSQL DB中存储事件和快照。
我们有用快照序列化的状态类。但有时这些状态类会发生变化，这使得读取快照明显失败。我们通过删除更改的快照来管理它：
delete from snapshot sn
where sn.persistence_id::uuid in (select id from some_entity_table);
但是
浏览 10提问于2021-12-10得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
