使用req/resp和pub/sub要求设计REST API
现在我正在为一个分布式系统设计REST接口。这是一个客户端/服务器架构，但有两种消息交换模式： 请求/响应：最符合REST原则的方法，它将是一个CRUD接口，可用于访问/创建/修改/删除服务器中的对象。 发布/订阅：这是我的主要疑问。我需要服务器尽快向客户端发送异步通知。 在网上搜索后...
使用Google Pub/Sub更新单例HashMap
我有一个使用情况，需要初始化一个HashMap，其中包含一组查找数据（关于IoT设备的物理位置等信息）。这些查找数据作为第二个数据集的参考数据，该数据集是PCollection。这个PCollection是一个数据流，提供IoT设备记录的数据。来自IoT设备的数据流使用作为Google Dat...
在双工绑定的WCF应用程序中处理断开连接的客户端
我们的 WCF 应用程序使用发布-订阅模型，基本上遵循了 Microsoft 的示例：Design Patterns: List-Based Publish-Subscribe。 虽然该服务提供了 subscribe() 和 unsubscribe() 的概念，但在客户端死亡或通道故障的情况...
Redis 的发布-订阅或 Socket.IO 的广播
我看到了这个代码片段： 在服务器上io.sockets.on('connection', function(socket) { const subscribe = redis.createClient(); const publish = redis.createClient(); ...
Golang: 我能转换为 chan interface{} 吗？
我正在尝试编写一个通用的订阅包装器，类似于：type Subscriber interface{ Subscribe(addr string) chan interface{} } 假设有一个我想要使用的库，其中有一个名为subscribe的方法，但它使用了chan library.O...
RabbitMQ：如何指定要发布到的队列？
RabbitMQ的Channel＃basicConsume方法提供以下参数：channel.basicConsume(queueName, autoAck, consumerTag, noLocal, exclusive, arguments, callback); 让我们具有告诉Ra...
Sails.js简单的私信系统（发布/订阅和模型）
我的目标: 使用Sails.js创建一个私人消息平台，尽可能简化代码。 最佳实践的假设: 使用 Sails.js Webockets 进行实时通知 使用 Sails.js PubSub 与 Websockets 一起使用数据库 使用 Sails.js .watch() 获取消息 ...
保持WCF回调通道无限期开放 / 如果客户端出现故障，则重新连接
我目前正在尝试设置类似于这样的东西: 一个服务器端的Windows WCF服务通过TCP侦听来自客户端Windows服务的连接。 当收到连接(客户端调用服务上的CheckIn方法)时，服务通过OperationContext.Current.GetCallbackChannel<T&...
实时应用新手-Node.JS+Redis或RabbitMQ->客户端/服务器如何？
我是一个实时应用程序开发的新手，试图理解各种选项。我阅读了许多人们乐于分享的博客文章、笔记和论文。然而，一个简单的问题在我的小脑袋中没有得到答案。我认为其他许多人可能有同样的问题，所以我也来这里发帖。问题如下： 我正在构建一个微型实时应用程序，其中包含异步聊天和另一个有趣的功能。我将我的选择...
如何在App Engine上实现一个轻量级发布-订阅服务？
在他的Google I/O 2009“App Engine上的离线处理：展望”演讲（video，slides）中，Brett Slatkin介绍了任务队列服务。 他指出， 发布-订阅系统最大化事务，解耦： 每秒大量小事务 一对多的扇出，接收者会发生变化 保证排序、过滤和两阶段提交 ...