Android拾萃 - RxJava５種響應(yīng)類型的區(qū)別和背壓（三）

Android拾萃 - RxJava最簡(jiǎn)單的入門（一）
Android拾萃 - RxJava操作符列表和響應(yīng)類型（二）

本文首先會(huì)給出ReactiveX的核心操作符列表和對(duì)應(yīng)的文檔鏈接炭剪，后面會(huì)具體的介紹和實(shí)踐所有的操作符乙漓。

如果想實(shí)現(xiàn)自己的操作符有送，可以參考：實(shí)現(xiàn)自定義操作符

創(chuàng)建操作
用于創(chuàng)建Observable的操作符
Create
— 通過調(diào)用觀察者的方法從頭創(chuàng)建一個(gè)Observable
Defer
— 在觀察者訂閱之前不創(chuàng)建這個(gè)Observable闯两，為每一個(gè)觀察者創(chuàng)建一個(gè)新的Observable
Empty/Never/Throw
— 創(chuàng)建行為受限的特殊Observable
From
— 將其它的對(duì)象或數(shù)據(jù)結(jié)構(gòu)轉(zhuǎn)換為Observable
Interval
— 創(chuàng)建一個(gè)定時(shí)發(fā)射整數(shù)序列的Observable
Just
— 將對(duì)象或者對(duì)象集合轉(zhuǎn)換為一個(gè)會(huì)發(fā)射這些對(duì)象的Observable
Range
— 創(chuàng)建發(fā)射指定范圍的整數(shù)序列的Observable
Repeat
— 創(chuàng)建重復(fù)發(fā)射特定的數(shù)據(jù)或數(shù)據(jù)序列的Observable
Start
— 創(chuàng)建發(fā)射一個(gè)函數(shù)的返回值的Observable
Timer
— 創(chuàng)建在一個(gè)指定的延遲之后發(fā)射單個(gè)數(shù)據(jù)的Observable

變換操作
這些操作符可用于對(duì)Observable發(fā)射的數(shù)據(jù)進(jìn)行變換朱转，詳細(xì)解釋可以看每個(gè)操作符的文檔
Buffer
— 緩存准谚，可以簡(jiǎn)單的理解為緩存谦炒，它定期從Observable收集數(shù)據(jù)到一個(gè)集合贯莺，然后把這些數(shù)據(jù)集合打包發(fā)射，而不是一次發(fā)射一個(gè)
FlatMap
— 扁平映射编饺，將Observable發(fā)射的數(shù)據(jù)變換為Observables集合乖篷，然后將這些Observable發(fā)射的數(shù)據(jù)平坦化的放進(jìn)一個(gè)單獨(dú)的Observable，可以認(rèn)為是一個(gè)將嵌套的數(shù)據(jù)結(jié)構(gòu)展開的過程透且。
GroupBy
— 分組撕蔼，將原來的Observable分拆為Observable集合豁鲤，將原始Observable發(fā)射的數(shù)據(jù)按Key分組，每一個(gè)Observable發(fā)射一組不同的數(shù)據(jù)
Map
— 映射鲸沮，通過對(duì)序列的每一項(xiàng)都應(yīng)用一個(gè)函數(shù)變換Observable發(fā)射的數(shù)據(jù)琳骡，實(shí)質(zhì)是對(duì)序列中的每一項(xiàng)執(zhí)行一個(gè)函數(shù)，函數(shù)的參數(shù)就是這個(gè)數(shù)據(jù)項(xiàng)
Scan
— 掃描讼溺，對(duì)Observable發(fā)射的每一項(xiàng)數(shù)據(jù)應(yīng)用一個(gè)函數(shù)楣号，然后按順序依次發(fā)射這些值
Window
— 窗口，定期將來自O(shè)bservable的數(shù)據(jù)分拆成一些Observable窗口怒坯，然后發(fā)射這些窗口炫狱，而不是每次發(fā)射一項(xiàng)。類似于Buffer剔猿，但Buffer發(fā)射的是數(shù)據(jù)视译，Window發(fā)射的是Observable，每一個(gè)Observable發(fā)射原始Observable的數(shù)據(jù)的一個(gè)子集

