publish-subscribe 相关问题

发布/订阅是一种消息模式，其中消息的发送者（发布者）不对要直接发送到特定接收者（订阅者）的消息进行编程。相反，已发布的消息被表征为频道，而不知道可能存在的订户（如果有的话）。

在 GCP PubSub 中，如果必须重试消息，如果配置了退避，那么在重试尝试之前，它是否会被推送到现有消息的后面？

我想检查特定消息的重试在 GCP 发布-订阅中如何工作？如果必须重试一条消息并且订阅还有其他消息，当前消息是否会被推到后面，或者...

google-cloud-pubsub publish-subscribe

回答 1 投票 0

在订阅上应用过滤器时，Python Pubsub 订阅者客户端不会拉取消息

我在我的 Python Web 应用程序中使用 Pubsub 流式拉取订阅。当我没有应用任何订阅过滤器时，订阅者客户端能够成功从

python google-cloud-pubsub publish-subscribe

回答 1 投票 0

NATS-Python中使用request-reply时如何设置订阅和发布权限？

我想设置auth权限，但是使用请求-回复模式时似乎有所不同。这是我的设置：值.yaml 用户： -用户：测试密码：测试测试权限：订阅：[“...

kubernetes-helm publish-subscribe nats.io nats-jetstream

回答 1 投票 0

无法从正在运行的事件循环中调用 asyncio.run()

我有一个在 uvicorn 服务器内运行的 python 应用程序。我已经创建了一个 Pub/sub 订阅者并尝试从我的 main.py 中启用它。我正在使用流式拉取订阅。现在，我的

python async-await python-asyncio google-cloud-pubsub publish-subscribe

回答 1 投票 0

subscribe()方法是否阻塞？

我从 Project Reactor 开始，我无法理解为什么这段代码无限地打印“Hello”并且从不返回 Disposable 对象。 Flux Flux = Flux.generate(sink -&... 我从 Project Reactor 开始，我无法理解为什么这段代码无限地打印“Hello”并且从不返回 Disposable 对象。 Flux<Object> flux = Flux.generate(sink -> sink.next("Hello")); Disposable disposable = flux.subscribe(System.out::println); disposable.dispose(); System.out.println("This doesn't print"); 我认为，当调用 subscribe() 方法时，它必须立即返回 Disposable 对象，如果我愿意，我可以使用该对象取消订阅。我知道这个 subscribe 方法中的代码在同一个线程中运行，如果我在 delayElements 调用之前替换 subscribe 方法，那么下面的代码将起作用，因为它在单独的守护线程中运行，所以可以解释为什么吗？它是否停止在 subscribe 方法并且不返回 Disposable 以及是否有任何方法可以通过调用 subscribe 方法来管理订阅？是否可以类比delayElements方法，在单独的线程中执行，并且调用subscribe方法的结果立即返回Disposable？我找不到这个问题的具体答案。在我看到的所有示例中，要么是有限数据流，要么使用了delayElements方法。是的，subscribe()在这个特定场景中会阻塞。 Reactor 是并发无关的，这意味着默认情况下它不会对您强制执行任何线程/异步性，并在调用线程（在本例中为主线程）上执行管道。您可以使用 subscribeOn 或 publishOn 显式更改此设置，也可以使用 delayElements 等某些运算符隐式更改。 Flux<Object> flux = Flux.generate(sink -> sink.next("Hello")).publishOn(Schedulers.parallel()); Disposable disposable = flux.subscribe(System.out::println); disposable.dispose(); System.out.println("This doesn't print");

java project-reactor publish-subscribe blocking

回答 1 投票 0

如何获取GCloud Pubsub的所有消息？

我正在编写一个计划的云函数，它订阅一个 pubsub 主题并从 pubsub 中提取所有消息，直到队列空闲。我想确认一些消息，但确认其他消息，以便它们

python google-cloud-platform google-cloud-pubsub publish-subscribe python-3.9

回答 1 投票 0

非父子React组件之间如何共享数据？

在子父关系中的组件之间共享数据的过程在 React 文档中有详细记录并直接处理。不太明显的是 h...

reactjs publish-subscribe observer-pattern rxjs reactjs-flux

回答 2 投票 0

如何存储Websocket连接以进行过滤？

我正在尝试为一家运输公司构建一个系统。该公司拥有多辆卡车，将物品运送到不同的国家。该系统的用例之一是跟踪每辆卡车并查看...