publish-subscribe相关内容

未使用com.google.cloud.pubsub.v1获取TopicName类的';个方法

我正在使用GCP PubSub和TopicName类。我想编写以下代码: TopicName topicName = TopicName.of(projectId, topicId); 但我无法获取'of'方法。 请大家指出我做错了什么。 推荐答案 我将我们的讨论总结为答案。 您引用的是documentation,它解释了如何使用Java在PubSub中发布消息,并且 ..

Pubsubite订阅第一条消息速度极慢

我使用的是GCP pubsubite,带有一个分区、几条消息的朴素主题。Python客户端库。使用回调执行标准订阅,订阅客户端,subscribe方法。在调用该方法和接收第一条消息之间,大约需要30秒。后续邮件速度较快,因为它们已在缓存中。 关于超长发作的问题:这是意料之中的吗?还是有一些常见的嫌疑人? 感谢您的指点。 编辑:代码粘贴在下面。编辑凭证后在Docker中运行。我的打 ..

如何在围棋中接收Redis发布消息

我正在尝试在Go中使用Redis PubSub,以便能够在订阅期间传递/发布消息并检索它。 我已经能够正确设置代码的发布和订阅/PubSub部分。以下是我的代码。我希望在订阅期间检索的(字符串)消息是test message.,但我的代码的输出给出了频道、种类和计数,并且没有显示预期的消息(test message)。 在Go中使用Redis发布/订阅发布后如何获取想要的消息(test ..
发布时间:2022-06-16 21:55:07 其他开发

线程中出现异常&;quot;main&;lang.UnssufiedLinkError:在Eclipse中的java.Library.Path中没有jzmq

导入org.zeromq.ZMQ; -对于上面的导入语句,我使用的是jzmq主文件夹中的“org文件夹”,该文件夹由ZMQ.Java文件组成。 -因此,编译没有问题。当我开始运行该程序时,它显示以下异常 线程“main”java.lang.UnssufiedLinkError中出现异常:在java.Library.Path中没有jzmq 在java.lang.ClassLoader. ..
发布时间:2022-06-16 21:50:45 Java开发

RabbitMQ发布/订阅与轮询

我在应用程序中使用RabbitMQ来实现客户端和服务器之间的通信。 大多数情况下,客户端将信息发送到服务器。但有时客户端需要了解服务器中的一些更新。 目前,我使用轮询每隔1分钟询问服务器是否有一些更新。 我的问题是,使用发布/订阅机制将更新推送到客户端会不会更好? 我有大量的客户(大约10000个)。那么,是否可以打开10000个队列,每个客户端一个队列? 推荐答案 ..
发布时间:2022-06-16 21:43:11 其他开发

如何将死信消息发送回原始主题?

我的Google Cloud发布/订阅订阅使用的是死信主题。我最近遇到了一次中断,导致许多邮件无法处理&它们最终变成了死信主题。 中断已解决,我想轻松地将死信订阅的内容发送回原始订阅。它们仍然存在于队列中(我没有消耗死信子的东西),所以我只需要将它们发送到某个地方。 这是一项管理任务,因此我希望手动启动它,如果这有什么不同的话。最好是通过用户界面,但我在那里看不到任何东西。 推荐 ..

中介者模式与发布/订阅

谁能指出两者之间的主要区别吗? 似乎,至少在概念上,这两者是非常密切相关的。如果我大胆猜测,我会说发布/订阅方法是中介模式的子集(因为中介不一定需要以发布/订阅的方式使用,但后者似乎需要一种中介对象)。那接近它了吗? 推荐答案 我如何描述不同之处在于,在Mediator中,您可能关心最终应用程序是否收到消息。因此,您可以使用它来保证谁在接收消息。而在pub/subs上,你只需发布 ..
发布时间:2022-06-16 21:12:45 C/C++开发

nestjs全局pubsub实例和依赖项注入

我遵循了Nestjs DOCS关于发布/订阅的说明: 根据示例,pubsub在给定解析器的顶部使用以下命令进行初始化: const pubSub = new PubSub(); 后来文档说: “我们在这里使用了一个本地的PubSub实例。相反,我们应该将PubSub定义为提供程序,通过构造函数(使用@Inject()修饰器)注入它,并在整个应用程序中重用它” { p ..
发布时间:2022-03-07 10:34:13 其他开发

AMQP 如何克服直接使用 TCP 的困难?

AMQP如何克服发送消息时直接使用TCP的困难?或者更具体地说是在发布/订阅场景中? 解决方案 在 AMQP 中有一个代理,该代理接收消息,然后完成将它们路由到交换和队列的困难部分.您还可以设置持久队列,即使客户端断开连接,也可以为客户端保存消息. 您当然可以自己完成所有这些工作,但要正确完成这些工作量很大.尤其是 RabbitMQ,已经在许多部署中进行了实战测试. 你还在使用 ..
发布时间:2022-01-11 18:06:45 其他开发

在 .NET 中使用 RabbitMQ 发布/订阅示例

我已经构建了这个示例:.net 中的 RabbitMQ 入门,但做了 2 个程序: 单一出版商 一个订阅者 我使用 BasicPublish 发布和 BasicAck 来收听,如示例所示.如果我在来自发布者的每条“发送消息"上运行一个发布者和几个订阅者,那么只有一个订阅者会收到它.因此,发布者向订阅者发送消息时存在某种顺序(当订阅者开始时),我想向所有订阅者发送一条消息.那个样本有什 ..
发布时间:2022-01-11 17:57:35 C#/.NET

实时应用新手 - Node.JS + Redis 或 RabbitMQ ->客户端/服务器如何?

我是实时应用程序开发的新手,我正在努力解决无数的选择.我已经阅读了尽可能多的博客文章、笔记和论文,人们很乐意分享.然而,在我的小脑袋里,一个简单的问题似乎没有答案.我认为其他一些人可能也有同样的问题,所以我不妨注册并在 SO 上发帖.如下: 我正在构建一个小型实时应用程序,它是异步聊天 + 另一个有趣的功能.我将我的选择归结为以下两个选项: LAMP + RabbitMQ Node. ..
发布时间:2022-01-11 17:39:31 服务器开发

事件驱动架构的jQuery插件?

是否有任何事件驱动架构 jQuery 插件? 第 1 步:订阅 订阅者订阅中间的事件处理函数,并传入一个回调方法,以及他们正在监听的事件的名称...... 即两个绿色订阅者将监听 p0 事件.蓝色的订阅者将监听 p1 事件. 第 2 步:p0 事件由另一个组件触发到事件处理程序 一个 p0 事件被触发到事件处理程序 事件处理程序通知它的订阅者该事件,调用他们在订阅时 ..

如何从 Firebase Cloud Function 在 Google Pub/Sub 中发布消息?

我写了一个函数来接收一个 http 请求并发送一封电子邮件.但是,我想收到一个 http 请求并发送一个 pub 消息.问题是文档不清楚.我该怎么做? 这是我的实际代码. exports.weeklyEmail = functions.https.onRequest((req,res) => {常量电子邮件 = '****@gmail.com'console.log('发送邮件')常量邮件 ..

如何取消订阅 socket.io 订阅?

假设有像这样订阅套接字服务器的对象: socket.on('news', obj.socketEvent) 这些对象的生命周期很短并且经常被创建,从而产生很多订阅.这看起来像是内存泄漏和容易出错的情况,可以通过这种方式直观地防止: socket.off('news', obj.socketEvent) 在对象被删除之前,但可惜的是,套接字中没有 off 方法.有没有其他方法 ..
发布时间:2021-12-30 21:51:19 前端开发

在 Knockout 中链接/同步视图模型的最佳方法是什么?

如果您在一个页面上有多个视图模型,您如何确保可以使它们保持同步?例如,如果添加了一个项目或在一个视图模型上单击了一个按钮,并且您希望另一个视图模型对该更改敏感,那么 Knockout 是否可以在本机进行管理,或者最好使用一些消息传递或发布/订阅架构. 我不想在模型之间管理可观察对象. 解决方案 Knockout 2.0 确实包含可让您执行基本发布/订阅的功能.这是一个示例,其中两个视 ..
发布时间:2021-12-29 20:20:36 其他开发

我应该使用什么?Socket.io 房间还是 Redis 发布订阅?

很简单的问题.我正在使用 nodejs 作为我的后端构建一个实时游戏,我想知道是否有任何可用的信息来说明哪个更可靠,哪个更有效?我在整个代码中大量使用 Redis 和 Socket.io.所以我想知道我是否应该使用 Socket.io 的 Rooms 或者我会最好使用 redis 的 pub-sub ? 更新:刚刚意识到您可能想要在 socket.io 房间上使用 redis pub/sub ..
发布时间:2021-12-28 09:19:00 其他开发