mirror of
https://gitee.com/yudaocode/SpringBoot-Labs.git
synced 2026-09-03 05:53:54 +08:00
删除 target
This commit is contained in:
@@ -1,8 +0,0 @@
|
||||
spring:
|
||||
# Spring Security 配置项,对应 SecurityProperties 配置类
|
||||
security:
|
||||
# 配置默认的 InMemoryUserDetailsManager 的用户账号与密码。
|
||||
user:
|
||||
name: user # 账号
|
||||
password: user # 密码
|
||||
roles: ADMIN # 拥有角色
|
||||
@@ -1,3 +0,0 @@
|
||||
# Spring Security Setting
|
||||
security.user.name=yunai
|
||||
security.user.password=1024
|
||||
@@ -1,3 +0,0 @@
|
||||
# Spring Security Setting
|
||||
security.user.name=yunai
|
||||
security.user.password=1024
|
||||
@@ -1,9 +0,0 @@
|
||||
# Spring Security Setting
|
||||
security.user.name=yunai
|
||||
security.user.password=1024
|
||||
|
||||
##################### MySQL #####################
|
||||
jdbc.driverClassName=com.mysql.jdbc.Driver
|
||||
jdbc.url=jdbc:mysql://127.0.0.1:33061/oauth2
|
||||
jdbc.user=root
|
||||
jdbc.pass=123456
|
||||
@@ -1,21 +0,0 @@
|
||||
INSERT INTO oauth_client_details
|
||||
(client_id, client_secret, scope, authorized_grant_types,
|
||||
web_server_redirect_uri, authorities, access_token_validity,
|
||||
refresh_token_validity, additional_information, autoapprove)
|
||||
VALUES
|
||||
('fooClientIdPassword', 'secret', 'foo,read,write',
|
||||
'password,authorization_code,refresh_token', null, null, 36000, 36000, null, true);
|
||||
INSERT INTO oauth_client_details
|
||||
(client_id, client_secret, scope, authorized_grant_types,
|
||||
web_server_redirect_uri, authorities, access_token_validity,
|
||||
refresh_token_validity, additional_information, autoapprove)
|
||||
VALUES
|
||||
('sampleClientId', 'secret', 'read,write,foo,bar',
|
||||
'implicit', null, null, 36000, 36000, null, false);
|
||||
INSERT INTO oauth_client_details
|
||||
(client_id, client_secret, scope, authorized_grant_types,
|
||||
web_server_redirect_uri, authorities, access_token_validity,
|
||||
refresh_token_validity, additional_information, autoapprove)
|
||||
VALUES
|
||||
('barClientIdPassword', 'secret', 'bar,read,write',
|
||||
'password,authorization_code,refresh_token', null, null, 36000, 36000, null, true);
|
||||
@@ -1,66 +0,0 @@
|
||||
--------------- MySQL ---------------
|
||||
drop table if exists oauth_client_details;
|
||||
create table oauth_client_details (
|
||||
client_id VARCHAR(255) PRIMARY KEY,
|
||||
resource_ids VARCHAR(255),
|
||||
client_secret VARCHAR(255),
|
||||
scope VARCHAR(255),
|
||||
authorized_grant_types VARCHAR(255),
|
||||
web_server_redirect_uri VARCHAR(255),
|
||||
authorities VARCHAR(255),
|
||||
access_token_validity INTEGER,
|
||||
refresh_token_validity INTEGER,
|
||||
additional_information VARCHAR(4096),
|
||||
autoapprove VARCHAR(255)
|
||||
);
|
||||
|
||||
create table if not exists oauth_client_token (
|
||||
token_id VARCHAR(255),
|
||||
token LONG VARBINARY,
|
||||
authentication_id VARCHAR(255) PRIMARY KEY,
|
||||
user_name VARCHAR(255),
|
||||
client_id VARCHAR(255)
|
||||
);
|
||||
|
||||
create table if not exists oauth_access_token (
|
||||
token_id VARCHAR(255),
|
||||
token LONG VARBINARY,
|
||||
authentication_id VARCHAR(255) PRIMARY KEY,
|
||||
user_name VARCHAR(255),
|
||||
client_id VARCHAR(255),
|
||||
authentication LONG VARBINARY,
|
||||
refresh_token VARCHAR(255)
|
||||
);
|
||||
|
||||
create table if not exists oauth_refresh_token (
|
||||
token_id VARCHAR(255),
|
||||
token LONG VARBINARY,
|
||||
authentication LONG VARBINARY
|
||||
);
|
||||
|
||||
create table if not exists oauth_code (
|
||||
code VARCHAR(255), authentication LONG VARBINARY
|
||||
);
|
||||
|
||||
create table if not exists oauth_approvals (
|
||||
userId VARCHAR(255),
|
||||
clientId VARCHAR(255),
|
||||
scope VARCHAR(255),
|
||||
status VARCHAR(10),
|
||||
expiresAt TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||
lastModifiedAt TIMESTAMP DEFAULT CURRENT_TIMESTAMP
|
||||
);
|
||||
|
||||
create table if not exists ClientDetails (
|
||||
appId VARCHAR(255) PRIMARY KEY,
|
||||
resourceIds VARCHAR(255),
|
||||
appSecret VARCHAR(255),
|
||||
scope VARCHAR(255),
|
||||
grantTypes VARCHAR(255),
|
||||
redirectUrl VARCHAR(255),
|
||||
authorities VARCHAR(255),
|
||||
access_token_validity INTEGER,
|
||||
refresh_token_validity INTEGER,
|
||||
additionalInformation VARCHAR(4096),
|
||||
autoApproveScopes VARCHAR(255)
|
||||
);
|
||||
@@ -1,3 +0,0 @@
|
||||
# Spring Security Setting
|
||||
security.user.name=yunai
|
||||
security.user.password=1024
|
||||
@@ -1,3 +0,0 @@
|
||||
# Spring Security Setting
|
||||
security.user.name=yunai
|
||||
security.user.password=1024
|
||||
@@ -1,3 +0,0 @@
|
||||
# Spring Security Setting
|
||||
security.user.name=yunai
|
||||
security.user.password=1024
|
||||
@@ -1,33 +0,0 @@
|
||||
spring:
|
||||
# Kafka 配置项,对应 KafkaProperties 配置类
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
enable-auto-commit: false # 使用 Spring-Kafka 的消费进度的提交机制
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
missing-topics-fatal: false # 消费监听接口监听的主题不存在时,默认会报错。所以通过设置为 false ,解决报错
|
||||
ack-mode: MANUAL
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,40 +0,0 @@
|
||||
spring:
|
||||
# Kafka 配置项,对应 KafkaProperties 配置类
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
batch-size: 16384 # 每次批量发送消息的最大数量
|
||||
buffer-memory: 33554432 # 每次批量发送消息的最大内存
|
||||
properties:
|
||||
linger:
|
||||
ms: 30000 # 批处理延迟时间上限。这里配置为 30 * 1000 ms 过后,不管是否消息数量是否到达 batch-size 或者消息大小到达 buffer-memory 后,都直接发送一次请求。
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
fetch-max-wait: 10000 # poll 一次拉取的阻塞的最大时长,单位:毫秒。这里指的是阻塞拉取需要满足至少 fetch-min-size 条消息
|
||||
fetch-min-size: 10 # poll 一次消息拉取的最小数量
|
||||
max-poll-records: 100 # poll 一次消息拉取的最大数量
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
type: BATCH # 监听器类型,默认为 SINGLE ,只监听单条消息。这里我们配置 BATCH ,监听多条消息,批量消费
|
||||
missing-topics-fatal: false # 消费监听接口监听的主题不存在时,默认会报错。所以通过设置为 false ,解决报错
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,36 +0,0 @@
|
||||
spring:
|
||||
# Kafka 配置项,对应 KafkaProperties 配置类
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
batch-size: 16384 # 每次批量发送消息的最大数量
|
||||
buffer-memory: 33554432 # 每次批量发送消息的最大内存
|
||||
properties:
|
||||
linger:
|
||||
ms: 30000 # 批处理延迟时间上限。这里配置为 30 * 1000 ms 过后,不管是否消息数量是否到达 batch-size 或者消息大小到达 buffer-memory 后,都直接发送一次请求。
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
missing-topics-fatal: false # 消费监听接口监听的主题不存在时,默认会报错。所以通过设置为 false ,解决报错
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,31 +0,0 @@
|
||||
spring:
|
||||
# Kafka 配置项,对应 KafkaProperties 配置类
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
auto-offset-reset: latest # 设置消费者分组最初的消费进度为 latest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
missing-topics-fatal: false # 消费监听接口监听的主题不存在时,默认会报错。所以通过设置为 false ,解决报错
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,31 +0,0 @@
|
||||
spring:
|
||||
# Kafka 配置项,对应 KafkaProperties 配置类
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
missing-topics-fatal: false # 消费监听接口监听的主题不存在时,默认会报错。所以通过设置为 false ,解决报错
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,34 +0,0 @@
|
||||
spring:
|
||||
# Kafka 配置项,对应 KafkaProperties 配置类
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: all # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
transaction-id-prefix: demo. # 事务编号前缀
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
isolation:
|
||||
level: read_committed # 读取已提交的消息
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
missing-topics-fatal: false # 消费监听接口监听的主题不存在时,默认会报错。所以通过设置为 false ,解决报错
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,35 +0,0 @@
|
||||
spring:
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
batch-size: 16384 # 每次批量发送消息的最大数量
|
||||
buffer-memory: 33554432 # 每次批量发送消息的最大内存
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
enable-auto-commit: false # true-使用 kafka 默认自带的提交模式。false-使用 Spring-Kafka 的自动提交 offset 机制。建议设置为 false 使用 kafka-spring 的机制,分析见 https://juejin.im/entry/5a6e8dea518825732472710c 。
|
||||
auto-commit-interval: 1000 # 在开启 enable-auto-commit 时,自动提交消费进度频率,单位:毫秒。如果 enable-auto-commit 为 false 时候,可以不设置
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
concurrency: 10 # 每个消费者监听器最大并发数,默认为 1 。可以通过设置 n ,这样对于每个监听器就会使用 n 个线程消费消息,提高整体消费速度。详细可参考博客 https://www.jianshu.com/p/ad0e5424edbd 理解。
|
||||
# Producer 配置项
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,31 +0,0 @@
|
||||
spring:
|
||||
# Kafka 配置项,对应 KafkaProperties 配置类
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
missing-topics-fatal: false # 消费监听接口监听的主题不存在时,默认会报错。所以通过设置为 false ,解决报错
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,35 +0,0 @@
|
||||
spring:
|
||||
kafka:
|
||||
bootstrap-servers: 127.0.0.1:9092 # 指定 Kafka Broker 地址,可以设置多个,以逗号分隔
|
||||
# Kafka Producer 配置项
|
||||
producer:
|
||||
acks: 1 # 0-不应答。1-leader 应答。all-所有 leader 和 follower 应答。
|
||||
retries: 3 # 发送失败时,重试发送的次数
|
||||
batch-size: 16384 # 每次批量发送消息的最大数量
|
||||
buffer-memory: 33554432 # 每次批量发送消息的最大内存
|
||||
key-serializer: org.apache.kafka.common.serialization.StringSerializer # 消息的 key 的序列化
|
||||
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer # 消息的 value 的序列化
|
||||
# Kafka Consumer 配置项
|
||||
consumer:
|
||||
enable-auto-commit: false # true-使用 kafka 默认自带的提交模式。false-使用 Spring-Kafka 的自动提交 offset 机制。建议设置为 false 使用 kafka-spring 的机制,分析见 https://juejin.im/entry/5a6e8dea518825732472710c 。
|
||||
auto-commit-interval: 1000 # 在开启 enable-auto-commit 时,自动提交消费进度频率,单位:毫秒。如果 enable-auto-commit 为 false 时候,可以不设置
|
||||
auto-offset-reset: earliest # 设置消费者分组最初的消费进度为 earliest 。可参考博客 https://blog.csdn.net/lishuangzhe7047/article/details/74530417 理解
|
||||
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
|
||||
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
|
||||
properties:
|
||||
spring:
|
||||
json:
|
||||
trusted:
|
||||
packages: cn.iocoder.springboot.lab03.kafkademo.message
|
||||
# Kafka Consumer Listener 监听器配置
|
||||
listener:
|
||||
concurrency: 10 # 每个消费者监听器最大并发数,默认为 1 。可以通过设置 n ,这样对于每个监听器就会使用 n 个线程消费消息,提高整体消费速度。详细可参考博客 https://www.jianshu.com/p/ad0e5424edbd 理解。
|
||||
|
||||
|
||||
logging:
|
||||
level:
|
||||
org:
|
||||
springframework:
|
||||
kafka: ERROR # spring-kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
apache:
|
||||
kafka: ERROR # kafka INFO 日志太多了,所以我们限制只打印 ERROR 级别
|
||||
@@ -1,20 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
template:
|
||||
# 对应 RabbitProperties.Retry 类
|
||||
retry:
|
||||
enabled: true # 开启发送机制
|
||||
max-attempts: 3 # 最大重试次数。默认为 3 。
|
||||
initial-interval: 1000 # 重试间隔,单位为毫秒。默认为 1000 。
|
||||
listener:
|
||||
simple:
|
||||
# 对应 RabbitProperties.ListenerRetry 类
|
||||
retry:
|
||||
enabled: true # 开启消费重试机制
|
||||
max-attempts: 3 # 最大重试次数。默认为 3 。
|
||||
initial-interval: 1000 # 重试间隔,单位为毫秒。默认为 1000 。
|
||||
@@ -1,10 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
listener:
|
||||
simple:
|
||||
acknowledge-mode: manual # 配置 Consumer 手动提交
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,14 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
listener:
|
||||
type: simple # 选择的 ListenerContainer 的类型。默认为 direct 类型
|
||||
simple:
|
||||
concurrency: 2 # 每个 @ListenerContainer 的并发消费的线程数
|
||||
max-concurrency: 10 # 每个 @ListenerCon 允许的并发消费的线程数
|
||||
# direct:
|
||||
# consumers-per-queue: 2 # 对于每一个 @RabbitListener ,一个 Queue ,对应创建几个 Consumer 。
|
||||
@@ -1,9 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
publisher-confirm-type: correlated # 设置 Confirm 类型为 CORRELATED 。
|
||||
publisher-returns: true #
|
||||
@@ -1,8 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
publisher-confirm-type: simple # 设置 Confirm 类型为 SIMPLE 。
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,20 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
template:
|
||||
# 对应 RabbitProperties.Retry 类
|
||||
retry:
|
||||
enabled: true # 开启发送机制
|
||||
max-attempts: 3 # 最大重试次数。默认为 3 。
|
||||
initial-interval: 1000 # 重试间隔,单位为毫秒。默认为 1000 。
|
||||
listener:
|
||||
simple:
|
||||
# 对应 RabbitProperties.ListenerRetry 类
|
||||
retry:
|
||||
enabled: true # 开启消费重试机制
|
||||
max-attempts: 3 # 最大重试次数。默认为 3 。
|
||||
initial-interval: 1000 # 重试间隔,单位为毫秒。默认为 1000 。
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
@@ -1,7 +0,0 @@
|
||||
spring:
|
||||
# RabbitMQ 配置项,对应 RabbitProperties 配置类
|
||||
rabbitmq:
|
||||
host: 127.0.0.1 # RabbitMQ 服务的地址
|
||||
port: 5672 # RabbitMQ 服务的端口
|
||||
username: guest # RabbitMQ 服务的账号
|
||||
password: guest # RabbitMQ 服务的密码
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0-SNAPSHOT
|
||||
groupId=cn.iocoder.springboot.labs
|
||||
artifactId=lab-05-jetty
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-jetty/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/JettyApplication.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-jetty/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/Controller.java
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0-SNAPSHOT
|
||||
groupId=cn.iocoder.springboot.labs
|
||||
artifactId=lab-05-tomcat-apr
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-tomcat-apr/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/Controller.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-tomcat-apr/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/TomcatAprApplication.java
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0-SNAPSHOT
|
||||
groupId=cn.iocoder.springboot.labs
|
||||
artifactId=lab-05-tomcat
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-tomcat/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/TomcatApplication.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-tomcat/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/Controller.java
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-tomcat/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/TomcatApplication.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-tomcat/src/main/java/cn/iocoder/springboot/labs/lab05/tomcat/Controller.java
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0.0
|
||||
groupId=cn.iocoder.springboot.labs
|
||||
artifactId=lab-05-undertow
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-undertow/src/main/java/cn/iocoder/springboot/labs/lab05/undertow/UndertowApplication.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-05/lab-05-undertow/src/main/java/cn/iocoder/springboot/labs/lab05/undertow/Controller.java
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0-SNAPSHOT
|
||||
groupId=cn.iocoder.springboot.labs
|
||||
artifactId=lab-06-springmvc-tomcat
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-06/lab-06-springmvc-tomcat/src/main/java/cn/iocoder/springboot/labs/lab06/springmvc/SpringMVCApplication.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-06/lab-06-springmvc-tomcat/src/main/java/cn/iocoder/springboot/labs/lab06/springmvc/Controller.java
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0-SNAPSHOT
|
||||
groupId=cn.iocoder.springboot.labs
|
||||
artifactId=lab-06-webflux-netty
|
||||
@@ -1 +0,0 @@
|
||||
cn/iocoder/springboot/labs/lab06/webflux/WebfluxNettyApplication.class
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-06/lab-06-webflux-netty/src/main/java/cn/iocoder/springboot/labs/lab06/webflux/WebfluxNettyApplication.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-06/lab-06-webflux-netty/src/main/java/cn/iocoder/springboot/labs/lab06/webflux/Controller.java
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0-SNAPSHOT
|
||||
groupId=cn.iocoder.springboot.labs
|
||||
artifactId=lab-06-webflux-tomcat
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-06/lab-06-webflux-tomcat/src/main/java/cn/iocoder/springboot/labs/lab06/webflux/WebfluxTomcatApplication.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-06/lab-06-webflux-tomcat/src/main/java/cn/iocoder/springboot/labs/lab06/webflux/Controller.java
|
||||
@@ -1,2 +0,0 @@
|
||||
server:
|
||||
port: 8081
|
||||
Binary file not shown.
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0.0
|
||||
groupId=org.springframework.boot
|
||||
artifactId=lab-07-spring-cloud-gateway
|
||||
@@ -1 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-07/lab-07-spring-cloud-gateway/src/main/java/cn/iocoder/springboot/labs/lab07/springcloudgateway/SpringCloudGatewayApplication.java
|
||||
@@ -1,13 +0,0 @@
|
||||
zuul:
|
||||
routes:
|
||||
static:
|
||||
path: /hello.txt
|
||||
url: http://127.0.0.1:8000/
|
||||
stripPrefix: false
|
||||
api:
|
||||
path: /**
|
||||
url: http://127.0.0.1:8080
|
||||
include-debug-header: true
|
||||
|
||||
server:
|
||||
port: 8081
|
||||
Binary file not shown.
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=1.0.0
|
||||
groupId=org.springframework.boot
|
||||
artifactId=lab-07-zuul
|
||||
@@ -1 +0,0 @@
|
||||
cn/iocoder/springboot/labs/lab07/zuul/ZuulApplication.class
|
||||
@@ -1 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-07/lab-07-zuul/src/main/java/cn/iocoder/springboot/labs/lab07/zuul/ZuulApplication.java
|
||||
@@ -1,22 +0,0 @@
|
||||
spring:
|
||||
application:
|
||||
name: user-application
|
||||
# jpa
|
||||
redis:
|
||||
password:
|
||||
database: 0
|
||||
port: 6379
|
||||
host: 127.0.0.1
|
||||
timeout: 0
|
||||
jedis:
|
||||
pool:
|
||||
max-wait:
|
||||
max-idle: 8
|
||||
min-idle: 0
|
||||
|
||||
|
||||
# server
|
||||
server:
|
||||
port: 16003
|
||||
servlet:
|
||||
context-path: /user-api/
|
||||
Binary file not shown.
@@ -1,4 +0,0 @@
|
||||
#Created by Apache Maven 3.3.9
|
||||
version=2.1.4.RELEASE
|
||||
groupId=org.springframework.boot
|
||||
artifactId=lab-08
|
||||
@@ -1,2 +0,0 @@
|
||||
cn/iocoder/springboot/labs/lab08/UserApplication.class
|
||||
cn/iocoder/springboot/labs/lab08/UserController.class
|
||||
@@ -1,2 +0,0 @@
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-08/src/main/java/cn/iocoder/springboot/labs/lab08/UserController.java
|
||||
/Users/yunai/Java/SpringBoot-Labs/lab-08/src/main/java/cn/iocoder/springboot/labs/lab08/UserApplication.java
|
||||
@@ -1,2 +0,0 @@
|
||||
management.endpoint.health.show-details=always
|
||||
server.port=9080
|
||||
@@ -1,15 +0,0 @@
|
||||
spring:
|
||||
# 对应 RedisProperties 类
|
||||
redis:
|
||||
host: 127.0.0.1
|
||||
port: 6379
|
||||
password: # Redis 服务器密码,默认为空。生产中,一定要设置 Redis 密码!
|
||||
database: 0 # Redis 数据库号,默认为 0 。
|
||||
timeout: 0 # Redis 连接超时时间,单位:毫秒。
|
||||
# 对应 RedisProperties.Jedis 内部类
|
||||
jedis:
|
||||
pool:
|
||||
max-active: 8 # 连接池最大连接数,默认为 8 。使用负数表示没有限制。
|
||||
max-idle: 8 # 默认连接数最小空闲的连接数,默认为 8 。使用负数表示没有限制。
|
||||
min-idle: 0 # 默认连接池最小空闲的连接数,默认为 0 。允许设置 0 和 正数。
|
||||
max-wait: -1 # 连接池最大阻塞等待时间,单位:毫秒。默认为 -1 ,表示不限制。
|
||||
@@ -1,5 +0,0 @@
|
||||
if redis.call('GET', KEYS[1]) ~= ARGV[1] then
|
||||
return 0
|
||||
end
|
||||
redis.call('SET', KEYS[1], ARGV[2])
|
||||
return 1
|
||||
@@ -1,5 +0,0 @@
|
||||
if redis.call('GET', KEYS[1]) != ARGV[1] then
|
||||
return {0}
|
||||
end
|
||||
redis.call('SET', KEYS[2], ARGV[2])
|
||||
return {1}
|
||||
@@ -1 +0,0 @@
|
||||
return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}
|
||||
@@ -1,11 +0,0 @@
|
||||
spring:
|
||||
# 对应 RedisProperties 类
|
||||
redis:
|
||||
host: 127.0.0.1
|
||||
port: 6379
|
||||
# password: # Redis 服务器密码,默认为空。生产中,一定要设置 Redis 密码!
|
||||
database: 0 # Redis 数据库号,默认为 0 。
|
||||
timeout: 0 # Redis 连接超时时间,单位:毫秒。
|
||||
# 对应 RedissonProperties 类
|
||||
# redisson:
|
||||
# config: classpath:redisson.yml # 具体的每个配置项,见 org.redisson.config.Config 类。
|
||||
@@ -1,5 +0,0 @@
|
||||
if redis.call('GET', KEYS[1]) ~= ARGV[1] then
|
||||
return 0
|
||||
end
|
||||
redis.call('SET', KEYS[1], ARGV[2])
|
||||
return 1
|
||||
@@ -1,5 +0,0 @@
|
||||
if redis.call('GET', KEYS[1]) != ARGV[1] then
|
||||
return {0}
|
||||
end
|
||||
redis.call('SET', KEYS[2], ARGV[2])
|
||||
return {1}
|
||||
@@ -1 +0,0 @@
|
||||
return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user