从JetStream中删除特定主题或创建多少个主题 | 您所在的位置:网站首页 › 码云 ArduinoOpenSource › 从JetStream中删除特定主题或创建多少个主题 |
我认为您正在寻找的是您的流的“WorkingQueue”保留策略,一旦消息被订阅者发送并确认到流上的使用者,它就会从流中删除消息。 因此,例如,在“orders.new”上发布了新的订单请求。并且您有一个包含“WorkingQueue”保持策略的流,用于侦听主题'orders.new.*‘,并且工作进程订阅了一个(持久的、拉出的)使用者。工作进程从流中提取新的订单,一旦成功完成处理,它们就会对消息进行包装,并将其从请求流中删除。一定要根据您的处理时间调整消费者的“AckWait”和/或使用“给我更多时间处理”确认。 您可以重复此模式来创建工作流(例如,消息在“orders.new”流中,另一条消息被发布到“orders.processing”流中,并由此从“orders.new”中添加并删除),或者执行长时间的请求回复(例如提交作业),例如将答复发布到“结果”的地方。并且您定义了一个侦听“结果.*”(工作队列或时间限制)的流,您可以让客户端使用对“结果”的临时消费者筛选来等待其订单处理的结果。 |
今日新闻 |
推荐新闻 |
专题文章 |
CopyRight 2018-2019 实验室设备网 版权所有 |