草庐IT

javascript - 仅当监听器存在时才发布消息？

coder 2024-04-20 原文

使用 RabbitMQ，我希望我的 (PHP) 代码仅在该特定用户当前正在收听时才向该特定客户发布消息。

原因是我连接的用户将打开一个 websocket，它将等待来自 RabbitMQ 的通知并在通知到达时更新 UI。但是当他们第一次加载页面时，所有之前的通知都会被加载，所以不需要重新加载队列中的通知。

作为消息队列的新手，我不知道是否可行，但我希望我的发布者检查用户 ID = X 当前是否正在监听(因为 websocket 将在执行时打开一个 channel )，以及是否他目前正在收听，发布一条消息。如果他不是，则不会发布该消息(但将其添加到数据库中)。

工作流程是这样的:

发布者:

  1. 端点正在接收事件
  2. 将事件保存在数据库中
  3. 它检查用户 ID =X 是否有一个开放的 channel ，如果是，它将事件发布到该 channel

订阅者:

  1. 客户连接到应用
  2. 前端从数据库中加载最后的事件
  3. 前端为该特定用户打开一个 websocket 以监听可能发布的事件
  4. 发布事件时，websocket 会通知前端。

也许我问的很基础，但我缺乏知识。

一个额外的问题:是为每个客户打开一个 channel 更好，还是为所有客户打开一个通用 channel ，订阅方将过滤？

谢谢你的帮助:)

最佳答案

我相信您遇到了您的问题，因为在 AMQP 中发布者和队列之间存在区别。两者之间没有一一对应关系。

如果我对你的情况的理解正确，你有一个中央发布者正在向消息代理发送消息。同时，您有许多潜在订阅者正在注册和退出代理(在​​本例中是通过 websockets)。其中一个订阅者是一个数据库进程，它将所有消息存档以供以后检索。

我推荐的是:

  1. 将这些消息发布到主题式交换
  2. 订阅消费者各自在订阅时创建自己的队列。这将在 Web 服务器代码中完成，并将到达的消息汇集到 websocket。
  3. (动态)创建订阅队列时，将队列设置为在(短)秒数后自动删除，因此连接中的小中断不会导致消息丢失。
  4. 为进入数据库进程的消息创建一个持久队列。
  5. 消费应用程序有责任删除从数据库加载的消息和通过 websocket 流入的消息之间的重复数据。为每条消息分配一个 guid 应该对此有所帮助。

要回答您的第二个问题，这取决于您的网络服务器架构。本人对PHP了解不够，但就AMQP协议(protocol)本身而言，没有影响。 channel 只是协议(protocol)级结构，因此创建它们的影响可以忽略不计。多个消费者可以共享一个 channel ，或者您可以为每个消费者创建一个 channel 。这真的没有什么区别。

关于javascript - 仅当监听器存在时才发布消息？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31289494/

监听器javascriptlisectionchannelphprabbitmq

