package Ġcom . sa ff rame work . server . core . handler . socket And WS Ċ Ċ import Ġio . netty . channel . Channel HandlerContext Ċ import Ġio . netty . handler . codec . http . Http Object Aggregator Ċ import Ġio . netty . handler . codec . http . HttpServer Codec Ċ import Ġio . netty . handler . codec . http . websocket x . WebSocket Frame Aggregator Ċ import Ġio . netty . handler . codec . http . websocket x . WebSocket Server Protocol Handler Ċ import Ġio . netty . handler . stream . Chunk ed Write Handler Ċ Ċ /** Ċ Ġ* Ċ Ġ* Ġ@ FileName : Ċ Ġ* ĠĠĠĠĠĠĠĠĠ Ġcom . sa ff rame work . server . core . handler . socket . Pipeline Add Ċ Ġ* Ġ@ author : ĠT ony ĠSh en Ċ Ġ* Ġ@ date : Ġ 2 0 2 0 - 0 3 - 2 5 Ġ 1 3 : 4 8 Ċ Ġ* Ġ@ version : ĠV 1 . 0 Ġ< æııè¿° å½ĵåīį çīĪæľ¬ åĬŁèĥ½ > Ċ Ġ*/ Ċ object ĠPipeline Add Ġ{ ĊĊĠĠĠ Ġfun Ġwebsocket Add ( ctx : ĠChannel HandlerContext , Ġweb Socket Path : String Ġ= Ġ"/ ws ") Ġ{ ĊĊĠĠĠĠĠĠĠ Ġprintln (" Pipeline Add ") ĊĠĠĠĠĠĠĠ Ġval Ġpipeline Ġ= Ġctx . pipeline () ĊĊĠĠĠĠĠĠĠ Ġ// ĠHttp Server Codec ï¼ļ å°Ĩ è¯·æ±Ĥ åĴĮ åºĶ çŃĶ æ¶Īæģ¯ è§£ çłģ ä¸º HTTP æ¶Īæģ¯ ĊĠĠĠĠĠĠĠ Ġpipeline . add Before (" common _ handler ", Ġ" http - codec ", ĠHttp Server Codec ()) ĊĊĠĠĠĠĠĠĠ Ġ// ĠHttp Object Aggregator ï¼ļ å°Ĩ HTTP æ¶Īæģ¯ çļĦ å¤ļä¸ª éĥ¨åĪĨ åĲĪ æĪĲ ä¸ĢæĿ¡ å®Įæķ´ çļĦ HTTP æ¶Īæģ¯ ĊĠĠĠĠĠĠĠ Ġpipeline . add Before (" common _ handler ", Ġ" ag gregator ", ĠHttp Object Aggregator ( 6 5 5 3 5 )) ĊĊĠĠĠĠĠĠĠ Ġ// ĠChunk ed Write Handler ï¼ļ åĲĳ å®¢æĪ·ç«¯ åıĳéĢģ HTML 5 æĸĩä»¶ , æĸĩä»¶ è¿ĩ å¤§ ä¼ļ å°Ĩ åĨħåŃĺ æĴ ĳ çĪ Ĩ ĊĠĠĠĠĠĠĠ Ġpipeline . add Before (" common _ handler ", Ġ" http - chunk ed ", ĠChunk ed Write Handler ()) ĊĠĠĠĠĠĠĠ Ġpipeline . add Before (" common _ handler ", Ġ" websocket - ag gregator ", ĠWebSocket Frame Aggregator ( 6 5 5 3 5 )) ĊĊĠĠĠĠĠĠĠ Ġ// çĶ¨äºİ å¤ĦçĲĨ websocket , Ġweb Socket Path Ġä¸º è®¿éĹ® websocket æĹ¶çļĦ uri ĊĠĠĠĠĠĠĠ Ġpipeline . add Before (" common _ handler ", Ġ" protocol - handler ", ĠWebSocket Server Protocol Handler ( web Socket Path )) ĊĊĠĠĠ Ġ} Ċ }