@on_login_reply
def login_reply(user_id, ret_code, ret_msg):
    if (ret_code == 0):
        api_logger.info(f'@{user_id.decode()}登录成功')
        self._init_subscribe()
    else:
        api_logger.error(f'@{user_id.decode()}登录失败--errcode:{ret_code}--errmsg:{ret_msg.decode()}')
@on_login_reply
def login_reply(user_id, ret_code, ret_msg):
    if (ret_code == 0):
        api_logger.info(f'@{user_id.decode()}登录成功')
        self._init_subscribe()
    else:
        api_logger.error(f'@{user_id.decode()}登录失败--errcode:{ret_code}--errmsg:{ret_msg.decode()}')