code: def pub_msg(self, msg):
          
          topic = msg.get('topic')
          self.pub_socket.send_multipart(
              [pickle.dumps(topic), pickle.dumps(msg)])
  
          for h in self._handle_funcs.get(topic, []):
              h(msg)
docs: 核心的处理函数，如果是handle_func直接处理，如果是handler，推送到handler的队列