ns_game 0.2.26

ns_game lib.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use crate::controller::{IProxy, ___impl_IProxy_call};
use crate::services::IProxyService;
use crate::static_def::PROXY;
use anyhow::Result;
use netxserver::prelude::*;

/// 广播服务
#[derive(Default)]
pub struct BroadcastService;

impl BroadcastService {
    /// 广播到 所有服务器的此玩家 所有连接
    /// 一般用于资产发生变化
    #[inline]
    pub async fn broadcast_to_account_id(&self, account_id: i32, data: &[u8]) -> Result<()> {
        for netx_token in PROXY.get_all_token().await? {
            let proxy = impl_ref!(netx_token=>IProxy);
            proxy.broadcast_to_account_id(account_id, data).await;
        }
        Ok(())
    }

    /// 广播到所有用户的所有连接
    /// 一般用于紧急公告 跑马灯等
    #[inline]
    pub async fn broadcast_to_all_users(&self, data: &[u8]) -> Result<()> {
        for netx_token in PROXY.get_all_token().await? {
            let proxy = impl_ref!(netx_token=>IProxy);
            proxy.broadcast_to_all_users(data).await;
        }
        Ok(())
    }

    /// 广播到 此服务器 的所有连接
    /// 一般用于游戏内部通知
    #[inline]
    pub async fn broadcast_to_server_id(&self, data: &[u8]) -> Result<()> {
        for netx_token in PROXY.get_all_token().await? {
            let proxy = impl_ref!(netx_token=>IProxy);
            proxy.broadcast_to_server_id(0, data).await;
        }
        Ok(())
    }

    /// 广播到 此服务器的,此玩家 所有连接
    /// 一般用于大厅客服服务
    #[inline]
    pub async fn broadcast_to_server_id_and_account_id(
        &self,
        account_id: i32,
        data: &[u8],
    ) -> Result<()> {
        for netx_token in PROXY.get_all_token().await? {
            let proxy = impl_ref!(netx_token=>IProxy);
            proxy
                .broadcast_to_server_id_and_account_id(0, account_id, data)
                .await;
        }
        Ok(())
    }
}