Carson帶你學(xué)Android：RxJava過濾操作符

前言

Rxjava掷漱，由于其基于事件流的鏈?zhǔn)秸{(diào)用粘室、邏輯簡潔 & 使用簡單的特點(diǎn)，深受各大 Android開發(fā)者的歡迎卜范。

如果還不了解 RxJava衔统，請看文章：Android：這是一篇 清晰 & 易懂的Rxjava 入門教程

  • RxJava如此受歡迎的原因，在于其提供了豐富 & 功能強(qiáng)大的操作符海雪，幾乎能完成所有的功能需求
  • 今天锦爵，我將為大家詳細(xì)介紹RxJava操作符中最常用的 過濾操作符，希望你們會(huì)喜歡奥裸。

Carson帶你學(xué)RxJava系列文章险掀，包括 原理、操作符湾宙、應(yīng)用場景樟氢、背壓等等，請關(guān)注看文章：Android：這是一份全面 & 詳細(xì)的RxJava學(xué)習(xí)指南

目錄

示意圖

1. 作用

過濾 / 篩選 被觀察者（Observable）發(fā)送的事件 & 觀察者 （Observer）接收的事件

2. 類型

  • RxJava2中侠鳄，過濾操作符的類型包括：

    示意圖

  • 下面埠啃，我將對每個(gè)操作符進(jìn)行詳細(xì)講解

3. 應(yīng)用場景 & 對應(yīng)操作符詳解

  • 過濾操作符的應(yīng)用場景包括：
    1. 根據(jù) 指定條件 過濾事件
    2. 根據(jù) 指定事件數(shù)量 過濾事件
    3. 根據(jù) 指定時(shí)間 過濾事件
    4. 根據(jù) 指定事件位置 過濾事件
  • 下面，我將根據(jù)上述應(yīng)用場景伟恶，講解對應(yīng)的操作符使用

注：在使用RxJava 2操作符前碴开，記得在項(xiàng)目的Gradle中添加依賴：

dependencies {
      compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
      compile 'io.reactivex.rxjava2:rxjava:2.0.7'
      // 注：RxJava2 與 RxJava1 不能共存，即依賴不能同時(shí)存在
}

3.1 根據(jù) 指定條件 過濾事件

  • 需求場景
    通過設(shè)置指定的過濾條件博秫，當(dāng)且僅當(dāng)該事件滿足條件叹螟，就將該事件過濾（不發(fā)送）

  • 對應(yīng)操作符類型

示意圖
  • 對應(yīng)操作符使用

Filter（）

  • 作用
    過濾 特定條件的事件

  • 原理

示意圖
  • 具體使用
Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                // 1. 發(fā)送5個(gè)事件
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onNext(4);
                emitter.onNext(5);
            }

            // 2. 采用filter（）變換操作符
        }).filter(new Predicate<Integer>() {
            // 根據(jù)test()的返回值 對被觀察者發(fā)送的事件進(jìn)行過濾 & 篩選
              // a. 返回true鹃骂，則繼續(xù)發(fā)送
              // b. 返回false台盯，則不發(fā)送（即過濾）
            @Override
            public boolean test(Integer integer) throws Exception {
                return integer > 3;
                // 本例子 = 過濾了整數(shù)≤3的事件
            }
        }).subscribe(new Observer<Integer>() {

            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "過濾后得到的事件是："+ value  );
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }
        });
  • 測試結(jié)果
示意圖

ofType（）

  • 作用
    過濾 特定數(shù)據(jù)類型的數(shù)據(jù)

  • 具體使用

Observable.just(1, "Carson", 3, "Ho", 5)
                  .ofType(Integer.class) // 篩選出 整型數(shù)據(jù)
                  .subscribe(new Consumer<Integer>() {
                      @Override
                      public void accept( Integer integer) throws Exception {
                          Log.d(TAG,"獲取到的整型事件元素是： "+ integer);
                      }
        });
  • 測試結(jié)果
