Введение

=== Данный компонент предоставляет основные инструменты и другие базовые общие компоненты, которые могут быть использованы в любых других проектах для обеспечения базовой поддержки.

Техническая архитектура

===

• SpringBoot 2.2.4
• MongoDB
• mybatis-plugs
• HBase
• RabbitMQ
• Redis
• beetlsql
• Lombok
• Druid — данные мониторинга http://localhost:8080/druid
• JavaMelody — мониторинг производительности http://localhost:8080/monitoring
• Swagger — описание интерфейса документа http://localhost:8080/swagger-ui.html

Компонентный обзор

starsky-commons-beetlsql

Компонент для работы с базой данных beetlsql и соответствующая конфигурация:

Локальная конфигурация

В системе зарегистрирована системная кодировка: sys.appNo = A8360D1FEBB74EF59DEA49457743A2D6

Конфигурация асинхронного журнала Auth

Конфигурация асинхронной передачи журнала: sys.logAsync = false Адрес вызова асинхронного журнального интерфейса: sys.logAsyncUrl = http://localhost:8801

Сервер

Путь контекста сервлета: server.servlet.context-path = /cache Порт сервера: server.port = 8901 Кодировка URI Tomcat: server.tomcat.uri-encoding = UTF-8 Максимальное количество потоков Tomcat: server.tomcat.max-threads = 100 Минимальное количество свободных потоков Tomcat: server.tomcat.min-spare-threads = 20 Максимальное количество подключений Tomcat: server.tomcat.max-connections = 5000

Spring Config

Кодировка HTTP: spring.http.encoding.charset = UTF-8 Включена кодировка HTTP: spring.http.encoding.enabled = true Принудительная кодировка HTTP: spring.http.encoding.force = true Кодировка баннера: spring.banner.charset = UTF-8 Кодировка сообщений: spring.messages.encoding = UTF-8

Конфигурирование журнала

Путь к журналу: logging.path = /home/cache Файл конфигурации журнала: logging.config = classpath:logback-spring.xml Уровень журнала: logging.level.root = info logging.level.springfox.documentation = info logging.level.org.apache.coyote.http11.Http11InputBuffer = info logging.level.org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor = info

Основная конфигурация базы данных

URL источника данных: datasource.master.url = jdbc:mysql://localhost:3306/sys/wbs_ocs?useUnicode=true&characterEncoding=UTF-8&useSSL=false&allowMultiQueries=true Имя пользователя источника данных: datasource.master.userName = root Пароль источника данных: datasource.master.pwd = 123456 Драйвер источника данных: datasource.master.driver = com.mysql.jdbc.Driver Максимальное активное соединение источника данных: datasource.master.maxActive = 10 Начальный размер источника данных: datasource.master.initialSize = 1 Максимальное время ожидания миллисекунд источника данных: datasource.master.maxWaitMillis = 15000 Минимальный простаивающий источник данных: datasource.master.minIdle = 5 Время между запусками очистки источника данных (миллисекунды): datasource.master.timeBetweenEvictionRunsMillis = 60000 Минимально допустимое время простоя источника данных (миллисекунды): datasource.master.minEvictableIdleTimeMillis = 300000 Запрос проверки источника данных: datasource.master.validationQuery = SELECT 'x' Проверка соединения при простое: datasource.master.testWhileIdle = true Проверка при заимствовании соединения: datasource.master.testOnBorrow = false Проверка после возврата соединения: datasource.master.testOnReturn = false Подготовка операторов пула соединений: datasource.master.poolPreparedStatements = true Максимальный размер подготовленных операторов на соединение: datasource.master.maxPoolPreparedStatementPerConnectionSize = 20 Фильтры источника данных: datasource.master.filters = stat,slf4j Свойства соединения источника данных: datasource.master.connectionProperties = druid.stat.mergeSql = true;druid.stat.slowSqlMillis = 2000 Использовать глобальную статистику источника данных: datasource.master.useGlobalDataSourceStat = true

Мониторинг Druid

Разрешённые пользователи: druidMonitor.allow = Запрещённые пользователи: druidMonitor.deny = Логин пользователя: druidMonitor.loginUsername = boot Пароль пользователя: druidMonitor.loginPassword = 123456 Включить сброс: druidMonitor.resetEnable = false

Конфигурация Swagger

Включить Swagger: swagger.enable = true Контактная информация Swagger: swagger.contact = Wbs-Auth Пакет Swagger: swagger.package = com.starsky

