liyunjia/chuanyue-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化websocket代码

Browse Source
This commit is contained in:
李运家 2025-05-11 20:43:33 +08:00
parent 9fd55c68b3
commit 6d33a8a486
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/service/websocket_service.rs
View File

@ -88,10 +88,11 @@ pub async fn broadcast_message(msg: Message) {
} }
/// 发送定向消息 /// 发送定向消息
pub async fn send_message(msg: Message, accoudIds: Vec<String>) { #[allow(dead_code)]
pub async fn send_message(msg: Message, accoud_ids: Vec<String>) {
for ele in WS_POOL.iter() { for ele in WS_POOL.iter() {
let mut sender = ele.value().lock().await; let mut sender = ele.value().lock().await;
if accoudIds.contains(&ele.key().to_string()) { if accoud_ids.contains(&ele.key().to_string()) {
if let Err(err) = sender.send(msg.clone()).await { if let Err(err) = sender.send(msg.clone()).await {
tracing::error!("Failed to send message: {:?}", err); tracing::error!("Failed to send message: {:?}", err);
} }