首页 > TAG信息列表 > publish-subscribe

Javascript-OpenAjax联盟与普通Web开发人员之间的相关性如何？

OpenAjax Alliance表示它是“使用Ajax的领先供应商,开源项目和公司的组织”,但是我在引用它们的stackoverflow上没有发现任何问题.我想知道这对实践Web开发人员是否重要. John Resig在2007年2月发表了一篇Thoughts on OpenAjax博客文章,但我找不到很多其他参考文献. 我已经将OpenAj

基于Python的发布订阅中间件

是否有可扩展的,基于python的发布订阅中间件？我尝试了RabbitMQ,但是在32-64个节点上无法很好地扩展. 我需要一个可以运行超过1000个节点的中间件 谢谢解决方法:这取决于您对“可扩展性”的含义. RabbitMQ专为实现高稳定性和可扩展性而设计. 还有ZeroMQ,专为极高性能而设计(但功能较

python-具有redis pubsub的Django / gevent socket.IO.我在哪里放东西？

我有一个隔离的python脚本,该脚本仅从Twitter的流API捕获数据,然后在接收到每条消息时,使用redis pubsub将其发布到“ tweets”频道.这是该脚本： def main(): username = "username" password = "password" track_list = ["apple", "microsoft", "google"]

python-txredisapi订阅并收听异步

我正在使用Python,Twisted和Redis进行项目.因此,团队决定使用txredisapi进行Python模块和Redis之间的通信.这个项目做很多不同的事情,我们需要订阅几个频道来监听Redis发送的消息,而其他功能不会停止(异步). 一个执行程序可以同时处理所有工作并监听Redis发送的消息吗？还是必须分开

javascript-KnockoutJS,使用可订阅的. callbackTarget

我想在我的应用程序中实现一个简单的pub-sub,因此可订阅的KO似乎很有希望. 我有以下代码. var announcer = new ko.subscribable(); var s1 = announcer.subscribe(function(val){ console.log('subscriber1: ' + val); }, null, 'news'); var s2 = announcer.subscribe(fun

python-wx.lib.pubsub：如何更改计时器中的值

您好,我有一个问题,计时器设置为1000毫秒,我想用单选按钮更改该值.上面有一个示例代码,但我不知道确切的操作方法.wx.lib.pubsub是否可能更改计时器的值？有人可以给我一个例子吗？ 这是代码： import wx import time class SettingsFrame(wx.Frame): def __init__(self):

用于golang <-> python通信的最简单的pub-sub,可能跨机器吗？

我正在使用Golang编写的Web应用程序,需要调用Python程序/模块来完成一些繁重的工作.由于那会占用大量内存/ CPU,因此它可能在单独的计算机上.由于Golang和Python无法直接对话,因此有3种方法可以实现此目的： >只需从Go(如果在同一台机器上)(或RPC？)中将python程序作为OS进程执行即可.>

将消息发布到MQ Topic时是否可以使用内置关联？

我对WebSphere MQ 7中主题的使用只迷失了一点.假设一个简单的场景： >我有一个将消息发布到主题的过程. >我有零个或多个订阅者收到该消息.>任何订户都可以决定对收到的消息=可选的“答复”作出反应. (旁注：最初的决定是也将主题用于回复,但如有必要,我将其更改为队列)已发布的消息可

使用PHP在网络上实时更新？

我希望在网络上的文档上实现实时协作.是否有某种库可以在PHP中启用它？ similar to SignalR通过长轮询创建“持久连接”的东西. 更新为pubsubhubbub http://code.google.com/p/pubsubhubbub/source/browse/trunk/publisher_clients/php/找到了该库 搜索图书馆名称导致我进入How to im

java-SubmissionPublisher在提交时未调用订户的Next

每隔一段时间,我都会通过某个查询来检索推文. 这些推文必须传递给计算和操纵这些推文的服务.因此,这些服务已订阅我的发布者.因此Publisher.hasSubscribers()返回true.但是Submit或offer函数不会调用我的订阅者的onNext.因此,作为“修复”,我循环浏览订户并自己调用它.但是事实并非

php-服务器端推送的可扩展解决方案？

我想实现一种机制,该机制将提供RESTful API,该API允许客户端使用服务器注册对主题的兴趣,并在兴趣被注册后从服务器接收异步通知.在企业(消息传递)体系结构中,这称为发布/订阅“模式”. 对于桌面应用程序,这是很容易实现的-但是对于Web应用程序,事实证明这更加困难. 是否有一个(最

将Android-Tablet用作MQTT服务器

我已经阅读了有关使用MQTT协议的“消息系统”的信息.但我一直在阅读有关星座的信息： 将Android用作未安装在Android智能手机oder平板电脑上(但作为独立服务器)的MQTT-Client和MQTT-Server. 是否可以将一个Android平板电脑用作MQTT服务器,而将其他一些Android平板电脑(例如5个平板电

javascript – pubnub和head.js

有没有人设法正确整合pubnub和head.js？ Pubnub希望我将他们的脚本放在页面底部,并带有< div>标签就在它之前.这确保了`标签在最后调用javascript时完全加载. 问题是,我的应用程序和pubnub的其余部分都是通过head.js加载的,因此它继续发生JS文件在pubnub订阅/发布密钥之前加载并且它

javascript – 如何在Redis / Node.js / Socket.io pub / sub设置中让不同的Web浏览器订阅单独的频道？

我希望不同的客户端(Web浏览器)能够订阅单独的Redis频道. 我能够将请求的通道从客户端页面传递到node.js服务器.但是,如果我有三个浏览器订阅,每个订阅三个单独的频道,所有三个浏览器接收发布到三个频道中的任何一个的消息. 这是客户端HTML代码.我有三个单独的页面,其中频道名称是

java – 在春天发布 – 订阅？

任何人都可以告诉我如何在Spring中使用Publish-Subscribe模式吗？ Spring是否有任何内置功能来实现它？ 在Java中我们可以这样做：http://www.avajava.com/tutorials/lessons/observer-pattern.html.解决方法:Spring是Java;显然,你可以在Spring中使用任何Java模式,还有Spring的额外好处(

python – ZMQ pub / sub可靠/可扩展设计

我使用ZMQ设计了一个pub / sub架构.我需要最大的可靠性和可扩展性,并且在所提供的可能性方面有点迷失. 目前,我有一个由经纪人链接的出版商和订阅者.代理是一个简单的转发器设备,为发布者提供前端,为订阅者提供后端. 我需要在代理崩溃或断开连接时处理这种情况,并提高整体可伸缩性.

Spring Integration：发布订阅频道.它是异步的吗？

在入站网关收到String消息后,我正在使用发布 – 订阅通道,并将其并行发送到记录器以记录消息,并转换为变换器以转换消息.我希望这两种活动同时发生. 我的问题非常简单 – Spring集成中的发布订阅频道是否并行发送消息给它的子文件？ 以下是spring-integration-context.xml源代码片段

javascript – 授予成功后无法订阅频道

这就是我在PHP中所做的： $pubnub = new Pubnub(array( 'subscribe_key' => '<SUBSCRIBE_KEY>', 'publish_key' => '<PUBLISH_KEY>', 'secret_key' => '<SECRET_KEY>', 'uuid�

java – 模块的设计模式,它不断检查系统中的其他模块是否正常工作？

我正在实现一个java项目,其中有多个解耦模块与共享服务(数据库/ Web服务)交互. 有一个运行状况检查器模块,可以连续轮询所有模块以查看它们是否正常运行.如果发现模块处于非活动状态或无法正常运行,则运行状况检查程序模块会执行修复并重新启动它. 这属于哪种行为模式？解决方法:Heal

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

我想做这样的事情： var events = require("events"); var emitterA = new events.EventEmitter(); var emitterB = new events.EventEmitter(); emitterA.addListener("testA", function(){ console.log("emitterA detected testA"); }); emitt

android – 如何发布和解析pubsub xmpp smack库的自定义有效负载

这个问题在here和here之前被问到,但我从那里得不到答案. 我正在开发我正在使用pubsub和xmpp的应用程序,对于android我正在使用smack库.我想将自定义有效负载发送到节点,并在接收自定义有效负载时如何解析并将其显示在列表中？现在我能够发送和接收消息,但它只是文档中的一个小例子.这

有什么方法可以让D-Bus在多台Linux机器上运行,可能通过防火墙？

D-Bus specification说 D-Bus is.. a simple way for applications to talk to one another… Currently the communicating applications are on one computer… 我想像D-Bus这样的东西,但是可以在多台Linux机器上工作,并且可能涉及防火墙.例如,如果我的邮件服务器决定它收到一

java – ZeroMQ,我们可以使用inproc：transport和pub / sub消息模式

场景： 我们正在评估ZeroMQ(特别是jeroMq)的事件驱动机制. 应用程序分布在多个服务(发布者和订阅者都是服务)可以存在于同一个jvm或不同节点中,这取决于部署体系结构. 意见 为了玩游戏我用inproc创建了一个pub / sub模式：作为传输,使用jero mq(版本：0.3.5) >线程发布能够发布(看起来像

Python Asyncio阻止了协同程序

我正在尝试编写基于Asyncio的简单程序和使用ZeroMQ实现的发布/订阅设计模式.出版商有2个协同程序;一个用于侦听传入的订阅,另一个用于将值(通过HTTP请求获取)发布到订阅者.订户订阅特定参数(在这种情况下为城市名称),并等待该值(该城市的温度). 这是我的代码： publisher.py #!/usr/

php – Laravel作业队列未使用Redis驱动程序进行处理

我正在创建一个作业,将其推送到自定义队列,并尝试使用Redis驱动程序然后在它到达队列时处理该作业,但没有成功： class MyController extends Controller { public function method() { $job = (new UpdateLiveThreadJob())->onQueue('live'); $this->dispatch(