主题订阅者在长时间运行过程中的多条消息期间的行为

用户名

我有一个主题和相应的订阅者,形式为Spring DMLC。我的问题与以下情况有关:

在主题上发布一条消息,并且订户开始处理该消息。如果在处理前一条消息的同时又有另一条消息到达此主题,则假定订户忙,则新消息将丢失,否则在处理前一条消息后将处理该消息。

如果答案是第二条消息将在第一条消息之后处理,则后续问题是此行为是由代理处理还是由订户处理。

加里·罗素

除非客户端取消订阅(或死亡),否则下一条消息不会丢失-您可以使订阅持久,这意味着即使在这种情况下,消息也不会丢失。

这种(消息处理)是在代理而不是客户的控制之下;订阅是否持久取决于客户端。

一些代理提供了预取功能,在这种情况下,消息可能会在仍在处理当前消息的同时发送给客户端,但是如果客户端死了,消息也不会丢失,因为消息只有在确认后才被删除。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

在长时间运行的过程中停止冻结GUI

来自分类Dev

在长时间运行的hangfire过程中发送心跳

来自分类Dev

在长时间运行的过程中,什么可能导致突然的ClassNotFoundException?

来自分类Dev

在长时间运行的过程中多次抓取爬网

来自分类Dev

Blazor WebAssembly:如何在长时间运行的非异步过程中更新UI

来自分类Dev

避免在长时间运行报告生成过程中超时

来自分类Dev

如何确保在WPF应用程序中长时间运行的过程中更新了UI?

来自分类Dev

在Windows Store应用中实施长时间运行的过程

来自分类Dev

RxJS 检测长时间运行的订阅

来自分类Dev

长时间运行过程中频繁刷新网页

来自分类Dev

如何使用TPL处理长时间运行的过程

来自分类Dev

扩展长时间运行的消息处理Azure Service Bus

来自分类Dev

在Rails中运行大量长时间运行的后台作业

来自分类Dev

在终端中暂停长时间运行的程序?

来自分类Dev

如何在PowerShell中停止长时间运行的cmdlet

来自分类Dev

在Go中,如何关闭长时间运行的阅读?

来自分类Dev

如何在mysql中优化长时间运行的查询

来自分类Dev

在Android中处理“阻止”长时间运行的操作

来自分类Dev

查询以在SQL Server中查找长时间运行的作业

来自分类Dev

如何使长时间运行的事务在Clojure中快速失败

来自分类Dev

从长时间运行的命令的输出中过滤多个项目

来自分类Dev

在终端中暂停长时间运行的程序?

来自分类Dev

ssh登录过程中的长时间延迟

来自分类Dev

MQTT 订阅者能否同时接收同一主题的多条消息?

来自分类Dev

长时间运行的订阅中出现Angular2内存泄漏

来自分类Dev

如何在长时间运行的操作开始之前/期间显示进度屏幕?

来自分类Dev

C# 如何防止数据在长时间运行的查询期间因崩溃而丢失?

来自分类Dev

通过Web服务异步执行长时间运行的存储过程

来自分类Dev

是否可以在进入长时间运行的同步过程之前显示元素?

Related 相关文章

  1. 1

    在长时间运行的过程中停止冻结GUI

  2. 2

    在长时间运行的hangfire过程中发送心跳

  3. 3

    在长时间运行的过程中,什么可能导致突然的ClassNotFoundException?

  4. 4

    在长时间运行的过程中多次抓取爬网

  5. 5

    Blazor WebAssembly:如何在长时间运行的非异步过程中更新UI

  6. 6

    避免在长时间运行报告生成过程中超时

  7. 7

    如何确保在WPF应用程序中长时间运行的过程中更新了UI?

  8. 8

    在Windows Store应用中实施长时间运行的过程

  9. 9

    RxJS 检测长时间运行的订阅

  10. 10

    长时间运行过程中频繁刷新网页

  11. 11

    如何使用TPL处理长时间运行的过程

  12. 12

    扩展长时间运行的消息处理Azure Service Bus

  13. 13

    在Rails中运行大量长时间运行的后台作业

  14. 14

    在终端中暂停长时间运行的程序?

  15. 15

    如何在PowerShell中停止长时间运行的cmdlet

  16. 16

    在Go中,如何关闭长时间运行的阅读?

  17. 17

    如何在mysql中优化长时间运行的查询

  18. 18

    在Android中处理“阻止”长时间运行的操作

  19. 19

    查询以在SQL Server中查找长时间运行的作业

  20. 20

    如何使长时间运行的事务在Clojure中快速失败

  21. 21

    从长时间运行的命令的输出中过滤多个项目

  22. 22

    在终端中暂停长时间运行的程序?

  23. 23

    ssh登录过程中的长时间延迟

  24. 24

    MQTT 订阅者能否同时接收同一主题的多条消息?

  25. 25

    长时间运行的订阅中出现Angular2内存泄漏

  26. 26

    如何在长时间运行的操作开始之前/期间显示进度屏幕?

  27. 27

    C# 如何防止数据在长时间运行的查询期间因崩溃而丢失?

  28. 28

    通过Web服务异步执行长时间运行的存储过程

  29. 29

    是否可以在进入长时间运行的同步过程之前显示元素?

热门标签

归档