示意圖

skip（） / skipLast（）

  • 作用
    跳過某個(gè)事件

  • 具體使用

// 使用1：根據(jù)順序跳過數(shù)據(jù)項(xiàng)
        Observable.just(1, 2, 3, 4, 5)
                .skip(1) // 跳過正序的前1項(xiàng)
                .skipLast(2) // 跳過正序的后2項(xiàng)
                  .subscribe(new Consumer<Integer>() {
                      @Override
                      public void accept( Integer integer) throws Exception {
                          Log.d(TAG,"獲取到的整型事件元素是： "+ integer);
                      }
        });

// 使用2：根據(jù)時(shí)間跳過數(shù)據(jù)項(xiàng)
        // 發(fā)送事件特點(diǎn)：發(fā)送數(shù)據(jù)0-5罢绽，每隔1s發(fā)送一次，每次遞增1静盅；第1次發(fā)送延遲0s
        Observable.intervalRange(0, 5, 0, 1, TimeUnit.SECONDS)
                .skip(1, TimeUnit.SECONDS) // 跳過第1s發(fā)送的數(shù)據(jù)
                .skipLast(1, TimeUnit.SECONDS) // 跳過最后1s發(fā)送的數(shù)據(jù)
                .subscribe(new Consumer<Long>() {

                    @Override
                    public void accept( Long along ) throws Exception {
                        Log.d(TAG,"獲取到的整型事件元素是： "+ along);
                    }
                });
  • 測試結(jié)果
image.png

distinct（） / distinctUntilChanged（）

  • 作用
    過濾事件序列中重復(fù)的事件 / 連續(xù)重復(fù)的事件

  • 具體使用

// 使用1：過濾事件序列中重復(fù)的事件
        Observable.just(1, 2, 3, 1 , 2 )
                .distinct()
                .subscribe(new Consumer<Integer>() {
                      @Override
                      public void accept( Integer integer) throws Exception {
                          Log.d(TAG,"不重復(fù)的整型事件元素是： "+ integer);
                      }
        });

        // 使用2：過濾事件序列中 連續(xù)重復(fù)的事件
        // 下面序列中良价，連續(xù)重復(fù)的事件 = 3、4
        Observable.just(1,2,3,1,2,3,3,4,4 )
                .distinctUntilChanged()
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept( Integer integer) throws Exception {
                        Log.d(TAG,"不連續(xù)重復(fù)的整型事件元素是： "+ integer);
                    }
                });
  • 測試結(jié)果
示意圖

3.2 根據(jù) 指定事件數(shù)量 過濾事件

  • 需求場景
    通過設(shè)置指定的事件數(shù)量蒿叠，僅發(fā)送特定數(shù)量的事件

  • 對應(yīng)操作符類型
    take（） & takeLast（）

  • 對應(yīng)操作符使用

take（）

  • 作用
    指定觀察者最多能接收到的事件數(shù)量

  • 原理

示意圖
  • 具體使用
Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                // 1. 發(fā)送5個(gè)事件
                emitter.onNext(1);
                emitter.onNext(2);
                emitter.onNext(3);
                emitter.onNext(4);
                emitter.onNext(5);
            }

            // 采用take（）變換操作符
            // 指定了觀察者只能接收2個(gè)事件
        }).take(2)
        .subscribe(new Observer<Integer>() {

            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "過濾后得到的事件是："+ value  );
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }
        });

// 實(shí)際上明垢，可理解為：被觀察者還是發(fā)送了5個(gè)事件，只是因?yàn)椴僮鞣拇嬖跀r截了3個(gè)事件市咽，最終觀察者接收到的是2個(gè)事件
  • 測試結(jié)果
示意圖

takeLast（）

  • 作用
    指定觀察者只能接收到被觀察者發(fā)送的最后幾個(gè)事件

  • 具體使用

