public class MyPushMessageService implements IPushMessageService {
             @Override
             public void pushMessage(List<Message> messageList) {
                 // TODO Auto-generated method stub
                 // 异步处理消费到的消息
            }
         }
        

         // 开发者账号信息，使用云眸管理员账号登录open2.hik-cloud.com，进入秘钥管理页面获取
         String clientId = "";
         String clientSecret = "";
         MyPushMessageService myPushMessageService = new MyPushMessageService();
         Consumer consumer = new Consumer(clientId, clientSecret, myPushMessageService);
         // 启动消费线程
         consumer.run();