hcnet

HCネット

仮想化されたサーバーとクライアントの最下層では、tcp/tcps/ws/wss/udp などのプロトコルを簡単に切り替えることができるため、どのような状況でもプロトコルの切り替えが容易になります。オンライン番号やフロー制御などの後続の要件は後で処理されます。

コールバック処理

処理関数のコールバックの統合使用

 /// 连接处理回调函数
# [ async_trait ]
pub trait Handler {
    /// 此接口只有在服务端接受服务时进行触发
    /// 接收新的端口连接, 如果处理将在此触发
    async fn on_accept ( & mut self , conn : NetConn ) -> NetResult < ( ) > {
        let _conn = conn ;
        unreachable ! ( "Listener must impl accept" )
    }

    /// 此接口在可以发送消息时触发
    /// 例如websocket将在握手成功后触发该函数
    async fn on_open ( & mut self ) -> NetResult < ( ) > {
        trace ! ( "ws on_open" ) ;
        Ok ( ( ) )
    }

    /// 此接口在远程服务端被关闭时进行触发
    async fn on_close ( & mut self , code : CloseCode , reason : String ) {
        trace ! (
            "on_close code = {}, reason = {reason}" ,
            Into :: < u16 > :: into ( code )
        ) ;
    }

    /// ping消息收到, 将会自动返回pong消息
    async fn on_ping ( & mut self , data : Vec < u8 > ) -> NetResult < Vec < u8 > > {
        trace ! ( "on_ping" ) ;
        Ok ( data )
    }

    /// pong消息
    async fn on_pong ( & mut self , data : Vec < u8 > ) -> NetResult < ( ) > {
        let _data = data ;
        trace ! ( "on_pong" ) ;
        Ok ( ( ) )
    }

    /// message信息收到
    async fn on_message ( & mut self , msg : Message ) -> NetResult < ( ) > {
        let _ = msg ;
        Ok ( ( ) )
    }

    async fn on_request ( & mut self , req : Request < Vec < u8 > > ) -> NetResult < Response < Vec < u8 > > > {
        WsHandshake :: build_request ( & req )
    }

    async fn on_response ( & mut self , res : Request < Vec < u8 > > ) -> NetResult < ( ) > {
        let _ = res ;
        Ok ( ( ) )
    }
}

サーバー側の監視

TCPリスニング

 NetConn :: tcp_bind ( "0.0.0.0:2003" , Settings :: default ( ) ) . await 

WSモニタリング

 NetConn :: ws_bind ( "0.0.0.0:2003" , Settings :: default ( ) ) . await 

WSS監視

監視時に証明書情報を設定することで、簡単にwssプロトコルに対応できます。

 let mut settings = Settings {
    domain : Some ( "test.wmproxy.net" . to_string ( ) ) ,
    cert : Some ( "key/example.com.pem" . to_string ( ) ) ,
    key : Some ( "key/example.com.key" . to_string ( ) ) ,
    .. Settings :: default ( )
} ;
NetConn :: ws_bind ( "0.0.0.0:2003" , settings ) . await 

kcp (udp) 監視

 NetConn :: kcp_bind ( "0.0.0.0:2003" ) . await

基本的に、監視は一般的なソケット監視と同じであり、複雑さは同様です。任意のプロトコルを切り替えることができます。

サーバー側でリッスンを開始する

 let h = conn . run_handler ( |_| ServerHandler ) . await . unwrap ( ) ;
let _ = tokio :: join! ( h ) ;

具体的な例については、server_echo を参照してください。

クライアント接続

TCP接続

 NetConn :: tcp_connect ( "127.0.0.1:2003" ) . await 

WS接続

 NetConn :: ws_connect ( "ws://example.com:2003" ) . await 

WSS接続

 NetConn :: ws_connect ( "wss://example.com:2003" ) . await 

kcp(udp)接続

 NetConn :: kcp_connect ( "wss://example.com:2003" ) . await

クライアントはリスニングを開始します

 let ( mut sender , receiver ) = NetSender :: new ( 10 , 1 ) ;
let _ = conn . run_with_handler (
        ClientHandler {
            sender : sender . clone ( ) ,
        } ,
        receiver ,
    ) . await ;

または

 let _ = conn . run_handler ( |sender| ClientHandler { sender } ) . await ;

具体的な例については、 client_echo を参照してください。

デモを開始する

最初にサーバーを起動します

cargo run --example server_echo tcp

クライアントを再起動します

cargo run --example client_echo tcp