RxJava 多播

Multicasting in RxJava (RxJava中的多播) 原文

Multicasting is a key method for reducing duplicated work in RxJava.
多路是一種解決在RxJava減少重復(fù)的有效方法闪萄。

When you multicast an event, you send the same event to all downstream operators/subscribers. This is useful when you're doing an expensive operation like a network request. You don't want to repeatedly execute identical network requests for each subscriber - you just want to execute one then multicast the results.

當(dāng)你多播一個(gè)事件的時(shí)候闷营,你發(fā)送了同樣的事件給下流 operators/subscribers.皮仁。這是非常有用的剃根,比如當(dāng)你正在做一個(gè)網(wǎng)絡(luò)請(qǐng)求操作時(shí)。你不想對(duì)每個(gè)訂閱都做同樣的網(wǎng)絡(luò)請(qǐng)求操作--你只是想執(zhí)行一次網(wǎng)絡(luò)請(qǐng)求鹰祸,然后把請(qǐng)求的結(jié)果多播出去甫窟。

There are two ways to multicast:
有兩種方式去實(shí)現(xiàn)多播:

  • Use a ConnectableObservable (via publish() or replay()1)
    使用一個(gè)ConnectableObservable ,通過(guò)publish() or replay()操作符實(shí)現(xiàn)蛙婴。
  • Use a Subject

Any work done before the ConnectableObservable or Subject will only happen once, then that work will be multicast to all downstream Subscribers.
任何在ConnectableObservable or Subject之前完成工作只會(huì)執(zhí)行一次粗井,接著把結(jié)果多播給所有的下流訂閱者。

There is a subtle point here you must recognize: Streams only multicast at the point of the ConnectableObservable or Subject. As a result, any work done after the multicast is duplicated per Subscriber.
必須認(rèn)識(shí)到一點(diǎn):多播只會(huì)在使用 ConnectableObservable or Subject那個(gè)點(diǎn)發(fā)生街图。因此浇衬,對(duì)于多播以后的操作每個(gè)訂閱者都會(huì)去執(zhí)行。

Let's look at an example of how this can come into play:

Observable<String> observable = Observable.just("Event")  
    .publish()
    .autoConnect(2)
    .map(s -> {
      System.out.println("Expensive operation for " + s);
      return s;
    });

observable.subscribe(s -> System.out.println("Sub1 got: " + s));  
observable.subscribe(s -> System.out.println("Sub2 got: " + s));

// Output:
// Expensive operation for Event
// Sub1 got: Event
// Expensive operation for Event
// Sub2 got: Event
Here we have a ConnectableObservable, an expensive map() operation and two Subscribers. The surprising result is that the expensive map() operation is executed twice, even though we tried to prevent that with publish()!
從上面的結(jié)果來(lái)看餐济,map()操作執(zhí)行了兩次耘擂,盡管我們已經(jīng)使用了publish()來(lái)實(shí)現(xiàn)多播。也就驗(yàn)證了只要使用了 ConnectableObservable(通過(guò)publish() or replay()操作符實(shí)現(xiàn)) or Subjec之后絮姆,那么后面的操作每個(gè)訂閱者都會(huì)去執(zhí)行醉冤。

This chart makes the situation clearer:

Chart showing why publish didn't work

If you actually wanted the map() to happen once, you would need to put it before the publish() call:
如果你想要map()只執(zhí)行一次,你需要把map()操作放在publish()調(diào)用之前:

Observable<String> observable = Observable.just("Event")  
    .map(s -> {
      System.out.println("Expensive operation for " + s);
      return s;
    })
    .publish()
    .autoConnect(2);

observable.subscribe(s -> System.out.println("Sub1 got: " + s));  
observable.subscribe(s -> System.out.println("Sub2 got: " + s));

// Output:
// Expensive operation for Event
// Sub1 received: Event
// Sub2 received: Event
Here's an updated chart:


Chart with correct publish usage

What's the lesson here? If you're relying on multicasting to reduce work, make sure you multicast at the right point.
我們學(xué)到了什么篙悯? 如果你想要通過(guò)multicasting (多播)來(lái)減少工作蚁阳,確定你在正確的地方使用ConnectableObservable(通過(guò)publish() or replay() 操作符實(shí)現(xiàn))。