過濾操作
這些操作符用于從Observable發(fā)射的數(shù)據(jù)中進(jìn)行選擇
Debounce
— 只有在空閑了一段時(shí)間后才發(fā)射數(shù)據(jù)归敬，通俗的說酷含，就是如果一段時(shí)間沒有操作，就執(zhí)行一次操作
Distinct
— 去重汪茧，過濾掉重復(fù)數(shù)據(jù)項(xiàng)
ElementAt
— 取值椅亚，取特定位置的數(shù)據(jù)項(xiàng)
Filter
— 過濾，過濾掉沒有通過謂詞測(cè)試的數(shù)據(jù)項(xiàng)舱污，只發(fā)射通過測(cè)試的
First
— 首項(xiàng)呀舔，只發(fā)射滿足條件的第一條數(shù)據(jù)
IgnoreElements
— 忽略所有的數(shù)據(jù)，只保留終止通知(onError或onCompleted)
Last
— 末項(xiàng)慌闭，只發(fā)射最后一條數(shù)據(jù)
Sample
— 取樣别威，定期發(fā)射最新的數(shù)據(jù)，等于是數(shù)據(jù)抽樣驴剔，有的實(shí)現(xiàn)里叫ThrottleFirst
Skip
— 跳過前面的若干項(xiàng)數(shù)據(jù)
SkipLast
— 跳過后面的若干項(xiàng)數(shù)據(jù)
Take
— 只保留前面的若干項(xiàng)數(shù)據(jù)
TakeLast
— 只保留后面的若干項(xiàng)數(shù)據(jù)

組合操作
組合操作符用于將多個(gè)Observable組合成一個(gè)單一的Observable
And/Then/When
— 通過模式(And條件)和計(jì)劃(Then次序)組合兩個(gè)或多個(gè)Observable發(fā)射的數(shù)據(jù)集
CombineLatest
— 當(dāng)兩個(gè)Observables中的任何一個(gè)發(fā)射了一個(gè)數(shù)據(jù)時(shí)省古，通過一個(gè)指定的函數(shù)組合每個(gè)Observable發(fā)射的最新數(shù)據(jù)（一共兩個(gè)數(shù)據(jù)），然后發(fā)射這個(gè)函數(shù)的結(jié)果
Join
— 無論何時(shí)丧失，如果一個(gè)Observable發(fā)射了一個(gè)數(shù)據(jù)項(xiàng)豺妓，只要在另一個(gè)Observable發(fā)射的數(shù)據(jù)項(xiàng)定義的時(shí)間窗口內(nèi)，就將兩個(gè)Observable發(fā)射的數(shù)據(jù)合并發(fā)射
Merge
— 將兩個(gè)Observable發(fā)射的數(shù)據(jù)組合并成一個(gè)
StartWith
— 在發(fā)射原來的Observable的數(shù)據(jù)序列之前布讹，先發(fā)射一個(gè)指定的數(shù)據(jù)序列或數(shù)據(jù)項(xiàng)
Switch
— 將一個(gè)發(fā)射Observable序列的Observable轉(zhuǎn)換為這樣一個(gè)Observable：它逐個(gè)發(fā)射那些Observable最近發(fā)射的數(shù)據(jù)
Zip
— 打包琳拭，使用一個(gè)指定的函數(shù)將多個(gè)Observable發(fā)射的數(shù)據(jù)組合在一起，然后將這個(gè)函數(shù)的結(jié)果作為單項(xiàng)數(shù)據(jù)發(fā)射

錯(cuò)誤處理
這些操作符用于從錯(cuò)誤通知中恢復(fù)
Catch
— 捕獲描验，繼續(xù)序列操作白嘁，將錯(cuò)誤替換為正常的數(shù)據(jù)，從onError通知中恢復(fù)
Retry
— 重試膘流，如果Observable發(fā)射了一個(gè)錯(cuò)誤通知絮缅，重新訂閱它鲁沥，期待它正常終止