Observable.just(1, 2, 3, 4, 5)
          .takeLast(3) //指定觀察者只能接受被觀察者發(fā)送的3個(gè)事件
          .subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }

            @Override
            public void onNext(Integer value) {
                Log.d(TAG, "過濾后得到的事件是："+ value  );
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對Complete事件作出響應(yīng)");
            }
        });
  • 測試結(jié)果
示意圖

3.3 根據(jù) 指定時(shí)間 過濾事件

  • 需求場景
    通過設(shè)置指定的時(shí)間痊银，僅發(fā)送在該時(shí)間內(nèi)的事件

  • 對應(yīng)操作符類型

示意圖
  • 對應(yīng)操作符使用

throttleFirst（）/ throttleLast（）

  • 作用
    在某段時(shí)間內(nèi)，只發(fā)送該段時(shí)間內(nèi)第1次事件 / 最后1次事件

如施绎，1段時(shí)間內(nèi)連續(xù)點(diǎn)擊按鈕溯革，但只執(zhí)行第1次的點(diǎn)擊操作

  • 原理示意圖
示意圖
  • 具體使用
<<- 在某段時(shí)間內(nèi)，只發(fā)送該段時(shí)間內(nèi)第1次事件 ->>
Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                // 隔段事件發(fā)送時(shí)間
                e.onNext(1);
                Thread.sleep(500);
                
                e.onNext(2);
                Thread.sleep(400);
                
                e.onNext(3);
                Thread.sleep(300);
                
                e.onNext(4);
                Thread.sleep(300);
                
                e.onNext(5);
                Thread.sleep(300);
                
                e.onNext(6);
                Thread.sleep(400);
                
                e.onNext(7);
                Thread.sleep(300);
                e.onNext(8);

                Thread.sleep(300);
                e.onNext(9);

                Thread.sleep(300);
                e.onComplete();
            }
        }).throttleFirst(1, TimeUnit.SECONDS)//每1秒中采用數(shù)據(jù)
                .subscribe(new Observer<Integer>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        Log.d(TAG, "開始采用subscribe連接");
                    }

                    @Override
                    public void onNext(Integer value) {
                        Log.d(TAG, "接收到了事件"+ value  );
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.d(TAG, "對Error事件作出響應(yīng)");
                    }

                    @Override
                    public void onComplete() {
                        Log.d(TAG, "對Complete事件作出響應(yīng)");
                    }
                });


<<- 在某段時(shí)間內(nèi)谷醉，只發(fā)送該段時(shí)間內(nèi)最后1次事件 ->>
Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                // 隔段事件發(fā)送時(shí)間
                e.onNext(1);
                Thread.sleep(500);

                e.onNext(2);
                Thread.sleep(400);

                e.onNext(3);
                Thread.sleep(300);

                e.onNext(4);
                Thread.sleep(300);

                e.onNext(5);
                Thread.sleep(300);

                e.onNext(6);
                Thread.sleep(400);

                e.onNext(7);
                Thread.sleep(300);
                e.onNext(8);

                Thread.sleep(300);
                e.onNext(9);

                Thread.sleep(300);
                e.onComplete();
            }
        }).throttleLast(1, TimeUnit.SECONDS)//每1秒中采用數(shù)據(jù)
                .subscribe(new Observer<Integer>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        Log.d(TAG, "開始采用subscribe連接");
                    }

                    @Override
                    public void onNext(Integer value) {
                        Log.d(TAG, "接收到了事件"+ value  );
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.d(TAG, "對Error事件作出響應(yīng)");
                    }

                    @Override
                    public void onComplete() {
                        Log.d(TAG, "對Complete事件作出響應(yīng)");
                    }
                });
  • 測試結(jié)果
示意圖

Sample（）

  • 作用
    在某段時(shí)間內(nèi)致稀，只發(fā)送該段時(shí)間內(nèi)最新（最后）1次事件

與 throttleLast（） 操作符類似

  • 具體使用

