publish-subscribe相关内容

重订订户-发布者系统.仅由单个订户处理消息

我有一个拥有一个发布者和几个订阅者的系统.但是某些消息应仅由单个订户处理.在我的情况下，发布者发送有关更改数据库中数据的消息，所有订阅者都可以访问相同的数据库，但是我不需要他们都更改相同的数据. 如何使用rebus来实现? PS.忘了提.我不能只订阅一个订阅者，因为订阅者可以一直在线/离线. 解决方案 但是某些消息应仅由单个订户处理 然后，您不应该将bus.Publish用 ..

发布时间：2020-05-09 01:30:56 message-queue publish-subscribe rebus 其他开发

带有多订阅的MassTransit MSMQ Pub. RuntimeServices何时准备就绪?

我已经建立了一个简单的测试，该测试包括具有两个订阅者的发布者，所有订阅者均使用MSMQ和MassTransit(2.1.1)RuntimeServices在一台计算机上运行，​​后者使用本地Sql Server数据库. 我在下面包括了总线设置代码，因此您可以查看设置内容.我正在手动并独立地启动每个组件，以尝试锻炼如果订户没有运行时会发生什么. 我先运行了两个订阅者，因此队列和订阅都已设 ..

发布时间：2020-05-06 09:12:05 msmq publish-subscribe masstransit 其他开发

仅发布从现在起10秒钟前阅读的内容