輔助操作
一組用于處理Observable的操作符
Delay
— 延遲一段時(shí)間發(fā)射結(jié)果數(shù)據(jù)
Do
— 注冊(cè)一個(gè)動(dòng)作占用一些Observable的生命周期事件，相當(dāng)于Mock某個(gè)操作
Materialize/Dematerialize
— 將發(fā)射的數(shù)據(jù)和通知都當(dāng)做數(shù)據(jù)發(fā)射耕魄，或者反過來
ObserveOn
— 指定觀察者觀察Observable的調(diào)度程序（工作線程）
Serialize
— 強(qiáng)制Observable按次序發(fā)射數(shù)據(jù)并且功能是有效的
Subscribe
— 收到Observable發(fā)射的數(shù)據(jù)和通知后執(zhí)行的操作
SubscribeOn
— 指定Observable應(yīng)該在哪個(gè)調(diào)度程序上執(zhí)行
TimeInterval
— 將一個(gè)Observable轉(zhuǎn)換為發(fā)射兩個(gè)數(shù)據(jù)之間所耗費(fèi)時(shí)間的Observable
Timeout
— 添加超時(shí)機(jī)制画恰，如果過了指定的一段時(shí)間沒有發(fā)射數(shù)據(jù)，就發(fā)射一個(gè)錯(cuò)誤通知
Timestamp
— 給Observable發(fā)射的每個(gè)數(shù)據(jù)項(xiàng)添加一個(gè)時(shí)間戳
Using
— 創(chuàng)建一個(gè)只在Observable的生命周期內(nèi)存在的一次性資源

條件和布爾操作v
這些操作符可用于單個(gè)或多個(gè)數(shù)據(jù)項(xiàng)吸奴，也可用于Observable
All
— 判斷Observable發(fā)射的所有的數(shù)據(jù)項(xiàng)是否都滿足某個(gè)條件
Amb
— 給定多個(gè)Observable允扇，只讓第一個(gè)發(fā)射數(shù)據(jù)的Observable發(fā)射全部數(shù)據(jù)
Contains
— 判斷Observable是否會(huì)發(fā)射一個(gè)指定的數(shù)據(jù)項(xiàng)
DefaultIfEmpty
— 發(fā)射來自原始Observable的數(shù)據(jù)，如果原始Observable沒有發(fā)射數(shù)據(jù)则奥，就發(fā)射一個(gè)默認(rèn)數(shù)據(jù)
SequenceEqual
— 判斷兩個(gè)Observable是否按相同的數(shù)據(jù)序列
SkipUntil
— 丟棄原始Observable發(fā)射的數(shù)據(jù)考润，直到第二個(gè)Observable發(fā)射了一個(gè)數(shù)據(jù)，然后發(fā)射原始Observable的剩余數(shù)據(jù)
SkipWhile
— 丟棄原始Observable發(fā)射的數(shù)據(jù)读处，直到一個(gè)特定的條件為假额划，然后發(fā)射原始Observable剩余的數(shù)據(jù)
TakeUntil
— 發(fā)射來自原始Observable的數(shù)據(jù)，直到第二個(gè)Observable發(fā)射了一個(gè)數(shù)據(jù)或一個(gè)通知
TakeWhile
— 發(fā)射原始Observable的數(shù)據(jù)档泽，直到一個(gè)特定的條件為真，然后跳過剩余的數(shù)據(jù)

算術(shù)和聚合操作
這些操作符可用于整個(gè)數(shù)據(jù)序列
Average
— 計(jì)算Observable發(fā)射的數(shù)據(jù)序列的平均值揖赴，然后發(fā)射這個(gè)結(jié)果
Concat
— 不交錯(cuò)的連接多個(gè)Observable的數(shù)據(jù)
Count
— 計(jì)算Observable發(fā)射的數(shù)據(jù)個(gè)數(shù)馆匿，然后發(fā)射這個(gè)結(jié)果
Max
— 計(jì)算并發(fā)射數(shù)據(jù)序列的最大值
Min
— 計(jì)算并發(fā)射數(shù)據(jù)序列的最小值
Reduce
— 按順序?qū)?shù)據(jù)序列的每一個(gè)應(yīng)用某個(gè)函數(shù)，然后返回這個(gè)值
Sum
— 計(jì)算并發(fā)射數(shù)據(jù)序列的和