僅需要把上文的 throttleLast（） 改成Sample（）操作符即可，此處不作過多描述

throttleWithTimeout （） / debounce（）

  • 作用
    發(fā)送數(shù)據(jù)事件時(shí)俱尼，若2次發(fā)送事件的間隔＜指定時(shí)間抖单，就會(huì)丟棄前一次的數(shù)據(jù)，直到指定時(shí)間內(nèi)都沒有新數(shù)據(jù)發(fā)射時(shí)才會(huì)發(fā)送后一次的數(shù)據(jù)

  • 具體使用

Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                // 隔段事件發(fā)送時(shí)間
                e.onNext(1);
                Thread.sleep(500);
                e.onNext(2); // 1和2之間的間隔小于指定時(shí)間1s遇八，所以前1次數(shù)據(jù)（1）會(huì)被拋棄矛绘，2會(huì)被保留
                Thread.sleep(1500);  // 因?yàn)?和3之間的間隔大于指定時(shí)間1s，所以之前被保留的2事件將發(fā)出
                e.onNext(3);
                Thread.sleep(1500);  // 因?yàn)?和4之間的間隔大于指定時(shí)間1s刃永，所以3事件將發(fā)出
                e.onNext(4);
                Thread.sleep(500); // 因?yàn)?和5之間的間隔小于指定時(shí)間1s货矮，所以前1次數(shù)據(jù)（4）會(huì)被拋棄，5會(huì)被保留
                e.onNext(5);
                Thread.sleep(500); // 因?yàn)?和6之間的間隔小于指定時(shí)間1s揽碘，所以前1次數(shù)據(jù)（5）會(huì)被拋棄次屠，6會(huì)被保留
                e.onNext(6);
                Thread.sleep(1500); // 因?yàn)?和Complete實(shí)踐之間的間隔大于指定時(shí)間1s，所以之前被保留的6事件將發(fā)出

                e.onComplete();
            }
        }).throttleWithTimeout(1, TimeUnit.SECONDS)//每1秒中采用數(shù)據(jù)
                .subscribe(new Observer<Integer>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(Integer value) {
                        Log.d(TAG, "接收到了事件"+ value  );
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.d(TAG, "對Error事件作出響應(yīng)");
                    }

                    @Override
                    public void onComplete() {
                        Log.d(TAG, "對Complete事件作出響應(yīng)");
                    }
                });
  • 測試結(jié)果
示意圖

3.4 根據(jù) 指定事件位置 過濾事件

  • 需求場景
    通過設(shè)置指定的位置雳刺，過濾在該位置的事件

  • 對應(yīng)操作符類型

示意圖
  • 對應(yīng)操作符使用

firstElement（） / lastElement（）

  • 作用
    僅選取第1個(gè)元素 / 最后一個(gè)元素

  • 具體使用

// 獲取第1個(gè)元素
        Observable.just(1, 2, 3, 4, 5)
                  .firstElement()
                  .subscribe(new Consumer<Integer>() {
                      @Override
                      public void accept( Integer integer) throws Exception {
                          Log.d(TAG,"獲取到的第一個(gè)事件是： "+ integer);
                      }
        });

// 獲取最后1個(gè)元素
        Observable.just(1, 2, 3, 4, 5)
                .lastElement()
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept( Integer integer) throws Exception {
                        Log.d(TAG,"獲取到的最后1個(gè)事件是： "+ integer);
                    }
                });
  • 測試結(jié)果
示意圖

elementAt（）

  • 作用
    指定接收某個(gè)元素（通過 索引值 確定）

注：允許越界劫灶，即獲取的位置索引 ＞ 發(fā)送事件序列長度

  • 具體使用
// 使用1：獲取位置索引 = 2的 元素
        // 位置索引從0開始
        Observable.just(1, 2, 3, 4, 5)
                  .elementAt(2)
                  .subscribe(new Consumer<Integer>() {
                      @Override
                      public void accept( Integer integer) throws Exception {
                          Log.d(TAG,"獲取到的事件元素是： "+ integer);
                      }
        });

