sendOnyWay消息改成异步发送消息

themis-admin/src/main/java/com/qmth/themis/admin/api/TBExamInvigilateUserController.java

@@ -194,7 +194,7 @@ public class TBExamInvigilateUserController {
             //mq发送消息start
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.ROOM_CODE_IMPORT.name(), transMap,
                     MqTagEnum.ROOM_CODE_IMPORT, String.valueOf(tbTaskHistory.getId()), tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
             //mq发送消息end
         } catch (Exception e) {
             log.error(SystemConstant.LOG_ERROR, e);
@@ -237,7 +237,7 @@ public class TBExamInvigilateUserController {
                 //mq发送消息start
                 MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.ROOM_CODE_EXPORT.name(), transMap,
                         MqTagEnum.ROOM_CODE_EXPORT, String.valueOf(tbTaskHistory.getId()), tbUser.getName());
-                mqDtoService.assembleSendOneWayMsg(mqDto);
+                mqDtoService.assembleSendAsyncMsg(mqDto);
                 //mq发送消息end
             } else {
                 return ResultUtil.ok(true);

themis-admin/src/main/java/com/qmth/themis/admin/api/TBUserController.java

@@ -209,10 +209,10 @@ public class TBUserController {
         redisUtil.setUserSession(sessionId, tbSession, expireTime.getExpireSeconds());
         //mq发送消息start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), platform.name(), SystemOperationEnum.SESSION, sessionId);
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         MqDto mqDtoLog = new MqDto(mqUtil.getTopic(), MqTagEnum.USER.name(), SystemOperationEnum.LOGIN,
                 MqTagEnum.USER, String.valueOf(user.getId()), user.getLoginName());
-        mqDtoService.assembleSendOneWayMsg(mqDtoLog);
+        mqDtoService.assembleSendAsyncMsg(mqDtoLog);
         //mq发送消息end
         //测试
 //        String test = SignatureInfo.build(SignatureType.TOKEN, sessionId, token);
@@ -555,7 +555,7 @@ public class TBUserController {
         //mq发送消息start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.USER.name(), SystemOperationEnum.LOGOUT,
                 MqTagEnum.USER, String.valueOf(tbUser.getId()), tbSession.getId());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //mq发送消息end
         return ResultUtil.ok(true);
     }

themis-admin/src/main/java/com/qmth/themis/admin/api/TEExamController.java

@@ -530,7 +530,7 @@ public class TEExamController {
             //mq发送消息start
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_SCORE_CALCULATE.name(), transMap,
                     MqTagEnum.EXAM_SCORE_CALCULATE, String.valueOf(tbTaskHistory.getId()), tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
             //mq发送消息end
         } catch (Exception e) {
             if (e instanceof BusinessException) {
@@ -618,7 +618,7 @@ public class TEExamController {
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.CLOUD_MARK_DATA_PUSH.name(),
                     transMap, MqTagEnum.CLOUD_MARK_DATA_PUSH, String.valueOf(tbTaskHistory.getId()),
                     tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
         } catch (Exception e) {
             log.error(SystemConstant.LOG_ERROR, e);
             if (e instanceof BusinessException) {

themis-admin/src/main/java/com/qmth/themis/admin/api/TEExamPaperController.java

@@ -186,7 +186,7 @@ public class TEExamPaperController {
             //mq发送消息start
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_PAPER_IMPORT.name(), transMap,
                     MqTagEnum.EXAM_PAPER_IMPORT, String.valueOf(tbTaskHistory.getId()), tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
             //mq发送消息end
         } catch (Exception e) {
             log.error(SystemConstant.LOG_ERROR, e);

themis-admin/src/main/java/com/qmth/themis/admin/api/TEExamStudentController.java

@@ -176,7 +176,7 @@ public class TEExamStudentController {
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_STUDENT_EXPORT.name(), transMap,
                 MqTagEnum.EXAM_STUDENT_EXPORT, String.valueOf(tbTaskHistory.getId()), tbUser.getName());
 
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //mq发送消息end
         return ResultUtil.ok(Collections.singletonMap(SystemConstant.TASK_ID, tbTaskHistory.getId()));
     }
@@ -406,7 +406,7 @@ public class TEExamStudentController {
             // mq发送消息start
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_STUDENT_IMPORT.name(), transMap,
                     MqTagEnum.EXAM_STUDENT_IMPORT, String.valueOf(tbTaskHistory.getId()), tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
             // mq发送消息end
         } catch (Exception e) {
             log.error(SystemConstant.LOG_ERROR, e);
@@ -517,7 +517,7 @@ public class TEExamStudentController {
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MARK_RESULT_SIMPLE_EXPORT.name(),
                     transMap, MqTagEnum.MARK_RESULT_SIMPLE_EXPORT, String.valueOf(tbTaskHistory.getId()),
                     tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
             //mq发送消息end
         } catch (Exception e) {
             log.error(SystemConstant.LOG_ERROR, e);
@@ -564,7 +564,7 @@ public class TEExamStudentController {
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MARK_RESULT_STANDARD_EXPORT.name(),
                     transMap, MqTagEnum.MARK_RESULT_STANDARD_EXPORT, String.valueOf(tbTaskHistory.getId()),
                     tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
             //mq发送消息end
         } catch (Exception e) {
             log.error(SystemConstant.LOG_ERROR, e);
@@ -680,7 +680,7 @@ public class TEExamStudentController {
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.CLOUD_MARK_SCORE_SYNC.name(),
                     transMap, MqTagEnum.CLOUD_MARK_SCORE_SYNC, String.valueOf(tbTaskHistory.getId()),
                     tbUser.getName());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
         } catch (Exception e) {
             log.error(SystemConstant.LOG_ERROR, e);
             if (e instanceof BusinessException) {

themis-admin/src/main/java/com/qmth/themis/admin/api/TENotifyController.java

@@ -321,7 +321,7 @@ public class TENotifyController {
 
         //监考监控通话信息 发送mq start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(), tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()), MonitorVideoSourceEnum.valueOf(source).name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
     }
 

themis-admin/src/main/java/com/qmth/themis/admin/api/TIeInvigilateCallMobileController.java

@@ -226,7 +226,7 @@ public class TIeInvigilateCallMobileController {
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(),
                 tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()),
                 source.name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
         return ResultUtil.ok(true);
     }
@@ -286,7 +286,7 @@ public class TIeInvigilateCallMobileController {
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(),
                 tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()),
                 source.name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
         return ResultUtil.ok(true);
     }

themis-business/src/main/java/com/qmth/themis/business/service/MqDtoService.java

@@ -13,6 +13,22 @@ import java.util.Map;
  */
 public interface MqDtoService {
 
+    /**
+     * 组装异步消息
+     *
+     * @param mqDto
+     * @return
+     */
+    public MqDto assembleSendAsyncMsg(MqDto mqDto);
+
+    /**
+     * 组装同步消息
+     *
+     * @param mqDto
+     * @return
+     */
+    public MqDto assembleSendSyncMsg(MqDto mqDto);
+
     /**
      * 组装单向消息
      *

themis-business/src/main/java/com/qmth/themis/business/service/impl/MqDtoServiceImpl.java

@@ -4,7 +4,6 @@ import com.qmth.themis.business.constant.SystemConstant;
 import com.qmth.themis.business.dto.MqDto;
 import com.qmth.themis.business.service.MqDtoService;
 import com.qmth.themis.business.service.ProducerServer;
-import com.qmth.themis.business.service.TMRocketMessageService;
 import com.qmth.themis.business.util.RedisUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -34,8 +33,49 @@ public class MqDtoServiceImpl implements MqDtoService {
     @Resource
     RedisUtil redisUtil;
 
-    @Resource
-    TMRocketMessageService tmRocketMessageService;
+    /**
+     * 组装异步消息
+     *
+     * @param mqDto
+     * @return
+     */
+    @Override
+    public MqDto assembleSendAsyncMsg(MqDto mqDto) {
+        mqDto.setAck(SystemConstant.DELIVERED_ACK_TYPE);
+        try {
+            producerServer.asyncMsg(mqDto);
+        } catch (Exception e) {
+            log.error(SystemConstant.LOG_ERROR, e);
+            if (Objects.nonNull(mqDto)) {
+                mqDto.setAck(SystemConstant.UNSEND_ACK_TYPE);
+            }
+        } finally {
+            setTopicBuffer(mqDto);
+        }
+        return null;
+    }
+
+    /**
+     * 组装同步消息
+     *
+     * @param mqDto
+     * @return
+     */
+    @Override
+    public MqDto assembleSendSyncMsg(MqDto mqDto) {
+        mqDto.setAck(SystemConstant.DELIVERED_ACK_TYPE);
+        try {
+            producerServer.syncMsg(mqDto);
+        } catch (Exception e) {
+            log.error(SystemConstant.LOG_ERROR, e);
+            if (Objects.nonNull(mqDto)) {
+                mqDto.setAck(SystemConstant.UNSEND_ACK_TYPE);
+            }
+        } finally {
+            setTopicBuffer(mqDto);
+        }
+        return null;
+    }
 
     /**
      * 组装单向消息

themis-business/src/main/java/com/qmth/themis/business/service/impl/TEExamBreachLogServiceImpl.java

@@ -133,7 +133,7 @@ public class TEExamBreachLogServiceImpl extends ServiceImpl<TEExamBreachLogMappe
                 properties.put(SystemConstant.BREACH_LOG_STATUS, status);
                 ExamStudentCacheBean examStudentCacheBean = teExamStudentService.getExamStudentCacheBean(eb.getExamStudentId());
                 MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.STUDENT.name(), eb.getStatus() == 0 ? SystemOperationEnum.BREACH_HANDLE : SystemOperationEnum.BREACH_REVOKE, MqTagEnum.STUDENT, String.valueOf(examStudentCacheBean.getStudentId()), properties, IpUtil.getRemoteIp(ServletUtil.getRequest()));
-                mqDtoService.assembleSendOneWayMsg(mqDto);
+                mqDtoService.assembleSendAsyncMsg(mqDto);
             }
             teExamBreachLogService.saveOrUpdateBatch(teExamBreachLogList);
         }

themis-business/src/main/java/com/qmth/themis/business/service/impl/TEExamServiceImpl.java

@@ -386,7 +386,7 @@ public class TEExamServiceImpl extends ServiceImpl<TEExamMapper, TEExam> impleme
         transMap.put("currentRecordId", String.valueOf(currentRecordId));
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_STUDNET_UPDATE.name(), transMap,
                 MqTagEnum.EXAM_STUDNET_UPDATE, examStudentId.toString(), examStudentId.toString());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
     }
 
     /**
@@ -596,7 +596,7 @@ public class TEExamServiceImpl extends ServiceImpl<TEExamMapper, TEExam> impleme
                     MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_STUDENT.name(),
                             JacksonUtil.parseJson(examStudentCacheBean), MqTagEnum.EXAM_STUDENT, String.valueOf(recordId),
                             prop, es.getName());
-                    mqDtoService.assembleSendOneWayMsg(mqDto);
+                    mqDtoService.assembleSendAsyncMsg(mqDto);
                     //新增quartz任务,发送mq消息end
                 }
             }
@@ -1459,7 +1459,7 @@ public class TEExamServiceImpl extends ServiceImpl<TEExamMapper, TEExam> impleme
         properties.put(SystemConstant.EXAM_STUDENT_ID, examStudentId);
         properties.put(SystemConstant.EXAM_RECORD_ID, recordId);
         mqDto.setProperties(properties);
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //mq发送消息end
     }
 

themis-business/src/main/java/com/qmth/themis/business/service/impl/TEExamStudentOnlineLogServiceImpl.java

@@ -38,6 +38,6 @@ public class TEExamStudentOnlineLogServiceImpl extends ServiceImpl<TEExamStudent
     @Override
     public void sendExamStudentOnlineLogSaveMq(TEExamStudentOnlineLog teExamStudentOnlineLog) {
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.ONLINE_LOG.name(), JacksonUtil.parseJson(teExamStudentOnlineLog), MqTagEnum.ONLINE_LOG, String.valueOf(teExamStudentOnlineLog.getExamRecordId()), String.valueOf(teExamStudentOnlineLog.getExamRecordId()));
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
     }
 }

themis-business/src/main/java/com/qmth/themis/business/service/impl/TEMobileServiceImpl.java

@@ -111,10 +111,10 @@ public class TEMobileServiceImpl implements TEMobileService {
         ret.setMode(mode);
         //mq发送消息start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), platform.name(), SystemOperationEnum.SESSION, sessionId);
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         MqDto mqDtoLog = new MqDto(mqUtil.getTopic(), MqTagEnum.STUDENT.name(),
                 SystemOperationEnum.LOGIN, MqTagEnum.STUDENT, String.valueOf(es.getStudentId()), IpUtil.getRemoteIp(ServletUtil.getRequest()));
-        mqDtoService.assembleSendOneWayMsg(mqDtoLog);
+        mqDtoService.assembleSendAsyncMsg(mqDtoLog);
         //mq发送消息end
         //测试
         //        String test = SignatureInfo.build(SignatureType.TOKEN, sessionId, token);

themis-business/src/main/java/com/qmth/themis/business/service/impl/TOeExamBreakHistoryServiceImpl.java

@@ -91,6 +91,6 @@ public class TOeExamBreakHistoryServiceImpl extends ServiceImpl<TOeExamBreakHist
     @Override
     public void sendExamRecordBreakHistoryDataMq(Long breakId) {
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_BREAK_HISTORY_PERSISTED.name(), breakId.toString());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
     }
 }

themis-business/src/main/java/com/qmth/themis/business/service/impl/TOeExamRecordServiceImpl.java

@@ -548,7 +548,7 @@ public class TOeExamRecordServiceImpl extends ServiceImpl<TOeExamRecordMapper, T
         } finally {
             ExamRecordCacheUtil.setUpdateTime(recordId, timestamp);
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_RECORD_UPDATE.name(), recordId.toString(), timestamp);
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
         }
     }
 
@@ -562,7 +562,7 @@ public class TOeExamRecordServiceImpl extends ServiceImpl<TOeExamRecordMapper, T
     public void sendExamRecordDataSaveMqNotIp(Long recordId, Long timestamp) {
         ExamRecordCacheUtil.setUpdateTime(recordId, timestamp);
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_RECORD_UPDATE.name(), recordId.toString(), timestamp);
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
     }
 
     /**
@@ -1120,7 +1120,7 @@ public class TOeExamRecordServiceImpl extends ServiceImpl<TOeExamRecordMapper, T
                         MqDto mqDtoBreak = new MqDto(mqUtil.getTopic(), MqTagEnum.EXAM_BREAK.name(),
                                 ExceptionEnum.NET_TIME_OUT, MqTagEnum.EXAM_BREAK, String.valueOf(recordId),
                                 String.valueOf(recordId));
-                        mqDtoService.assembleSendOneWayMsg(mqDtoBreak);
+                        mqDtoService.assembleSendAsyncMsg(mqDtoBreak);
 //                        //考试断点异常原因 发送mq end
 
                         ExamCacheBean ec = examService.getExamCacheBean(examId);//考试缓存

themis-exam/src/main/java/com/qmth/themis/exam/api/TEExamController.java

@@ -165,7 +165,7 @@ public class TEExamController {
             tIeExamInvigilateCallLog.setEndTime(System.currentTimeMillis());
             //监考监控通话信息 发送mq start
             MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(), tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()), source.name());
-            mqDtoService.assembleSendOneWayMsg(mqDto);
+            mqDtoService.assembleSendAsyncMsg(mqDto);
             //监考监控通话信息 发送mq end
         }
 
@@ -207,7 +207,7 @@ public class TEExamController {
                     MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.EXCEPTION_LOG.name(),
                             JacksonUtil.parseJson(param), MqTagEnum.EXCEPTION_LOG, String.valueOf(param.getRecordId()),
                             param.getReason());
-                    mqDtoService.assembleSendOneWayMsg(mqDto);
+                    mqDtoService.assembleSendAsyncMsg(mqDto);
                     //考试断点异常原因 发送mq end
                 }
             } else {

themis-exam/src/main/java/com/qmth/themis/exam/api/TEFaceController.java

@@ -95,7 +95,7 @@ public class TEFaceController {
         ExamRecordCacheUtil.setClientCurrentIp(param.getRecordId(), ip);
         //mq发送消息start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.FACE_VERIFY_SAVE.name(), transMap, MqTagEnum.FACE_VERIFY_SAVE, param.getRecordId().toString(), ip);
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         return ResultUtil.ok(ret);
     }
 

themis-exam/src/main/java/com/qmth/themis/exam/api/TELivenessController.java

@@ -94,7 +94,7 @@ public class TELivenessController {
         // mq发送消息start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.LIVENESS_VERIFY_SAVE.name(), transMap,
                 MqTagEnum.LIVENESS_VERIFY_SAVE, param.getRecordId().toString(), ip);
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         return ResultUtil.ok(ret);
     }
 

themis-exam/src/main/java/com/qmth/themis/exam/api/TEStudentController.java

@@ -228,12 +228,12 @@ public class TEStudentController {
         //mq发送消息start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), platform.name(), SystemOperationEnum.SESSION,
                 sessionId);
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
 
         MqDto mqDtoLog = new MqDto(mqUtil.getTopic(), MqTagEnum.STUDENT.name(),
                 SystemOperationEnum.LOGIN, MqTagEnum.STUDENT, String.valueOf(teStudent.getId()),
                 IpUtil.getRemoteIp(ServletUtil.getRequest()));
-        mqDtoService.assembleSendOneWayMsg(mqDtoLog);
+        mqDtoService.assembleSendAsyncMsg(mqDtoLog);
         //mq发送消息end
         //测试
         //        String test = SignatureInfo.build(SignatureType.TOKEN, sessionId, token);
@@ -320,7 +320,7 @@ public class TEStudentController {
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.STUDENT.name(),
                 SystemOperationEnum.LOGOUT, MqTagEnum.STUDENT, String.valueOf(teStudent.getId()),
                 IpUtil.getRemoteIp(ServletUtil.getRequest()));
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //mq发送消息end
         return ResultUtil.ok(true);
     }

themis-exam/src/main/java/com/qmth/themis/exam/api/TIeInvigilateCallMobileController.java

@@ -163,7 +163,7 @@ public class TIeInvigilateCallMobileController {
         tIeExamInvigilateCallLog.setStartTime(System.currentTimeMillis());
         //监考监控通话信息 发送mq start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(), tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()), source.name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
         return ResultUtil.ok(Collections.singletonMap(SystemConstant.UPDATE_TIME, System.currentTimeMillis()));
     }
@@ -297,7 +297,7 @@ public class TIeInvigilateCallMobileController {
         tIeExamInvigilateCallLog.setEndTime(System.currentTimeMillis());
         //监考监控通话信息 发送mq start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(), tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()), source.name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
         return ResultUtil.ok(Collections.singletonMap(SystemConstant.UPDATE_TIME, System.currentTimeMillis()));
     }

themis-exam/src/main/java/com/qmth/themis/exam/api/TIeInvigilateCallOeController.java

@@ -178,7 +178,7 @@ public class TIeInvigilateCallOeController {
 
         //监考监控通话信息 发送mq start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(), tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()), source.name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
         Map map = new HashMap();
         map.put(SystemConstant.STATUS, status.name());
@@ -243,7 +243,7 @@ public class TIeInvigilateCallOeController {
         tIeExamInvigilateCallLog.setStartTime(System.currentTimeMillis());
         //监考监控通话信息 发送mq start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(), tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()), source.name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
         return ResultUtil.ok(Collections.singletonMap(SystemConstant.UPDATE_TIME, System.currentTimeMillis()));
     }
@@ -305,7 +305,7 @@ public class TIeInvigilateCallOeController {
         tIeExamInvigilateCallLog.setEndTime(System.currentTimeMillis());
         //监考监控通话信息 发送mq start
         MqDto mqDto = new MqDto(mqUtil.getTopic(), MqTagEnum.MONITOR_LOG.name(), tIeExamInvigilateCallLog, MqTagEnum.MONITOR_LOG, String.valueOf(tIeExamInvigilateCallLog.getId()), source.name());
-        mqDtoService.assembleSendOneWayMsg(mqDto);
+        mqDtoService.assembleSendAsyncMsg(mqDto);
         //监考监控通话信息 发送mq end
         return ResultUtil.ok(Collections.singletonMap(SystemConstant.UPDATE_TIME, System.currentTimeMillis()));
     }

themis-task/src/main/java/com/qmth/themis/task/quartz/MqJob.java

@@ -60,7 +60,7 @@ public class MqJob extends QuartzJobBean {
                 } else {
                     mqDto.setReconsume(mqDto.getReconsume() + 1);
                     redisUtil.set(redisKey, mqDto.getId(), mqDto);
-                    producerServer.sendOneWay(mqDto);
+                    producerServer.asyncMsg(mqDto);
                 }
             });
         }
@@ -87,7 +87,7 @@ public class MqJob extends QuartzJobBean {
                     if (Objects.nonNull(mqExecTime) && (mqExecTime - System.currentTimeMillis()) / 1000 / 60 <= -1) {
                         mqDto.setReconsume(mqDto.getReconsume() + 1);
                         redisUtil.set(redisKey, mqDto.getId(), mqDto);
-                        producerServer.sendOneWay(mqDto);
+                        producerServer.asyncMsg(mqDto);
                     }
                 }
             });
@@ -111,7 +111,7 @@ public class MqJob extends QuartzJobBean {
                 } else {
                     mqDto.setReconsume(mqDto.getReconsume() + 1);
                     redisUtil.set(redisKey, mqDto.getId(), mqDto);
-                    producerServer.sendOneWay(mqDto);
+                    producerServer.asyncMsg(mqDto);
                 }
             });
         }