v連接操作
一些有精確可控的訂閱行為的特殊Observable
Connect
— 指示一個(gè)可連接的Observable開始發(fā)射數(shù)據(jù)給訂閱者
Publish
— 將一個(gè)普通的Observable轉(zhuǎn)換為可連接的
RefCount
— 使一個(gè)可連接的Observable表現(xiàn)得像一個(gè)普通的Observable
Replay
— 確保所有的觀察者收到同樣的數(shù)據(jù)序列燥滑，即使他們?cè)贠bservable開始發(fā)射數(shù)據(jù)之后才訂閱

轉(zhuǎn)換操作
To
— 將Observable轉(zhuǎn)換為其它的對(duì)象或數(shù)據(jù)結(jié)構(gòu)
Blocking
阻塞Observable的操作符

操作符決策樹
幾種主要的需求
直接創(chuàng)建一個(gè)Observable（創(chuàng)建操作）
組合多個(gè)Observable（組合操作）
對(duì)Observable發(fā)射的數(shù)據(jù)執(zhí)行變換操作（變換操作）
從Observable發(fā)射的數(shù)據(jù)中取特定的值（過濾操作）
轉(zhuǎn)發(fā)Observable的部分值（條件/布爾/過濾操作）
對(duì)Observable發(fā)射的數(shù)據(jù)序列求值（算術(shù)/聚合操作）

創(chuàng)建操作

建議在傳遞給create方法的函數(shù)中檢查觀察者的isUnsubscribed狀態(tài)渐北，以便在沒有觀察者的時(shí)候，讓你的Observable停止發(fā)射數(shù)據(jù)或者做昂貴的運(yùn)算铭拧。
在rxjava2中（本系列都是在rxjava2的基礎(chǔ)上進(jìn)行論述的赃蛛，rxjava1請(qǐng)自行查閱），create接收的類型都為xxxOnSubscrible(xxx為5種類型對(duì)應(yīng)的名字),發(fā)射器為xxxEmitter搀菩，具體如下表：

RxJava 2.x 類型	create參數(shù)（響應(yīng)接口）	發(fā)射器	Observer
Observable	ObservableOnSubscribe	ObservableEmitter	Observer
Flowable	FlowableOnSubscribe	FlowableEmitter	FlowableSubscriber
Single	SingleOnSubscribe	SingleEmitter	SingleObserver
Completable	CompletableOnSubscribe	CompletableEmitter	CompletableObserver
Maybe	MaybeOnSubscribe	MaybeEmitter	MaybeObserver

再次借用Android拾萃 - RxJava操作符和響應(yīng)類型（二）的圖片呕臂。

RxJava 2.x的5種響應(yīng)類型

下面來看下，五種響應(yīng)類型具體代碼．

1. Observable