有关javascript - 仅当监听器存在时才发布消息？的更多相关文章

  1. ruby-on-rails - 如何在 Rails View 上显示错误消息？ - 2

    我是rails的新手，想在form字段上应用验证。myviewsnew.html.erb.....模拟.rbclassSimulation{:in=>1..25,:message=>'Therowmustbebetween1and25'}end模拟Controller.rbclassSimulationsController我想检查模型类中row字段的整数范围，如果不在范围内则返回错误信息。我可以检查上面代码的范围，但无法返回错误消息提前致谢 最佳答案 关键是您使用的是模型表单，一种显示ActiveRecord模型实例属性的表单。c

  2. ruby-on-rails - rspec - 如何检查方法是否存在？ - 2

    我的模型有defself.empty_building//stuffend我怎样才能对这个现有的进行rspec？，已经尝试过:describe"empty_building"dosubject{Building.new}it{shouldrespond_to:empty_building}endbutgetting:Failure/Error:it{shouldrespond_to:empty_building}expected#torespondto:empty_building 最佳答案 你有一个类方法self.empty_bu

  3. 世界前沿3D开发引擎HOOPS全面讲解——集3D数据读取、3D图形渲染、3D数据发布于一体的全新3D应用开发工具 - 2

    无论您是想搭建桌面端、WEB端或者移动端APP应用，HOOPSPlatform组件都可以为您提供弹性的3D集成架构，同时，由工业领域3D技术专家组成的HOOPS技术团队也能为您提供技术支持服务。如果您的客户期望有一种在多个平台（桌面/WEB/APP，而且某些客户端是“瘦”客户端）快速、方便地将数据接入到3D应用系统的解决方案，并且当访问数据时，在各个平台上的性能和用户体验保持一致，HOOPSPlatform将帮助您完成。利用HOOPSPlatform，您可以开发在任何环境下的3D基础应用架构。HOOPSPlatform可以帮您打造3D创新型产品，HOOPSSDK包含的技术有：快速且准确的CAD

  4. ruby - 使用 Ruby 通过 Outlook 发送消息的最简单方法是什么？ - 2

    我的工作要求我为某些测试自动生成电子邮件。我一直在四处寻找，但未能找到可以快速实现的合理解决方案。它需要在outlook而不是其他邮件服务器中，因为我们有一些奇怪的身份验证规则，我们需要保存草稿而不是仅仅发送邮件的选项。显然win32ole可以做到这一点，但我找不到任何相当简单的例子。 最佳答案 假设存储了Outlook凭据并且您设置为自动登录到Outlook，WIN32OLE可以很好地完成此操作:require'win32ole'outlook=WIN32OLE.new('Outlook.Application')message=

  5. ruby-on-rails - 如何在发布新的 Ruby 或 Rails 版本时收到通知？ - 2

    有人知道在发布新版本的Ruby和Rails时收到电子邮件的方法吗？他们有邮件列表，RubyonRails有一个推特，但我不想听到那些随之而来的喧嚣，我只想知道什么时候发布新版本，尤其是那些有安全修复的版本。 最佳答案 从therailsblog获取提要.http://weblog.rubyonrails.org/feed/atom.xml 关于ruby-on-rails-如何在发布新的Ruby或Rails版本时收到通知？，我们在StackOverflow上找到一个类似的问题：

  6. Ruby - 如何将消息长度表示为 2 个二进制字节 - 2

    我正在使用Ruby，我正在与一个网络端点通信，该端点在发送消息本身之前需要格式化“header”。header中的第一个字段必须是消息长度，它被定义为网络字节顺序中的2二进制字节消息长度。比如我的消息长度是1024。如何将1024表示为二进制双字节？ 最佳答案 Ruby(以及Perl和Python等)中字节整理的标准工具是pack和unpack。ruby的packisinArray.您的长度应该是两个字节长，并且按网络字节顺序排列，这听起来像是n格式说明符的工作:n|Integer|16-bitunsigned,network(bi

  7. ruby-on-rails - 在 Flash 警报 Rails 3 中显示错误消息 - 2

    如果我在模型中设置验证消息validates:name,:presence=>{:message=>'Thenamecantbeblank.'}我如何让该消息显示在闪光警报中，这是我迄今为止尝试过的方法defcreate@message=Message.new(params[:message])if@message.valid?ContactMailer.send_mail(@message).deliverredirect_to(root_path,:notice=>"Thanksforyourmessage,Iwillbeintouchsoon")elseflash[:error]

  8. ruby-on-rails - 在 RSpec 中，如何以任意顺序期望具有不同参数的多条消息？ - 2

    RSpec似乎按顺序匹配方法接收的消息。我不确定如何使以下代码工作:allow(a).toreceive(:f)expect(a).toreceive(:f).with(2)a.f(1)a.f(2)a.f(3)我问的原因是a.f的一些调用是由我的代码的上层控制的，所以我不能对这些方法调用添加期望。 最佳答案 RSpecspy是测试这种情况的一种方式。要监视一个方法，用allowstub，除了方法名称之外没有任何约束，调用该方法，然后expect确切的方法调用。例如:allow(a).toreceive(:f)a.f(2)a.f(1)

  9. ruby-on-rails - ActiveRecord 的 find_or_create* 方法是否存在根本性缺陷？ - 2

    有几种方法:first_or_create_by、find_or_create_by等，它们的工作原理是:与数据库对话以尝试找到我们想要的东西如果我们找不到，就自己做保存到数据库显然，并发调用这些方法可能会使两个线程都找不到它们想要的东西，并且在第3步中一个线程会意外失败。似乎更好的解决方案是，创建或查找即:提前在您的数据库中创建合理的唯一性约束。如果你想保存一些东西，就保存它如果有效，那就太好了。如果它因为RecordNotUnique异常而无法工作，它已经存在，太好了，加载它那么在什么情况下我想使用Rails内置的东西而不是我自己的(看起来更可靠)create_or_find？

  10. ruby-on-rails - 使用 javascript 更改数据方法不会更改 ajax 调用用户的什么方法？ - 2

    我遇到了一个非常奇怪的问题，我很难解决。在我看来，我有一个与data-remote="true"和data-method="delete"的链接。当我单击该链接时，我可以看到对我的Rails服务器的DELETE请求。返回的JS代码会更改此链接的属性，其中包括href和data-method。再次单击此链接后，我的服务器收到了对新href的请求，但使用的是旧的data-method，即使我已将其从DELETE到POST(它仍然发送一个DELETE请求)。但是，如果我刷新页面，HTML与"new"HTML相同(随返回的JS发生变化)，但它实际上发送了正确的请求类型。这就是这个问题令我困惑的

随机推荐