publish-subscribe 第3页 - IT屋-程序员软件开发技术分享社区

每个生产者的 Kafka 主题

假设我有多个设备.每个设备都有不同类型的传感器.现在我想将每个传感器的每个设备的数据发送到 kafka.但我对 kafka 主题感到困惑.用于处理这些实时数据每个设备都有一个 kafka 主题，并且该设备的所有传感器都将数据发送到特定的 kafka 主题，或者我应该创建一个主题并让所有设备将数据发送到该主题. 如果我采用第一种情况，我们将为每个设备创建主题，然后，设备 1(传 ..

发布时间：2021-11-12 01:55:14 apache-kafka real-time scalability publish-subscribe bigdata 其他开发

Angularjs pubsub 与 $broadcast

我一直在阅读 Angularjs 中的事件传递，但我不相信使用 $broadcast 是个好主意. 像这样的博客一个提倡习惯 $on，即使它“感觉有点矫枉过正." 我的困惑是该实现使用范围的深度优先遍历并查找订阅者，这使得事件的速度取决于您的树结构.这是一些角度的代码: //疯狂警告:范围深度优先遍历//是的，这段代码有点疯狂，但它有效，我们有测试来证明它！//这一块应该与 $d ..

发布时间：2021-11-09 03:17:59 javascript angularjs publish-subscribe 前端开发

到目前为止，我已经看到了许多问题的解决方案.当然，最简单的方法是将 $rootScope 中的一个事件 $emit 作为事件总线，例如( https://github.com/btilford/anti-patterns/blob/master/angular/Angular.md ) angular.module('myModule').directive('directiveA', func ..

发布时间：2021-11-09 02:53:18 javascript angularjs design-patterns publish-subscribe mediator 前端开发

如果订阅者未在 2/4/6 角完成，如何等待返回语句

目前我正在处理 Angular6 项目，并且我有 auth-http-interceptor.此文件中的问题是我想每次都从 angular4-adal 服务获取刷新令牌/获取令牌，为此，我必须订阅获取令牌，该令牌将提供令牌，然后想在 authReq 对象中分配该令牌. 但是我的拦截方法的返回类型是 Observable. 那我怎么能等到订阅获取令牌然后返回next.handle(aut ..

发布时间：2021-11-08 23:17:27 angular publish-subscribe angular6 adal angular-observable 其他开发

如何在 TypeScript 中实现发布订阅模式?

我正在为我的游戏创建一个事件系统，目前我的代码如下所示: export const enum ET { Collision, Dying, Damage }type ActionCallback = (scene: Scene, event: GameEvent) =>空白;订阅(事件类型:ET，回调:ActionCallback){this.subscriptions[eventType].p ..

发布时间：2021-09-11 20:16:17 typescript events types publish-subscribe 其他开发

如何限制到 ZeroMQ 发布者端点的并发订阅者连接总数?

在 Linux 系统上使用 ZeroMQ 构建发布-订阅服务时，有没有办法强制执行并发订阅者限制? 例如，我可能想在资源有限的系统上创建一个 ZeroMQ 发布者服务，并希望通过设置到 tcp 发布者端点的 100 个并发连接的限制来防止系统过载.达到该限制后，来自 ZeroMQ 订阅者的所有后续连接尝试都将失败. 我知道 ZeroMQ 不提供有关连接/断开连接的通知，但我一直在寻找可 ..

发布时间：2021-06-23 18:46:36 zeromq publish-subscribe 其他开发

Redis，主题(发布/订阅)是否总是至少交付给一个订阅者?

例如，如果发生键/val 上的到期事件并且发送了一个主题，但所有客户端都关闭了，那么即使一个客户端上线并且在一年后该主题也将被传送并且订阅该主题? 如果两个客户稍后同时上网怎么办? 如果两个客户上网但中间有很大的延迟怎么办? 这些主题稍后会广播，但我注意到如果我掉线并重新连接，我可以在重新上线时获得这些主题. 当我重新启动时，尽管它是“新客户"，但我没有得到旧的. ..

发布时间：2021-06-23 18:46:33 redis publish-subscribe 其他开发

如何配置多个 PUB/单个 SUB python ZMQ Ubuntu

我有两个 VM(VirtualBOx、Ubuntu 18.04 和 python-zmq[16.0.2-2build2])在同一台物理机 (Win10) 中运行.两台机器都配置为Bridge，可以ping通192.168.1.66-192.168.1.55.我遵循了本教程 https://learning-0mq-with-pyzmq.readthedocs.io/en/latest/pyzmq/ ..

发布时间：2021-06-23 18:46:30 python zeromq publish-subscribe pyzmq Python

如何在Pubnub中重新连接?

我正在使用 PubNub 在我的 Js 代码中传输通知.一旦互联网断开连接并恢复，我无法弄清楚如何在 PubNub 中重新连接. 在我的初始化和执行中恢复:true this.listeners = {消息:msgEvent =>{控制台日志(msgEvent)；},状态:statusEvent =>{if (statusEvent.category === "PNNetworkUpCat ..

发布时间：2021-06-23 18:46:20 javascript publish-subscribe pubnub 前端开发

ZeroMQ 个人订阅者队列

我有一个关于 ZeroMQ PUB/SUB 的问题.发布者是为每个订阅者创建一个单独的队列，还是为所有订阅者创建一个队列(因此受到最慢订阅者的限制)? 解决方案每个连接的订阅者都有自己的队列.当订阅者速度很慢时，它自己的队列将填满然后溢出(默认情况下高水位为 1,000)，并且它的消息将被丢弃.这不会影响其他订阅者. ..

发布时间：2021-06-23 18:46:17 queue zeromq publish-subscribe 其他开发

如何在两个 VM 之间使用 pyZMQ 发布/订阅

我有两个 VM(VirtualBOx、Ubuntu 18.04 和 python-zmq)在同一台物理机 (Win10) 中运行.两台机器都配置为Bridge，可以ping通192.168.1.56-192.168.1.65.我遵循了本教程 https://learning-0mq-with-pyzmq.readthedocs.io/en/latest/pyzmq/patterns/pubsub. ..

发布时间：2021-06-23 18:46:14 python virtual-machine publish-subscribe pyzmq Python

如何在 ZMQ PUB/SUB 中获得转发器的冗余?

我尝试并运行了这个示例.效果很好. 我可以添加任意数量的发布者或订阅者，一切都将通过转发器进行通信.我担心的是冗余.如果转发器不再响应，则在转发器启动之前什么都不会工作. 我找到了一个示例用于 REQ/REP，但不能作为订阅者申请 PUB/SUB.但想法就在这里. 有没有办法在发布/订阅场景中使用类似的东西? 谢谢. 解决方案首先阅读 this 章节. 在它 ..

发布时间：2021-06-23 18:46:11 zeromq publish-subscribe pyzmq 其他开发

如何使用 acl 限制对 redis pubsub 中某些主题的访问?

我希望某些客户端无法订阅 Redis pubsub 中的某些主题.redis acl 可以实现吗? 解决方案是的，这就是您可以使用 ACL 将客户端限制为“foo"主题的方法: $ redis-cli127.0.0.1:6379>ACL SETUSER limitedpubsub on nopass -@all +subscribe|foo好的127.0.0.1:6379>AUTH 有 ..

发布时间：2021-06-23 18:46:08 redis acl publish-subscribe access-control 其他开发

rspec:如何测试 redis#subscribe 代码?

假设如下: class MyClass定义订阅$redis.subscribe('channel') 做 |on|on.message do |channel, msg|东西.创建(味精)结尾结尾结尾结尾我如何测试当 MyClass 执行 subscribe 时，它会为它在频道上收到的每条消息运行 Something.create? 解决方案你有这个代码，它不是很可测试.首先，绝对 ..

发布时间：2021-06-23 18:46:06 ruby rspec redis publish-subscribe 其他开发

从 OpenDDS 发布者传递复杂结构

我有以下idl结构.我想使用 opendds 发布它 #pragma DCPS_DATA_TYPE "B::CData"#pragma DCPS_DATA_KEY "B::CData id"模块 B {结构引用 {字符串短剧名；字符串剧集名称；字符串线；};结构体数据{长身份证；报价有效载荷；};}; 我用java编写了发布者和订阅者.但是在发布和订阅上述主题时，JVM 崩溃了. 有人对 ..

发布时间：2021-06-23 18:46:03 java publish-subscribe data-distribution-service Java开发

Redis 客户端广播问题(在 Socket.IO 的上下文中)

所以我阅读了一些关于扩展 Socket.IO 的文章.由于各种原因，我不想使用内置的 Socket.IO 缩放机制(主要是它似乎效率低下，因为它向 Redis 发布了更多的东西，然后从我的角度来看是必需的). 所以我想出了一个简单的想法: 每个 Socket.IO 服务器创建 Redis 发布/订阅/存储客户端，连接到 Redis 并订阅频道.现在，当我想广播数据时，我只需将其发布到 ..

发布时间：2021-06-23 18:46:00 redis socket.io scalability publish-subscribe disconnect 其他开发

Sails js 订阅由 groupid 属性限定的模型更改

我有一个名为 Groupfeed 的模型，它看起来像这样 module.exports = {架构:真，属性:{组别:{模型:'组'，要求:真},邮政编号:{型号:'post',要求:真},对象编号:{模型:'对象'，要求:真},}}; 在客户端，我可以使用订阅 Groupfeed 模型 io.socket.get('/groupfeed') 这是由蓝图api自动完成的然后 io.s ..

发布时间：2021-06-23 18:45:54 javascript socket.io sails.js publish-subscribe 前端开发

pub.py 中有无效的语法

后面的方法定义在 pubsub.py 中，它是站点包 pubsub 中的一个 python 文件.当我尝试使用它时，pycharm 用指向“->"的箭头告诉我这是无效的语法.我不知道为什么，我已经安装了 pypubsub. def getDefaultPublisher() -> 发布者:"""获取本模块默认创建的Publisher实例是进口的.有关此实例的详细信息，请参阅模块文档."""返回_ ..

发布时间：2021-06-23 18:45:51 publish-subscribe pypubsub 其他开发

如何在 pubsub 节点上发送/接收自定义项目负载

如何使用有效载荷在 pubsub 节点上发送/接收自定义项目，我使用的是 qsmack lib. 这是我的代码. StringBuilder strBuffer = new StringBuilder();strBuffer.append("Test") ..

发布时间：2021-06-23 18:45:48 android xmpp publish-subscribe 移动开发

Redis 多个订阅者

我有多个订阅者订阅了同一个 Redis 频道.Redis 是否保证订阅者订阅频道后，所有订阅者都能获得推送到频道中的所有消息? 解决方案来自 redis 文档其他客户端发送到这些频道的消息将由Redis 给所有订阅的客户端. 我想你的问题是肯定的. ..

发布时间：2021-06-23 18:45:46 redis publish-subscribe jeditorpane 其他开发

publish-subscribe相关内容