Observable是最完整的肪跋，擁有四個(gè)回調(diào)方法onSubscribe會(huì)在收到數(shù)據(jù)之前調(diào)用歧蒋，可以做一些動(dòng)畫加載之類的操作．onNext收到數(shù)據(jù)會(huì)調(diào)用，onError和onComplete是互斥的州既，只會(huì)調(diào)用一個(gè)．

  //ObservableOnSubscribe接口
            Observable observable = Observable.create(new ObservableOnSubscribe() {
                @Override
                public void subscribe(@NonNull ObservableEmitter e) throws Exception {
                    //判斷下是否釋放了
                    if (!e.isDisposed()){
                        for (int i = 0; i<5; i++) {
                            e.onNext(i);
                        }
                        e.onComplete();
                    }
                }
            });
            
            //<Integer>泛型沒有添加的話谜洽，默認(rèn)的是object ，然后onext強(qiáng)制轉(zhuǎn)換一下即可
            observable.subscribe(new Observer<Integer>() {
                @Override
                public void onSubscribe(@NonNull Disposable d) {
                    
                }

                @Override
                public void onNext(@NonNull Integer o) {
                    Log.d(TAG, o + "");
                }

                @Override
                public void onError(@NonNull Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            });

Consumer是簡(jiǎn)化版的Observer, 可以只關(guān)心某個(gè)步驟(onNext　onError　　onComplete),對(duì)應(yīng)的有一個(gè)參數(shù)吴叶，兩個(gè)參數(shù)阐虚，三個(gè)參數(shù)的方法如下

可以簡(jiǎn)單理解微，Action和Consumer可以單獨(dú)行動(dòng)蚌卤，單獨(dú)存在
Action 對(duì)應(yīng)　　無參的onComplete()
Consumer　對(duì)應(yīng)　單個(gè)參數(shù)的onError(Throwable t)　或者　onNext(T t)

            observable.subscribe(new Consumer() {
                @Override
                public void accept(Object o) throws Exception {
                    //對(duì)應(yīng)onNext方法
                }
            }, new Consumer<Throwable>() {
                @Override
                public void accept(Throwable throwable) throws Exception {
                    //對(duì)應(yīng)onError
                }
            });

            observable.subscribe(new Consumer() {
                @Override
                public void accept(Object o) throws Exception {
                    //對(duì)應(yīng)onNext方法
                }
            }, new Consumer<Throwable>() {
                @Override
                public void accept(Throwable throwable) throws Exception {
                    //對(duì)應(yīng)onError
                }
            }, new Action() {
                @Override
                public void run() throws Exception {
                    //對(duì)應(yīng)onComplete　　無參返回
                }
            });

下面的幾種case, Consumer就不再討論了实束，具體參考上面的代碼

2. Flowable

Backpressure的策略

我們發(fā)現(xiàn) Flowable.create 多了一個(gè)參數(shù)奥秆，背壓策略

點(diǎn)進(jìn)去源碼發(fā)現(xiàn)總共有五種策略

/**
 * Represents the options for applying backpressure to a source sequence.
 */
public enum BackpressureStrategy {
    /**
     * OnNext events are written without any buffering or dropping.
     * Downstream has to deal with any overflow.
     * <p>Useful when one applies one of the custom-parameter onBackpressureXXX operators.
     */
    MISSING,
    /**
     * Signals a MissingBackpressureException in case the downstream can't keep up.
     */
    ERROR,
    /**
     * Buffers <em>all</em> onNext values until the downstream consumes it.
     */
    BUFFER,
    /**
     * Drops the most recent onNext value if the downstream can't keep up.
     */
    DROP,
    /**
     * Keeps only the latest onNext value, overwriting any previous value if the
     * downstream can't keep up.
     */
    LATEST
}

處理Backpressure的策略僅僅是處理Subscriber接收事件的方式，并不影響Flowable發(fā)送事件和事件產(chǎn)生速度磕洪。

我們知道只有生產(chǎn)者的速度大于消費(fèi)者的速度吭练，才會(huì)產(chǎn)生Backpressure問題。也就是說只會(huì)發(fā)生在異步的情況下析显。

Flowable的幾種背壓策略：

BackpressureStrategy.ERROR：緩存區(qū)默人大小128鲫咽，流速不均衡時(shí)發(fā)射MissingBackpressureException信號(hào)。
BackpressureStrategy.BUFFER：緩存區(qū)不限制大小谷异，使用不當(dāng)仍會(huì)OOM分尸。
BackpressureStrategy.DROP：緩存最近的nNext事件。
BackpressureStrategy.LATEST：緩存區(qū)會(huì)保留最后的OnNext事件歹嘹，覆蓋之前緩存的OnNext事件箩绍。
BackpressureStrategy.MISSING：OnNext事件沒有任何緩存和丟棄，下游要處理任何溢出尺上。

onBackpressureBuffer是不丟棄數(shù)據(jù)的處理方式材蛛。把上游收到的全部緩存下來，等下游來請(qǐng)求再發(fā)給下游怎抛。相當(dāng)于一個(gè)水庫(kù)卑吭。但上游太快，水庫(kù)（buffer）就會(huì)溢出马绝。
onBackpressureDrop和onBackpressureLatest比較類似豆赏，都會(huì)丟棄數(shù)據(jù)。這兩種策略相當(dāng)于一種令牌機(jī)制（或者配額機(jī)制）富稻，下游通過request請(qǐng)求產(chǎn)生令牌（配額）給上游掷邦，上游接到多少令牌，就給下游發(fā)送多少數(shù)據(jù)椭赋。當(dāng)令牌數(shù)消耗到0的時(shí)候抚岗，上游開始丟棄數(shù)據(jù)。但這兩種策略在令牌數(shù)為0的時(shí)候有一點(diǎn)微妙的區(qū)別：onBackpressureDrop直接丟棄數(shù)據(jù)哪怔，不緩存任何數(shù)據(jù)苟跪；而onBackpressureLatest則緩存最新的一條數(shù)據(jù)崎逃，這樣當(dāng)上游接到新令牌的時(shí)候咬展，它就先把緩存的上一條“最新”數(shù)據(jù)發(fā)送給下游。

 //我們發(fā)現(xiàn)Flowable 多了一個(gè)參數(shù)岸梨，背壓策略
            Flowable flowable = Flowable.create(new FlowableOnSubscribe<Object>() {
                @Override
                public void subscribe(@NonNull FlowableEmitter<Object> e) throws Exception {

  //判斷下是否釋放了
                    if (!e.isCancelled()){
                        for (int i = 0; i<5; i++) {
                            e.onNext(i);
                        }
                        e.onComplete();
                    }
                }
            }, BackpressureStrategy.DROP);

            //這里建立關(guān)系都是使用了subscribe元暴，只不過對(duì)應(yīng)的方法不一樣篷扩，請(qǐng)參照上面的表
            flowable
           .subscribeOn(Schedulers.io())
           .observeOn(AndroidSchedulers.mainThread())

          .subscribe(new FlowableSubscriber() {
                @Override
                public void onSubscribe(@NonNull Subscription s) {

                }

                @Override
                public void onNext(Object o) {
                    Log.d(TAG, o + "");
                }

                @Override
                public void onError(Throwable t) {

                }

                @Override
                public void onComplete() {

                }
            });

3. Single

Single 是沒有complete的，因?yàn)檐哉担话l(fā)送一個(gè)數(shù)據(jù)之后鉴未，默認(rèn)就會(huì)調(diào)用complete

