{"id":347633,"date":"2023-05-19T03:00:37","date_gmt":"2023-05-19T03:00:37","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=347633"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=347633","title":{"rendered":"WebSocket \u0441\u0435\u0440\u0432\u0435\u0440 \u0434\u043b\u044f \u043c\u0438\u043d\u0438 \u0438\u0433\u0440\u044b \u043e\u0431\u043c\u0435\u043d\u0430 \u0444\u0430\u0439\u043b\u0430\u043c\u0438 (Rust)<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n

\u0412\u0441\u0435\u043c \u043f\u0440\u0438\u0432\u0435\u0442! \u042d\u0442\u043e \u0442\u0443\u0442\u043e\u0440\u0438\u0430\u043b \u043f\u043e \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044e \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0433\u043e WebSocket \u0441\u0435\u0440\u0432\u0435\u0440\u0430 \u0434\u043b\u044f \u043c\u0443\u043b\u044c\u0442\u0438\u043f\u043b\u0435\u0435\u0440\u043d\u043e\u0439 \u043c\u0438\u043d\u0438 \u0438\u0433\u0440\u044b. \u0421\u0443\u0442\u044c \u0438\u0433\u0440\u044b \u043f\u0440\u043e\u0441\u0442\u0430\u044f \u2013 \u043e\u0431\u043c\u0435\u043d\u0438\u0432\u0430\u0435\u0448\u044c\u0441\u044f \u0444\u0430\u0439\u043b\u0430\u043c\u0438 \u0441 \u0434\u0440\u0443\u0433\u0438\u043c\u0438 \u0438\u0433\u0440\u043e\u043a\u0430\u043c\u0438 \u0432 \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u043c 2D \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0435. \u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0439 \u0435\u0441\u0442\u044c \u0432 \u0433\u0438\u0442\u0445\u0430\u0431\u0435<\/a>, \u043f\u0440\u043e\u0442\u0435\u0441\u0442\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043c\u043e\u0436\u043d\u043e \u043d\u0430 \u0441\u0430\u0439\u0442\u0435<\/a>.<\/p>\n

\"Demo\"<\/p>\n
Demo<\/figcaption><\/div>\n<\/figure>\n

\u041d\u0430\u0447\u0430\u043b\u043e<\/h2>\n
\n

\u0411\u043e\u043b\u044c\u0448\u0430\u044f \u0447\u0430\u0441\u0442\u044c \u043e\u0431\u044a\u044f\u0441\u043d\u0435\u043d\u0438\u0439 \u043e\u043f\u0438\u0441\u0430\u043d\u0430 \u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u043a\u043e\u043c\u043c\u0435\u043d\u0442\u0430\u0440\u0438\u0435\u0432 \u043a \u043a\u043e\u0434\u0443. <\/p>\n<\/blockquote>\n

\u0421\u043e\u0437\u0434\u0430\u0439\u0442\u0435 \u043f\u0440\u043e\u0435\u043a\u0442 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043a\u043e\u043c\u0430\u043d\u0434\u044b cargo new <name>. \u041f\u043e\u0441\u043b\u0435 \u044d\u0442\u043e\u0433\u043e \u0434\u043e\u0431\u0430\u0432\u044c\u0442\u0435 \u0432 \u0444\u0430\u0439\u043b Cargo.toml \u0432\u0441\u0435 \u044d\u0442\u0438 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438. <\/p>\n

[dependencies] # \u0420\u0430\u043d\u0442\u0430\u0439\u043c \u0434\u043b\u044f \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 tokio = { version = \"1.28.1\", features = [\"full\"] }  # \u0410\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0430\u044f \u0432\u0435\u0440\u0441\u0438\u044f \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 tungstenite, \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u044e\u0449\u0435\u0439 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b WebSocket,  # \u0440\u0430\u0431\u043e\u0442\u0430\u044e\u0449\u0430\u044f \u0432 \u0441\u0432\u044f\u0437\u043a\u0435 \u0441 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u043e\u0439 tokio. tokio-tungstenite = \"0.18.0\"  # \u0412\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u044b \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u043c\u0430\u0441\u0441\u0438\u0432\u0430\u043c\u0438 \u0431\u0430\u0439\u0442\u043e\u0432.  bstr = \"1.4.0\"  # \u0412\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u0430 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u043c\u0438 \u043e\u0431\u044a\u0435\u043a\u0442\u0430\u043c\u0438. futures-util = \"0.3\"  # \u0411\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0440\u0435\u0433\u0443\u043b\u044f\u0440\u043d\u044b\u043c\u0438 \u0432\u044b\u0440\u0430\u0436\u0435\u043d\u0438\u044f\u043c\u0438. regex = \"1\"  # Mutex, RwLock \u0438 \u0442\u0434. \u0431\u044b\u0441\u0442\u0440\u0435\u0435 \u0447\u0435\u043c \u0432 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u043e\u0439 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0435. parking_lot = \"0.12.1\"  # \u0413\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u0442 \u0440\u0430\u043d\u0434\u043e\u043c\u043d\u044b\u0435 \u0447\u0438\u0441\u043b\u0430. rand = \"0.8.5\"<\/code><\/pre>\n
\u0411\u0430\u0437\u043e\u0432\u044b\u0435 \u0442\u0438\u043f\u044b  <\/h2>\n
\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 UserFileMessage<\/code> \u2013 \u0445\u0440\u0430\u043d\u0438\u0442 \u0432 \u0441\u0435\u0431\u0435 \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044e \u043e \u0444\u0430\u0439\u043b\u0435, \u043f\u0435\u0440\u0435\u0434\u0430\u043d\u043d\u0443\u044e \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u043c, \u0430 \u0442\u0430\u043a \u0436\u0435 \u0438\u043c\u0435\u0435\u0442 \u043c\u0435\u0442\u043e\u0434 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u044e\u0449\u0438\u0439 \u043f\u0430\u0440\u0441\u0438\u0442\u044c \u044d\u0442\u0443 \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044e \u0438\u0437 \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0431\u0430\u0439\u0442\u043e\u0432. \u0411\u0443\u0434\u0435\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u043f\u0440\u0438 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0438 \u0431\u0438\u043d\u0430\u0440\u043d\u043e\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f (\u043e\u0434\u0438\u043d \u0438\u0437 \u0442\u0438\u043f\u043e\u0432 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 WebSocket) \u043e\u0442 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f, \u0434\u043b\u044f \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0438 \u0435\u0433\u043e \u0432\u0430\u043b\u0438\u0434\u043d\u043e\u0441\u0442\u0438.<\/p>\n
\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 Connection<\/code> \u2013 \u0445\u0440\u0430\u043d\u0438\u0442 \u0432 \u0441\u0435\u0431\u0435 \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0430 \u0442\u0430\u043a\u0436\u0435 \u0441\u0430\u043c\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435, \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044f \u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u0442\u0441\u044f \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u043e\u043c\u0443 \u044e\u0437\u0435\u0440\u0443.<\/p>\n
Enum BroadcastEvents<\/code> \u2013 \u0441\u043e\u0434\u0435\u0440\u0436\u0438\u0442 \u0441\u043f\u0438\u0441\u043e\u043a \u0441\u043e\u0431\u044b\u0442\u0438\u0439, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u043e\u0433\u0443\u0442 \u0431\u044b\u0442\u044c \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u044b \u0432\u0441\u0435\u043c \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u043c \u0441\u0440\u0430\u0437\u0443. \u041d\u0443\u0436\u0435\u043d \u0434\u043b\u044f \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u0438\u0442\u044c \u043d\u0430 \u0442\u0438\u043f\u044b \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c\u044b\u0435 Broadcast\u2019\u0435\u0440\u043e\u043c (\u043e \u043d\u0451\u043c \u043d\u0438\u0436\u0435).<\/p>\n
\n\u041a\u043e\u0434 \u0442\u0438\u043f\u043e\u0432 (\u0424\u0430\u0439\u043b server\/src\/types.rs)<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/types.rs  \/\/ \u0422\u0440\u0435\u0439\u0442 \u0441 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u043c\u0438 \u043c\u0435\u0442\u043e\u0434\u0430\u043c\u0438 \u0434\u043b\u044f \u043c\u0430\u0441\u0441\u0438\u043c\u0430 \u0431\u0430\u0439\u0442\u043e\u0432  use bstr::ByteSlice;  \/\/ SplitSink \u044d\u0442\u043e Sink \u0447\u0430\u0441\u0442\u044c \u0440\u0430\u0437\u0434\u0435\u043b\u0451\u043d\u043d\u043e\u0433\u043e \u043d\u0430 \u0434\u0432\u0430 \u043e\u0431\u044a\u0435\u043a\u0442\u0430 \u043f\u043e\u0442\u043e\u043a\u0430.  \/\/ \u041f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043f\u043e\u0437\u0436\u0435 use futures_util::stream::SplitSink;  \/\/ \u0410\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 TCP \u0441\u0442\u0440\u0438\u043c  use tokio::net::TcpStream;  \/\/ \u0422\u0438\u043f WebSocket \u043f\u043e\u0442\u043e\u043a\u0430 \u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438\u0437 \u043d\u0435\u0433\u043e use tokio_tungstenite::{tungstenite::Message, WebSocketStream};  pub struct UserFileMessage {   \/\/ \u0418\u043c\u044f \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0432\u0448\u0435\u0433\u043e \u0444\u0430\u0439\u043b   pub username: String,    \/\/ \u0418\u043c\u044f \u0444\u0430\u0439\u043b\u0430   pub file_name: String,    \/\/ Content-Type \u0444\u0430\u0439\u043b\u0430   pub file_type: String,    \/\/ \u0421\u0430\u043c \u0444\u0430\u0439\u043b    pub file_bytes: Vec<u8>, }  impl UserFileMessage {   \/\/ \u041c\u0435\u0442\u043e\u0434 \u0438\u0437 \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0431\u0430\u0439\u0442\u043e\u0432 \u0441\u043e\u0431\u0438\u0440\u0430\u0435\u0442 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 UserFileMessage.   pub fn from(data: Vec<u8>) -> Option<Self> {     \/\/ \u041f\u0430\u0442\u0442\u0435\u0440\u043d \u0440\u0430\u0437\u0434\u0435\u043b\u0438\u0442\u0435\u043b\u044f, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043e\u0442\u0434\u0435\u043b\u044f\u0435\u0442 \u043a\u0430\u0436\u0434\u044b\u0439 \u0444\u0440\u0430\u0433\u043c\u0435\u043d\u0442      \/\/ \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u0438 \u043e\u0442 \u0434\u0440\u0443\u0433\u043e\u0433\u043e. \u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440:     \/\/ username<pattern>filename<pattern>filetype<pattern>filebytes     let pattern: [u8; 12] = [226, 128, 147, 226, 128, 147, 226, 128, 147, 226, 128, 147];           \/\/ \u0414\u0435\u043b\u0438\u0442 \u043c\u0430\u0441\u0441\u0438\u0432 \u043f\u043e \u043f\u0430\u0442\u0442\u0435\u0440\u043d\u0443     let result: Vec<Vec<u8>> = data.split_str(&pattern).map(|x|x.to_vec()).filter(|x| x.len() > 0).collect();          \/\/ \u0415\u0441\u043b\u0438 \u0440\u0430\u0437\u0434\u0435\u043b\u0435\u043d\u0438\u0435 \u043f\u0440\u043e\u0448\u043b\u043e \u043d\u0430 4 \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u0430, \u0442\u043e \u0432\u0441\u0435 \u043f\u0440\u043e\u0448\u043b\u043e \u0443\u0441\u043f\u0435\u0448\u043d\u043e.      \/\/ \u0415\u0441\u043b\u0438 \u043d\u0435\u0442, \u0442\u043e \u0434\u0430\u043d\u043d\u044b\u0435 \u043f\u0435\u0440\u0435\u0434\u0430\u043d\u044b \u043d\u0435\u043a\u043e\u0440\u0440\u0435\u043a\u0442\u043d\u043e \u0438 \u043d\u0443\u0436\u043d\u043e \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0442\u044c None.     if result.len() == 4 {       let username = String::from_utf8_lossy(&result[0]).to_string();       let file_name = String::from_utf8_lossy(&result[1]).to_string();       let file_type = String::from_utf8_lossy(&result[2]).to_string();              let file_bytes = result[3].clone();              Some(UserFileMessage { username, file_name, file_type, file_bytes })     } else {       None     }   } }  #[derive(Debug)] pub struct Connection {   \/\/ \u0420\u0430\u043d\u0434\u043e\u043c\u043d\u044b\u0439 \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f   pub id: u32,    \/\/ Sink \u0447\u0430\u0441\u0442\u044c websocket \u043f\u043e\u0442\u043e\u043a\u0430 \u0434\u043b\u044f \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0438 \u0432 \u043d\u0435\u0433\u043e \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u0438   pub con: SplitSink<WebSocketStream<TcpStream>, Message>, }  #[derive(Debug)] pub enum BroadcastEvents {   \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u0432 broadcast'\u0435\u0440   AddConn(Connection),     \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432\u0441\u0435\u043c \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0438 \u043d\u043e\u0432\u043e\u0433\u043e   Join(String),    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432\u0441\u0435\u043c \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043e \u0432\u044b\u0445\u043e\u0434\u0435 \u0438\u0433\u0440\u043e\u043a\u0430.    \/\/ \u0422\u0430\u043a \u0436\u0435 \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u043c \u043f\u0435\u0440\u0432\u044b\u043c \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u043c \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 \u0435\u0433\u043e   \/\/ \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u044f, \u0447\u0442\u043e\u0431\u044b \u0443\u0434\u0430\u043b\u0438\u0442\u044c \u0435\u0433\u043e \u0438\u0437 \u0441\u043f\u0438\u0441\u043a\u0430.   Quit(u32, String),    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432\u0441\u0435\u043c \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0430\u043c \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u043e\u0433\u043e \u043e\u0442 \u043e\u0434\u043d\u043e\u0433\u043e \u0438\u0437 \u043d\u0438\u0445 \u0444\u0430\u0439\u043b\u0430.   SendFile(Message) }<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
Broadcast  <\/h2>\n
Broadcast \u2013 \u044d\u0442\u043e \u0444\u0443\u043d\u043a\u0446\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0432 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0439 Task\u2019\u0435 tokio, \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0442\u044c \u0441\u0438\u0433\u043d\u0430\u043b\u044b \u043e\u0442 \u0434\u0440\u0443\u0433\u0438\u0445 \u043f\u043e\u0442\u043e\u043a\u043e\u0432 \u0438 \u0432 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438 \u043e\u0442 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u043e\u0433\u043e \u0441\u0438\u0433\u043d\u0430\u043b\u0430, \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0432\u0441\u0435\u043c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u044b\u043c \u0438\u0433\u0440\u043e\u043a\u0430\u043c \u0440\u0430\u0437\u043d\u044b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f.<\/p>\n
\n
Task \u0432 tokio \u044d\u0442\u043e \u0437\u0435\u043b\u0451\u043d\u044b\u0439 (\u0432\u0438\u0440\u0442\u0443\u0430\u043b\u044c\u043d\u044b\u0439) \u043f\u043e\u0442\u043e\u043a. \u041e\u043d \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u043e\u043c \u0442\u043e\u043a\u0438\u043e, \u0430 \u043d\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u043e\u043d\u043d\u043e\u0439 \u0441\u0438\u0441\u0442\u0435\u043c\u043e\u0439.  <\/p>\n<\/blockquote>\n
\n\u041a\u043e\u0434 broadcast (\u0424\u0430\u0439\u043b server\/src\/broadcast.rs)<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/broadcast.rs  use std::collections::HashMap;  \/\/ \u0422\u0440\u0435\u0439\u0442 \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u044e\u0449\u0438\u0439 \u0443\u0434\u043e\u0431\u043d\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u044b \u0434\u043b\u044f Sink \u043e\u0431\u044a\u0435\u043a\u0442\u043e\u0432 (\u0432  \/\/ \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 Sink'\u043e\u043c \u0431\u0443\u0434\u0435\u0442, \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u0430\u044f \u043f\u043e\u0441\u043b\u0435 \u0434\u0435\u043b\u0435\u043d\u0438\u044f, \u0432\u0442\u043e\u0440\u0430\u044f \u0447\u0430\u0441\u0442\u044c \/\/ \u043f\u043e\u0442\u043e\u043a\u0430 WebSocketStream, \u0432 \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435, \u0434\u043b\u044f  \/\/ \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0438 \u0438\u0445 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044e). use futures_util::SinkExt;  \/\/ \u0422\u0438\u043f \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u0435\u043b\u044f \u0434\u043b\u044f \u043d\u0435\u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u043d\u043e\u0433\u043e mpsc \u043a\u0430\u043d\u0430\u043b\u0430 use tokio::sync::mpsc::UnboundedReceiver;  \/\/ \u0422\u0438\u043f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0435\u043c\u043e\u0433\u043e \u043f\u043e WebSocket'\u0443 use tokio_tungstenite::tungstenite::Message;  use crate::types::{BroadcastEvents, Connection};  pub async fn run(mut rx: UnboundedReceiver<BroadcastEvents>) {   let mut connections: HashMap<u32, Connection> = HashMap::new();    \/\/ \u0412 \u0446\u0438\u043a\u043b\u0435 \u0436\u0434\u0451\u043c \u043d\u043e\u0432\u044b\u0439 \u0441\u0438\u0433\u043d\u0430\u043b    while let Some(event) = rx.recv().await {     match event {       \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0432 \u0441\u043f\u0438\u0441\u043e\u043a \u0434\u043b\u044f \u0440\u0430\u0441\u0441\u044b\u043b\u043a\u0438       BroadcastEvents::AddConn(conn) => {         connections.insert(conn.id, conn);       }    \/\/ \u0420\u0430\u0441\u0441\u044b\u043b\u0430\u0435\u043c \u0432\u0441\u0435\u043c \u044e\u0437\u0435\u0440\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0438 \u043d\u043e\u0432\u043e\u0433\u043e \u0438\u0433\u0440\u043e\u043a\u0430       \/\/ \u041f\u0440\u0438\u043c\u0435\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f: JOIN|userA       BroadcastEvents::Join(username) => {         for (_, iconn) in connections.iter_mut() {           let _ = iconn.con.send(Message::Text(format!(\"JOIN|{}\", username))).await;         }       }        \/\/ \u0420\u0430\u0441\u0441\u044b\u043b\u0430\u0435\u043c \u0432\u0441\u0435\u043c \u044e\u0437\u0435\u0440\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e \u0432\u044b\u0445\u043e\u0434\u0435 \u0438\u0433\u0440\u043e\u043a\u0430       \/\/ \u041f\u0440\u0438\u043c\u0435\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f: LEFT|userA       BroadcastEvents::Quit(id, username) => {         connections.remove(&id);          if !username.is_empty() {           for (_, conn) in connections.iter_mut() {             let _ = conn.con.send(Message::Text(format!(\"LEFT|{}\", username))).await;           }         }       }        \/\/ \u041f\u0435\u0440\u0435\u0441\u044b\u043b\u0430\u0435\u043c \u044e\u0437\u0435\u0440\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441 \u0444\u0430\u0439\u043b\u043e\u043c.       \/\/ \u0422\u0430\u043a \u043a\u0430\u043a \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0434\u043b\u044f \u043f\u0435\u0440\u0435\u0441\u044b\u043b\u043a\u0438 \u043d\u0443\u0436\u043d\u043e \u043a\u043b\u043e\u043d\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0438 \u043f\u0440\u0438    \/\/ \u0431\u043e\u043b\u044c\u0448\u043e\u043c \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0435 \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u044d\u0442\u043e \u043c\u043e\u0436\u0435\u0442 \u0432\u044b\u0437\u0432\u0430\u0442\u044c \u0437\u0430\u043c\u0435\u0434\u043b\u0435\u043d\u0438\u044f \u0432 \u0440\u0430\u0431\u043e\u0442\u0435       \/\/ \u0444\u0443\u043d\u043a\u0446\u0438\u0438, \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0439 \u0440\u0430\u0437\u043c\u0435\u0440 \u0444\u0430\u0439\u043b\u0430 \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d 5\u041c\u0411. (\u042d\u0442\u043e \u0431\u0443\u0434\u0435\u0442 \u043d\u0438\u0436\u0435)       BroadcastEvents::SendFile(msg) => {         for (_, conn) in connections.iter_mut() {           let _ = conn.con.send(msg.clone()).await;         }       }     }   } }<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u0421\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u044f \u0438\u0433\u0440\u043e\u043a\u043e\u0432  <\/h2>\n
\u0414\u043b\u044f \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f \u0437\u0430 \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435\u043c \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u0443\u044e \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 Game<\/code>, \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u0431\u0443\u0434\u0435\u043c \u0445\u0440\u0430\u043d\u0438\u0442\u044c \u0441\u043f\u0438\u0441\u043e\u043a \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0451\u043d\u043d\u044b\u0445 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u0435\u043b\u044c \u0441\u0438\u0433\u043d\u0430\u043b\u043e\u0432 \u0432 Broadcast.<\/p>\n
\u0414\u043b\u044f \u043f\u0440\u0435\u0434\u043e\u0442\u0432\u0440\u0430\u0449\u0435\u043d\u0438\u044f \u0441\u043f\u0430\u043c\u0430 \u0444\u0430\u0439\u043b\u0430\u043c\u0438, \u0443 \u043d\u0430\u0441 \u0431\u0443\u0434\u0435\u0442 \u0441\u0442\u043e\u044f\u0442\u044c \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0439 cooldown \u0432 15 \u0441\u0435\u043a\u0443\u043d\u0434 \u0434\u043b\u044f \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u043d\u0430 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0443 \u0444\u0430\u0439\u043b\u0430. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0437\u0430 \u043a\u0430\u0436\u0434\u044b\u043c \u0438\u0433\u0440\u043e\u043a\u043e\u043c, \u043a\u0440\u043e\u043c\u0435 \u0435\u0433\u043e \u0438\u043c\u0435\u043d\u0438 \u0438 \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0435\u0439 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438 \u0444\u0430\u0439\u043b\u0430, \u043d\u0438\u0447\u0435\u0433\u043e \u0437\u0430\u043a\u0440\u0435\u043f\u043b\u0435\u043d\u043e \u043d\u0435 \u0431\u0443\u0434\u0435\u0442.<\/p>\n
\n\u041a\u043e\u0434 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b Game (\u0424\u0430\u0439\u043b server\/src\/game.rs)<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/game.rs  use std::{collections::HashMap, sync::Arc};  use parking_lot::Mutex; use tokio::{sync::mpsc::UnboundedSender, time::Instant}; use tokio_tungstenite::tungstenite::Message;  use crate::types::{BroadcastEvents, Connection};  pub struct Player {   \/\/ \u0412\u0440\u0435\u043c\u044f \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0435\u0433\u043e \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u043d\u043e\u0433\u043e \u0444\u0430\u0439\u043b\u0430.    \/\/ \u0422\u0430\u043a \u043a\u0430\u043a, \u043a\u043e\u0433\u0434\u0430 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c \u0442\u043e\u043b\u044c\u043a\u043e \u0437\u0430\u0448\u0435\u043b, \u043e\u043d \u0435\u0449\u0451 \u043d\u0435 \u0443\u0441\u043f\u0435\u043b \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c   \/\/ \u0447\u0442\u043e-\u043d\u0438\u0431\u0443\u0434\u044c, \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u0442\u044c \u0432 \u044d\u0442\u043e \u043f\u043e\u043b\u0435 \u043d\u0435\u0447\u0435\u0433\u043e. \u0412 \u0442\u0430\u043a\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u0431\u0443\u0434\u0435\u0442   \/\/ \u0432\u044b\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043e \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 \u0435\u043d\u0430\u043c\u0430 Option \u2013 None.   pub dt_last_send: Option<Instant>, }  #[derive(Clone)] pub struct Game {   \/\/ \u041c\u0430\u043f\u0430 \u0441\u043e \u0432\u0441\u0435\u043c\u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u044b\u043c\u0438 \u0438\u0433\u0440\u0430\u043a\u0430\u043c\u0438 (\u0424\u043e\u0440\u043c\u0430\u0442: username:Player).   \/\/ \u0414\u043b\u044f \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u044d\u0442\u043e \u043f\u043e\u043b\u0435 \u0431\u044b\u043b\u043e \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u043e \u0434\u043b\u044f \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u0445 \u043f\u043e\u0442\u043e\u043a\u043e\u0432,   \/\/ \u0435\u0433\u043e \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c \u0432 \u0441\u043c\u0430\u0440\u0442-\u043f\u043e\u0438\u043d\u0442\u0435\u0440 Arc, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442   \/\/ \u043c\u043d\u043e\u0436\u0435\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0435 \u0432\u043b\u0430\u0434\u0435\u043d\u0438\u0435 \u0434\u0430\u043d\u043d\u044b\u043c\u0438 \u0432 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u0445 \u043f\u043e\u0442\u043e\u043a\u0430\u0445. \u0410 \u0447\u0442\u043e\u0431\u044b    \/\/ \u043c\u0430\u043f\u0443 \u043c\u043e\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u0432\u043d\u0443\u0442\u0440\u0438 Arc'\u0430 \u0435\u0449\u0451 \u0438 \u0438\u0437\u043c\u0435\u043d\u044f\u0442\u044c, \u043d\u0443\u0436\u043d\u043e \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u043e   \/\/ \u0437\u0430\u0432\u0435\u0440\u043d\u0443\u0442\u044c \u0435\u0451 \u0432 Mutex. \u0422\u0430\u043a \u0436\u0435 Mutex \u043e\u0431\u0435\u0437\u043e\u043f\u0430\u0441\u0438\u0442 \u0434\u0430\u043d\u043d\u044b\u0435, \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0438\u0432   \/\/ \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u043e\u0435 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0435\u0434\u0438\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e \u0438\u0437\u043c\u0435\u043d\u044f\u0435\u043c\u044b\u0445 \u043c\u0430\u043f\u0443 \u043f\u043e\u0442\u043e\u043a\u043e\u0432 \u0434\u043e \u043e\u0434\u043d\u043e\u0433\u043e.   pub players: Arc<Mutex<HashMap<String, Player>>>,    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u0435\u043b\u044c \u0441\u0438\u0433\u043d\u0430\u043b\u043e\u0432 \u0432 Broadcast   pub broadcast_sender: UnboundedSender<BroadcastEvents> }  impl Game {   \/\/ \u0421\u043e\u0437\u0434\u0430\u0451\u043c \u043d\u043e\u0432\u044b\u0439 \u0438\u043d\u0441\u0442\u0430\u043d\u0441   pub fn new(broadcast_sender: UnboundedSender<BroadcastEvents>) -> Game {     Game {        players: Arc::new(Mutex::new(HashMap::new())),       broadcast_sender,     }   }      \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u0438\u0433\u0440\u043e\u043a\u0430 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u0438\u0433\u043d\u0430\u043b \u0432 Broadcast.     \/\/ \u0412\u044b\u0437\u043e\u0432 \u043c\u0435\u0442\u043e\u0434\u0430 send \u0432\u0435\u0440\u043d\u0451\u0442 Result, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043c\u044b \u043d\u0435 \u0445\u043e\u0442\u0438\u043c \u0432 \u0434\u0430\u043d\u043d\u043e\u043c   \/\/ \u0441\u043b\u0443\u0447\u0430\u0435 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0442\u044c. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0437\u0430\u0441\u0443\u043d\u0435\u043c \u0435\u0433\u043e \u0432 \u0438\u0433\u043d\u043e\u0440\u0438\u0440\u0443\u0435\u043c\u0443\u044e \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u0443\u044e.     \/\/ \u0422\u0430\u043a \u0436\u0435 \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u0435\u0441\u0442\u044c \u043b\u0438 \u0442\u0430\u043a\u043e\u0439 \u0438\u0433\u0440\u043e\u043a \u0443\u0436\u0435 \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435 \u0438    \/\/ \u043d\u0435 \u043f\u0440\u0435\u0432\u044b\u0441\u0438\u0442 \u043b\u0438 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435 50,   \/\/ \u0435\u0441\u043b\u0438 \u0438\u0433\u0440\u043e\u043a \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u0441\u044f. (\u041c\u0430\u043a\u0441\u0438\u043c\u0443\u043c 50 \u0438\u0433\u0440\u043e\u043a\u043e\u0432)   pub fn add_player(&self, username: String) {     let mut players = self.players.lock();     if !players.contains_key(&username) && players.len() < 50 {       players.insert(username.clone(), Player { dt_last_send: None });       let _ = self.broadcast_sender.send(BroadcastEvents::Join(username.clone()));     }   }    \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0432 Broadcast   pub fn add_connection(&self, conn: Connection) {     let _ = self.broadcast_sender.send(BroadcastEvents::AddConn(conn));   }     \/\/ \u0423\u0434\u0430\u043b\u044f\u0435\u043c \u0438\u0433\u0440\u043e\u043a\u0430 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u0438\u0433\u043d\u0430\u043b \u0432 Broadcast   pub fn remove_player(&self, username: String, id: u32) {     self.players.lock().remove(&username);     let _ = self.broadcast_sender.send(BroadcastEvents::Quit(id, username));   }    \/\/ \u0424\u043e\u0440\u043c\u0438\u0440\u0443\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441\u043e \u0441\u043f\u0438\u0441\u043a\u043e\u043c \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439.   \/\/ \u041f\u0440\u0438\u043c\u0435\u0440: LIST|userA,userB,userC   pub fn get_list_message(&self) -> Message {     let list_string = self.players.lock().iter().map(|w| w.0.to_owned()).collect::<Vec<String>>().join(\",\");      Message::Text(format!(\"LIST|{}\", list_string))   }    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441 \u0444\u0430\u0439\u043b\u043e\u043c \u0432 Broadcast.   \/\/ \u041f\u0435\u0440\u0435\u0434 \u044d\u0442\u0438\u043c \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u043f\u0440\u043e\u0448\u0435\u043b \u0438\u043b\u0438 \u043d\u0435\u0442 \u0443 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f    \/\/ cooldown \u043d\u0430 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0443 \u0444\u0430\u0439\u043b\u0430.   pub fn send_file(&self, from: String, msg: Message) {     let mut players = self.players.lock();     if let Some(player) = players.get(&from) {       if player.dt_last_send.is_none() || player.dt_last_send.unwrap().elapsed().as_secs() > 15 {         let _ = self.broadcast_sender.send(BroadcastEvents::SendFile(msg));         players.insert(from, Player { dt_last_send: Some(Instant::now()) });       }     }   } }<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432 \u043d\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435  <\/h2>\n
\u0422\u0430\u043a \u043a\u0430\u043a WebSocket \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u043f\u043e\u0432\u0435\u0440\u0445 TCP, \u0434\u043b\u044f \u043d\u0430\u0447\u0430\u043b\u0430 \u043d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u043f\u0440\u043e\u0441\u043b\u0443\u0448\u0438\u0432\u0430\u044e\u0449\u0438\u0439 TCP \u0441\u043e\u043a\u0435\u0442 \u043c\u0435\u0442\u043e\u0434\u043e\u043c bind<\/code> \u0443 TcpListener\u2019\u0430, \u0438 \u0432 \u0446\u0438\u043a\u043b\u0435 \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0442\u044c \u0432\u0441\u0435 \u0437\u0430\u043f\u0440\u043e\u0441\u044b \u043d\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435.<\/p>\n
\u0414\u043b\u044f \u043e\u043f\u0442\u0438\u043c\u0438\u0437\u0430\u0446\u0438\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439 \u043b\u0443\u0447\u0448\u0435 \u0432\u044b\u0432\u043e\u0434\u0438\u0442\u044c \u0438\u0445 \u0432 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043f\u043e\u0442\u043e\u043a. \u0412 \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435, \u0432 Task\u2019\u0443 \u0442\u043e\u043a\u0438\u043e.<\/p>\n
\n\u041d\u0430\u0447\u0430\u043b\u043e \u043a\u043e\u0434\u0430 main.rs<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/main.rs  \/\/ \u041c\u0435\u0442\u043e\u0434\u044b \u0434\u043b\u044f \u0443\u0434\u043e\u0431\u043d\u043e\u0433\u043e \u0443\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u044f \u043f\u043e\u0442\u043e\u043a\u043e\u043c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u044f WebSocket use futures_util::{StreamExt, SinkExt};  use tokio::net::{TcpStream, TcpListener};  \/\/ \u0424\u0443\u043d\u0446\u0438\u044f \u0434\u043b\u044f \u043f\u0440\u0438\u043d\u044f\u0442\u0438\u044f WebSocket \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f use tokio_tungstenite::accept_async;  use tokio::sync::mpsc;  \/\/ \u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u0440\u0435\u0433\u0443\u043b\u044f\u0440\u043d\u044b\u043c\u0438 \u0432\u044b\u0440\u0430\u0436\u0435\u043d\u0438\u044f\u043c\u0438 use regex::Regex;  \/\/ \u0420\u0430\u043d\u0434\u043e\u043c\u0430\u0439\u0437\u0435\u0440 \u0434\u043b\u044f \u0447\u0438\u0441\u0435\u043b use rand::Rng;  use types::{Connection, BroadcastEvents, UserFileMessage}; use game::Game;  mod types; mod game; mod broadcast;  \/\/ \u041e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u043e \u043d\u0430\u0432\u0435\u0448\u0438\u0432\u0430\u0435\u043c \u043d\u0430 main \u043c\u0430\u043a\u0440\u043e\u0441 tokio::main, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \/\/ \u0441\u043e\u0437\u0434\u0430\u0441\u0442 \u0440\u0430\u043d\u0442\u0430\u0439\u043c \u0442\u043e\u043a\u0438\u043e \u0434\u043b\u044f \u0438\u0441\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430. #[tokio::main] async fn main () {     \/\/ \u0421\u043e\u0437\u0434\u0430\u0451\u043c \u043f\u0440\u043e\u0441\u043b\u0443\u0448\u0438\u0432\u0430\u044e\u0449\u0438\u0439 TCP \u0441\u043e\u043a\u0435\u0442 \u043d\u0430 \u043f\u043e\u0440\u0442\u0435 8080 let server = TcpListener::bind(\"0.0.0.0:8080\").await.unwrap();      \/\/ \u0421\u043e\u0437\u0434\u0430\u0451\u043c \u043d\u0435\u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u043d\u044b\u0439 \u043a\u0430\u043d\u0430\u043b mpsc let (broadcast_sender, broadcast_receiver) = mpsc::unbounded_channel::<BroadcastEvents>();    \/\/ \u0421\u043e\u0437\u0434\u0430\u0451\u043c \u043d\u043e\u0432\u044b\u0439 \u043f\u043e\u0442\u043e\u043a \u0442\u043e\u043a\u0438\u043e \u0438 \u043d\u0430 \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u0435\u043c\u0443 \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u043c \u043d\u0430\u0448\u0443      \/\/ \u0444\u0443\u043d\u043a\u0446\u0438\u044e Broadcast. tokio::spawn(broadcast::run(broadcast_receiver));  let game = Game::new(broadcast_sender);  \/\/ \u0412 \u0446\u0438\u043a\u043b\u0435 \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0435\u043c \u0432\u0441\u0435 \u0437\u0430\u043f\u0440\u043e\u0441\u044b \u043d\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 loop { let (stream, _) = server.accept().await.unwrap();         \/\/ \u041e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c \u0432\u0441\u0435 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u0432 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u043c \u0442\u043e\u043a\u0438\u043e \u043f\u043e\u0442\u043e\u043a\u0435 tokio::spawn(process_con(stream, game.clone())); } }  \/\/ \u0424\u0443\u043d\u043a\u0446\u0438\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f async fn process_con(stream: TcpStream, game: Game) { println!(\"Connection!\") }<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439  <\/h2>\n
\u041d\u0430\u0448\u0430 \u0444\u0443\u043d\u043a\u0446\u0438\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0432 2 \u044d\u0442\u0430\u043f\u0430.<\/p>\n
\u041d\u0430 \u043f\u0435\u0440\u0432\u043e\u043c \u044d\u0442\u0430\u043f\u0435 \u043e\u043d\u0430 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442 \u0441\u043f\u0438\u0441\u043e\u043a \u0432\u0441\u0435 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0451\u043d\u043d\u044b\u0445 \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044e, \u0434\u043e\u0431\u0430\u0432\u0438\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0432 \u0441\u043f\u0438\u0441\u043e\u043a \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439 \u0432 Broadcaster\u2019\u0435, \u0447\u0442\u043e\u0431\u044b \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u044b\u0439 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c \u0443\u0436\u0435 \u043c\u043e\u0433 \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u043e \u0432\u044b\u0445\u043e\u0434\u0430\u0445 \u0438 \u0432\u0445\u043e\u0434\u0430\u0445 \u0434\u0440\u0443\u0433\u0438\u0445 \u0438\u0433\u0440\u043e\u043a\u043e\u0432. \u0418 \u043f\u043e\u0441\u043b\u0435 \u044d\u0442\u043e\u0433\u043e \u0431\u0443\u0434\u0435\u0442 \u0436\u0434\u0430\u0442\u044c \u043e\u0442 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0444\u043e\u0440\u043c\u0430\u0442\u0430 \u00abJOIN|<username>\u00bb. \u041f\u043e\u0441\u043b\u0435 \u0442\u043e\u0433\u043e, \u043a\u0430\u043a \u043e\u043d\u0430 \u0435\u0433\u043e \u043f\u043e\u043b\u0443\u0447\u0438\u0442, \u043f\u0435\u0440\u0435\u0439\u0434\u0451\u0442 \u043a\u043e \u0432\u0442\u043e\u0440\u043e\u043c\u0443 \u044d\u0442\u0430\u043f\u0443.<\/p>\n
\u041d\u0430 \u0432\u0442\u043e\u0440\u043e\u043c \u044d\u0442\u0430\u043f\u0435 \u043e\u043d\u0430 \u0431\u0443\u0434\u0435\u0442 \u0432 \u0446\u0438\u043a\u043b\u0435 \u0436\u0434\u0430\u0442\u044c \u043e\u0442 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0441 \u0444\u0430\u0439\u043b\u0430\u043c\u0438 \u0438 \u0440\u0430\u0441\u0441\u044b\u043b\u0430\u0442\u044c \u0438\u0445 \u0432\u0441\u0435\u043c \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u043c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0451\u043d\u043d\u044b\u043c \u0438\u0433\u0440\u043e\u043a\u0430\u043c. \u041a\u043e\u0433\u0434\u0430 \u0446\u0438\u043a\u043b \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u043d\u043e\u0439 \u0440\u0430\u0437 \u043f\u043e\u043f\u044b\u0442\u0430\u0435\u0442\u0441\u044f \u043f\u0440\u043e\u0447\u0438\u0442\u0430\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438 \u043f\u043e\u043b\u0443\u0447\u0438\u0442 \u043e\u0448\u0438\u0431\u043a\u0443, \u044d\u0442\u043e \u0431\u0443\u0434\u0435\u0442 \u043e\u0437\u043d\u0430\u0447\u0430\u0442\u044c \u043e\u0431\u0440\u044b\u0432 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u0441 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u043c. \u041f\u043e\u0441\u043b\u0435 \u044d\u0442\u043e\u0433\u043e \u0444\u0443\u043d\u043a\u0446\u0438\u044f \u0432\u044b\u0437\u043e\u0432\u0435\u0442 \u043c\u0435\u0442\u043e\u0434 remove_player<\/code> \u0443 \u0438\u043d\u0441\u0442\u0430\u043d\u0441\u0430 game<\/code>, \u0447\u0442\u043e \u0443\u0434\u0430\u043b\u0438\u0442 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f \u0438\u0437 Broadcast\u2019\u0430 \u0438 \u0435\u0433\u043e \u043d\u0438\u043a \u0438\u0437 \u0441\u043f\u0438\u0441\u043a\u0430 \u0438\u0433\u0440\u043e\u043a\u043e\u0432, \u0430 \u0442\u0430\u043a \u0436\u0435 \u0441\u043e\u043e\u0431\u0449\u0438\u0442 \u043e \u0435\u0433\u043e \u043e\u0442\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0438 \u0432\u0441\u0435\u043c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0451\u043d\u043d\u044b\u043c \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f\u043c.<\/p>\n
\n\u041a\u043e\u0434 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0439 (\u0424\u0430\u0439\u043b server\/mail.rs)<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/main.rs  \/\/ ...  async fn process_con(stream: TcpStream, game: Game) {     \/\/ \u0413\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u043c \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 \u0434\u043b\u044f \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f let id = rand::thread_rng().gen::<u32>();    \/\/ \u041f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u043c websocket handshake, \u043f\u043e\u0441\u043b\u0435 \u0447\u0435\u0433\u043e \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c      \/\/ websocket \u043f\u043e\u0442\u043e\u043a \u0438\u043b\u0438 \u043e\u0448\u0438\u0431\u043a\u0443. \u0412 \u0441\u043b\u0443\u0447\u0430\u0435 \u043e\u0448\u0438\u0431\u043a\u0438 \u0432\u0438\u0440\u0442\u0443\u0430\u043b\u044c\u043d\u044b\u0439      \/\/ \u043f\u043e\u0442\u043e\u043a \u0442\u043e\u043a\u0438\u043e \u043e\u0431\u043e\u0440\u0432\u0435\u0442\u0441\u044f. let websocket = accept_async(stream).await.unwrap();  \/\/ \u0414\u0435\u043b\u0438\u043c \u043f\u043e\u0442\u043e\u043a \u0432\u0435\u0431\u0441\u043e\u043a\u0435\u0442\u0430 \u043d\u0430 Sink \u0438 Stream \u043e\u0431\u044a\u0435\u043a\u0442\u044b      \/\/ \u0434\u043b\u044f \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u043c\u043e\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u0447\u0438\u0442\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0441 \u043f\u043e\u0442\u043e\u043a\u0430 \u0432      \/\/ \u043e\u0434\u043d\u043e\u043c \u043f\u043e\u0442\u043e\u043a\u0435, \u0430 \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u044c \u0432 \u0434\u0440\u0443\u0433\u043e\u043c. \u0412 \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435      \/\/ Sink \u043e\u0431\u044a\u0435\u043a\u0442 (sender) \u043c\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043c \u0431\u0440\u043e\u0430\u0434\u043a\u0430\u0441\u0442\u0435\u0440\u0443, \u0430 \u0441      \/\/ Stream \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0438\u043c \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0442\u0443\u0442 \u0447\u0442\u043e\u0431 \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f. let (mut sender, mut receiver) = websocket.split();  let mut username = String::new();   \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043f\u0438\u0441\u043e\u043a \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044e let _ = sender.send(game.get_list_message()).await;  \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u0432 \u0441\u043f\u0438\u0441\u043e\u043a \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0439 Broadcast game.add_connection(Connection { id, con: sender, });  \/\/ \u0416\u0434\u0451\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u0445\u043e\u0434\u0430 \u043e\u0442 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f.     \/\/ \u0415\u0441\u043b\u0438 \u043f\u0440\u0438\u0445\u043e\u0434\u044f\u0442 \u043b\u044e\u0431\u044b\u0435 \u0434\u0440\u0443\u0433\u0438\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043a\u0440\u043e\u043c\u0435 \u0442\u0435\u043a\u0441\u0442\u043e\u0432\u044b\u0445     \/\/ \u0444\u043e\u0440\u043c\u0430\u0442\u0430 \"JOIN|<username>\" \u2013 \u0438\u0433\u043d\u043e\u0440\u0438\u0440\u0443\u0435\u043c \u0438\u0445.     \/\/ \u041f\u0440\u0438 \u044d\u0442\u043e \u0434\u043b\u0438\u043d\u0430 \u0438\u043c\u0435\u043d\u0438 \u0438\u0433\u0440\u043e\u043a\u0430 \u043d\u0435 \u0434\u043e\u043b\u0436\u043d\u0430 \u043f\u0440\u0435\u0432\u044b\u0448\u0430\u0442\u044c 13 \u0441\u0438\u043c\u0432\u043e\u043b\u043e\u0432.      \/\/ \u041a\u043e\u0433\u0434\u0430 \u0432\u0430\u043b\u0438\u0434\u043d\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043e, \u043e\u043d \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u0438\u0433\u0440\u043e\u043a\u0430 \u0432 \u0441\u043f\u0438\u0441\u043e\u043a \u0438      \/\/ \u0441\u043e\u043e\u0431\u0449\u0430\u0435\u0442 \u0432\u0441\u0435\u043c \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u043c \u043e \u043d\u043e\u0432\u043e\u043c \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0435. while let Some(msg) = receiver.next().await { if let Ok(msg) = msg { if !msg.is_text() { continue; } if let Ok(data) = msg.clone().into_text() { let re = Regex::new(r\"JOIN\\|[A-Za-z0-9]*$\").unwrap(); if re.is_match(&data) { username = (&data[5..]).to_owned(); if username.len() > 13 { continue; } game.add_player(username.clone()); break; } } } else { game.remove_player(username, id); return; } }  \/\/ \u041e\u0431\u0440\u0430\u0431\u043e\u0442\u044b\u0432\u0430\u0435\u043c \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u044b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043f\u043e\u0441\u043b\u0435 \u0432\u0445\u043e\u0434\u0430.     \/\/ \u0412\u0441\u0435 \u043d\u0435 \u0431\u0438\u043d\u0430\u0440\u043d\u044b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0433\u043d\u043e\u0440\u0438\u0440\u0443\u0435\u043c, \u0430 \u0431\u0438\u043d\u0430\u0440\u043d\u044b\u0435 \u043f\u0430\u0440\u0441\u0438\u043c \u0438      \/\/ \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u043d\u0430 \u0432\u0430\u043b\u0438\u0434\u043d\u043e\u0441\u0442\u044c. \u0415\u0441\u043b\u0438 \u0440\u0430\u0437\u043c\u0435\u0440 \u0444\u0430\u0439\u043b\u0430 \u0431\u043e\u043b\u044c\u0448\u0435 5\u041c\u0411, \u0438\u043b\u0438      \/\/ \u0435\u0441\u043b\u0438 \u0432 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u0435\u043b\u0435\u043c \u0443\u043a\u0430\u0437\u0430\u043d \u043d\u0435 \u0442\u043e\u0442 \u0438\u0433\u0440\u043e\u043a, \u0447\u0442\u043e      \/\/ \u0437\u0430\u043f\u0438\u0441\u0430\u043d \u0432 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0438 \u2013 \u0438\u0433\u043d\u043e\u0440\u0438\u0440\u0443\u0435\u043c. \u0412 \u0438\u043d\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435, \u043f\u0435\u0440\u0435\u0441\u044b\u043b\u0430\u0435\u043c      \/\/ \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432\u0441\u0435\u043c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u044b\u043c \u0438\u0433\u0440\u043e\u043a\u0430\u043c. while let Some(msg) = receiver.next().await { if let Ok(msg) = msg { if !msg.is_binary() { continue; } if let Some(data) = UserFileMessage::from(msg.clone().into_data()) { if data.file_bytes.len() > 5_000_000 && data.username == username { continue; }  game.send_file(data.username, msg); } } else { break; } }  \/\/ \u041a\u043e\u0433\u0434\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u043e\u0431\u043e\u0440\u0432\u0430\u043d\u043e (\u0446\u0438\u043a\u043b \u0437\u0430\u043a\u043e\u043d\u0447\u0438\u043b\u0441\u044f), \u0443\u0434\u0430\u043b\u044f\u0435\u043c \u0438\u0433\u0440\u043e\u043a\u0430      \/\/ \u0438\u0437 \u0441\u043f\u0438\u0441\u043a\u0430 \u0438 \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u044f\u0435\u043c \u0432\u0441\u0435\u0445 \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0445 \u043e\u0431 \u044d\u0442\u043e\u043c. game.remove_player(username, id); } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\n
\u0421\u043f\u0430\u0441\u0438\u0431\u043e \u0437\u0430 \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u0435! \ud83d\ude42 \u0422\u0430\u043a \u0436\u0435 \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0443\u044e \u0447\u0430\u0441\u0442\u044c \u0438\u0433\u0440\u044b \u043c\u043e\u0436\u043d\u043e \u043d\u0430\u0439\u0442\u0438 \u0432 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u043f\u043e \u0441\u0441\u044b\u043b\u043a\u0435 \u043d\u0438\u0436\u0435.  <\/p>\n
 \u0421\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u2013 github.com\/IDSaves\/filecats<\/a><\/p>\n<\/p>\n<\/div>\n<\/div>\n
  <\/div>\n
  
 \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438  https:\/\/habr.com\/ru\/articles\/736174\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
<\/div>\n
\n
\n
\n
\u0412\u0441\u0435\u043c \u043f\u0440\u0438\u0432\u0435\u0442! \u042d\u0442\u043e \u0442\u0443\u0442\u043e\u0440\u0438\u0430\u043b \u043f\u043e \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044e \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0433\u043e WebSocket \u0441\u0435\u0440\u0432\u0435\u0440\u0430 \u0434\u043b\u044f \u043c\u0443\u043b\u044c\u0442\u0438\u043f\u043b\u0435\u0435\u0440\u043d\u043e\u0439 \u043c\u0438\u043d\u0438 \u0438\u0433\u0440\u044b. \u0421\u0443\u0442\u044c \u0438\u0433\u0440\u044b \u043f\u0440\u043e\u0441\u0442\u0430\u044f \u2013 \u043e\u0431\u043c\u0435\u043d\u0438\u0432\u0430\u0435\u0448\u044c\u0441\u044f \u0444\u0430\u0439\u043b\u0430\u043c\u0438 \u0441 \u0434\u0440\u0443\u0433\u0438\u043c\u0438 \u0438\u0433\u0440\u043e\u043a\u0430\u043c\u0438 \u0432 \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u043c 2D \u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u0435. \u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0439 \u0435\u0441\u0442\u044c \u0432 \u0433\u0438\u0442\u0445\u0430\u0431\u0435<\/a>, \u043f\u0440\u043e\u0442\u0435\u0441\u0442\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043c\u043e\u0436\u043d\u043e \u043d\u0430 \u0441\u0430\u0439\u0442\u0435<\/a>.<\/p>\n
\n
Demo<\/figcaption><\/div>\n<\/figure>\n
\u041d\u0430\u0447\u0430\u043b\u043e<\/h2>\n
\n
 \u0411\u043e\u043b\u044c\u0448\u0430\u044f \u0447\u0430\u0441\u0442\u044c \u043e\u0431\u044a\u044f\u0441\u043d\u0435\u043d\u0438\u0439 \u043e\u043f\u0438\u0441\u0430\u043d\u0430 \u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u043a\u043e\u043c\u043c\u0435\u043d\u0442\u0430\u0440\u0438\u0435\u0432 \u043a \u043a\u043e\u0434\u0443.  <\/p>\n<\/blockquote>\n
\u0421\u043e\u0437\u0434\u0430\u0439\u0442\u0435 \u043f\u0440\u043e\u0435\u043a\u0442 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043a\u043e\u043c\u0430\u043d\u0434\u044b cargo new <name>. \u041f\u043e\u0441\u043b\u0435 \u044d\u0442\u043e\u0433\u043e \u0434\u043e\u0431\u0430\u0432\u044c\u0442\u0435 \u0432 \u0444\u0430\u0439\u043b Cargo.toml \u0432\u0441\u0435 \u044d\u0442\u0438 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438.  <\/p>\n
[dependencies] # \u0420\u0430\u043d\u0442\u0430\u0439\u043c \u0434\u043b\u044f \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 tokio = { version = \"1.28.1\", features = [\"full\"] }  # \u0410\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0430\u044f \u0432\u0435\u0440\u0441\u0438\u044f \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 tungstenite, \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u044e\u0449\u0435\u0439 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b WebSocket,  # \u0440\u0430\u0431\u043e\u0442\u0430\u044e\u0449\u0430\u044f \u0432 \u0441\u0432\u044f\u0437\u043a\u0435 \u0441 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u043e\u0439 tokio. tokio-tungstenite = \"0.18.0\"  # \u0412\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u044b \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u043c\u0430\u0441\u0441\u0438\u0432\u0430\u043c\u0438 \u0431\u0430\u0439\u0442\u043e\u0432.  bstr = \"1.4.0\"  # \u0412\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u0430 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u043c\u0438 \u043e\u0431\u044a\u0435\u043a\u0442\u0430\u043c\u0438. futures-util = \"0.3\"  # \u0411\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430 \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0440\u0435\u0433\u0443\u043b\u044f\u0440\u043d\u044b\u043c\u0438 \u0432\u044b\u0440\u0430\u0436\u0435\u043d\u0438\u044f\u043c\u0438. regex = \"1\"  # Mutex, RwLock \u0438 \u0442\u0434. \u0431\u044b\u0441\u0442\u0440\u0435\u0435 \u0447\u0435\u043c \u0432 \u0441\u0442\u0430\u043d\u0434\u0430\u0440\u0442\u043d\u043e\u0439 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0435. parking_lot = \"0.12.1\"  # \u0413\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u0442 \u0440\u0430\u043d\u0434\u043e\u043c\u043d\u044b\u0435 \u0447\u0438\u0441\u043b\u0430. rand = \"0.8.5\"<\/code><\/pre>\n
\u0411\u0430\u0437\u043e\u0432\u044b\u0435 \u0442\u0438\u043f\u044b  <\/h2>\n
\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 UserFileMessage<\/code> \u2013 \u0445\u0440\u0430\u043d\u0438\u0442 \u0432 \u0441\u0435\u0431\u0435 \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044e \u043e \u0444\u0430\u0439\u043b\u0435, \u043f\u0435\u0440\u0435\u0434\u0430\u043d\u043d\u0443\u044e \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u043c, \u0430 \u0442\u0430\u043a \u0436\u0435 \u0438\u043c\u0435\u0435\u0442 \u043c\u0435\u0442\u043e\u0434 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u044e\u0449\u0438\u0439 \u043f\u0430\u0440\u0441\u0438\u0442\u044c \u044d\u0442\u0443 \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044e \u0438\u0437 \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0431\u0430\u0439\u0442\u043e\u0432. \u0411\u0443\u0434\u0435\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c\u0441\u044f \u043f\u0440\u0438 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0438 \u0431\u0438\u043d\u0430\u0440\u043d\u043e\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f (\u043e\u0434\u0438\u043d \u0438\u0437 \u0442\u0438\u043f\u043e\u0432 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 WebSocket) \u043e\u0442 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f, \u0434\u043b\u044f \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0438 \u0435\u0433\u043e \u0432\u0430\u043b\u0438\u0434\u043d\u043e\u0441\u0442\u0438.<\/p>\n
\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 Connection<\/code> \u2013 \u0445\u0440\u0430\u043d\u0438\u0442 \u0432 \u0441\u0435\u0431\u0435 \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f, \u0430 \u0442\u0430\u043a\u0436\u0435 \u0441\u0430\u043c\u043e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435, \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044f \u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u0442\u0441\u044f \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u043e\u043c\u0443 \u044e\u0437\u0435\u0440\u0443.<\/p>\n
Enum BroadcastEvents<\/code> \u2013 \u0441\u043e\u0434\u0435\u0440\u0436\u0438\u0442 \u0441\u043f\u0438\u0441\u043e\u043a \u0441\u043e\u0431\u044b\u0442\u0438\u0439, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043c\u043e\u0433\u0443\u0442 \u0431\u044b\u0442\u044c \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u044b \u0432\u0441\u0435\u043c \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u043c \u0441\u0440\u0430\u0437\u0443. \u041d\u0443\u0436\u0435\u043d \u0434\u043b\u044f \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u0438\u0442\u044c \u043d\u0430 \u0442\u0438\u043f\u044b \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c\u044b\u0435 Broadcast\u2019\u0435\u0440\u043e\u043c (\u043e \u043d\u0451\u043c \u043d\u0438\u0436\u0435).<\/p>\n
\n\u041a\u043e\u0434 \u0442\u0438\u043f\u043e\u0432 (\u0424\u0430\u0439\u043b server\/src\/types.rs)<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/types.rs  \/\/ \u0422\u0440\u0435\u0439\u0442 \u0441 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u043c\u0438 \u043c\u0435\u0442\u043e\u0434\u0430\u043c\u0438 \u0434\u043b\u044f \u043c\u0430\u0441\u0441\u0438\u043c\u0430 \u0431\u0430\u0439\u0442\u043e\u0432  use bstr::ByteSlice;  \/\/ SplitSink \u044d\u0442\u043e Sink \u0447\u0430\u0441\u0442\u044c \u0440\u0430\u0437\u0434\u0435\u043b\u0451\u043d\u043d\u043e\u0433\u043e \u043d\u0430 \u0434\u0432\u0430 \u043e\u0431\u044a\u0435\u043a\u0442\u0430 \u043f\u043e\u0442\u043e\u043a\u0430.  \/\/ \u041f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043f\u043e\u0437\u0436\u0435 use futures_util::stream::SplitSink;  \/\/ \u0410\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 TCP \u0441\u0442\u0440\u0438\u043c  use tokio::net::TcpStream;  \/\/ \u0422\u0438\u043f WebSocket \u043f\u043e\u0442\u043e\u043a\u0430 \u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0438\u0437 \u043d\u0435\u0433\u043e use tokio_tungstenite::{tungstenite::Message, WebSocketStream};  pub struct UserFileMessage {   \/\/ \u0418\u043c\u044f \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0432\u0448\u0435\u0433\u043e \u0444\u0430\u0439\u043b   pub username: String,    \/\/ \u0418\u043c\u044f \u0444\u0430\u0439\u043b\u0430   pub file_name: String,    \/\/ Content-Type \u0444\u0430\u0439\u043b\u0430   pub file_type: String,    \/\/ \u0421\u0430\u043c \u0444\u0430\u0439\u043b    pub file_bytes: Vec<u8>, }  impl UserFileMessage {   \/\/ \u041c\u0435\u0442\u043e\u0434 \u0438\u0437 \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0431\u0430\u0439\u0442\u043e\u0432 \u0441\u043e\u0431\u0438\u0440\u0430\u0435\u0442 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 UserFileMessage.   pub fn from(data: Vec<u8>) -> Option<Self> {     \/\/ \u041f\u0430\u0442\u0442\u0435\u0440\u043d \u0440\u0430\u0437\u0434\u0435\u043b\u0438\u0442\u0435\u043b\u044f, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043e\u0442\u0434\u0435\u043b\u044f\u0435\u0442 \u043a\u0430\u0436\u0434\u044b\u0439 \u0444\u0440\u0430\u0433\u043c\u0435\u043d\u0442      \/\/ \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u0438 \u043e\u0442 \u0434\u0440\u0443\u0433\u043e\u0433\u043e. \u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440:     \/\/ username<pattern>filename<pattern>filetype<pattern>filebytes     let pattern: [u8; 12] = [226, 128, 147, 226, 128, 147, 226, 128, 147, 226, 128, 147];           \/\/ \u0414\u0435\u043b\u0438\u0442 \u043c\u0430\u0441\u0441\u0438\u0432 \u043f\u043e \u043f\u0430\u0442\u0442\u0435\u0440\u043d\u0443     let result: Vec<Vec<u8>> = data.split_str(&pattern).map(|x|x.to_vec()).filter(|x| x.len() > 0).collect();          \/\/ \u0415\u0441\u043b\u0438 \u0440\u0430\u0437\u0434\u0435\u043b\u0435\u043d\u0438\u0435 \u043f\u0440\u043e\u0448\u043b\u043e \u043d\u0430 4 \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u0430, \u0442\u043e \u0432\u0441\u0435 \u043f\u0440\u043e\u0448\u043b\u043e \u0443\u0441\u043f\u0435\u0448\u043d\u043e.      \/\/ \u0415\u0441\u043b\u0438 \u043d\u0435\u0442, \u0442\u043e \u0434\u0430\u043d\u043d\u044b\u0435 \u043f\u0435\u0440\u0435\u0434\u0430\u043d\u044b \u043d\u0435\u043a\u043e\u0440\u0440\u0435\u043a\u0442\u043d\u043e \u0438 \u043d\u0443\u0436\u043d\u043e \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0442\u044c None.     if result.len() == 4 {       let username = String::from_utf8_lossy(&result[0]).to_string();       let file_name = String::from_utf8_lossy(&result[1]).to_string();       let file_type = String::from_utf8_lossy(&result[2]).to_string();              let file_bytes = result[3].clone();              Some(UserFileMessage { username, file_name, file_type, file_bytes })     } else {       None     }   } }  #[derive(Debug)] pub struct Connection {   \/\/ \u0420\u0430\u043d\u0434\u043e\u043c\u043d\u044b\u0439 \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f   pub id: u32,    \/\/ Sink \u0447\u0430\u0441\u0442\u044c websocket \u043f\u043e\u0442\u043e\u043a\u0430 \u0434\u043b\u044f \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0438 \u0432 \u043d\u0435\u0433\u043e \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u0438   pub con: SplitSink<WebSocketStream<TcpStream>, Message>, }  #[derive(Debug)] pub enum BroadcastEvents {   \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u0442 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u0432 broadcast'\u0435\u0440   AddConn(Connection),     \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432\u0441\u0435\u043c \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0438 \u043d\u043e\u0432\u043e\u0433\u043e   Join(String),    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432\u0441\u0435\u043c \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043e \u0432\u044b\u0445\u043e\u0434\u0435 \u0438\u0433\u0440\u043e\u043a\u0430.    \/\/ \u0422\u0430\u043a \u0436\u0435 \u043f\u0435\u0440\u0435\u0434\u0430\u0451\u043c \u043f\u0435\u0440\u0432\u044b\u043c \u044d\u043b\u0435\u043c\u0435\u043d\u0442\u043e\u043c \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 \u0435\u0433\u043e   \/\/ \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u044f, \u0447\u0442\u043e\u0431\u044b \u0443\u0434\u0430\u043b\u0438\u0442\u044c \u0435\u0433\u043e \u0438\u0437 \u0441\u043f\u0438\u0441\u043a\u0430.   Quit(u32, String),    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432\u0441\u0435\u043c \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0430\u043c \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u043e\u0433\u043e \u043e\u0442 \u043e\u0434\u043d\u043e\u0433\u043e \u0438\u0437 \u043d\u0438\u0445 \u0444\u0430\u0439\u043b\u0430.   SendFile(Message) }<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
Broadcast  <\/h2>\n
Broadcast \u2013 \u044d\u0442\u043e \u0444\u0443\u043d\u043a\u0446\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0431\u0443\u0434\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0432 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0439 Task\u2019\u0435 tokio, \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u0442\u044c \u0441\u0438\u0433\u043d\u0430\u043b\u044b \u043e\u0442 \u0434\u0440\u0443\u0433\u0438\u0445 \u043f\u043e\u0442\u043e\u043a\u043e\u0432 \u0438 \u0432 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438 \u043e\u0442 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u043e\u0433\u043e \u0441\u0438\u0433\u043d\u0430\u043b\u0430, \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0432\u0441\u0435\u043c \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u044b\u043c \u0438\u0433\u0440\u043e\u043a\u0430\u043c \u0440\u0430\u0437\u043d\u044b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f.<\/p>\n
\n
Task \u0432 tokio \u044d\u0442\u043e \u0437\u0435\u043b\u0451\u043d\u044b\u0439 (\u0432\u0438\u0440\u0442\u0443\u0430\u043b\u044c\u043d\u044b\u0439) \u043f\u043e\u0442\u043e\u043a. \u041e\u043d \u0443\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u043e\u043c \u0442\u043e\u043a\u0438\u043e, \u0430 \u043d\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u043e\u043d\u043d\u043e\u0439 \u0441\u0438\u0441\u0442\u0435\u043c\u043e\u0439.  <\/p>\n<\/blockquote>\n
\n\u041a\u043e\u0434 broadcast (\u0424\u0430\u0439\u043b server\/src\/broadcast.rs)<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/broadcast.rs  use std::collections::HashMap;  \/\/ \u0422\u0440\u0435\u0439\u0442 \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u044e\u0449\u0438\u0439 \u0443\u0434\u043e\u0431\u043d\u044b\u0435 \u043c\u0435\u0442\u043e\u0434\u044b \u0434\u043b\u044f Sink \u043e\u0431\u044a\u0435\u043a\u0442\u043e\u0432 (\u0432  \/\/ \u043d\u0430\u0448\u0435\u043c \u0441\u043b\u0443\u0447\u0430\u0435 Sink'\u043e\u043c \u0431\u0443\u0434\u0435\u0442, \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u0430\u044f \u043f\u043e\u0441\u043b\u0435 \u0434\u0435\u043b\u0435\u043d\u0438\u044f, \u0432\u0442\u043e\u0440\u0430\u044f \u0447\u0430\u0441\u0442\u044c \/\/ \u043f\u043e\u0442\u043e\u043a\u0430 WebSocketStream, \u0432 \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435, \u0434\u043b\u044f  \/\/ \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0438 \u0438\u0445 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044e). use futures_util::SinkExt;  \/\/ \u0422\u0438\u043f \u043f\u043e\u043b\u0443\u0447\u0430\u0442\u0435\u043b\u044f \u0434\u043b\u044f \u043d\u0435\u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u043d\u043e\u0433\u043e mpsc \u043a\u0430\u043d\u0430\u043b\u0430 use tokio::sync::mpsc::UnboundedReceiver;  \/\/ \u0422\u0438\u043f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0435\u043c\u043e\u0433\u043e \u043f\u043e WebSocket'\u0443 use tokio_tungstenite::tungstenite::Message;  use crate::types::{BroadcastEvents, Connection};  pub async fn run(mut rx: UnboundedReceiver<BroadcastEvents>) {   let mut connections: HashMap<u32, Connection> = HashMap::new();    \/\/ \u0412 \u0446\u0438\u043a\u043b\u0435 \u0436\u0434\u0451\u043c \u043d\u043e\u0432\u044b\u0439 \u0441\u0438\u0433\u043d\u0430\u043b    while let Some(event) = rx.recv().await {     match event {       \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0432 \u0441\u043f\u0438\u0441\u043e\u043a \u0434\u043b\u044f \u0440\u0430\u0441\u0441\u044b\u043b\u043a\u0438       BroadcastEvents::AddConn(conn) => {         connections.insert(conn.id, conn);       }    \/\/ \u0420\u0430\u0441\u0441\u044b\u043b\u0430\u0435\u043c \u0432\u0441\u0435\u043c \u044e\u0437\u0435\u0440\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0438 \u043d\u043e\u0432\u043e\u0433\u043e \u0438\u0433\u0440\u043e\u043a\u0430       \/\/ \u041f\u0440\u0438\u043c\u0435\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f: JOIN|userA       BroadcastEvents::Join(username) => {         for (_, iconn) in connections.iter_mut() {           let _ = iconn.con.send(Message::Text(format!(\"JOIN|{}\", username))).await;         }       }        \/\/ \u0420\u0430\u0441\u0441\u044b\u043b\u0430\u0435\u043c \u0432\u0441\u0435\u043c \u044e\u0437\u0435\u0440\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e \u0432\u044b\u0445\u043e\u0434\u0435 \u0438\u0433\u0440\u043e\u043a\u0430       \/\/ \u041f\u0440\u0438\u043c\u0435\u0440 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f: LEFT|userA       BroadcastEvents::Quit(id, username) => {         connections.remove(&id);          if !username.is_empty() {           for (_, conn) in connections.iter_mut() {             let _ = conn.con.send(Message::Text(format!(\"LEFT|{}\", username))).await;           }         }       }        \/\/ \u041f\u0435\u0440\u0435\u0441\u044b\u043b\u0430\u0435\u043c \u044e\u0437\u0435\u0440\u0430\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441 \u0444\u0430\u0439\u043b\u043e\u043c.       \/\/ \u0422\u0430\u043a \u043a\u0430\u043a \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0434\u043b\u044f \u043f\u0435\u0440\u0435\u0441\u044b\u043b\u043a\u0438 \u043d\u0443\u0436\u043d\u043e \u043a\u043b\u043e\u043d\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0438 \u043f\u0440\u0438    \/\/ \u0431\u043e\u043b\u044c\u0448\u043e\u043c \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0435 \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u044d\u0442\u043e \u043c\u043e\u0436\u0435\u0442 \u0432\u044b\u0437\u0432\u0430\u0442\u044c \u0437\u0430\u043c\u0435\u0434\u043b\u0435\u043d\u0438\u044f \u0432 \u0440\u0430\u0431\u043e\u0442\u0435       \/\/ \u0444\u0443\u043d\u043a\u0446\u0438\u0438, \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0439 \u0440\u0430\u0437\u043c\u0435\u0440 \u0444\u0430\u0439\u043b\u0430 \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d 5\u041c\u0411. (\u042d\u0442\u043e \u0431\u0443\u0434\u0435\u0442 \u043d\u0438\u0436\u0435)       BroadcastEvents::SendFile(msg) => {         for (_, conn) in connections.iter_mut() {           let _ = conn.con.send(msg.clone()).await;         }       }     }   } }<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u0421\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u044f \u0438\u0433\u0440\u043e\u043a\u043e\u0432  <\/h2>\n
\u0414\u043b\u044f \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f \u0437\u0430 \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435\u043c \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u0443\u044e \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443 Game<\/code>, \u0432 \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u0431\u0443\u0434\u0435\u043c \u0445\u0440\u0430\u043d\u0438\u0442\u044c \u0441\u043f\u0438\u0441\u043e\u043a \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0451\u043d\u043d\u044b\u0445 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u0435\u043b\u044c \u0441\u0438\u0433\u043d\u0430\u043b\u043e\u0432 \u0432 Broadcast.<\/p>\n
\u0414\u043b\u044f \u043f\u0440\u0435\u0434\u043e\u0442\u0432\u0440\u0430\u0449\u0435\u043d\u0438\u044f \u0441\u043f\u0430\u043c\u0430 \u0444\u0430\u0439\u043b\u0430\u043c\u0438, \u0443 \u043d\u0430\u0441 \u0431\u0443\u0434\u0435\u0442 \u0441\u0442\u043e\u044f\u0442\u044c \u043d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0439 cooldown \u0432 15 \u0441\u0435\u043a\u0443\u043d\u0434 \u0434\u043b\u044f \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u043d\u0430 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0443 \u0444\u0430\u0439\u043b\u0430. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0437\u0430 \u043a\u0430\u0436\u0434\u044b\u043c \u0438\u0433\u0440\u043e\u043a\u043e\u043c, \u043a\u0440\u043e\u043c\u0435 \u0435\u0433\u043e \u0438\u043c\u0435\u043d\u0438 \u0438 \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0435\u0439 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438 \u0444\u0430\u0439\u043b\u0430, \u043d\u0438\u0447\u0435\u0433\u043e \u0437\u0430\u043a\u0440\u0435\u043f\u043b\u0435\u043d\u043e \u043d\u0435 \u0431\u0443\u0434\u0435\u0442.<\/p>\n
\n\u041a\u043e\u0434 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u044b Game (\u0424\u0430\u0439\u043b server\/src\/game.rs)<\/summary>\n
\n
\/\/ \u0424\u0430\u0439\u043b server\/src\/game.rs  use std::{collections::HashMap, sync::Arc};  use parking_lot::Mutex; use tokio::{sync::mpsc::UnboundedSender, time::Instant}; use tokio_tungstenite::tungstenite::Message;  use crate::types::{BroadcastEvents, Connection};  pub struct Player {   \/\/ \u0412\u0440\u0435\u043c\u044f \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0435\u0433\u043e \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u043d\u043e\u0433\u043e \u0444\u0430\u0439\u043b\u0430.    \/\/ \u0422\u0430\u043a \u043a\u0430\u043a, \u043a\u043e\u0433\u0434\u0430 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044c \u0442\u043e\u043b\u044c\u043a\u043e \u0437\u0430\u0448\u0435\u043b, \u043e\u043d \u0435\u0449\u0451 \u043d\u0435 \u0443\u0441\u043f\u0435\u043b \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c   \/\/ \u0447\u0442\u043e-\u043d\u0438\u0431\u0443\u0434\u044c, \u0437\u0430\u043f\u0438\u0441\u044b\u0432\u0430\u0442\u044c \u0432 \u044d\u0442\u043e \u043f\u043e\u043b\u0435 \u043d\u0435\u0447\u0435\u0433\u043e. \u0412 \u0442\u0430\u043a\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u0431\u0443\u0434\u0435\u0442   \/\/ \u0432\u044b\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043e \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 \u0435\u043d\u0430\u043c\u0430 Option \u2013 None.   pub dt_last_send: Option<Instant>, }  #[derive(Clone)] pub struct Game {   \/\/ \u041c\u0430\u043f\u0430 \u0441\u043e \u0432\u0441\u0435\u043c\u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u044b\u043c\u0438 \u0438\u0433\u0440\u0430\u043a\u0430\u043c\u0438 (\u0424\u043e\u0440\u043c\u0430\u0442: username:Player).   \/\/ \u0414\u043b\u044f \u0442\u043e\u0433\u043e \u0447\u0442\u043e\u0431\u044b \u044d\u0442\u043e \u043f\u043e\u043b\u0435 \u0431\u044b\u043b\u043e \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u043e \u0434\u043b\u044f \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u0445 \u043f\u043e\u0442\u043e\u043a\u043e\u0432,   \/\/ \u0435\u0433\u043e \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c \u0432 \u0441\u043c\u0430\u0440\u0442-\u043f\u043e\u0438\u043d\u0442\u0435\u0440 Arc, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442   \/\/ \u043c\u043d\u043e\u0436\u0435\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0435 \u0432\u043b\u0430\u0434\u0435\u043d\u0438\u0435 \u0434\u0430\u043d\u043d\u044b\u043c\u0438 \u0432 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u0445 \u043f\u043e\u0442\u043e\u043a\u0430\u0445. \u0410 \u0447\u0442\u043e\u0431\u044b    \/\/ \u043c\u0430\u043f\u0443 \u043c\u043e\u0436\u043d\u043e \u0431\u044b\u043b\u043e \u0432\u043d\u0443\u0442\u0440\u0438 Arc'\u0430 \u0435\u0449\u0451 \u0438 \u0438\u0437\u043c\u0435\u043d\u044f\u0442\u044c, \u043d\u0443\u0436\u043d\u043e \u0434\u043e\u043f\u043e\u043b\u043d\u0438\u0442\u0435\u043b\u044c\u043d\u043e   \/\/ \u0437\u0430\u0432\u0435\u0440\u043d\u0443\u0442\u044c \u0435\u0451 \u0432 Mutex. \u0422\u0430\u043a \u0436\u0435 Mutex \u043e\u0431\u0435\u0437\u043e\u043f\u0430\u0441\u0438\u0442 \u0434\u0430\u043d\u043d\u044b\u0435, \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0438\u0432   \/\/ \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u043e\u0435 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0435\u0434\u0438\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e \u0438\u0437\u043c\u0435\u043d\u044f\u0435\u043c\u044b\u0445 \u043c\u0430\u043f\u0443 \u043f\u043e\u0442\u043e\u043a\u043e\u0432 \u0434\u043e \u043e\u0434\u043d\u043e\u0433\u043e.   pub players: Arc<Mutex<HashMap<String, Player>>>,    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u0435\u043b\u044c \u0441\u0438\u0433\u043d\u0430\u043b\u043e\u0432 \u0432 Broadcast   pub broadcast_sender: UnboundedSender<BroadcastEvents> }  impl Game {   \/\/ \u0421\u043e\u0437\u0434\u0430\u0451\u043c \u043d\u043e\u0432\u044b\u0439 \u0438\u043d\u0441\u0442\u0430\u043d\u0441   pub fn new(broadcast_sender: UnboundedSender<BroadcastEvents>) -> Game {     Game {        players: Arc::new(Mutex::new(HashMap::new())),       broadcast_sender,     }   }      \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u0438\u0433\u0440\u043e\u043a\u0430 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u0438\u0433\u043d\u0430\u043b \u0432 Broadcast.     \/\/ \u0412\u044b\u0437\u043e\u0432 \u043c\u0435\u0442\u043e\u0434\u0430 send \u0432\u0435\u0440\u043d\u0451\u0442 Result, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043c\u044b \u043d\u0435 \u0445\u043e\u0442\u0438\u043c \u0432 \u0434\u0430\u043d\u043d\u043e\u043c   \/\/ \u0441\u043b\u0443\u0447\u0430\u0435 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0442\u044c. \u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u0437\u0430\u0441\u0443\u043d\u0435\u043c \u0435\u0433\u043e \u0432 \u0438\u0433\u043d\u043e\u0440\u0438\u0440\u0443\u0435\u043c\u0443\u044e \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u0443\u044e.     \/\/ \u0422\u0430\u043a \u0436\u0435 \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u0435\u0441\u0442\u044c \u043b\u0438 \u0442\u0430\u043a\u043e\u0439 \u0438\u0433\u0440\u043e\u043a \u0443\u0436\u0435 \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435 \u0438    \/\/ \u043d\u0435 \u043f\u0440\u0435\u0432\u044b\u0441\u0438\u0442 \u043b\u0438 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0438\u0433\u0440\u043e\u043a\u043e\u0432 \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435 50,   \/\/ \u0435\u0441\u043b\u0438 \u0438\u0433\u0440\u043e\u043a \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u0442\u0441\u044f. (\u041c\u0430\u043a\u0441\u0438\u043c\u0443\u043c 50 \u0438\u0433\u0440\u043e\u043a\u043e\u0432)   pub fn add_player(&self, username: String) {     let mut players = self.players.lock();     if !players.contains_key(&username) && players.len() < 50 {       players.insert(username.clone(), Player { dt_last_send: None });       let _ = self.broadcast_sender.send(BroadcastEvents::Join(username.clone()));     }   }    \/\/ \u0414\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0432 Broadcast   pub fn add_connection(&self, conn: Connection) {     let _ = self.broadcast_sender.send(BroadcastEvents::AddConn(conn));   }     \/\/ \u0423\u0434\u0430\u043b\u044f\u0435\u043c \u0438\u0433\u0440\u043e\u043a\u0430 \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u0438\u0433\u043d\u0430\u043b \u0432 Broadcast   pub fn remove_player(&self, username: String, id: u32) {     self.players.lock().remove(&username);     let _ = self.broadcast_sender.send(BroadcastEvents::Quit(id, username));   }    \/\/ \u0424\u043e\u0440\u043c\u0438\u0440\u0443\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441\u043e \u0441\u043f\u0438\u0441\u043a\u043e\u043c \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439.   \/\/ \u041f\u0440\u0438\u043c\u0435\u0440: LIST|userA,userB,userC   pub fn get_list_message(&self) -> Message {     let list_string = self.players.lock().iter().map(|w| w.0.to_owned()).collect::<Vec<String>>().join(\",\");      Message::Text(format!(\"LIST|{}\", list_string))   }    \/\/ \u041e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0441 \u0444\u0430\u0439\u043b\u043e\u043c \u0432 Broadcast.   \/\/ \u041f\u0435\u0440\u0435\u0434 \u044d\u0442\u0438\u043c \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u043f\u0440\u043e\u0448\u0435\u043b \u0438\u043b\u0438 \u043d\u0435\u0442 \u0443 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f    \/\/ cooldown \u043d\u0430 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0443 \u0444\u0430\u0439\u043b\u0430.   pub fn send_file(&self, from: String,<\/code><\/pre>\n<\/div>\n<\/details>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-347633","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/347633","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=347633"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/347633\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=347633"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=347633"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=347633"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}