From f16094885f5cb07902f2d8408c434f40f55f8133 Mon Sep 17 00:00:00 2001
From: 86186 <2002915>
Date: Sun, 17 Dec 2023 09:14:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=8E=E7=AB=AF=E6=A1=86=E6=9E=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.idea/compiler.xml | 32 ++
.idea/encodings.xml | 17 +
.idea/inspectionProfiles/Project_Default.xml | 9 +
.idea/jarRepositories.xml | 20 ++
.idea/misc.xml | 12 +
.idea/uiDesigner.xml | 124 +++++++
bwie-auth/pom.xml | 43 +++
.../java/com/bwie/auth/AuthApplication.java | 17 +
.../auth/config/ConfirmCallbackConfig.java | 48 +++
.../bwie/auth/config/KafkaConsumerConfig.java | 103 ++++++
.../bwie/auth/config/KafkaProviderConfig.java | 85 +++++
.../auth/config/KafkaSendResultHandler.java | 25 ++
.../config/MyKafkaListenerErrorHandler.java | 34 ++
.../bwie/auth/config/RabbitAdminConfig.java | 53 +++
.../com/bwie/auth/config/RabbitmqConfig.java | 15 +
.../auth/config/ReturnCallbackConfig.java | 39 +++
.../bwie/auth/controller/AuthController.java | 26 ++
.../com/bwie/auth/feign/AuthFeignService.java | 13 +
.../com/bwie/auth/service/AuthService.java | 10 +
.../auth/service/impl/AuthServiceImpl.java | 20 ++
.../java/com/bwie/auth/utils/DLXQueue.java | 77 +++++
.../com/bwie/auth/utils/DelayedQueue.java | 79 +++++
.../java/com/bwie/auth/utils/TtlQueue.java | 66 ++++
bwie-auth/src/main/resources/bootstrap.yml | 117 +++++++
bwie-common/pom.xml | 100 ++++++
.../com/bwie/common/constants/Constants.java | 18 +
.../bwie/common/constants/JwtConstants.java | 29 ++
.../bwie/common/constants/QueueConstants.java | 15 +
.../common/constants/RabbitMQConstants.java | 11 +
.../constants/RabbitMQOneConstants.java | 18 +
.../constants/RabbitMQTwoConstants.java | 18 +
.../bwie/common/constants/TokenConstants.java | 24 ++
.../bwie/common/domain/request/VoClazz.java | 20 ++
.../common/domain/request/VoInsertClazz.java | 14 +
.../com/bwie/common/domain/request/VoStu.java | 21 ++
.../bwie/common/domain/response/DTOClazz.java | 20 ++
.../common/domain/response/DTOStudent.java | 30 ++
.../com/bwie/common/result/PageResult.java | 34 ++
.../java/com/bwie/common/result/Result.java | 76 +++++
.../java/com/bwie/common/utils/IpUtils.java | 312 ++++++++++++++++++
.../java/com/bwie/common/utils/JwtUtils.java | 109 ++++++
.../com/bwie/common/utils/KafkaTopic.java | 5 +
.../java/com/bwie/common/utils/RabbitMQ.java | 5 +
.../com/bwie/common/utils/StringUtils.java | 68 ++++
.../com/bwie/common/utils/TelSmsUtils.java | 88 +++++
bwie-gateway/pom.xml | 37 +++
.../com/bwie/gateway/GateWayApplication.java | 17 +
.../gateway/config/IgnoreWhiteConfig.java | 32 ++
.../com/bwie/gateway/filters/AuthFilter.java | 85 +++++
.../com/bwie/gateway/utils/GatewayUtils.java | 98 ++++++
bwie-gateway/src/main/resources/bootstrap.yml | 29 ++
bwie-modules/bwie-clazz/pom.xml | 68 ++++
.../main/java/com/bwie/ClazzApplication.java | 19 ++
.../com/bwie/controller/ClazzController.java | 57 ++++
.../src/main/java/com/bwie/dao/ClazzDao.java | 14 +
.../java/com/bwie/service/ClazzService.java | 11 +
.../bwie/service/impl/ClazzServiceImpl.java | 43 +++
.../src/main/resources/bootstrap.yml | 43 +++
.../src/main/resources/mapper/ClazzMapper.xml | 45 +++
bwie-modules/bwie-es/pom.xml | 42 +++
.../main/java/com/bwie/es/EsApplication.java | 15 +
.../java/com/bwie/es/config/InitEsRes.java | 25 ++
.../bwie-es/src/main/resources/bootstrap.yml | 26 ++
bwie-modules/bwie-menu/pom.xml | 61 ++++
.../java/com/bwie/menu/MemuApplication.java | 17 +
.../bwie/menu/controller/MenuController.java | 25 ++
.../java/com/bwie/menu/mapper/MenuMapper.java | 13 +
.../com/bwie/menu/service/MenuService.java | 10 +
.../menu/service/impl/MenuServiceImpl.java | 21 ++
.../java/com/bwie/menu/util/FastUtil.java | 55 +++
.../src/main/resources/bootstrap.yml | 41 +++
.../src/main/resources/mapper/MainMapper.xml | 5 +
bwie-modules/bwie-mq/pom.xml | 35 ++
.../main/java/com/bwie/mq/MqApplication.java | 17 +
.../java/com/bwie/mq/config/MqConfig.java | 80 +++++
.../bwie-mq/src/main/resources/bootstrap.yml | 41 +++
bwie-modules/bwie-user/pom.xml | 61 ++++
.../java/com/bwie/user/UserApplication.java | 17 +
.../bwie/user/controller/UserController.java | 27 ++
.../java/com/bwie/user/mapper/UserMapper.java | 13 +
.../com/bwie/user/service/UserService.java | 10 +
.../user/service/impl/UserServiceImpl.java | 18 +
.../java/com/bwie/user/util/FastUtil.java | 55 +++
.../src/main/resources/bootstrap.yml | 41 +++
.../src/main/resources/mapper/UserMapper.xml | 5 +
bwie-modules/pom.xml | 22 ++
pom.xml | 62 ++++
87 files changed, 3577 insertions(+)
create mode 100644 .idea/compiler.xml
create mode 100644 .idea/encodings.xml
create mode 100644 .idea/inspectionProfiles/Project_Default.xml
create mode 100644 .idea/jarRepositories.xml
create mode 100644 .idea/misc.xml
create mode 100644 .idea/uiDesigner.xml
create mode 100644 bwie-auth/pom.xml
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/ConfirmCallbackConfig.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/KafkaConsumerConfig.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/KafkaProviderConfig.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/KafkaSendResultHandler.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/MyKafkaListenerErrorHandler.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/RabbitAdminConfig.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/RabbitmqConfig.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/config/ReturnCallbackConfig.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/controller/AuthController.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/feign/AuthFeignService.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/service/AuthService.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/service/impl/AuthServiceImpl.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/utils/DLXQueue.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/utils/DelayedQueue.java
create mode 100644 bwie-auth/src/main/java/com/bwie/auth/utils/TtlQueue.java
create mode 100644 bwie-auth/src/main/resources/bootstrap.yml
create mode 100644 bwie-common/pom.xml
create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/Constants.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/JwtConstants.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/QueueConstants.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/RabbitMQConstants.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/RabbitMQOneConstants.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/RabbitMQTwoConstants.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/constants/TokenConstants.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/request/VoClazz.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/request/VoInsertClazz.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/request/VoStu.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/response/DTOClazz.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/domain/response/DTOStudent.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/result/PageResult.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/result/Result.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/IpUtils.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/JwtUtils.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/KafkaTopic.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/RabbitMQ.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/StringUtils.java
create mode 100644 bwie-common/src/main/java/com/bwie/common/utils/TelSmsUtils.java
create mode 100644 bwie-gateway/pom.xml
create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/GateWayApplication.java
create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/config/IgnoreWhiteConfig.java
create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/filters/AuthFilter.java
create mode 100644 bwie-gateway/src/main/java/com/bwie/gateway/utils/GatewayUtils.java
create mode 100644 bwie-gateway/src/main/resources/bootstrap.yml
create mode 100644 bwie-modules/bwie-clazz/pom.xml
create mode 100644 bwie-modules/bwie-clazz/src/main/java/com/bwie/ClazzApplication.java
create mode 100644 bwie-modules/bwie-clazz/src/main/java/com/bwie/controller/ClazzController.java
create mode 100644 bwie-modules/bwie-clazz/src/main/java/com/bwie/dao/ClazzDao.java
create mode 100644 bwie-modules/bwie-clazz/src/main/java/com/bwie/service/ClazzService.java
create mode 100644 bwie-modules/bwie-clazz/src/main/java/com/bwie/service/impl/ClazzServiceImpl.java
create mode 100644 bwie-modules/bwie-clazz/src/main/resources/bootstrap.yml
create mode 100644 bwie-modules/bwie-clazz/src/main/resources/mapper/ClazzMapper.xml
create mode 100644 bwie-modules/bwie-es/pom.xml
create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/EsApplication.java
create mode 100644 bwie-modules/bwie-es/src/main/java/com/bwie/es/config/InitEsRes.java
create mode 100644 bwie-modules/bwie-es/src/main/resources/bootstrap.yml
create mode 100644 bwie-modules/bwie-menu/pom.xml
create mode 100644 bwie-modules/bwie-menu/src/main/java/com/bwie/menu/MemuApplication.java
create mode 100644 bwie-modules/bwie-menu/src/main/java/com/bwie/menu/controller/MenuController.java
create mode 100644 bwie-modules/bwie-menu/src/main/java/com/bwie/menu/mapper/MenuMapper.java
create mode 100644 bwie-modules/bwie-menu/src/main/java/com/bwie/menu/service/MenuService.java
create mode 100644 bwie-modules/bwie-menu/src/main/java/com/bwie/menu/service/impl/MenuServiceImpl.java
create mode 100644 bwie-modules/bwie-menu/src/main/java/com/bwie/menu/util/FastUtil.java
create mode 100644 bwie-modules/bwie-menu/src/main/resources/bootstrap.yml
create mode 100644 bwie-modules/bwie-menu/src/main/resources/mapper/MainMapper.xml
create mode 100644 bwie-modules/bwie-mq/pom.xml
create mode 100644 bwie-modules/bwie-mq/src/main/java/com/bwie/mq/MqApplication.java
create mode 100644 bwie-modules/bwie-mq/src/main/java/com/bwie/mq/config/MqConfig.java
create mode 100644 bwie-modules/bwie-mq/src/main/resources/bootstrap.yml
create mode 100644 bwie-modules/bwie-user/pom.xml
create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/UserApplication.java
create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/controller/UserController.java
create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/mapper/UserMapper.java
create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/service/UserService.java
create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/service/impl/UserServiceImpl.java
create mode 100644 bwie-modules/bwie-user/src/main/java/com/bwie/user/util/FastUtil.java
create mode 100644 bwie-modules/bwie-user/src/main/resources/bootstrap.yml
create mode 100644 bwie-modules/bwie-user/src/main/resources/mapper/UserMapper.xml
create mode 100644 bwie-modules/pom.xml
create mode 100644 pom.xml
diff --git a/.idea/compiler.xml b/.idea/compiler.xml
new file mode 100644
index 0000000..bac9fd8
--- /dev/null
+++ b/.idea/compiler.xml
@@ -0,0 +1,32 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/encodings.xml b/.idea/encodings.xml
new file mode 100644
index 0000000..de4bfbe
--- /dev/null
+++ b/.idea/encodings.xml
@@ -0,0 +1,17 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml
new file mode 100644
index 0000000..597c296
--- /dev/null
+++ b/.idea/inspectionProfiles/Project_Default.xml
@@ -0,0 +1,9 @@
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml
new file mode 100644
index 0000000..5a2f139
--- /dev/null
+++ b/.idea/jarRepositories.xml
@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/misc.xml b/.idea/misc.xml
new file mode 100644
index 0000000..d5cd614
--- /dev/null
+++ b/.idea/misc.xml
@@ -0,0 +1,12 @@
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/uiDesigner.xml b/.idea/uiDesigner.xml
new file mode 100644
index 0000000..2b63946
--- /dev/null
+++ b/.idea/uiDesigner.xml
@@ -0,0 +1,124 @@
+
+
+
+
+ -
+
+
+ -
+
+
+ -
+
+
+ -
+
+
+ -
+
+
+
+
+
+ -
+
+
+
+
+
+ -
+
+
+
+
+
+ -
+
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+
+
+ -
+
+
+ -
+
+
+ -
+
+
+ -
+
+
+ -
+
+
+
+
+ -
+
+
+ -
+
+
+
+
+
\ No newline at end of file
diff --git a/bwie-auth/pom.xml b/bwie-auth/pom.xml
new file mode 100644
index 0000000..02f7232
--- /dev/null
+++ b/bwie-auth/pom.xml
@@ -0,0 +1,43 @@
+
+
+
+ bwie-12_16manage
+ com.bwie
+ 1.0-SNAPSHOT
+
+ 4.0.0
+
+ bwie-auth
+
+
+
+ com.bwie
+ bwie-common
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+ com.fasterxml.jackson.dataformat
+ jackson-dataformat-xml
+
+
+
+
+ org.springframework.kafka
+ spring-kafka
+
+
+
+
\ No newline at end of file
diff --git a/bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java b/bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java
new file mode 100644
index 0000000..c43cad0
--- /dev/null
+++ b/bwie-auth/src/main/java/com/bwie/auth/AuthApplication.java
@@ -0,0 +1,17 @@
+package com.bwie.auth;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @ClassName AuthApplication
+ * @Description 描述
+ * @Author LiAng.xiAo
+ * @Date 2023/12/17 9:04
+ */
+@SpringBootApplication
+public class AuthApplication {
+ public static void main(String[] args) {
+ SpringApplication.run(AuthApplication.class);
+ }
+}
diff --git a/bwie-auth/src/main/java/com/bwie/auth/config/ConfirmCallbackConfig.java b/bwie-auth/src/main/java/com/bwie/auth/config/ConfirmCallbackConfig.java
new file mode 100644
index 0000000..6cbc083
--- /dev/null
+++ b/bwie-auth/src/main/java/com/bwie/auth/config/ConfirmCallbackConfig.java
@@ -0,0 +1,48 @@
+package com.bwie.auth.config;
+
+import org.springframework.amqp.rabbit.connection.CorrelationData;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+
+/**
+ * 消息发送确认配置 消息发送到交换机的确认
+ */
+@Component
+public class ConfirmCallbackConfig implements RabbitTemplate.ConfirmCallback {
+
+ @Autowired
+ private RabbitTemplate rabbitTemplate;
+
+ /**
+ * @PostContruct是spring框架的注解,在⽅法上加该注解会在项⽬启动的时候执⾏该⽅法,也可以理解为在spring容器初始化的时候执
+ * @PostConstruct bean 被初始化的时候执行的方法的注解
+ * @PreDestory bean 被销毁的时候执行的方法的注解
+ */
+ @PostConstruct
+ public void init() {
+ rabbitTemplate.setConfirmCallback(this);
+ }
+
+ /**
+ * 交换机不管是否收到消息的一个回调方法
+ *
+ * @param correlationData 消息相关数据
+ * @param ack 交换机是否收到消息
+ * @param cause 失败原因
+ */
+ @Override
+ public void confirm(CorrelationData correlationData, boolean ack, String cause) {
+ if (ack) {
+ // 消息投递到 broker 的状态,true表示成功
+ System.out.println("消息发送成功!");
+ } else {
+ // 发送异常
+ System.out.println("发送异常原因 = " + cause);
+ // TODO 可以将消息 内容 以及 失败的原因 记录到 日志表中
+ }
+ }
+
+}
diff --git a/bwie-auth/src/main/java/com/bwie/auth/config/KafkaConsumerConfig.java b/bwie-auth/src/main/java/com/bwie/auth/config/KafkaConsumerConfig.java
new file mode 100644
index 0000000..5dced0e
--- /dev/null
+++ b/bwie-auth/src/main/java/com/bwie/auth/config/KafkaConsumerConfig.java
@@ -0,0 +1,103 @@
+package com.bwie.auth.config;
+
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.SpringBootConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
+import org.springframework.kafka.config.KafkaListenerContainerFactory;
+import org.springframework.kafka.core.ConsumerFactory;
+import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
+import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
+import org.springframework.kafka.listener.ContainerProperties;
+import org.springframework.kafka.support.serializer.JsonDeserializer;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author 徐一杰
+ * @date 2022/10/31 18:05
+ * kafka配置,也可以写在yml,这个文件会覆盖yml
+ */
+@SpringBootConfiguration
+public class KafkaConsumerConfig {
+
+ @Value("${spring.kafka.consumer.bootstrap-servers}")
+ private String bootstrapServers;
+ @Value("${spring.kafka.consumer.group-id}")
+ private String groupId;
+ @Value("${spring.kafka.consumer.enable-auto-commit}")
+ private boolean enableAutoCommit;
+ @Value("${spring.kafka.properties.session.timeout.ms}")
+ private String sessionTimeout;
+ @Value("${spring.kafka.properties.max.poll.interval.ms}")
+ private String maxPollIntervalTime;
+ @Value("${spring.kafka.consumer.max-poll-records}")
+ private String maxPollRecords;
+ @Value("${spring.kafka.consumer.auto-offset-reset}")
+ private String autoOffsetReset;
+ @Value("${spring.kafka.listener.concurrency}")
+ private Integer concurrency;
+ @Value("${spring.kafka.listener.missing-topics-fatal}")
+ private boolean missingTopicsFatal;
+ @Value("${spring.kafka.listener.poll-timeout}")
+ private long pollTimeout;
+
+ @Bean
+ public Map consumerConfigs() {
+
+ Map propsMap = new HashMap<>(16);
+ propsMap.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+ propsMap.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
+ //是否自动提交偏移量,默认值是true,为了避免出现重复数据和数据丢失,可以把它设置为false,然后手动提交偏移量
+ propsMap.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, enableAutoCommit);
+ //自动提交的时间间隔,自动提交开启时生效
+ propsMap.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "2000");
+ //该属性指定了消费者在读取一个没有偏移量的分区或者偏移量无效的情况下该作何处理:
+ //earliest:当各分区下有已提交的offset时,从提交的offset开始消费;无提交的offset时,从头开始消费分区的记录
+ //latest:当各分区下有已提交的offset时,从提交的offset开始消费;无提交的offset时,消费新产生的该分区下的数据(在消费者启动之后生成的记录)
+ //none:当各分区都存在已提交的offset时,从提交的offset开始消费;只要有一个分区不存在已提交的offset,则抛出异常
+ propsMap.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, autoOffsetReset);
+ //两次poll之间的最大间隔,默认值为5分钟。如果超过这个间隔会触发reBalance
+ propsMap.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, maxPollIntervalTime);
+ //这个参数定义了poll方法最多可以拉取多少条消息,默认值为500。如果在拉取消息的时候新消息不足500条,那有多少返回多少;如果超过500条,每次只返回500。
+ //这个默认值在有些场景下太大,有些场景很难保证能够在5min内处理完500条消息,
+ //如果消费者无法在5分钟内处理完500条消息的话就会触发reBalance,
+ //然后这批消息会被分配到另一个消费者中,还是会处理不完,这样这批消息就永远也处理不完。
+ //要避免出现上述问题,提前评估好处理一条消息最长需要多少时间,然后覆盖默认的max.poll.records参数
+ //注:需要开启BatchListener批量监听才会生效,如果不开启BatchListener则不会出现reBalance情况
+ propsMap.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, maxPollRecords);
+ //当broker多久没有收到consumer的心跳请求后就触发reBalance,默认值是10s
+ propsMap.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, sessionTimeout);
+ //序列化(建议使用Json,这种序列化方式可以无需额外配置传输实体类)
+ propsMap.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
+ propsMap.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
+ return propsMap;
+ }
+
+ @Bean
+ public ConsumerFactory