webflux實戰(zhàn)笆凌、壓測甩栈、原理示意圖

實戰(zhàn)示例

  1. 添加maven依賴:
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.4.RELEASE</version>
</parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-webflux</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
  1. 添加啟動類
@SpringBootApplication
public class RetailApp {
  
  public static void main(String[] args){
      SpringApplication.run(RetailApp.class, args);
  }
}
  1. 添加領(lǐng)域?qū)嶓w和服務(wù)類
@Data
@Accessors(chain = true)
public class Spu {
  private Long id;
  private String name;
}
@Service
public class SpuService {
  
  public Spu findSpuById(Long id){
    try {
      TimeUnit.MILLISECONDS.sleep(50); //模擬耗時任務(wù)
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    return new Spu().setId(id).setName("spu"+id);
  }
}
  1. 添加rest api
@RestController
@Slf4j
public class SpuRestApi {
  
  @Autowired
  SpuService spuService;
  
  @GetMapping("/v1/spu/detail")
  public Mono<Spu> findById(Long id){
    StopWatch stopWatch = new StopWatch();
    stopWatch.start();
    return Mono.just(id)
        .flatMap(x-> Mono.fromCallable(()-> spuService.findSpuById(x))
        .subscribeOn(Schedulers.elastic())) //關(guān)鍵,netty線程不適合用來處理長時間阻塞的任務(wù)
        .doOnSuccess(x-> {
          stopWatch.stop();
          log.info("{}", stopWatch.toString());
        });
  }
}

壓力測試

壓測環(huán)境:

  • macbook pro
  • 2.7 GHz Intel Core i7
  • 16 GB

從壓測結(jié)果來看屑那,可以達到驚人的1.5w+以上的QPS拱镐,系統(tǒng)表現(xiàn)還相對穩(wěn)定。

wrk -t10 -c100 -d120s --timeout 2s --latency 'http://localhost:8080/v1/spu/detail?id=1'
Running 2m test @ http://localhost:8080/v1/spu/detail?id=1
  10 threads and 100 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency    54.09ms    2.71ms 163.71ms   86.00%
    Req/Sec   185.59     17.25   203.00     85.88%
  Latency Distribution
     50%   54.29ms
     75%   55.26ms
     90%   55.94ms
     99%   58.27ms
  221895 requests in 2.00m, 22.64MB read
Requests/sec:   1847.68
Transfer/sec:    193.07KB


wrk -t10 -c500 -d120s --timeout 2s --latency 'http://localhost:8080/v1/spu/detail?id=1'
Running 2m test @ http://localhost:8080/v1/spu/detail?id=1
  10 threads and 500 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency    55.44ms    6.89ms 294.20ms   97.99%
    Req/Sec     0.89k   108.62     1.01k    91.97%
  Latency Distribution
     50%   55.14ms
     75%   56.32ms
     90%   57.70ms
     99%   66.94ms
  1067897 requests in 2.00m, 108.97MB read
  Socket errors: connect 0, read 464, write 0, timeout 0
Requests/sec:   8894.89
Transfer/sec:      0.91MB


wrk -t10 -c1000 -d120s --timeout 2s --latency 'http://localhost:8080/v1/spu/detail?id=1'
Running 2m test @ http://localhost:8080/v1/spu/detail?id=1
  10 threads and 1000 connections
  Thread Stats   Avg      Stdev     Max   +/- Stdev
    Latency    61.92ms   20.97ms 536.55ms   94.69%
    Req/Sec     1.58k   294.84     2.02k    83.12%
  Latency Distribution
     50%   57.85ms
     75%   62.72ms
     90%   73.75ms
     99%  118.44ms
  1875346 requests in 2.00m, 191.37MB read
  Socket errors: connect 0, read 1081, write 0, timeout 0
Requests/sec:  15616.09
Transfer/sec:      1.59MB

用VisualVM跟蹤如下:


壓測跟蹤.png

spring-boot webflux配置圖

webflux config.png

webflux核心組件示意圖

webflux component.png
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末持际,一起剝皮案震驚了整個濱河市沃琅,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌选酗,老刑警劉巖阵难,帶你破解...
    沈念sama閱讀 216,496評論 6 501
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異芒填,居然都是意外死亡呜叫,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,407評論 3 392
  • 文/潘曉璐 我一進店門殿衰,熙熙樓的掌柜王于貴愁眉苦臉地迎上來朱庆,“玉大人,你說我怎么就攤上這事闷祥∮榧眨” “怎么了傲诵?”我有些...
    開封第一講書人閱讀 162,632評論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長箱硕。 經(jīng)常有香客問我拴竹,道長,這世上最難降的妖魔是什么剧罩? 我笑而不...
    開封第一講書人閱讀 58,180評論 1 292
  • 正文 為了忘掉前任栓拜,我火速辦了婚禮,結(jié)果婚禮上惠昔,老公的妹妹穿的比我還像新娘幕与。我一直安慰自己,他們只是感情好镇防,可當我...
    茶點故事閱讀 67,198評論 6 388
  • 文/花漫 我一把揭開白布啦鸣。 她就那樣靜靜地躺著,像睡著了一般来氧。 火紅的嫁衣襯著肌膚如雪诫给。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,165評論 1 299
  • 那天饲漾,我揣著相機與錄音蝙搔,去河邊找鬼。 笑死考传,一個胖子當著我的面吹牛吃型,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播僚楞,決...
    沈念sama閱讀 40,052評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼勤晚,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了泉褐?” 一聲冷哼從身側(cè)響起赐写,我...
    開封第一講書人閱讀 38,910評論 0 274
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎膜赃,沒想到半個月后挺邀,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,324評論 1 310
  • 正文 獨居荒郊野嶺守林人離奇死亡跳座,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,542評論 2 332
  • 正文 我和宋清朗相戀三年端铛,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片疲眷。...
    茶點故事閱讀 39,711評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡禾蚕,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出狂丝,到底是詐尸還是另有隱情换淆,我是刑警寧澤哗总,帶...
    沈念sama閱讀 35,424評論 5 343
  • 正文 年R本政府宣布,位于F島的核電站倍试,受9級特大地震影響讯屈,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜易猫,卻給世界環(huán)境...
    茶點故事閱讀 41,017評論 3 326
  • 文/蒙蒙 一耻煤、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧准颓,春花似錦、人聲如沸棺妓。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,668評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽怜跑。三九已至样勃,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間性芬,已是汗流浹背峡眶。 一陣腳步聲響...
    開封第一講書人閱讀 32,823評論 1 269
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留植锉,地道東北人辫樱。 一個月前我還...
    沈念sama閱讀 47,722評論 2 368
  • 正文 我出身青樓,卻偏偏與公主長得像俊庇,于是被迫代替她去往敵國和親狮暑。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 44,611評論 2 353

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

  • 由于 Elasticsearch(后文簡稱es) 的簡單易用及其在大數(shù)據(jù)處理方面的良好性能辉饱,越來越多的公司選用 e...
    rockybean閱讀 8,899評論 0 12
  • 魯大師檢測 詳細報表 --------[ 魯大師 ]-------------------------------...
    Feel君閱讀 11,877評論 0 0
  • 昨天公司一個做文秘的同事由于公司給配的電腦很不給力搬男,用個office,再打開一兩個其他的軟件就卡的要死彭沼,最后實在是...
    XcqRomance閱讀 10,796評論 26 47
  • 目的 壓測服務(wù)缔逛,找到服務(wù)器里應(yīng)用的瓶頸。 選取業(yè)務(wù) 選取了高PV的業(yè)務(wù)姓惑,和用戶能一步觸達的業(yè)務(wù)(本人指的“一步觸達...
    拉普拉斯獸閱讀 1,297評論 0 1
  • 今天在公園里天天因為弟弟失控了褐奴,蹲在地上很久很久……旁邊有人過來勸說,可勸說的內(nèi)容盡是指責(zé)挺益,我客氣的反駁后歉糜,...
    寧子沫沫閱讀 303評論 1 0