我需要从我的CPU，内存和其他存储在集合中的东西发布统计信息.事情是，它只需要从现在开始发布最后10秒钟. 我加入了一张图片以帮助对此进行理解: 我编写了一个函数，但问题是它不会删除比现在早11秒，12秒的信息. Meteor.publish('dockerStats', function readInfosDockerStats(timeLimitSecond) { co ..

发布时间：2020-05-03 09:03:24 javascript meteor logic publish-subscribe 前端开发

发布者订阅者模式的现代替代方案

我有一个C ++ Windows应用程序.我正在处理发布者－订阅者的情况，其中我的一个类(发布者)会定期生成数据，并将其交给另一个类(订阅者)，该类一直在等待接收来自发布者的通知.我对设计模式不熟悉，我查找了发布者订户模型的常见实现，我发现它们通常很老，并且通常涉及维护指向对象的指针列表.我想知道是否有使用C ++ 11编码发布者订户模型的更好方法，或者完全使用完全不同的模型代替发布者-订户. 如 ..

发布时间：2020-05-02 09:36:43 c++ design-patterns c++11 listener publish-subscribe C/C++开发

具有剔除发布/订阅的可观察数组

我正在关注该帖子: http://www.knockmeout.net/2012/05/using-ko-native-pubsub.html 允许我的一个虚拟机与另一个虚拟机通信.我的一个viewModels有一个数组，我需要将该数组公开给另一个viewModel.如果该数组不是可观察到的，则上述文章中的方法就可以正常工作. 如果该数组是可观察的数组，则永远不会填充publis ..

发布时间：2020-04-26 11:28:08 knockout.js publish-subscribe single-page-application 其他开发

在淘汰赛中链接/同步视图模型的最佳方法是什么?

如果一页上有多个视图模型，如何确保它们可以保持同步? 例如，如果添加了一个项目或在一个视图模型上单击了一个按钮，而您又希望另一个视图模型对该更改敏感，则Knockout可以本机管理，还是最好使用某些消息传递或发布/订阅体系结构. /p> 我希望不必管理模型之间的可观测对象. 解决方案 Knockout 2.0确实包含使您可以进行基本发布/订阅的功能.这是两个视图模型通过调解器进行通信的示 ..

发布时间：2020-04-26 11:04:57 knockout.js publish-subscribe knockout-postbox 其他开发

用于事件驱动架构的jQuery插件吗?

是否有任何事件驱动架构jQuery插件? 第1步:订阅 即两个绿色订户将监听p0事件.蓝色的订户将监听p1事件. 步骤2:另一个组件向事件处理程序触发了p0事件 将p0事件触发给事件处理程序 事件处理程序将事件通知给其订阅者，调用在步骤1:订阅中订阅时指定的回调方法. 请注意，蓝色订户没有收到通知，因为它没有监听p0事件. 步骤3:将p1事件触发到事件处理程序 ..

发布时间：2019-11-19 18:25:42 javascript jquery-plugins publish-subscribe event-driven-design event-bus 前端开发

如何在ActiveMQ中保留订单?

我已经设置了一个应用程序来监听ActiveMQ主题.这是我配置它的方式: ..

发布时间：2019-09-18 19:46:28 jms activemq publish-subscribe 其他开发

Kafka是否具有“持久订阅"功能?

我有兴趣在我的一个项目中使用Kafka，但是有一个要求，当一个订户(使用者)断开连接时，消息传递代理必须保留消息. 我看到JMS具有功能. 在网站上说，Kafka具有耐久性功能. 与JMS一样还是具有不同的含义? 解决方案 消费者从kafka(经纪人)中提取数据.消费者指定要从其收集数据的位置开始的偏移量.如果Consumer断开连接并回来，它可以在离开的地方继续.它还可 ..

发布时间：2019-09-18 19:44:02 jms messaging publish-subscribe apache-kafka 其他开发

JMSTemplate检查主题是否存在并获取订阅者计数

我一直在寻找一些文档/示例来检查是否存在动态创建的主题，如果存在，如何获取该主题的订阅者计数. 我使用以下代码向某个主题发送消息- jmsTemplate.send(destination, new MessageCreator() { @Override public Message createMessage(Session sess ..

发布时间：2019-09-18 19:42:37 java spring jms activemq publish-subscribe Java开发

如何在activemq.xml中创建/预配置持久订阅者，以便在ActiveMQ启动时准备好这些订阅?

如何在activemq.xml中创建/预配置持久性订阅者，以便在ActiveMQ出现时就可以准备好这些订阅?好像订阅者处于离线状态一样. 我们期望有固定数量(但仍可配置)的已知订户. 要缓冲发布者从第一天开始发送的所有消息，以防并非所有订阅者都收到 起来了.不知道这是否是常见的情况，但请先感谢您的帮助. 解决方案 这是一个非常常见的用例.您实际上应该查看的是复合目标，而不是持久性主题 ..

发布时间：2019-09-18 19:39:45 java jms activemq publish-subscribe subscriber Java开发

群集应用程序服务器中的JMS主题订户如何接收消息?

假设我用一个订阅者(PropertiesSubscriber)创建了一个JMS主题(PropertiesTopic). PropertiesSubscriber在负载平衡的应用程序服务器群集中运行，如下图所示. 替代文本http://www.freeimagehosting.net/uploads/be28c03781.png 将消息传递到PropertiesTopic时，在不同应用程 ..

发布时间：2019-09-18 19:36:13 jms load-balancing publish-subscribe cluster-computing subscriber 其他开发

HornetQ中JMS主题的确切示例

我阅读了hornetQ文档，非常困惑.有人可以举一个确切的例子在hornetQ中创建一个JMS主题.我的意思是hornetq-jms.xml和hornetq-configuration.xml中的xml配置.假设我们有一个名为top的主题和2个名为sub1，sub2的订阅者.我得到的是，我们应该定义两个队列(每个订阅者一个)，并将它们绑定到实际上是主题名称的地址，但是订阅者如何知道他们应该连接到哪 ..

发布时间：2019-09-18 19:30:46 jms publish-subscribe hornetq 其他开发

将JaxRS REST服务与WebSocket集成

我正在尝试开发一种实现发布者-订阅模式的社交网络(类似于Twitter的做法):用户可以关注人们，因此在发送其关注者的新出版物时会收到通知. 我现在所拥有的就是通过JaxRS实现的可运行的REST服务，它在Tomcat 7上运行，提供用于登录，注册，获取配置文件数据和提交帖子的服务. Servlet映射是通过web.xml完成​​的 我的JaxRS应用配置 RestService ..

发布时间：2019-08-30 10:09:05 java rest websocket jax-rs publish-subscribe Java开发

jQuery中的Pub / Sub范围

我正在尝试使用以下代码在jQuery中实现Pub / Sub模式： $。each（{ 触发器：'publish'， on：'subscribe'， off：'unsubscribe' }，function（key，val）{ jQuery [val] = function（）{ o [key] .apply（o，arguments）; }; }）; 这种方式正常 ..

发布时间：2019-06-13 18:41:55 javascript jquery javascript-events publish-subscribe 前端开发

Nodejs：如何处理对象之间的事件监听？

我目前遇到的问题是我有一个应该侦听另一个对象的对象。 问题是：我该如何处理订阅？目前，我只知道两种可能的方式： 使用registrator： var Registrator = function（）{ this.listener = new Listener（）; }; Registrator.prototype.register = function（subsri ..

发布时间：2019-06-13 18:23:04 node.js javascript-events module publish-subscribe commonjs JavaScript

在条件之后使用mufa停止反应组件之间的通信

我通过 mufa 使用子/ pub模式在React组件之间进行通信而不是道具。然后，我们将缓解Parent组件中的逻辑（正如您将在下面的代码片段中看到的那样）。 const {on，fire} = mufa; class Input扩展React.Component {onChange（event）{fire（'input_change'，event.target.value）; } re ..

发布时间：2019-06-12 15:23:11 javascript reactjs publish-subscribe mufa 前端开发

订阅完成后如何在客户端上运行方法

以下是我的设置： //在global.js文件中 items = new Meteor.Collection（ “项目”）; //在main.coffee中的服务器上 Meteor.publish“nearItems”，（lat，lng） - > 返回items.find（{loc：{$ near：[lng，lat]}}） //在map.coffee中的客户端 Met ..

发布时间：2019-06-08 22:06:43 javascript meteor publish-subscribe 前端开发

pubnub和head.js

有没有人设法正确整合 pubnub 和head.js？ Pubnub 希望我将他们的脚本放在页面底部，并带有 标记就在它之前。这确保了`标签在最后一次调用javascript时完全加载。 事情是，我的应用程序和pubnub的其余部分都通过head.js加载所以它一直发生JS文件在pubnub订阅/发布密钥之前加载并且它的订阅/发布到'demo'而不是我自己的pubnub区域 ..

发布时间：2019-06-07 22:57:21 javascript jquery publish-subscribe head.js pubnub 前端开发

如何让EventEmitter监听Node.js中的另一个EventEmitter？

我想做这样的事情： var events = require（“events”）; var emitterA = new events.EventEmitter（）; var emitterB = new events.EventEmitter（）; emitterA.addListener（“testA”，function（）{ console.log（“emitt ..

发布时间：2019-06-07 21:12:29 javascript node.js events publish-subscribe eventemitter 前端开发