package Ġcom . q ing zh u . im access . socket io . handler Ċ Ċ import Ġcom . cor und um studio . socket io . Ack Request Ċ import Ġcom . cor und um studio . socket io . Socket IO Client Ċ import Ġcom . cor und um studio . socket io . annotation . On Event Ċ import Ġcom . q ing zh u . common . domain . shared . msg . dto . Message Dto Ċ import Ġcom . q ing zh u . im access . domain . query . WebSocket Request Message Ċ import Ġcom . q ing zh u . im access . domain . query . message Subscribe Ċ import Ġcom . q ing zh u . im access . domain . view . Message Response Ċ import Ġcom . q ing zh u . im access . service . Message Filter Service Ċ import Ġcom . q ing zh u . im access . service . Message Service Ċ import Ġcom . q ing zh u . im access . socket io . Abstract Handler Ċ import Ġcom . q ing zh u . im access . socket io . constant . Socket Event Ċ import Ġcom . q ing zh u . im access . socket io . constant . Socket IO Namespace Ċ import Ġorg . springframework . stereotype . Service Ċ import Ġreactor . kotlin . core . publisher . to Mono Ċ Ċ /** Ċ Ġ* Ġ å®¢ æľį åĴĮ å®¢æĪ· åħ± çĶ¨çļĦ æ¶Īæģ¯ Ġhandler Ċ Ġ*/ Ċ @ Service Ċ class ĠMessage Handler ( ĊĠĠĠ Ġprivate Ġval Ġmessage Service : ĠMessage Service , ĊĠĠĠ Ġprivate Ġval Ġmessage Filter Service : ĠMessage Filter Service Ċ ) Ġ: ĠAbstract Handler ( Socket IO Namespace . STA FF , ĠSocket IO Namespace . CUSTOMER ) Ġ{ ĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġ åıĳéĢģ èģ Ĭ å¤© æ¶Īæģ¯ ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġ@ On Event ( Socket Event . Message . send ) ĊĠĠĠ Ġfun Ġon Send ( socket IO Client : ĠSocket IO Client , Ġack Request : ĠAck Request , Ġrequest : ĠWebSocket Request Message ) Ġ{ ĊĠĠĠĠĠĠĠ Ġrequest . to Mono Monad ( socket IO Client ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. do On Next Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġ( organization Id , Ġfrom ) Ġ= Ġget Organization Id And Register Name ( socket IO Client ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . organization Id Ġ= Ġorganization Id ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġ éĩį åĨĻ Ġ åıĳéĢģ æĸ¹ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġit . from Ġ= Ġfrom ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ// Ġ è¿ĩæ»¤ æ¶Īæģ¯ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. transform ( message Filter Service :: filter ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. message Subscribe ( ack Request , Ġrequest ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmessage Service . send ( Message Dto ( socket IO Client . sessionId . toString (), Ġit ). to Mono ()). subscribe () ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠMessage Response . from Message ( it ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ// Ġsocket io ĠæĶ¯æĮģ å¤ļ æ¬¡ çĽĳåĲ¬ åĲĮ ä¸Ģ äºĭä»¶ ĊĠĠĠ Ġ} Ċ }