Struct Server

pub struct Server { /* private fields */ }

RPC服务端

Implementations

impl Server

pub fn new() -> Self

创建一个RPC服务

pub fn bind(&mut self, name: &'static str, f: Callback)

绑定RPC回调函数，请使用callback!宏必要时结合clone!宏进行bind操作

pub fn publisher(&self) -> Publisher

获取发布器用于发布消息

pub async fn run_by_unix( self, path: &str, on_subcribe: impl FnMut(&str) -> Option<Bytes> + Send + Sync + 'static, ) -> Result<()>

通过unix域套接字异步运行服务端监听指定的路径

pub async fn run_by_tcp( self, addr: &str, on_subcribe: impl FnMut(&str) -> Option<Bytes> + Send + Sync + 'static, ) -> Result<()>

通过tcp套接字异步运行服务端监听指定的地址

pub async fn run(self, addr: &str) -> Result<()>

异步运行服务端监听指定的地址，如果是类unix系统则使用unix域套接字通信，如果是其他系统则使用tcp通信

pub async fn run_with( self, addr: &str, on_subcribe: impl FnMut(&str) -> Option<Bytes> + Send + Sync + 'static, ) -> Result<()>