ElvesMqMessage.java 文件源码

/**
 * @Title: validateElvesMqMessage
 * @Description: 校验接收到的mq消息body 内容， 是否符合elves模块通讯的规范
 * @param msgStr
 * @return boolean    返回类型
 */
public static boolean validateElvesMqMessage(String msgStr){
    try {
        Map<String,Object> reqMsgMap =JSON.parseObject(msgStr,new TypeReference<Map<String, Object>>(){});
        if(null==reqMsgMap||null==reqMsgMap.get("mqkey")||null==reqMsgMap.get("mqtype")){
            return false;
        }
        String[] arr = reqMsgMap.get("mqkey").toString().trim().split("[.]");
        if(null==arr||arr.length!=3){
            return false;
        }

        String mqtype = reqMsgMap.get("mqtype").toString().trim();
        if(!"call".equals(mqtype)&&!"cast".equals(mqtype)){
            return false;
        }

        if(null!=reqMsgMap.get("mqbody")){
            JSON.parseObject(reqMsgMap.get("mqbody").toString().trim(),new TypeReference<Map<String, Object>>(){});
        }
        return true;
    } catch (Exception e) {
        return false;
    }
}