如何避免2个可观察到的订阅者的竞争情况？

在云计算领域中，避免两个可观察到的订阅者之间的竞争情况可以通过以下方法实现：

使用消息队列：消息队列是一种常见的解决方案，可以将发布者和订阅者解耦。发布者将消息发送到消息队列中，而订阅者从消息队列中接收消息。这样，即使有多个订阅者，它们也可以独立地消费消息，避免了竞争情况的发生。腾讯云提供了消息队列产品，例如腾讯云消息队列 CMQ（https://cloud.tencent.com/product/cmq）。
使用事件驱动架构：事件驱动架构是一种基于事件的系统设计方法，通过定义和触发事件来实现系统的解耦和灵活性。在这种架构中，发布者发布事件，而订阅者订阅感兴趣的事件。当事件发生时，订阅者会接收到相应的通知，从而避免了竞争情况的发生。腾讯云的云函数 SCF（https://cloud.tencent.com/product/scf）可以用于实现事件驱动架构。
使用分布式锁：分布式锁是一种用于协调分布式系统中并发访问的机制。通过使用分布式锁，可以确保同一时间只有一个订阅者能够处理某个资源或执行某个操作，从而避免了竞争情况的发生。腾讯云的分布式锁服务 TDSQL（https://cloud.tencent.com/product/tdsql）可以用于实现分布式锁。
使用分布式事务：如果多个订阅者需要对同一资源进行操作，并且需要保证操作的一致性，可以使用分布式事务来避免竞争情况。分布式事务可以确保多个操作在一个事务中进行，要么全部成功，要么全部失败。腾讯云的分布式数据库 TDSQL（https://cloud.tencent.com/product/tdsql）支持分布式事务。

总结起来，避免两个可观察到的订阅者之间的竞争情况可以通过使用消息队列、事件驱动架构、分布式锁或分布式事务等方法来实现。腾讯云提供了相应的产品和服务来支持这些解决方案。

如何避免2个可观察到的订阅者的竞争情况？

android、rx-java2

我正在尝试在我的应用程序中的几个不同位置实现1个可观察对象的一致调用。所以，我写了一些例子，但我不能成功完成。Random.nextLong(500), TimeUnit.MILLISECONDS) } 因此，我尝试使用share运算符并使requestResponse返回ConnectableObservable，但无论如何都不起作用因此，我期望在日志中看到的结果。

浏览 17提问于2019-08-31得票数 1

2回答

具有反应性扩展的双向通信

c#、.net、system.reactive、reactive-programming

让我们想象一下，我有一个可以观察到的热点，这是天气事件的一个来源。此源是与远程服务器的套接字连接，该服务器提供有关当前位置天气的信息。远程服务器还可以向我发送有关其他相关主题的事件，如交通、极端天气警告等。如果我发出命令来表示这个愿望。我如何在不创建可观察到的和观察者之间的耦合的情况下用反应性扩展来建模呢？其思想是，当我订阅ExtremeWea

浏览 3提问于2014-03-31得票数 1

回答已采纳

2回答

如何通过Rx测试防止绞刑？

c#、system.reactive、rx.net

我正在用下面一个简化的测试用例复制我的Rx问题。下面的测试挂起了。我确信这是一个小的，但基本的，我缺少的东西，但不能把我的手指放在它上。在我的例子中，GetProgress()是发布下载进度的各种Observables的合并，其中一个Observables是每当有人调用方法删除下载时发布0的Subject<double>。种族条件确定的神秘和西奥多祖利亚斯可以(？)发生在现实生活中。我展

浏览 1提问于2019-12-05得票数 2

回答已采纳

1回答

RxJS订阅用户数量的更改

angular、rxjs、rxjs-observables、subject-observer

问题：--我使用Subject可观察到在组件之间传递字符串数据(在层次结构中相距太远)。当组件订阅或取消订阅时，我想知道主题的订阅者有多少。如何才能实现上述目标？对不起，我是RxJS的新手。背景：我在顶部(导航栏)有一个简单的搜索/筛选字段。主视图显示一个组件，一些组件是可搜索的，另一些则不是。每个可搜索组件订阅搜索/过滤器(通过服务)。I希望

浏览 9提问于2021-04-27得票数 0

2回答

从IObservable<T>获得Action<T>的最佳方法

c#、system.reactive

我找到了两种可以帮助我的方法：Observable.FromEvent()和Observable.Start() }); 第二个操作参数将给定的事件处理程序从底层的.NET事件中分离出来.但是OnAction方法不是.NET事件。那么，从IObservable方法创建OnAction的最佳方法是什么？

浏览 5提问于2014-05-06得票数 2

回答已采纳

1回答

RxJava --观察员一段时间后不会得到onNext()项

java、rx-java、reactive-programming

我有一个由几个相互关联的组件组成的系统。一切都运行良好一段时间，但经过一定时间，有几个观察者停止接收由一个可观察的onNext()发送的项目。，并订阅Component2。这个可观察到的对象在循环中发出一些项，然后在它完成时调用s.onComplete()。我注意到了一些奇怪的事情。如果我从程序中删除任何其他可观察到<em

浏览 2提问于2016-06-08得票数 0

1回答

RxJava:我怎么能重新设置一个长时间运行的热可观察链？