Single single = Single.create(new SingleOnSubscribe<Object>() {
                @Override
                public void subscribe(@NonNull SingleEmitter<Object> e) throws Exception {
                    e.onSuccess(1);
                }
            });

            single.subscribeOn(Schedulers.io()).subscribe(new SingleObserver() {
                @Override
                public void onSubscribe(@NonNull Disposable d) {

                }

                @Override
                public void onSuccess(@NonNull Object o) {
                    Log.d(TAG, o + "");
                }

                @Override
                public void onError(@NonNull Throwable e) {

                }
            });

4. Completable

Completable只關(guān)心onComplete枢冤，所以上游發(fā)射的數(shù)據(jù)，都不會(huì)進(jìn)行處理的．

Completable completable =  Completable.create(new CompletableOnSubscribe() {
                @Override
                public void subscribe(@NonNull CompletableEmitter e) throws Exception {
                    e.onComplete();
                }
            });
            completable.subscribe(new CompletableObserver() {
                @Override
                public void onSubscribe(@NonNull Disposable d) {
                    
                }

                @Override
                public void onComplete() {

                }

                @Override
                public void onError(@NonNull Throwable e) {

                }
            });

5. Maybe

Maybe是Single　和　Completable的合體铜秆，只會(huì)處理一條數(shù)據(jù)淹真，但是onComplete不會(huì)自動(dòng)調(diào)用

            Maybe maybe = Maybe.create(new MaybeOnSubscribe() {
                @Override
                public void subscribe(@NonNull MaybeEmitter e) throws Exception {
                    e.onSuccess(12);
                    e.onComplete();
                }
            });
            
            maybe.subscribe(new MaybeObserver() {
                @Override
                public void onSubscribe(@NonNull Disposable d) {
                    
                }

                @Override
                public void onSuccess(@NonNull Object o) {
                    Log.d(TAG, o + "");
                }

                @Override
                public void onError(@NonNull Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            });

最后編輯于：2017.12.10 07:18:00

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者

人面猴
序言：七十年代末，一起剝皮案震驚了整個(gè)濱河市连茧，隨后出現(xiàn)的幾起案子核蘸，更是在濱河造成了極大的恐慌，老刑警劉巖啸驯，帶你破解...
沈念sama閱讀 216,997評(píng)論 6贊 502
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件客扎，死亡現(xiàn)場(chǎng)離奇詭異，居然都是意外死亡罚斗，警方通過查閱死者的電腦和手機(jī)徙鱼，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 92,603評(píng)論 3贊 392
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來针姿，“玉大人袱吆，你說我怎么就攤上這事【嘁” “怎么了杆故？”我有些...
開封第一講書人閱讀 163,359評(píng)論 0贊 353
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵，是天一觀的道長(zhǎng)溉愁。經(jīng)常有香客問我，道長(zhǎng)饲趋，這世上最難降的妖魔是什么拐揭？我笑而不...
開封第一講書人閱讀 58,309評(píng)論 1贊 292
?港島之戀（遺憾婚禮）
正文為了忘掉前任，我火速辦了婚禮奕塑，結(jié)果婚禮上堂污，老公的妹妹穿的比我還像新娘。我一直安慰自己龄砰，他們只是感情好盟猖，可當(dāng)我...
茶點(diǎn)故事閱讀 67,346評(píng)論 6贊 390
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布。她就那樣靜靜地躺著换棚，像睡著了一般式镐。火紅的嫁衣襯著肌膚如雪。梳的紋絲不亂的頭發(fā)上固蚤，一...
開封第一講書人閱讀 51,258評(píng)論 1贊 300
城市分裂傳說
那天娘汞，我揣著相機(jī)與錄音，去河邊找鬼夕玩。笑死你弦，一個(gè)胖子當(dāng)著我的面吹牛惊豺，可吹牛的內(nèi)容都是我干的。我是一名探鬼主播禽作，決...
沈念sama閱讀 40,122評(píng)論 3贊 418
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼尸昧，長(zhǎng)吁一口氣：“原來是場(chǎng)噩夢(mèng)啊……” “哼！你這毒婦竟也來了旷偿？” 一聲冷哼從身側(cè)響起烹俗，我...
開封第一講書人閱讀 38,970評(píng)論 0贊 275
萬榮殺人案實(shí)錄
序言：老撾萬榮一對(duì)情侶失蹤，失蹤者是張志新（化名）和其女友劉穎狸捅，沒想到半個(gè)月后衷蜓，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體，經(jīng)...
沈念sama閱讀 45,403評(píng)論 1贊 313
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡尘喝，尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 37,596評(píng)論 3贊 334
?白月光啟示錄
正文我和宋清朗相戀三年磁浇，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片朽褪。...
茶點(diǎn)故事閱讀 39,769評(píng)論 1贊 348
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡置吓，死狀恐怖，靈堂內(nèi)的尸體忽然破棺而出缔赠，到底是詐尸還是另有隱情衍锚，我是刑警寧澤，帶...
沈念sama閱讀 35,464評(píng)論 5贊 344
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布嗤堰，位于F島的核電站戴质，受9級(jí)特大地震影響，放射性物質(zhì)發(fā)生泄漏踢匣。R本人自食惡果不足惜告匠，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 41,075評(píng)論 3贊 327
男人毒藥：我在死后第九天來索命
文/蒙蒙一、第九天我趴在偏房一處隱蔽的房頂上張望离唬。院中可真熱鬧后专，春花似錦、人聲如沸输莺。這莊子的主人今日做“春日...
開封第一講書人閱讀 31,705評(píng)論 0贊 22
一樁弒父案，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽(yáng)嫂用。三九已至型凳，卻和暖如春，著一層夾襖步出監(jiān)牢的瞬間嘱函，已是汗流浹背啰脚。一陣腳步聲響...
開封第一講書人閱讀 32,848評(píng)論 1贊 269
情欲美人皮
我被黑心中介騙來泰國(guó)打工，沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留，地道東北人橄浓。一個(gè)月前我還...
沈念sama閱讀 47,831評(píng)論 2贊 370
代替公主和親
正文我出身青樓粒梦，卻偏偏與公主長(zhǎng)得像，于是被迫代替她去往敵國(guó)和親荸实。傳聞我的和親對(duì)象是個(gè)殘疾皇子匀们，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 44,678評(píng)論 2贊 354