For better or worse, a lot of people are using Subjects. One advantage is that they are multicast but you have to remember that they are only multicast at the point they emit. If you have a bunch of expensive operators applied downstream of the Subject then you should consider adding another publish() somewhere downstream.

不論好壞鸽照,好多人使用Subjects螺捐。一個(gè)好處它確實(shí)是多播的,但是它只會(huì)在發(fā)送事件(OnNext, OnComplete等)的地方多播矮燎。如果你下游要使用一些昂貴的操作符如(map())定血,最好在下游的某個(gè)地方給這個(gè)Subject 加一個(gè)publish() 操作符來(lái)減少工作。

share() and cache() are also options, but they are basically just shortcuts around ConnectableObservable. share() is just publish().refCount() and cache() can be recreated by using replay().autoConnect().

share()和cache()也是一個(gè)方法诞外,但是它們也只不過(guò)是ConnectableObservable的簡(jiǎn)寫(xiě)澜沟。share()可以使用publish().refCount() ,cache()使用replay().autoConnect()來(lái)代替峡谊。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末倔喂,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子靖苇,更是在濱河造成了極大的恐慌席噩,老刑警劉巖,帶你破解...
    沈念sama閱讀 222,729評(píng)論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件贤壁,死亡現(xiàn)場(chǎng)離奇詭異悼枢,居然都是意外死亡,警方通過(guò)查閱死者的電腦和手機(jī)脾拆,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,226評(píng)論 3 399
  • 文/潘曉璐 我一進(jìn)店門(mén)馒索,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)莹妒,“玉大人,你說(shuō)我怎么就攤上這事绰上≈嫉。” “怎么了?”我有些...
    開(kāi)封第一講書(shū)人閱讀 169,461評(píng)論 0 362
  • 文/不壞的土叔 我叫張陵蜈块,是天一觀的道長(zhǎng)鉴腻。 經(jīng)常有香客問(wèn)我,道長(zhǎng)百揭,這世上最難降的妖魔是什么爽哎? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 60,135評(píng)論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮器一,結(jié)果婚禮上课锌,老公的妹妹穿的比我還像新娘。我一直安慰自己祈秕,他們只是感情好渺贤,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,130評(píng)論 6 398
  • 文/花漫 我一把揭開(kāi)白布。 她就那樣靜靜地躺著请毛,像睡著了一般志鞍。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上获印,一...
    開(kāi)封第一講書(shū)人閱讀 52,736評(píng)論 1 312
  • 那天述雾,我揣著相機(jī)與錄音街州,去河邊找鬼兼丰。 笑死,一個(gè)胖子當(dāng)著我的面吹牛唆缴,可吹牛的內(nèi)容都是我干的鳍征。 我是一名探鬼主播,決...
    沈念sama閱讀 41,179評(píng)論 3 422
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼面徽,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼艳丛!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起趟紊,我...
    開(kāi)封第一講書(shū)人閱讀 40,124評(píng)論 0 277
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤氮双,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后霎匈,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體戴差,經(jīng)...
    沈念sama閱讀 46,657評(píng)論 1 320
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,723評(píng)論 3 342
  • 正文 我和宋清朗相戀三年铛嘱,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了暖释。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片袭厂。...
    茶點(diǎn)故事閱讀 40,872評(píng)論 1 353
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖球匕,靈堂內(nèi)的尸體忽然破棺而出纹磺,到底是詐尸還是另有隱情,我是刑警寧澤亮曹,帶...
    沈念sama閱讀 36,533評(píng)論 5 351
  • 正文 年R本政府宣布橄杨,位于F島的核電站,受9級(jí)特大地震影響乾忱,放射性物質(zhì)發(fā)生泄漏讥珍。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,213評(píng)論 3 336
  • 文/蒙蒙 一窄瘟、第九天 我趴在偏房一處隱蔽的房頂上張望衷佃。 院中可真熱鬧,春花似錦蹄葱、人聲如沸氏义。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 32,700評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)惯悠。三九已至,卻和暖如春竣况,著一層夾襖步出監(jiān)牢的瞬間克婶,已是汗流浹背。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,819評(píng)論 1 274
  • 我被黑心中介騙來(lái)泰國(guó)打工丹泉, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留情萤,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 49,304評(píng)論 3 379
  • 正文 我出身青樓摹恨,卻偏偏與公主長(zhǎng)得像筋岛,于是被迫代替她去往敵國(guó)和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子晒哄,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,876評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容