publish-subscribe相关内容

在UI呈现最佳实践之后,是否发布/订阅事件,无论框架如何?

我继承了一个相当大的Javascript / ExtJS3代码库,并且在调用“... superclass.initComponent.apply(this,arguments)”之后,在覆盖的initComponent方法中有许多调用事件的实例。 。特定事件正以下列方式被调用于特定对象: this.filter.on('filterUpdated'函数(filter,params) ..

什么是*像*一个承诺,但可以解决多个时间?

我正在寻找一个行为像承诺的pub / sub机制,但可以多次解析,并且表现得像一个事件,除非您在通知发生后订阅,并触发最新的值。 我知道 通知 ,但 deferred.notify 对订单敏感,所以这样做就像一个事件。例如: d.notify('notify before'); //未观察到:( d.promise.progress(function(data){console. ..
发布时间:2017-08-31 03:03:19 开发方法

一次使用承诺的事件处理?

几乎平常的情况。我想要有一些去耦的代码,那就是当事情准备就绪时触发事件。这将在整个应用程序运行中发生一次。另一方面,另外还有一段代码,当两个或多个事件被触发时,我想要再发生一些事情。我的意思是像他们所有的一样,像依赖关系。 好吧,更多异步的东西在一起...肯定是承诺吗? 然后我开始思考使用pub / sub进行一次性活动是否真的很明智?一旦这个事件即将被触发,解决方案就不会更好吗?然而 ..
发布时间:2017-08-31 01:07:56 前端开发

观察者,Pub / Sub和数据绑定之间的区别

观察者模式 ,有什么区别? > 发布/订阅 和 数据绑定 ? I在SO上搜索了一下,没有找到任何好的答案。 我所相信的是数据绑定是一个通用术语,有不同的实现方式它如Observer Pattern或Pub / Sub模式。使用Observer模式,Observable可更新其观察者。使用Pub / Sub,0多个发布商可以发布某些类的消息,0多个订阅者可以订阅某些类的消息。 是否 ..

发布者/订阅者模式的并发实现

我想使用Java实现各种发布商/订阅者模式,并且目前运行的想法不多。 有1个发布商和N个订阅者发布对象,则每个订阅者需要以正确的顺序处理每个对象一次且仅一次。发布商和每个订阅者都在自己的线程中运行。 在我原来的实现中,每个订阅者都有自己的阻塞队列,发布者将对象放入每个订阅者的队列。这工作正常,但发布商将被阻止,如果任何订阅者的队列已满。这导致性能的降低,因为每个订户在处理对象时花费不同 ..

Meteor:在collectionHandle.ready()为true后,如何触发助手函数的reRun

这是我的旧问题的新版本: 因此,感谢汤姆·科尔曼的帮助我终于找出了如何正确检查一个订阅是否准备好()或不。 我当前的代码结构看起来像这样: /client/app.js: eventsHandle = null; groupsHandle = null; // ... //第一个Deps.autorun(): //不依赖任何会话var,应该每次都运行 De ..
发布时间:2016-12-15 20:38:20 前端开发

使用WCF回调和asp.net实现发布/订阅模式的问题

这是我的第一个web应用程序与wcf。所以请指导我作为一个新的家伙。 我试图使用WCF回调来实现发布/订阅模式。我想将消息从UserA发送到UserB或UserA到每个客户端。我有一个来自这里的示例 在我的应用程序中,我使用asp.net作为客户端连接wcf服务,而我发现一个问题,当我订阅wcf服务。 wcf服务不包含任何其他客户端对象。所以当我调用GetAllClients(_ ..
发布时间:2016-11-10 10:59:22 C#/.NET

ZMQ发布 - 订阅程序故障时丢失网络连接

我有一个中等规模的网络上的简单的发布 - 订阅设置,使用ZMQ 2.1。虽然有些用户正在使用C#绑定,别人都在用Python绑定,而我遇到的问题是不是一样的。 如果我拉网线从机中运行的用户,我得到一个未开捕错误立即终止该订户。 下面是用Python(而不是实际的生产代码,但足以重现该问题)用户的一个非常简单的例子: 进口ZMQ DEF主(服务器地址,端口): =背景 ..
发布时间:2016-10-04 23:10:21 C#/.NET

发布/ .NET与RabbitMQ的订阅样本

我已经建立了这个示例:入门:在.NET RabbitMQ的,但做2个节目: 一个出版商 一户 我用 BasicPublish 公布和 BasicAck 来聆听示例所示。如果我的用户运行一个发布和若干从每只有个出版者一个用户得到它“发送消息”。所以,有一些顺序(如用户已启动),其中发行人发送消息给用户,我想发一条消息给所有用户。什么是错的样品?可能是你能提供通过RabbitMQ的工作出 ..
发布时间:2016-09-29 13:30:57 C#/.NET

间的pubsub没有网络依赖

假设我已经安装在我的电脑上没有网卡,我想有类似以下功能: 流程1将消息发布到一些URI,说“Uri1” VAR出版商=新的出版商(“Uri1”); publisher.publish(新消息(“Somedata”); 2过程都将听关于“Uri1”消息和消息发布到“Uri2” VAR用户=新用户(“Uri1”) subscriber.MessageR ..
发布时间:2016-09-26 12:58:52 C#/.NET

木偶事件聚合VS骨干路由器

我是pretty新的这个世界,所以我需要它的一些澄清。也许我可能是错的题目。因此,随时纠正我。 我在研究如何木偶和骨干一起工作。哦耶。木偶给了我们扩展骨干。真是不错的东西。 这不是明显对我的事情是,当使用由骨干提供的路由机制,当木偶使用发布/订阅模式。 有经验的规则? 在这里, ..
发布时间:2016-07-30 16:01:09 前端开发

Azure的活动中心和多个消费群体

需要在以下情况下使用Azure的事件中心的帮助。我认为,消费群体可能是这种情况下正确的选择,但我没能在网上找到一个具体的例子。 这是问题的粗略描述和使用事件中心的建议的解决方案(我不知道这是否是最佳的解决方案。请问AP preciate您的反馈) 我有多个事件源产生大量的事件数据(来自传感器遥测数据),这需要被保存到我们的数据库和一些分析,像跑步平均值,最小值,最大值应平行 发送者可以只 ..
发布时间:2016-07-29 17:38:39 云存储

自动终止孤立的认购(天青ServiceBus消息SubscriptionClient)

我心目中的情形是这样的:服务总线是用于实例到实例的沟通,使订阅是每个服务实例是唯一的。最终的结果是,如果一个实例没有正常关闭,它的订阅不会被删除。 当一个服务实例“死”并重新启动,$ P $认购pvious内容是不相关的,可以将其丢弃。 那么,有没有一种方法来设置一个“生存时间”为服务总线认购或模拟类似的东西,而不必诉诸于一些自定义的孤儿检测机制? 解决方案 这是确切的特点是对积压在接 ..
发布时间:2016-07-29 17:21:17 云存储

使用阻塞REST请求来实现发布/订阅

我最近一直要求调查与谁愿意做电话事件(例如线路振铃,分机应答,呼叫清除)可使用RESTful Web服务的电话系统供应商整合的可行性。 我指出,REST是一种请求/响应协议,他们正在做的发布/订阅。他们建议的解决方案是使一个HTTP REST请求这会阻止并最终如果当一个事件是可利用的回应 - 或超时 无论哪种方式,另一个请求将作出获取下一个事件,并如此循环往复。 这个想法让我畏缩,但我确信, ..
发布时间:2016-07-21 10:39:24 其他开发

在后台线程火灾事件

我道歉,我不是我的问题和努力准确。我正在开发具有不同的组件控制台应用程序。现在我已经脱钩他们,并希望他们使用异步发布/订阅的方式进行交互他们。类似WPF。因此,在这种情况下,我将有一个主线程,这将永远存在,并根据要求将调用例如事件DataRequested这将在后台线程被解雇。一旦后台线程完成过程中,它会触发事件再次如DataCompleted应该回过头来调用线程,即主线程。我希望我在我解释清楚了 ..
发布时间:2016-07-21 10:38:34 C#/.NET

ZMQ VS Redis的为发布 - 订阅模式

Redis的支持发布 - 订阅 ZMQ 还支持通过消息代理发布 - 订阅 什么是建筑的优点\\利弊它们之间选择?结果 我针对这些都超出了明显的用例特定的性能基准测试应该做(这里的一个很好的例子)。 假设使用高级语言如Python的。 解决方案 我既ZeroMQ和Redis的使用Python的工作。我想说ZeroMQ更强劲,它提供了真正简单的负载均衡,也比发布 - 订阅越多,就像 ..