java、android、system.reactive、rx-java、rx-android

对于我的应用程序的搜索功能，我有一个热门的可观察的链，做以下工作。使用该字符串查询SQL (此查询可以从100 on到2000 on不等)(在Schedulers.io()上) 首先发出对chick<e

浏览 3提问于2015-08-04得票数 3

回答已采纳

2回答

RX误解行为

system.reactive

下面的repro代码演示了一个更复杂的流程中的问题： { }使用r src (var src = r.Publish().RefCount())运行这个代码段将生成从1到10的所有数字，将src切换到x(例如)只会产生对，实际上是第一个可观察到的订阅，除非我将Publish()更改

浏览 6提问于2014-03-25得票数 1

回答已采纳

1回答

角5后请求返回两次

angular、post、request

然而，帖子请求被发送了两次，我没有使用Cors，所以我假设这不可能是预先准备好的请求？Profile.component.ts ngoninit似乎运行了两次，因为我首先使用正确的id接收coinId，然后是未定义的coinId。

浏览 4提问于2017-12-06得票数 0

1回答

Rxjs在不通知订阅者的情况下静默地更新可观测值

javascript、angular、typescript、rxjs

我试图以静默的方式更新可观察到的内容，这样下一个值就不会通知订阅者了。我使用角反应形式和订阅形式控制值的变化，可观察到如下。this.form.get('someSelection').valueChanges.susbscribe(value => this.selectionValue = value); 在某些情况下，我希望手动更新控件的值，但通过这样做，可观察到<e

浏览 4提问于2020-08-04得票数 1

回答已采纳

1回答

AnonymousSafeObservable的用途是什么?创建它的时间/原因是什么？

system.reactive

我使用Where谓词和ObservableExtensions.Subscribe(this, Action<T>)方法订阅Observable。当在订阅Action中抛出异常时，我可以在堆栈上看到一个名为AnonymousSafeObserver的类，这似乎是导致在订阅Action中的异常之后处理我的底层Observable的原因。这不是我所期望的行为，也不是我以前在其他订阅中见过的行为，通常异常只是被

浏览 0提问于2013-07-29得票数 0

2回答

响应扩展吞食了线程池线程上调用的OnNext()的异常？

c#、system.reactive、reactive-programming

如果我在Scheduler.CurrentThread中使用ToObservable，它至少会抛出错误并终止程序，此时不执行OnCompleted是有意义的。但是，当这在主线程之外的线程中执行时，这种行为似乎是不合理的，也是不可接受的。我有错过什么吗？但是，当我在NUnit中以测试的形式运行这段代码时，它在2秒后(线程休眠时间)就会悄然退出，没有任何错误或消息(期望“完成”)。那么，是NUnit导致了这个问题吗？

浏览 3提问于2014-09-13得票数 4

回答已采纳

1回答

从远程API重用RxJava流

android、rx-java

我有一个API调用，我想用可观察到的方式包装它： final Observablereturn Observable.from(accounts); }); 如何使用可观察到的我需要处理帐户流，并从中提取不同的数据集。

浏览 2提问于2015-03-26得票数 2

回答已采纳

1回答

如何处理观察者的onNext在RxJava中引发的异常？

java、system.reactive、reactive-programming、rx-java

;}, Throwable::printStackTrace);我尝试过使用retry()和，但是，正如文档中所说的，它们的目的是处理可观察到的自身发出的错误。最简单的解决方案就是将整个onNext包到一个try-catch块中，但对我来说，这听起来并不是一个好

浏览 2提问于2014-08-16得票数 28

回答已采纳

1回答

RxJS可观测与订阅方法

javascript、rxjs

RxJS Observable是否在发出项后删除它(到Observer)？

浏览 2提问于2022-02-02得票数 2

回答已采纳

2回答

RxJava，一个可观察的多个订阅者: publish().autoConnect()

rx-java、reactive-programming

每当有人订阅可观察到的内容时，它就开始发出数字序列。我明白了。因此，当Subscriber 1连接时，它开始释放项。Subscriber 2马上就连接起来，为什么它没有得到值呢？从可观察的角度来看，我就是这样理解的：用户: 1 用户: 1 订户:1& 2向订阅者发送项“2

浏览 2提问于2017-01-28得票数 21

回答已采纳

1回答

iOS RxSwift是否可以从.replay()中观察到将完成事件传递给订阅者？

observable、swift4、ios11、rx-swift

我在试着弄清楚可观察到的可连接性。我已经看到有人说应该这样做，但在RxSwift中似乎没有这样做。这是我的错误，还是这是斯威夫特的正确行为？

浏览 3提问于2018-08-16得票数 1

1回答

从重放可观察对象中删除项目

buffer、system.reactive、replay

想象一下，您有一个通过其中一个创建的可重放对象。有没有一个Replay的变种，可以用一个方法来产生一个可观察的重放对象，让我从重放缓冲区中删除一个项目/消息/元素？我需要重放观察值来避免竞争条件:两个观察值A和B产生相关的消息。如果A生成一个消息m，那么B可能会生成一个相应的消息m' (但这是可选的)。为了从B的所有消息中过滤出m'，A的订户向B注册订户(针对

浏览 5提问于2013-08-15得票数 0

1回答