Redis Pub Config

Общая конфигурация, не подлежащая изменению: redis pub Config Включить кэш Redis: spring.redis.open = false Хост Redis: spring.redis.host = localhost Порт Redis: spring.redis.port = 6379 Пароль Redis (по умолчанию пустой): spring.redis.password = 123456 Подключение к базе данных Redis: spring.redis.database = 12 Тайм-аут подключения Redis (миллисекунды): spring.redis.timeout = 120000 Тестирование при заимствовании подключения: spring.redis.testOnBorrow = false Максимальное подключение в пуле Redis: spring.redis.jedis.pool.max-active = 200 Максимальное свободное подключение в пуле Redis: spring.redis.jedis.pool.max-idle = 20 Минимальное свободное подключение в пуле Redis: spring.redis.jedis.pool.min-idle = 5 Максимальное ожидание блокировки в пуле Redis (использование отрицательного значения означает отсутствие ограничений): spring.redis.jedis.pool.max-wait = -1

Весенняя сессия

Тип хранилища весенней сессии: spring.session.store-type = redis Тайм-аут весенней сессии (дней): spring.session.timeout = 10D Очистка cron весенней сессии: spring.session.redis.cleanup-cron = 0 * * * * * Пространство имён весенней сессии: spring.session.redis.namespace = spring Режим очистки весенней сессии: spring.session.redis.flush-mode = on_save

Настройка кэша

Настройка времени истечения срока действия кэша, по умолчанию в секундах (60 * 60 * 24 * 7L = 7 дней): basedata.cache.expiretime = 604800 sys.logAsync = false # Интерфейс адреса для асинхронного вызова журнала sys.logAsyncUrl = http://localhost:8801

# Server
**server.servlet.context-path** = /framework
**server.port** = 8901
**server.tomcat.uri-encoding** = UTF-8
**server.tomcat.max-threads** = 100
**server.tomcat.min-spare-threads** = 20
**server.tomcat.max-connections** = 5000

# Spring Config
**spring.http.encoding.charset** = UTF-8
**spring.http.encoding.enabled** = true
**spring.http.encoding.force** = true
**spring.banner.charset** = UTF-8
**spring.messages.encoding** = UTF-8

# Logging Config
**logging.path** = /home/framework
**logging.config** = classpath:logback-spring.xml
**logging.level.root** = info
**logging.level.springfox.documentation** = info
**logging.level.org.apache.coyote.http11.Http11InputBuffer** = info
**logging.level.org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor** = info

starsky-commons-hbase

hbase操作及工具类
配置内容如下;
# hbase config
**hbase.zookeeper.property.clientPort** = 2181
**hbase.zookeeper.quorum** = 127.0.0.1
**hbase.client.retries.number** = 3
**zookeeper.recovery.retry** = 3

starsky-commons-kafka

kafka消息队列
 配置内容如下;
#============== kafka==================
**kafka.consumer.zookeeper.connect** = localhost:2181
#============== kafka 生产者===================
## 指定kafka server的地址，集群配多个，中间，逗号隔开
**kafka.producer.servers** = localhost:9092
## 写入失败时，重试次数。当leader节点失效，一个repli节点会替代成为leader节点，此时可能出现写入失败，
## 当retris为0时，produce不会重复。retirs重发，此时repli节点完全成为leader节点，不会产生消息丢失。
**kafka.producer.retries** = 0
## 每次批量发送消息的数量,produce积累到一定数据，一次发送
**kafka.producer.batch.size** = 4096
**kafka.producer.linger** = 1
## produce积紮数据一次发送，缓存大小达到buffer.memory就发送数据
**kafka.producer.buffer.memory** = 40960
##procedure要求leader在考虑完成请求之前收到的确认数，用于控制发送记录在服务端的持久化，其值可以为如下：
##acks = 0 如果设置为零，则生产者将不会等待来自服务器的任何确认，该记录将立即添加到套接字缓冲区并视为已发送。在这种情况下，无法保证服务器已收到记录，并且重试配置将不会生效（因为客户端通常不会知道任何故障），为每条记录返回的偏移量始终设置为-1。
##acks = 1 这意味着leader会将记录写入其本地日志，但无需等待所有副本服务器的完全确认即可做出回应，在这种情况下，如果leader在确认记录后立即失败，但在将数据复制到所有的副本服务器之前，则记录将会丢失。
##acks = all 这意味着leader将等待完整的同步副本集以确认记录，这保证了只要至少一个同步副本服务器仍然存活，记录就不会丢失，这是最强有力的保证，这相当于acks = -1的设置。
##可以设置的值为：all, -1, 0, 1
**kafka.producer.acks** = 1

