# :-: **客戶端日志功能** :-: \*\*\*\* 客戶端日志記錄采用了MQ消息傳送數據存儲的方式。在需要記錄日志的地方發送MQ消息。Kafka消費消息將日志數據存儲到數據庫 1、定義消息服務 ~~~ @FeignClient(name = "hmall-msg" ,configuration = FeignConfiguration.class) //調用的服務名 public interface MsgApi extends BaseApi { //日志服務 @PostMapping("/sendLog") BaseResp sendLog(@RequestBody String content) ; } ~~~ 2、記錄日志發送消息 ~~~ @Resource MsgApi msgApi; msgApi.sendLog("查看商品詳情"+pro.getProductName()); ~~~ 3、消息消費&日志存儲 ~~~ @Component @Slf4j public class LogMsgListener extends BaseService { @Resource SysLogClientMapper sysLogClientMapper; @KafkaListener(id="HjLog",topics = "HjLog",errorHandler ="consumerAwareErrorHandler" ) public void onMessage( ConsumerRecord r){ log.info("【kafka消息消費】HjLog.....接收到消息key...."+r.key()); log.info("【kafka消息消費】HjLog.....接收到消息value...."+r.value().toString()); Object msg=r.value().toString(); LogClient log= (LogClient) JsonUtil.json2Obj(msg.toString(),LogClient.class); addClientLog(log); } /** * 添加客戶日志到數據庫 */ public void addClientLog( LogClient logClient){ SysLogClient log=new SysLogClient (); copyProperties(log,logClient); sysLogClientMapper.insert(log); } } ~~~