publish-subscribe相关内容

AWS SQS 订阅 AWS SNS 主题

我有一个用例,我想将单个 SQS 订阅到两个 SNS 主题.因此,发布到任何 SNS 的任何消息都应该在 SQS 中可用.所以我的问题是我们可以将一个 sqs 订阅到两个 SNS 主题吗? 这里的任何帮助将不胜感激. 解决方案 是的,这是可能的. 单个 SQS 可以订阅多个 SNS 主题 ..
发布时间:2021-11-27 11:09:34 其他开发

如何使用 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-11-26 18:58:01 其他开发

c++ - 如何在扩展的PUB-SUB模式中将发布者和订阅者与C++中ZeroMQ中的中介同步?

扩展PUB/SUB拓扑 在一个有 1 个中介的用例中,我有多个发布者和多个订阅者. 在 ZeroMQ 指南中,我了解了如何使用额外的 REQ/REP 套接字同步 1 个发布者和 1 个订阅者.我尝试为我的用例编写同步代码,但是如果我尝试根据 1-1 PUB/SUB 给出的逻辑编写代码,它会变得混乱. 当我们只有 1 个发布者时的发布者代码是: //接收同步请求的套接字zmq:: ..
发布时间:2021-11-17 02:42:44 其他开发

“通知和检查"的名称发布订阅架构?

基本的发布订阅架构问题.在高层次上,在设计 pubsub 时,我有时会面临两种架构之间的选择: 发布突变或“新状态". 某些数据库状态发生了变化,发布者通过 pubsub 通知该更改.但是它们在消息中包含了足够的信息,因此订阅者不需要在数据库上进行查找.想象一下,订阅者有一个数据库缓存.它可以接收突变或新状态,并在不进行查找的情况下更新其缓存. 我的问题是,这两种类型的架构有通用 ..
发布时间:2021-11-17 02:13:11 其他开发

zmq 与 redis 的 pub-sub 模式

redis 支持 发布订阅 zmq 还支持 通过消息代理发布订阅 在它们之间进行选择的架构优点\缺点是什么? 我的目标是超出明显的用例特定性能基准测试应该完成的点(这里是 一个很好的例子). 假设使用 Python 等高级语言. 解决方案 我使用 Python 处理过 ZeroMQ 和 Redis.我会说 ZeroMQ 更健壮,它提供了真正简单的负载平衡,而且不仅仅是发布- ..
发布时间:2021-11-17 01:59:52 其他开发

Lagom 使用 Kafka 发布消息

此处仅描述了一种发布方式.还有别的方法吗?我需要使用动态主题 ID 和自定义事件制作发布而不使用 persistentEntityRegistry 的示例?以及如何使用 eventId 发布事件? @Override默认描述符描述符(){返回named("helloservice").withCalls(pathCall("/api/hello/:id", this::hello),pathC ..
发布时间:2021-11-12 03:22:22 其他开发

Kafka 有持久订阅功能吗?

我有兴趣在我的一个项目中使用 Kafka,但是当其中一个订阅者(消费者)断开连接时,消息代理必须保留这些消息. 我看到 JMS 有这个功能. 在网站上说 Kafka 具有耐用性特性. 是和JMS一样还是意思不同? 解决方案 Consumer 从 kafka(brokers)拉取数据.消费者指定它想要收集数据的位置的偏移量.如果消费者断开连接并返回,它可以从离开的地方继续. ..
发布时间:2021-11-12 02:55:20 其他开发

每个生产者的 Kafka 主题

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

Angularjs pubsub 与 $broadcast

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

angular 模块中的全局通信:事件总线或中介模式/服务

到目前为止,我已经看到了许多问题的解决方案.当然,最简单的方法是将 $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 其他开发

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

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

直接从 Angular 客户端订阅 Azure 事件网格主题

我正在开发一个需要响应来自第三方 WebHook 的事件的应用程序.我选择 Azure 事件网格作为我选择的事件代理,前端使用 Angular,后端使用 Asp.Net Core. 在我当前的解决方案中,我使用 HTTP 触发的 Azure 函数从 WebHook 发布到 Azure 事件网格.此函数将第三方事件格式化为正确的 Azure 事件网格格式(以相关事件用户为主题,事件类型为 We ..
发布时间:2021-11-04 11:56:50 其他开发

如何在 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 其他开发

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

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

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

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

如何配置多个 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 其他开发

Pusher 渠道结构在社交状态更新应用中的策略是什么?

在构建社交应用程序时,通常会关注其他用户或主题,以此表示对用户或主题更新的兴趣.例如,在 Twitter 上关注其他用户、在 Facebook 上与其他人交朋友或在 Facebook 上喜欢产品或品牌. Pusher 拥有您订阅的频道 的概念.频道是一个人类可读的字符串,它为信息提供了一个逻辑标识符(例如“某个频道名称"),因此似乎很自然地表明,在社交应用程序中,关于用户或主题的任何更新都应 ..
发布时间:2021-06-23 18:46:27 其他开发

Redis Pub/Sub - 发布者也是订阅者?

我是 Redis 的新手,我一直在使用 Pub/Sub.由于依赖因素,我希望发布者也是频道的订阅者,这样当发布者通过频道发送消息时,他们也会收到消息.这可能吗? 解决方案 不,pub/sub 是不可能的,因为没有持久性.当发布者将消息发布到通道时,只有通道的连接客户端会收到消息.不会保存任何消息.由于您的发布者不会作为订阅者连接,因此您无法接收之前发布的内容.即使订阅者断开连接并重新连接, ..
发布时间:2021-06-23 18:46:24 其他开发

如何在Pubnub中重新连接?

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

ZeroMQ 个人订阅者队列

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