From c0792dcbc27d0580d9ed0e7aa3cf34c96c651840 Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期四, 04 七月 2024 17:50:58 +0800
Subject: [PATCH] mq配置修改
---
src/main/java/com/ycl/jxkg/job/StudyRecordJob.java | 2 +-
src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java | 4 ++--
src/main/java/com/ycl/jxkg/service/HomeService.java | 6 ------
src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java | 26 ++++++++++++++++++++------
src/main/java/com/ycl/jxkg/job/ExamJob.java | 1 -
5 files changed, 23 insertions(+), 16 deletions(-)
diff --git a/src/main/java/com/ycl/jxkg/job/ExamJob.java b/src/main/java/com/ycl/jxkg/job/ExamJob.java
index 838054a..62872b7 100644
--- a/src/main/java/com/ycl/jxkg/job/ExamJob.java
+++ b/src/main/java/com/ycl/jxkg/job/ExamJob.java
@@ -48,5 +48,4 @@
}
}
-
}
diff --git a/src/main/java/com/ycl/jxkg/job/StudyRecordJob.java b/src/main/java/com/ycl/jxkg/job/StudyRecordJob.java
index 9d2ffc4..043daf9 100644
--- a/src/main/java/com/ycl/jxkg/job/StudyRecordJob.java
+++ b/src/main/java/com/ycl/jxkg/job/StudyRecordJob.java
@@ -32,7 +32,7 @@
private final StudyRecordMapper studyRecordMapper;
private final StudyRecordService studyRecordService;
- @Scheduled(fixedRate = 1200000) // 20鍒嗛挓鎵ц涓�娆�
+ @Scheduled(fixedRate = 120000) // 2鍒嗛挓鎵ц涓�娆�
private void updateStudyRecord() {
log.info("寮�濮嬪瓨瀛︿範鏃堕暱");
List<StudyRecord> cacheList = new ArrayList<>();
diff --git a/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java b/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java
index 47ff879..a5629df 100644
--- a/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java
+++ b/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java
@@ -26,11 +26,11 @@
private ConnectionFactory connectionFactory;
@Bean
- public DirectExchange examExchange() {
- return new DirectExchange("examExchange");
+ public DirectExchange jxkgExchange() {
+ return new DirectExchange("jxkgExchange");
}
- // 鍒涘缓鏅�氶槦鍒�
+ // 鍒涘缓鑰冭瘯鏅�氶槦鍒�
@Bean
public Queue examQueue() {
Map<String, Object> args = new HashMap<>();
@@ -39,12 +39,26 @@
return new Queue("jxkg", true, false, false, args);
}
- // 鏅�氫俊闃熷垪鍒颁氦鎹㈡満
+ // 鍒涘缓浼氳鏅�氶槦鍒�
@Bean
- public Binding binding(Queue examQueue, DirectExchange examExchange) {
- return BindingBuilder.bind(examQueue).to(examExchange).with("exam");
+ public Queue meetQueue() {
+ Map<String, Object> args = new HashMap<>();
+ // 璁剧疆姝讳俊浜ゆ崲鏈�
+ args.put("x-dead-letter-exchange", "dlxExchange");
+ return new Queue("meet", true, false, false, args);
}
+ // 鑰冭瘯鏅�氫俊闃熷垪鍒颁氦鎹㈡満
+ @Bean
+ public Binding binding(Queue examQueue, DirectExchange jxkgExchange) {
+ return BindingBuilder.bind(examQueue).to(jxkgExchange).with("exam");
+ }
+
+ // 浼氳鏅�氫俊闃熷垪鍒颁氦鎹㈡満
+ @Bean
+ public Binding binding2(Queue meetQueue, DirectExchange jxkgExchange) {
+ return BindingBuilder.bind(meetQueue).to(jxkgExchange).with("meet");
+ }
// 鍒涘缓姝讳俊浜ゆ崲鏈�
@Bean
public DirectExchange dlxExchange() {
diff --git a/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java b/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java
index cbb528e..aeabc0c 100644
--- a/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java
+++ b/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java
@@ -34,7 +34,7 @@
Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
// 璁剧疆娑堟伅鐨勫叧鑱旀暟鎹紝浠ヤ究鍙戦�佺‘璁ゅ洖璋冦�佹湭璺敱鎴愬姛娑堟伅鐨勫鐞�
MyCorrelationData msgCorrelationData = new MyCorrelationData(examId + "", RabbitMqMsgTypeEnum.EXAM);
- rabbitTemplate.convertAndSend("examExchange", "exam", message, msgCorrelationData);
+ rabbitTemplate.convertAndSend("jxkgExchange", "exam", message, msgCorrelationData);
}
public void meetMsg(Integer meetId, String jsonMsg, Long delayTime) {
@@ -43,7 +43,7 @@
Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
// 璁剧疆娑堟伅鐨勫叧鑱旀暟鎹紝浠ヤ究鍙戦�佺‘璁ゅ洖璋冦�佹湭璺敱鎴愬姛娑堟伅鐨勫鐞�
MyCorrelationData msgCorrelationData = new MyCorrelationData(meetId + "", RabbitMqMsgTypeEnum.MEET);
- rabbitTemplate.convertAndSend("meetExchange", "meet", message, msgCorrelationData);
+ rabbitTemplate.convertAndSend("jxkgExchange", "meet", message, msgCorrelationData);
}
}
diff --git a/src/main/java/com/ycl/jxkg/service/HomeService.java b/src/main/java/com/ycl/jxkg/service/HomeService.java
index 8d6a657..d787cdb 100644
--- a/src/main/java/com/ycl/jxkg/service/HomeService.java
+++ b/src/main/java/com/ycl/jxkg/service/HomeService.java
@@ -1,12 +1,6 @@
package com.ycl.jxkg.service;
-import com.baomidou.mybatisplus.extension.service.IService;
import com.ycl.jxkg.base.Result;
-import com.ycl.jxkg.domain.entity.Meet;
-import com.ycl.jxkg.domain.form.MeetForm;
-import com.ycl.jxkg.domain.query.MeetQuery;
-
-import java.util.List;
/**
* 棣栭〉 鏈嶅姟绫�
--
Gitblit v1.8.0