Axon事件处理程序和查询处理程序在kotlin中不能协同工作
Axon是一个用于构建事件驱动的分布式应用程序的开发框架。它提供了一种简单而强大的方式来处理事件和查询，并支持CQRS（命令查询责任分离）模式。
在Kotlin中，Axon事件处理程序和查询处理程序可以协同工作。Kotlin是一种现代的静态类型编程语言，它与Java完全兼容，并且具有更简洁、安全和表达性的语法。Axon框架提供了对Kotlin的良好支持，使得在Kotlin中编写事件处理程序和查询处理程序变得非常容易。
事件处理程序是用于处理领域事件的组件。它们负责接收事件并执行相应的业务逻辑。在Axon中，事件处理程序通过实现@EventHandler注解的方法来定义。这些方法可以在Kotlin中使用suspend关键字来声明为挂起函数，以支持协程和异步操作。
查询处理程序是用于处理查询请求的组件。它们负责从查询模型中检索数据，并将结果返回给调用方。在Axon中，查询处理程序通过实现@QueryHandler注解的方法来定义。与事件处理程序类似，这些方法也可以在Kotlin中使用suspend关键字来声明为挂起函数。
Axon框架提供了一些与Kotlin集成的功能，例如使用Kotlin扩展函数来简化代码、使用Kotlin协程来实现异步操作、使用Kotlin的空安全特性来提高代码的健壮性等等。
总结起来，Axon事件处理程序和查询处理程序在Kotlin中可以协同工作，并且可以利用Kotlin的语法和功能来简化开发过程。对于使用Axon框架构建事件驱动的应用程序的开发者来说，掌握Kotlin编程语言将是一个有益的技能。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云函数（Serverless）：https://cloud.tencent.com/product/scf
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云数据库 TDSQL：https://cloud.tencent.com/product/tdsql
- 腾讯云容器服务 TKE：https://cloud.tencent.com/product/tke
- 腾讯云人工智能 AI Lab：https://cloud.tencent.com/product/ai-lab
- 腾讯云物联网平台 IoT Hub：https://cloud.tencent.com/product/iothub
- 腾讯云移动开发 MSDK：https://cloud.tencent.com/product/msdk
- 腾讯云对象存储 COS：https://cloud.tencent.com/product/cos
- 腾讯云区块链服务 TBC：https://cloud.tencent.com/product/tbc
- 腾讯云游戏多媒体引擎 GME：https://cloud.tencent.com/product/gme
- 腾讯云视频直播 LVB：https://cloud.tencent.com/product/lvb
- 腾讯云音视频处理 VOD：https://cloud.tencent.com/product/vod
- 腾讯云安全加速 SSL：https://cloud.tencent.com/product/ssl
相关·内容
事件处理程序创建AnnotationQueryHandlerAdapter而不是AnnotationEventHandlerAdapter。解决方案是将@EventHandler移出以分离类，并保持它们在那里，而@QueryHandler也在单独的类中。 我记得它和java一起工作。我不确定我在这里错过了什么，但它似乎是一个spring-kotlin错误？任何建议都将不胜感激，谢谢
浏览 17提问于2019-05-09得票数 0
回答已采纳
1回答
@AnnotationDriven在AXON中的用途是什么，我们在Axon3.1中还有这个注释吗？import org.axonframework.contextsupport.spring.AnnotationDriven;
我正在进行迁移，这个特定的库在3.1中显示了错误，这在2.4中是很好的。
浏览 1提问于2018-01-03得票数 1
回答已采纳
我使用的是Axon版本(3.3)，它在SpringBoot主类中使用在我们的用例中它会将事件存储在事件存储中，然后将其移动到另一个kafka主题，供查询端微服务消费。
由于KafkaAutoCOnfiguration被禁用，我不能使用spring-kafka配置来编写消费者。如何在Axon中
浏览 18提问于2019-07-12得票数 0
1回答
目前我们正在使用Axon 2。我们希望将Axon 2升级到4。我们使用Axon 2订阅了带重放选项的事件处理器。在Axon 4中，一个重要的区别是跟踪事件处理器。看来，跟踪处理器是重播的必由之路。可以使用订阅和跟踪事件处理器吗？是否有可能只将跟踪处理器用于回放，而将其余部分保留下来？或者它必须改变整个结构？
浏览 8提问于2020-06-11得票数 1
1回答
读取模型上的轴突命令
、、、
我们目前正在使用带有hikaricp的axon框架作为数据源池系统。我们不时地面临着令人筋疲力尽的问题，我们有一个理论：提前感谢
浏览 3提问于2021-02-21得票数 0
我我检查了命令应用程序，它存储了仪表板()中的事件数据。但是，事件处理程序未被调用。: debugSimpleEvent.kt val id: String,
浏览 3提问于2022-02-22得票数 1
回答已采纳
2回答
在添加异步处理之类的技术复杂性之前，我想先这样做。用Axon实现这一功能模monolith
我们将使用modular monolith。虽然，我确信每个域都是完全分
浏览 3提问于2020-01-19得票数 4
回答已采纳
我在Kotlin中定义了一个类： @Id var submissionId: String, var accountNumber: String它由事件处理程序实例化和更新，然后响应查询返回。我需要创建一个查询，通过accountNumber (而不是id )查找一个accountNu
浏览 1提问于2019-03-26得票数 0
回答已采纳
我们有一个基于Sap Cloud SDK (3.32.0)的SpringBoot应用程序，并且在我们的本地SAP环境中使用PrincipalPropegation。我们的应用程序也在使用Axon框架(一个事件外包框架)。这意味着我们对RestControllers的调用是作为命令发送给Aggregate的，Aggregate反过来在eventbus上发送事件。通常，我们通过在事件消息上添加元数据来传递oauth令牌。
浏览 0提问于2020-11-13得票数 2
我们正在使用CQRS，事件源使用Axon 4.操作-使用Axon和事件源流(命令-聚合-事件)操作将新图书创建为DB -使用Axon CRQS和Axon事件存储中的事件源流(命令-聚合-事件)将已经创建的图书更新为DB --这两个命令(createCommand和updateCommand)具有相同的"aggr
浏览 0提问于2019-12-05得票数 1
@Endsaga仅在查询端(独立的项目)发送事件(来自读取存储查询端的成功或失败)，通知Saga发生了什么之后才会到达。这是使用以下链接中描述的saga模式向客户发送唯一性电子邮件的验证过程的一部分：
你能帮帮我吗?
谢谢。
浏览 2提问于2020-04-12得票数 0
1回答
我们正在运行Axon，并且有多个服务连接到它。一切正常，但有一个例外，在开发/测试应用程序时在本地运行所有程序会导致内存和磁盘达到100%的峰值，这使得开发变得有点困难。所以，我想知道，有没有可能创建某种“代理”服务，我们在本地运行，将我们的一些命令，查询和事件转发到另一个在其他地方运行的Axon实例，这个实例有真正的服务连接到它，这样我们就不必在本地运行所有的服务。
浏览 9提问于2020-04-01得票数 2
1回答
我正在研究在GCP的K8S托管平台中实现微服务Saga模式的解决方案。有两个选项:事件、Tram和Axon。那么，有没有办法集成Eventulate或Axon来使用谷歌云PubSub呢？谢谢
浏览 5提问于2020-08-25得票数 0
1回答
我会在一个单独的RiskScorePart1对象中创建一个PubSub事件处理程序，它只会使用事件中的数据在命令总线上放置一个CreateRiskScorePart2命令。在RiskScore聚合中，CreateRiskScorePart2 (Actor B)的命令处理程序将执行一些处理，然后将RiskScorePart2事件放到总线上。在聚合<
浏览 0提问于2019-06-05得票数 0
1回答
需求之一是能够根据现有的事件日志为查询子系统引入新的预测。为此，我需要能够迭代存储在数据存储中的所有事件记录。轴突有可能吗？
浏览 1提问于2018-11-30得票数 3
回答已采纳
我在PostgreSQL数据库中存储了状态聚合。我正在通过删除状态存储表和token_entry表并重新启动应用程序来测试重放。所有事件都将被重放，聚合将在内存中恢复。但是，我的状态存储表保持为空。我正在使用SpringBoot和最新的Axon。在这个时刻，代码是尽可能简单的。
浏览 8提问于2022-05-01得票数 1
回答已采纳
我的Axon测试设置
我希望由一个实例发布的事件只能由同一个实例来处理。不幸的是，在我的例子中，这不是一个选项，因为我们希望可以选择重播事件来
浏览 0提问于2020-08-08得票数 2
回答已采纳
我有两个弹簧引导微服务核心和web。Caused by: com.fasterxml.jackson.core.JsonParseException:= jac
浏览 3提问于2020-12-06得票数 0
1回答
我很难理解如何连接到默认的Axon事件存储库，并查看那里存储了哪些事件？有什么办法可以预演吗？
如何重播存储事件以重新创建存储实体的特定状态？我试图在互联网上找到一个例子、教程或视频课程，却找不到任何东西.如何制作快照，然后检索它？在网上找不到怎么做的例子.如果以前有人问过，有人能建议或分享到StackOverflow上讨论的链接吗？
浏览 2提问于2021-01-14得票数 1
(将这一讨论从Axon论坛中移到这里)来自：
但是，何时/在何处创建初始实体？
您的GiftCard聚合从没有实体开始。( a)在GiftCar
浏览 5提问于2022-01-10得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
