|  |  |  | 
|---|
|  |  |  | RtuLogNode logNode = new RtuLogNode(rtuAddr, content) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ResourceUnit.getInstance().rtuLog(logNode); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ///////////////////// | 
|---|
|  |  |  | // 或者向消息中间件发消息 | 
|---|
|  |  |  | //////////////////// | 
|---|
|  |  |  | } | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 记录Rtu日志 | 
|---|
|  |  |  | * @param devId | 
|---|
|  |  |  | * @param content | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | public static void log4Mqtt(String devId, String content){ | 
|---|
|  |  |  | if(devId == null || devId.trim().equals("")){ | 
|---|
|  |  |  | log.error("严重错误,记录Mqtt设备日志时,设备地址未提供!") ; | 
|---|
|  |  |  | return ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(content == null || content.equals("")){ | 
|---|
|  |  |  | log.error("严重错误,记录Mqtt设备日志时,日志内容未提供!") ; | 
|---|
|  |  |  | return ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | RtuLogNode logNode = new RtuLogNode(devId, content) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ResourceUnit.getInstance().rtuLog(logNode); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|