Eventstore:如何正确设置永久订阅客户端？
Eventstore是一个开源的事件存储数据库，用于存储和管理事件流数据。它提供了一种可靠的方式来捕获、存储和查询事件，并支持事件驱动架构的实现。
要正确设置永久订阅客户端，需要遵循以下步骤：
- 创建一个永久订阅：在Eventstore中，永久订阅是一种持久化的订阅方式，它可以在客户端断开连接后继续接收事件。通过调用Eventstore的API，可以创建一个永久订阅，并指定订阅的名称、订阅的事件类型等参数。
- 订阅事件流：一旦永久订阅创建成功，客户端可以通过订阅事件流来接收事件。订阅事件流时，需要指定订阅的名称和订阅的事件类型，以便只接收感兴趣的事件。
- 处理事件：当有新的事件发布到Eventstore中时，订阅客户端会收到相应的事件通知。客户端可以通过事件处理程序来处理接收到的事件，例如更新本地数据、发送通知等。
- 确认事件处理完成：在处理完一个事件后，客户端需要向Eventstore发送确认消息，以告知Eventstore该事件已被成功处理。这样Eventstore就可以继续向客户端发送下一个事件。
推荐的腾讯云相关产品：腾讯云数据库TDSQL、腾讯云消息队列CMQ、腾讯云函数计算SCF。
- 腾讯云数据库TDSQL：提供高可用、可扩展的数据库服务，适用于存储和管理Eventstore中的事件数据。了解更多：腾讯云数据库TDSQL
- 腾讯云消息队列CMQ：提供可靠的消息传递服务，可用于在Eventstore和订阅客户端之间传递事件通知。了解更多：腾讯云消息队列CMQ
- 腾讯云函数计算SCF：无服务器计算服务，可用于处理Eventstore中的事件。可以将事件处理程序部署为函数，根据需要自动触发执行。了解更多：腾讯云函数计算SCF
相关·内容
我正在使用EventStoreDB V20，并且正在尝试在我的本地开发机器上设置一个持久订阅。在仪表板上，我可以看到列出了持久订阅，但从未调用过处理程序。我正在使用这些小玩意儿：https://www.nuget.org/packages/EventStore.Client.Grpc/ https://www.nuget.org/packages/EventStore.Client.Grpc.PersistentSu
浏览 31提问于2020-12-20得票数 1
回答已采纳
客户端在总线上发送命令，域服务器接收并处理命令，并将事件存储到事件存储区，然后事件存储器将事件存储在总线上。然后读取模型服务器订阅这些事件以更新读取模型.没什么稀奇古怪的，就像书上写的那样。它正在工作，但是只是在简单的测试中，当事件被存储到EventStore时，我在域服务器上得到了很多并发异常(间歇性)。它正确地重试，但有时它达到5重试限制，命令在错误队列上结束。EventStore.ConcurrencyException:抛出了“EventStore.ConcurrencyExce
浏览 4提问于2012-03-18得票数 4
回答已采纳
我正在尝试根据这里给出的示例- 设置一个简单的事件订阅。这是我的活动商店：{}namespace CookBook\InheritanceBundle\Event;
use Symfony\Component\EventDispatcherCookBook\In
浏览 2提问于2013-08-28得票数 9
回答已采纳
我刚刚看了一下NES，它使用EventStore和NServiceBus进行CQRS。如果有人能给我介绍一下这个示例项目是如何工作的，那将是进入NES和NSB的一个很好的开始？JD
Ps。NES项目看起来很棒，现在需
浏览 0提问于2012-02-06得票数 2
回答已采纳
func createEvent(eventStore: EKEventStore, title: String, startDate: NSDate, endDate: NSDate) { event.startDate = startDateevent.endDate = endDate
event.calendar = eventStore.defaultCa
浏览 0提问于2016-05-09得票数 0
我已经正确地设置了一个EKEventEditViewController，其中包含一个EKEventStore、EKEvent和它的editViewDelegate作为呈现视图控制器。EKEventEditViewController正确地显示了自己，但是当我按下'add‘或'cancel’时，didCompleteWithAction不会在EKEventEditViewDelegate有没有人遇到过这个错误，或者有任何关于如何进一步调试的提示？谢谢!我运行的是iOS 11和Xcode9.0.1。
浏览 3提问于2017-11-08得票数 5
我在NET4.6.1和EventStore.Client 4.1.1中使用EventStore.Client模板var host = new jobHost(config);关闭原因:客户端请求成功连接关闭。我只是想找一种方法来订阅事件存储事件，使用一些Azure的方式来做，这样我们就可以监视它了。我是不是做错了？如何在Azure中获得持久的订阅服务？
浏览 0提问于2018-06-19得票数 0
回答已采纳
2回答
{
EKEventStore *eventStore = [[EKEventStorealloc] init];
// Define a range of event
浏览 4提问于2013-01-21得票数 1
我尝试使用.Net客户端在事件存储集群上写入和读取事件。因此，我已经设置了3个本地坞容器来测试写入和读取到集群。我已经建立了集群，它说它还活着(一个主人和两个奴隶)。如何连接到群集以写入和读取事件？事件存储集群按照中的描述进行设置。群集设置为，而不是，通过设置discover-via-dns=false使用dns。下面是我的.yaml文件，用于码头
浏览 0提问于2018-07-17得票数 2
一个用户被添加，但是没有被订阅，一般的错误代码是‘这个用户卸载了你的应用程序或者清除了站点数据’。
浏览 25提问于2022-02-16得票数 2
由于客户端设备的限制，任何客户端都不可能保留所有文档的副本，只有少数几个。由于每个客户端不能存储所有文档，因此需要有一种方法从客户端删除“旧”文档的副本，而不需要从中央存储中删除文档，最好是基于一种自动的、最近使用最少的方法。
浏览 5提问于2017-04-23得票数 1
回答已采纳
2回答
我使用spring与Websphere MQ一起进行发布/订阅。经过几次测试，我可以：
在我的应用程序中，我想对此管理上的订阅提出申请。我使用的配置与上面的步骤2相同：
如果是的话，如何</
浏览 5提问于2015-12-09得票数 0
2回答
我们通过提供createDurableSubscriber和订阅者名称，以编程方式为IBM主题创建了订阅服务器。当我们无法在订阅者的持久队列中看到消息时，这些消息在哪里？这取决于到期属性吗？id具有
浏览 5提问于2020-09-28得票数 0
我正在考虑将用户管理实现到使用cqrs+eventstore的.net核心应用程序接口中。继续读下去，还有一个IdentityServer4，我不太明白它是如何适应的。
有人能给我指个方向吗？
浏览 16提问于2017-01-10得票数 0
我试图创建3个订阅计划:每月，每年和终身。
我能够创建每月和每年的计划，但我不知道如何添加一个终身计划(也就是一次性支付，使订阅永远)。我能想到的唯一解决办法就是简单地使用每月和每年的定期付款，并为终身计划创建一个不同的产品，但这让我有点困扰，我不得不在代码中添加额外的逻辑，以检查客户是否购买了终身订阅产品。还有其他方法可以使它成为终身订阅相同的产品吗？
浏览 1提问于2021-05-01得票数 0
回答已采纳
最近，我意识到一些客户端连接到我的ActiveMQ Artemis，而不设置客户端id和订阅以及订阅某些主题。它们的队列变成了UUID，如下所示：那么，我想知道如何强制ActiveMQ客户端设置客户端id和订阅名？如果它们不配置客户端id和订阅名称，ActiveMQ Artemis可以将它们踢出。
浏览 2提问于2021-12-23得票数 0
回答已采纳
我有一个.Net核心Web设置，其中我公开了一个基本上是永久框架的端点。我受到一个API契约的约束，它迫使我公开它。 该永久帧推送从Redis发布/订阅信道接收的数据。我将在这个端点上有多个侦听器，它们基本上应该是同一通道的单个订阅者。 我使用StackExchange.Redis。有一件事我不能理解，那就是如何在这个场景中使用ConnectionMultiplexer。无论我在哪里读到它，我都被告知要有一个全局ConnectionMultiplexer。但是，如果我这样做了，
浏览 33提问于2019-01-21得票数 2
1回答
无论如何，我如何编辑和删除已经存在的事件？也就是我收到的EKEvent？
我需要通过编程来完成这一切，我没有使用任何苹果公司预制的EKEventViewController。我可以成功地创建和保存新的事件，但我不确定如何编辑或删除现有的事件，任何帮助都将不胜感激，谢谢。
浏览 0提问于2012-03-02得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
