package Ġcom . sy i yi . con voy . node . server Ċ Ċ import Ġcom . sy i yi . con voy . common . protocol . Message Proto Ċ import Ġio . netty . channel . Channel HandlerContext Ċ import Ġio . netty . channel . Simple Channel Inbound Handler Ċ import Ġjava . time . LocalDateTime Ċ import Ġjava . util .* Ċ Ċ class ĠWS Protocol Frame Handler Ġ: ĠSimple Channel Inbound Handler < Message Proto . Message >() Ġ{ ĊĊĊĠĠĠ Ġ@ Throws ( Exception :: class ) ĊĠĠĠ Ġoverride Ġfun Ġchannel Read 0 ( ctx : ĠChannel HandlerContext ?, Ġmsg : ĠMessage Proto . Message ?) Ġ{ ĊĠĠĠĠĠĠĠ Ġif Ġ( msg Ġ!= Ġnull ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġrec Content Ġ= Ġmsg . content ĊĠĠĠĠĠĠĠĠĠĠĠ Ġprintln (" äºĮ è¿ĽåĪ¶ åįıè®® æľįåĬ¡ ç«¯ æİ¥åıĹ åĪ°çļĦ æ¶Īæģ¯ :$ rec Content ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġè¿ĶåĽŀ æ¶Īæģ¯ ç»Ļ å®¢æĪ·ç«¯ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġreply Msg Ġ= ĠMessage Proto . Message . newBuilder (). apply Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġid Ġ= ĠUUID . randomUUID (). toString (). replace ("- ", Ġ"") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġcontent Ġ= Ġ" æľįåĬ¡åĻ¨ æĹ¶éĹ´ : Ġ" Ġ+ ĠLocalDateTime . now () Ġ+ Ġ" Ġ Ġ ï¼ļ Ġ" Ġ+ Ġrec Content ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġtype Ġ= Ġ" text " ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ}. build () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġctx ?. channel ()?. write And Flush ( reply Msg ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġ å®¢æĪ·ç«¯ è¿ŀæİ¥ çļĦæĹ¶åĢĻ è§¦åıĳ ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġoverride Ġfun Ġhandler Added ( ctx : ĠChannel HandlerContext ) Ġ{ Ġ// ĠLong Text () Ġ åĶ¯ä¸Ģ çļĦ Ġ ĠShort Text () Ġä¸į åĶ¯ä¸Ģ ĊĠĠĠĠĠĠĠ Ġprintln (" äºĮ è¿ĽåĪ¶ åįıè®® add ï¼ļ" Ġ+ Ġctx . channel (). id (). as Long Text ()) ĊĠĠĠĠĠĠĠ Ġprintln (" äºĮ è¿ĽåĪ¶ åįıè®® add ï¼ļ" Ġ+ Ġctx . channel (). id (). as Short Text ()) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġ å®¢æĪ·ç«¯ æĸŃ å¼Ģ è¿ŀæİ¥ çļĦæĹ¶åĢĻ è§¦åıĳ ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġoverride Ġfun Ġhandler Removed ( ctx : ĠChannel HandlerContext ) Ġ{ ĊĠĠĠĠĠĠĠ Ġprintln (" äºĮ è¿ĽåĪ¶ åįıè®® Removed ï¼ļ" Ġ+ Ġctx . channel (). id (). as Long Text ()) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġexception Ca ught ( ctx : ĠChannel HandlerContext , Ġcause : ĠThrowable ) Ġ{ ĊĠĠĠĠĠĠĠ Ġprintln (" äºĮ è¿ĽåĪ¶ åįıè®® å¼Ĥå¸¸ åıĳçĶŁ äºĨ ...") ĊĠĠĠĠĠĠĠ Ġctx . close () ĊĠĠĠ Ġ} ĊĊ Ċ }