Mutex进行保护,上一篇讲到过,凡是多线程读写的都需要Arc保护.
srv: 主要还是pub sub的时候都需要访问全局的sublist....在我们这个版本中则非常简单,就是一个TcpStream的writer.
rust #[derive(Debug)] pub struct Client { pub srv...: Arc>>, pub cid: u64, pub msg_sender: Arc>, } #[derive...里面使用的还是Parer缓冲区中的内存,当我们需要在连接之外访问这些信息的时候,我们就必须单独保存一份了,这里我们用的是sub.subject.to_string()来分配一个新的内存.
rust async...,因为考虑到设计中的负载均衡问题,qsubs则是从同一个queue中随机选择一个来推送消息.
rust async fn process_pub(&self, pub_arg: &PubArg)