// 使用2：獲取的位置索引 ＞ 發(fā)送事件序列長度時(shí)，設(shè)置默認(rèn)參數(shù)
        Observable.just(1, 2, 3, 4, 5)
                .elementAt(6,10)
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept( Integer integer) throws Exception {
                        Log.d(TAG,"獲取到的事件元素是： "+ integer);
                    }
                });
  • 測試結(jié)果
示意圖

elementAtOrError（）

  • 作用
    在elementAt（）的基礎(chǔ)上掖桦，當(dāng)出現(xiàn)越界情況（即獲取的位置索引 ＞ 發(fā)送事件序列長度）時(shí)本昏，即拋出異常

  • 具體使用

Observable.just(1, 2, 3, 4, 5)
                .elementAtOrError(6)
                .subscribe(new Consumer<Integer>() {
                    @Override
                    public void accept( Integer integer) throws Exception {
                        Log.d(TAG,"獲取到的事件元素是： "+ integer);
                    }
                });
  • 測試結(jié)果
示意圖

至此，RxJava2中常用的過濾操作符講解完畢枪汪。

4. 實(shí)際開發(fā)需求案例

  • 在實(shí)際開發(fā)中涌穆，常見的過濾操作符實(shí)際需求場景有：功能防抖 & 聯(lián)想搜索請求優(yōu)化
  • 下面怔昨，我將通過具體實(shí)例來講解上述2個(gè)需求

4.1 功能防抖

  • 需求場景
示意圖

4.2 聯(lián)想搜索優(yōu)化

  • 場景說明
示意圖

5. Demo地址

上述所有的Demo源代碼都存放在：Carson_Ho的Github地址：RxJava2_過濾操作符

6. 總結(jié)

  • 下面，我將用一張圖總結(jié) RxJava2 中常用的條件 / 布爾操作符
示意圖
  • Carson帶你學(xué)RxJava系列文章：

入門
Carson帶你學(xué)Android：這是一篇清晰易懂的Rxjava入門教程
Carson帶你學(xué)Android：面向初學(xué)者的RxJava使用指南
Carson帶你學(xué)Android：RxJava2.0到底更新了什么宿稀？
原理
Carson帶你學(xué)Android：圖文解析RxJava原理
Carson帶你學(xué)Android：手把手帶你源碼分析RxJava
使用教程：操作符
Carson帶你學(xué)Android：RxJava操作符教程
Carson帶你學(xué)Android：RxJava創(chuàng)建操作符
Carson帶你學(xué)Android：RxJava功能性操作符
Carson帶你學(xué)Android：RxJava過濾操作符
Carson帶你學(xué)Android：RxJava組合/合并操作符
Carson帶你學(xué)Android：RxJava變換操作符
Carson帶你學(xué)Android：RxJava條件/布爾操作符
實(shí)戰(zhàn)
Carson帶你學(xué)Android：什么時(shí)候應(yīng)該使用Rxjava趁舀？(開發(fā)場景匯總)
Carson帶你學(xué)Android：RxJava線程控制(含實(shí)例講解)
Carson帶你學(xué)Android：圖文詳解RxJava背壓策略
Carson帶你學(xué)Android：RxJava、Retrofit聯(lián)合使用匯總(含實(shí)例教程)
Carson帶你學(xué)Android：優(yōu)雅實(shí)現(xiàn)網(wǎng)絡(luò)請求嵌套回調(diào)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求輪詢(有條件)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求輪詢(無條件)
Carson帶你學(xué)Android：網(wǎng)絡(luò)請求出錯(cuò)重連(結(jié)合Retrofit)
Carson帶你學(xué)Android：合并數(shù)據(jù)源
Carson帶你學(xué)Android：聯(lián)想搜索優(yōu)化
Carson帶你學(xué)Android：功能防抖
Carson帶你學(xué)Android：從磁盤/內(nèi)存緩存中獲取緩存數(shù)據(jù)
Carson帶你學(xué)Android：聯(lián)合判斷

