再次更新+2

src/events.rs

@@ -159,12 +159,16 @@ pub async fn handle_events(mut receiver: mpsc::UnboundedReceiver<Event>) {
                         println!("将用户信息插入到 Redis 中时出错: {}", e);
                     }
                 });
+                tokio::spawn(async move {
                     notify_all_clients_to_update_online_users().await;
+                });
             }
             Event::CloseConnection(from_id) => {
                 println!("有关闭的连接 用户id {:?} 更新在线用户列表事件触发", from_id);
                 close_existing_connection(&from_id, false).await;
+                tokio::spawn(async move {
                     notify_all_clients_to_update_online_users().await;
+                });
             }
             Event::SendClientMessage(from_id, msg, close) => {
                 println!("事件中心代发消息 ===>> 发送消息 {:?} 到客户端 {:?}", msg, from_id);