#============== kafka =消费者==================
## 指定kafka server的地址，集群配多个，中间，逗号隔开
**kafka.consumer.servers** = localhost:9092
#指定topic
**kafka.consumer.topic** = test
## 指定默认消费者group id --> 由于在kafka中，同一组中的consumer不会读取到同一个消息，依靠groud.id设置组名
**kafka.consumer.group.id** = test
## smallest和largest才有效，如果smallest重新0开始读取，如果是largest从logfile的offset读取。一般情况下我们都是设置smallest
**kafka.consumer.auto.offset.reset** = latest
**kafka.consumer.concurrency** = 10
## enable.auto.commit:true --> 设置自动提交offset
**kafka.consumer.enable.auto.comment** = false
##如果'enable.auto.commit'为true，则消费者偏移自动提交给Kafka的频率（以毫秒为单位），默认值为5000。
**kafka.consumer.auto.commit.interval** = 100
# 设置session回话超时时间
**kafka.consumer.session.timeout** = 6000

starsky-commons-mongodb

mongodb数据库
 配置内容如下;
spring:
  data:
    mongodb:
      uri: mongodb://msguser:123456@localhost:27017/msg
logging:
  level:
    org.springframework.data.mongodb.core.MongoTemplate: DEBUG

starsky-commons-mybatisplus

mybatisplus配置
配置内容如下;
server:
  port: 9990
#数据源
spring:
  datasource:
    dynamic:
      primary: master
      strict: false
      datasource:
#      主库链接
        master:
          username: root
          password: test2016
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false
#          从库链接
        slave_1:
          username: root
          password: test2016
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false
#          从库链接
        slave_2:
          username: root
          password: test2016
          driver-class-name: com.mysql.cj.jdbc.Driver ## Конфигурация

Соединение с базой данных MySQL

url: jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false

MyBatis

MyBatis-Plus:

• mapper-locations: classpath:mapper/*.xml
• type-aliases-package: com.*

Глобальная конфигурация:

• db-config:
  • id-type: auto
  • field-strategy: NOT_EMPTY
  • db-type: MYSQL

Конфигурация:

• map-underscore-to-camel-case: true
• call-setters-on-nulls: true

Логирование

Уровень логирования:

• root: info

Starsky-Commons-RabbitMQ

Потребитель и производитель RabbitMQ.

Конфигурационные настройки:

• spring.rabbitmq.addresses = localhost:5672
• spring.rabbitmq.username = admin
• spring.rabbitmq.password = 123456
• spring.rabbitmq.virtual-host = /
• spring.rabbitmq.connection-timeout = 10000
• spring.rabbitmq.publisher-confirms = true
• spring.rabbitmq.publisher-returns = true
• spring.rabbitmq.template.mandatory = true

Настройки прослушивателя:

• spring.rabbitmq.listener.simple.acknowledge-mode = manual
• spring.rabbitmq.listener.simple.auto-startup = true
• spring.rabbitmq.listener.simple.default-requeue-rejected = false
• spring.rabbitmq.listener.simple.concurrency = 5
• spring.rabbitmq.listener.simple.max-concurrency = 20
• spring.rabbitmq.listener.simple.prefetch = 1
• spring.rabbitmq.listener.simple.retry.enabled = true

Starsky-Commons-Redis

Кэш Redis, конфигурационные настройки:

Swagger Config

• swagger.enable = true
• swagger.contact = 1057718431@qq.com
• swagger.package = com.*

Redis Pub Config

• spring.redis.open = false
• spring.redis.host = localhost
• spring.redis.port = 6379
• spring.redis.password = 123456
• spring.redis.database = 12
• spring.redis.timeout = 120000
• spring.redis.testOnBorrow = false
• spring.redis.jedis.pool.max-active = 200
• spring.redis.jedis.pool.max-idle = 20
• spring.redis.jedis.pool.min-idle = 5
• spring.redis.jedis.pool.max-wait = -1

Spring Session

• spring.session.store-type = redis
• spring.session.timeout = 10D
• spring.session.redis.cleanup-cron = 0 * * * * *
• spring.session.redis.namespace = spring
• spring.session.redis.flush-mode = on_save

Starsky-Commons-Tools

Класс инструментов.