歡迎關(guān)注Carson_Ho的簡書

不定期分享關(guān)于安卓開發(fā)的干貨祝沸，追求短矮烹、平、快罩锐，但卻不缺深度奉狈。

請點(diǎn)贊！因?yàn)槟愕墓膭?lì)是我寫作的最大動(dòng)力涩惑！

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末仁期，一起剝皮案震驚了整個(gè)濱河市，隨后出現(xiàn)的幾起案子竭恬，更是在濱河造成了極大的恐慌跛蛋，老刑警劉巖，帶你破解...
    沈念sama閱讀 206,968評論 6贊 482
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件萍聊，死亡現(xiàn)場離奇詭異问芬，居然都是意外死亡，警方通過查閱死者的電腦和手機(jī)寿桨，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,601評論 2贊 382
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進(jìn)店門此衅，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人亭螟，你說我怎么就攤上這事挡鞍。” “怎么了预烙？”我有些...
    開封第一講書人閱讀 153,220評論 0贊 344
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵墨微，是天一觀的道長。 經(jīng)常有香客問我扁掸，道長翘县，這世上最難降的妖魔是什么？ 我笑而不...
    開封第一講書人閱讀 55,416評論 1贊 279
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任谴分，我火速辦了婚禮锈麸，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘牺蹄。我一直安慰自己忘伞，他們只是感情好，可當(dāng)我...
    茶點(diǎn)故事閱讀 64,425評論 5贊 374
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布。 她就那樣靜靜地躺著氓奈，像睡著了一般翘魄。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上舀奶，一...
    開封第一講書人閱讀 49,144評論 1贊 285
  • 城市分裂傳說
    那天暑竟，我揣著相機(jī)與錄音，去河邊找鬼伪节。 笑死光羞，一個(gè)胖子當(dāng)著我的面吹牛，可吹牛的內(nèi)容都是我干的怀大。 我是一名探鬼主播，決...
    沈念sama閱讀 38,432評論 3贊 401
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼呀闻，長吁一口氣：“原來是場噩夢啊……” “哼化借！你這毒婦竟也來了？” 一聲冷哼從身側(cè)響起捡多，我...
    開封第一講書人閱讀 37,088評論 0贊 261
  • 萬榮殺人案實(shí)錄
    序言：老撾萬榮一對情侶失蹤蓖康，失蹤者是張志新（化名）和其女友劉穎，沒想到半個(gè)月后垒手，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體蒜焊，經(jīng)...
    沈念sama閱讀 43,586評論 1贊 300
  • ?護(hù)林員之死
    正文 獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,028評論 2贊 325
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年科贬，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了泳梆。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 38,137評論 1贊 334
  • 活死人
    序言：一個(gè)原本活蹦亂跳的男人離奇死亡榜掌，死狀恐怖优妙，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情憎账，我是刑警寧澤套硼，帶...
    沈念sama閱讀 33,783評論 4贊 324
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布，位于F島的核電站胞皱，受9級特大地震影響邪意，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜反砌，卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,343評論 3贊 307
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一雾鬼、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧于颖，春花似錦呆贿、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,333評論 0贊 19
  • 一樁弒父案做入，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽冒晰。三九已至，卻和暖如春竟块，著一層夾襖步出監(jiān)牢的瞬間壶运，已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,559評論 1贊 262
  • 情欲美人皮
    我被黑心中介騙來泰國打工浪秘， 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留蒋情，地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 45,595評論 2贊 355
  • 代替公主和親
    正文 我出身青樓耸携，卻偏偏與公主長得像棵癣，于是被迫代替她去往敵國和親。 傳聞我的和親對象是個(gè)殘疾皇子夺衍，可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 42,901評論 2贊 345