pub fn subscribe_notify<F>( connection: Connection, channel: &str, handler: F, ) -> Result<(), Box<dyn Error>>where F: FnMut(String) + Send + 'static,
使用独立连接订阅消息 - 不走连接池(没必要,在调用订阅处用一个长连接保持就行)