commit bece31356da952ce7460652d8e19b9006443da16
Author: hanxuanyu <2252193204@qq.com>
Date:   Fri Jan 21 23:03:41 2022 +0800

    项目迁移

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..d4f7300
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,2 @@
+/.idea/
+**/target/
\ No newline at end of file
diff --git a/common-spring-boot-starter/pom.xml b/common-spring-boot-starter/pom.xml
new file mode 100644
index 0000000..4960606
--- /dev/null
+++ b/common-spring-boot-starter/pom.xml
@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
+        <groupId>com.hxuanyu</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>common-spring-boot-starter</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+</project>
\ No newline at end of file
diff --git a/common-spring-boot-starter/src/main/java/com/hxuanyu/common/message/Msg.java b/common-spring-boot-starter/src/main/java/com/hxuanyu/common/message/Msg.java
new file mode 100644
index 0000000..6e91ebd
--- /dev/null
+++ b/common-spring-boot-starter/src/main/java/com/hxuanyu/common/message/Msg.java
@@ -0,0 +1,155 @@
+package com.hxuanyu.common.message;
+
+/**
+ * 用户端统一返回报文实体类
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+@SuppressWarnings("unused")
+public class Msg<T> {
+    /**
+     * 成功状态码
+     */
+    public static final Integer MSG_CODE_SUCCESS = 200;
+    /**
+     * 失败状态码
+     */
+    public static final Integer MSG_CODE_FAILED = -1;
+    /**
+     * 返回码，用于标识是否成功
+     */
+    private Integer code;
+    /**
+     * 返回信息，用于描述调用或请求状态，如果成功则添加成功的信息，若失败须写明失败原因
+     */
+    private String msg;
+    /**
+     * 调用或请求的实际结果，如果请求失败，该值应为空
+     */
+    private T data;
+
+    /**
+     * 构造器
+     */
+    private Msg() {
+    }
+
+    /**
+     * 全参构造器
+     *
+     * @param code 状态码
+     * @param msg  消息内容
+     * @param data 消息体
+     */
+    private Msg(Integer code, String msg, T data) {
+        this.code = code;
+        this.msg = msg;
+        this.data = data;
+    }
+
+    /**
+     * 构造成功消息，如果本次返回需要返回数据，则调用该方法并将数据传入
+     *
+     * @param <E>  消息体类型
+     * @param msg  消息内容
+     * @param data 消息体
+     * @return 统一消息报文
+     */
+    public static <E> Msg<E> success(String msg, E data) {
+        return new Msg<>(Msg.MSG_CODE_SUCCESS, msg, data);
+    }
+
+    /**
+     * 构造成功消息，本方法适用于不需要数据返回的情况
+     *
+     * @param <E> 消息体类型
+     * @param msg 消息内容
+     * @return 统一消息报文
+     */
+    public static <E> Msg<E> success(String msg) {
+        return success(msg, null);
+    }
+
+    /**
+     * 构造简单的成功消息，使用默认的msg
+     *
+     * @param <E> 消息体类型
+     * @return 统一消息报文
+     */
+    public static <E> Msg<E> success() {
+        return success("成功");
+    }
+
+    /**
+     * 构造失败消息，由于请求失败，调用方无法获得正确的数据，因此该类型消息的数据区为null，但是msg中必须注明失败原因，
+     * 失败原因由被调用方分析并设置
+     *
+     * @param msg 消息内容
+     * @param <T> 消息体类型
+     * @return 失败消息
+     */
+    public static <T> Msg<T> failed(String msg) {
+        return new Msg<>(Msg.MSG_CODE_FAILED, msg, null);
+    }
+
+    /**
+     * 构造带有默认msg字段的失败消息
+     *
+     * @param <T> 消息体的类型
+     * @return 失败报文
+     */
+    public static <T> Msg<T> failed() {
+        return failed("失败");
+    }
+
+    /**
+     * 返回是否成功，可直接用于if判断
+     *
+     * @return true：成功，false：失败
+     */
+    public boolean isSuccess() {
+        return Msg.MSG_CODE_SUCCESS.equals(this.code);
+    }
+
+    /**
+     * 返回是否失败，可直接用于if判断
+     *
+     * @return true：失败，false：失败
+     */
+    public boolean isFailed() {
+        return Msg.MSG_CODE_FAILED.equals(this.code);
+    }
+
+
+    /**
+     * 获取状态码
+     *
+     * @return 状态码
+     */
+    public Integer getCode() {
+        return code;
+    }
+
+    /**
+     * 获取消息内容
+     *
+     * @return 消息内容
+     */
+    public String getMsg() {
+        return msg;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    @Override
+    public String toString() {
+        return "Msg{" +
+                "code=" + code +
+                ", msg='" + msg + '\'' +
+                ", data=" + data +
+                '}';
+    }
+}
diff --git a/monitor-spring-boot-starter/pom.xml b/monitor-spring-boot-starter/pom.xml
new file mode 100644
index 0000000..1edecb1
--- /dev/null
+++ b/monitor-spring-boot-starter/pom.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
+        <groupId>com.hxuanyu</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>monitor-spring-boot-starter</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.hxuanyu</groupId>
+            <artifactId>notify-spring-boot-starter</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file
diff --git a/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/annotation/MonitorItem.java b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/annotation/MonitorItem.java
new file mode 100644
index 0000000..96fe837
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/annotation/MonitorItem.java
@@ -0,0 +1,20 @@
+package com.hxuanyu.monitor.annotation;
+
+import org.springframework.stereotype.Component;
+
+import java.lang.annotation.*;
+
+/**
+ * 监控项注解，标识在监控项实现类上，带有该注解的类会被扫描并根据配置的时间进行检查
+ *
+ * @author hxuanyu
+ */
+
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Component
+public @interface MonitorItem {
+    String name() default "";
+    String cron();
+}
diff --git a/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/base/BaseMonitorItem.java b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/base/BaseMonitorItem.java
new file mode 100644
index 0000000..f6f88a3
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/base/BaseMonitorItem.java
@@ -0,0 +1,57 @@
+package com.hxuanyu.monitor.base;
+
+
+import com.hxuanyu.monitor.common.CheckResult;
+
+/**
+ * 监控项模型类
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+public abstract class BaseMonitorItem {
+    private String monitorItemName;
+    private String cron;
+
+    public BaseMonitorItem() {
+    }
+
+    public BaseMonitorItem(String monitorItemName, String cron) {
+        this.monitorItemName = monitorItemName;
+        this.cron = cron;
+    }
+
+    public String getMonitorItemName() {
+        return monitorItemName;
+    }
+
+    public void setMonitorItemName(String monitorItemName) {
+        this.monitorItemName = monitorItemName;
+    }
+
+    public String getCron() {
+        return cron;
+    }
+
+    public void setCron(String cron) {
+        this.cron = cron;
+    }
+
+
+    /**
+     * 监控项检查器，需子类手动实现触发通知的条件，监控服务会定时调用该方法
+     * 并根据返回结果判断是否通知
+     *
+     * @return true：触发，false：不触发
+     */
+    public abstract CheckResult check();
+
+
+    @Override
+    public String toString() {
+        return "BaseMonitorItem{" +
+                "monitorItemName='" + monitorItemName + '\'' +
+                ", cron='" + cron + '\'' +
+                '}';
+    }
+}
diff --git a/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/common/CheckResult.java b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/common/CheckResult.java
new file mode 100644
index 0000000..e27a3b3
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/common/CheckResult.java
@@ -0,0 +1,77 @@
+package com.hxuanyu.monitor.common;
+
+import com.hxuanyu.notify.enums.NotifyType;
+
+/**
+ * 触发器通知
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+@SuppressWarnings("unused")
+public class CheckResult {
+    private boolean triggered;
+    private Object notifyContent;
+    private NotifyType notifyType;
+
+    public CheckResult() {
+    }
+
+    public CheckResult(boolean triggered, Object notifyContent, NotifyType notifyType) {
+        this.triggered = triggered;
+        this.notifyContent = notifyContent;
+        this.notifyType = notifyType;
+    }
+
+    @Override
+    public String toString() {
+        return "Notify{" +
+                "triggered=" + triggered +
+                ", notifyContent='" + notifyContent + '\'' +
+                '}';
+    }
+
+    /**
+     * 未触发，直接调用即可，后续用来判断是否触发
+     *
+     * @return 通知对象
+     */
+    public static CheckResult nonTriggered() {
+        return new CheckResult(false, null, null);
+    }
+
+    /**
+     * 通知触发，需要传入通知信息
+     *
+     * @param notifyContent 通知内容
+     * @param notifyType 通知类型
+     * @return 返回结果
+     */
+    public static CheckResult triggered(Object notifyContent, NotifyType notifyType) {
+        return new CheckResult(true, notifyContent, notifyType);
+    }
+
+    public boolean isTriggered() {
+        return triggered;
+    }
+
+    public void setTriggered(boolean triggered) {
+        this.triggered = triggered;
+    }
+
+    public Object getNotifyContent() {
+        return notifyContent;
+    }
+
+    public void setNotifyContent(Object notifyContent) {
+        this.notifyContent = notifyContent;
+    }
+
+    public NotifyType getNotifyType() {
+        return notifyType;
+    }
+
+    public void setNotifyType(NotifyType notifyType) {
+        this.notifyType = notifyType;
+    }
+}
diff --git a/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/config/DefaultSchedulingConfigurer.java b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/config/DefaultSchedulingConfigurer.java
new file mode 100644
index 0000000..6a86687
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/config/DefaultSchedulingConfigurer.java
@@ -0,0 +1,126 @@
+package com.hxuanyu.monitor.config;
+
+import com.hxuanyu.monitor.utils.BeanUtils;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.SchedulingException;
+import org.springframework.scheduling.TaskScheduler;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
+import org.springframework.scheduling.config.TriggerTask;
+
+import javax.annotation.Resource;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledFuture;
+
+/**
+ * 定时任务配置类
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+@SuppressWarnings({"unchecked", "unused"})
+@Configuration
+@EnableScheduling
+public class DefaultSchedulingConfigurer implements SchedulingConfigurer {
+    private ScheduledTaskRegistrar taskRegistrar;
+    private Set<ScheduledFuture<?>> scheduledFutures = null;
+    private final Map<String, ScheduledFuture<?>> taskFutures = new ConcurrentHashMap<>();
+
+    @Resource
+    ScheduledExecutorService scheduledExecutorService;
+
+    @Override
+    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
+        this.taskRegistrar = taskRegistrar;
+        taskRegistrar.setScheduler(scheduledExecutorService);
+    }
+
+    private Set<ScheduledFuture<?>> getScheduledFutures() {
+        if (scheduledFutures == null) {
+            try {
+                // spring版本不同选用不同字段scheduledFutures
+                scheduledFutures = (Set<ScheduledFuture<?>>) BeanUtils.getProperty(taskRegistrar, "scheduledTasks");
+            } catch (NoSuchFieldException e) {
+                throw new SchedulingException("not found scheduledFutures field.");
+            }
+        }
+        return scheduledFutures;
+    }
+
+    /**
+     * 添加任务
+     *
+     * @param taskId      taskId
+     * @param triggerTask triggerTask
+     */
+    public void addTriggerTask(String taskId, TriggerTask triggerTask) {
+        if (taskFutures.containsKey(taskId)) {
+            throw new SchedulingException("the taskId[" + taskId + "] was added.");
+        }
+        TaskScheduler scheduler = taskRegistrar.getScheduler();
+        if (scheduler == null) {
+            throw new SchedulingException("scheduler为空");
+        }
+        ScheduledFuture<?> future = scheduler.schedule(triggerTask.getRunnable(), triggerTask.getTrigger());
+        getScheduledFutures().add(future);
+        taskFutures.put(taskId, future);
+    }
+
+    /**
+     * 取消任务
+     *
+     * @param taskId taskId
+     */
+    public void cancelTriggerTask(String taskId) {
+        ScheduledFuture<?> future = taskFutures.get(taskId);
+        if (future != null) {
+            future.cancel(true);
+        }
+        taskFutures.remove(taskId);
+        getScheduledFutures().remove(future);
+    }
+
+    /**
+     * 重置任务
+     *
+     * @param taskId      taskId
+     * @param triggerTask triggerTask
+     */
+    public void resetTriggerTask(String taskId, TriggerTask triggerTask) {
+        cancelTriggerTask(taskId);
+        addTriggerTask(taskId, triggerTask);
+    }
+
+    /**
+     * 任务编号
+     *
+     * @return 任务编号列表
+     */
+    public Set<String> taskIds() {
+        return taskFutures.keySet();
+    }
+
+    /**
+     * 是否存在任务
+     *
+     * @param taskId taskId
+     * @return true: 存在任务；false：不存在任务
+     */
+    public boolean hasTask(String taskId) {
+        return this.taskFutures.containsKey(taskId);
+    }
+
+    /**
+     * 任务调度是否已经初始化完成
+     *
+     * @return true: 初始化完成；false：初始化未完成
+     */
+    public boolean inited() {
+        return this.taskRegistrar != null && this.taskRegistrar.getScheduler() != null;
+    }
+}
+
diff --git a/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/config/MonitorCoreConfiguration.java b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/config/MonitorCoreConfiguration.java
new file mode 100644
index 0000000..5ff506c
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/config/MonitorCoreConfiguration.java
@@ -0,0 +1,29 @@
+package com.hxuanyu.monitor.config;
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.ThreadFactory;
+
+/**
+ * MonitorCore配置类
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+
+@Configuration
+@ComponentScan("com.hxuanyu.monitor")
+public class MonitorCoreConfiguration {
+    @Bean("scheduledThreadPoolExecutor")
+    public ScheduledExecutorService scheduledThreadPoolExecutor() {
+        // 使用 ThreadFactoryBuilder 创建自定义线程名称的 ThreadFactory
+        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+                .setNameFormat("scheduled-%d").build();
+        return new ScheduledThreadPoolExecutor(10, namedThreadFactory);
+    }
+}
diff --git a/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/manager/MonitorItemBeanManager.java b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/manager/MonitorItemBeanManager.java
new file mode 100644
index 0000000..c48787f
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/manager/MonitorItemBeanManager.java
@@ -0,0 +1,98 @@
+package com.hxuanyu.monitor.manager;
+
+import com.hxuanyu.monitor.annotation.MonitorItem;
+import com.hxuanyu.monitor.base.BaseMonitorItem;
+import com.hxuanyu.monitor.common.CheckResult;
+import com.hxuanyu.monitor.config.DefaultSchedulingConfigurer;
+import com.hxuanyu.notify.enums.NotifyType;
+import com.hxuanyu.notify.service.NotifyService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextRefreshedEvent;
+import org.springframework.scheduling.config.TriggerTask;
+import org.springframework.scheduling.support.CronTrigger;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 当Bean注入成功后对Bean进行拉取，并根据注解的值为Item的属性赋值
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+@Component
+public class MonitorItemBeanManager implements ApplicationListener<ContextRefreshedEvent> {
+    private final Logger logger = LoggerFactory.getLogger(MonitorItemBeanManager.class);
+    private final Map<String, BaseMonitorItem> MONITOR_ITEM_MAP = new HashMap<>();
+
+    @Resource
+    DefaultSchedulingConfigurer schedulingConfigurer;
+
+    @Resource
+    NotifyService notifyService;
+
+    public Map<String, BaseMonitorItem> getMonitorItemMap() {
+        return MONITOR_ITEM_MAP;
+    }
+
+    @Override
+    public void onApplicationEvent(ContextRefreshedEvent event) {
+        // 根容器为Spring容器
+        if (event.getApplicationContext().getParent() == null) {
+            logger.info("=====ContextRefreshedEvent====={}", event.getSource().getClass().getName());
+            Map<String, Object> beans = event.getApplicationContext().getBeansWithAnnotation(MonitorItem.class);
+            for (Object bean : beans.values()) {
+                if (bean instanceof BaseMonitorItem) {
+                    BaseMonitorItem item = (BaseMonitorItem) bean;
+                    MonitorItem annotation = item.getClass().getAnnotation(MonitorItem.class);
+                    if (annotation != null) {
+                        String cron = annotation.cron();
+                        String name = annotation.name();
+                        if ("".equals(name)) {
+                            name = item.getClass().getSimpleName();
+                        }
+                        item.setMonitorItemName(name);
+                        item.setCron(cron);
+                        logger.info("获取到的Bean：{}", item);
+                        addMonitorTask(item);
+                    }
+                }
+            }
+        }
+    }
+
+    public void addMonitorTask(BaseMonitorItem item) {
+        String taskId = "ScheduledTask-" + item.getMonitorItemName();
+        MONITOR_ITEM_MAP.put(taskId, item);
+        logger.info("添加定时任务：{}, 执行周期：{}", taskId, item.getCron());
+        addTask(taskId, item);
+    }
+
+    public void setMonitorTaskCron(String taskId, String cron) {
+        if (MONITOR_ITEM_MAP.containsKey(taskId)) {
+            BaseMonitorItem item = MONITOR_ITEM_MAP.get(taskId);
+            item.setCron(cron);
+            addTask(taskId, item);
+        }
+    }
+
+    public void deleteMonitorTask(String taskId) {
+        MONITOR_ITEM_MAP.remove(taskId);
+        schedulingConfigurer.cancelTriggerTask(taskId);
+    }
+
+    private void addTask(String taskId, BaseMonitorItem item) {
+        String cron = item.getCron();
+        schedulingConfigurer.resetTriggerTask(taskId, new TriggerTask(() -> {
+            CheckResult checkResult = item.check();
+            if (checkResult.isTriggered()) {
+                logger.info("定时任务[{}]触发成功，发送通知：[{}]", taskId, checkResult.getNotifyContent());
+                notifyService.notify(checkResult.getNotifyContent(), NotifyType.MAIL_TYPE);
+            }
+        }, new CronTrigger(cron)));
+    }
+}
diff --git a/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/utils/BeanUtils.java b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/utils/BeanUtils.java
new file mode 100644
index 0000000..89b427e
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/java/com/hxuanyu/monitor/utils/BeanUtils.java
@@ -0,0 +1,129 @@
+package com.hxuanyu.monitor.utils;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+import java.lang.reflect.Modifier;
+import java.util.*;
+
+/**
+ * 反射工具，操作Bean对象的属性
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+public class BeanUtils {
+    public static Field findField(Class<?> clazz, String name) {
+        try {
+            return clazz.getField(name);
+        } catch (NoSuchFieldException ex) {
+            return findDeclaredField(clazz, name);
+        }
+    }
+
+    public static Field findDeclaredField(Class<?> clazz, String name) {
+        try {
+            return clazz.getDeclaredField(name);
+        } catch (NoSuchFieldException ex) {
+            if (clazz.getSuperclass() != null) {
+                return findDeclaredField(clazz.getSuperclass(), name);
+            }
+            return null;
+        }
+    }
+
+    public static Method findMethod(Class<?> clazz, String methodName, Class<?>... paramTypes) {
+        try {
+            return clazz.getMethod(methodName, paramTypes);
+        } catch (NoSuchMethodException ex) {
+            return findDeclaredMethod(clazz, methodName, paramTypes);
+        }
+    }
+
+    public static Method findDeclaredMethod(Class<?> clazz, String methodName, Class<?>... paramTypes) {
+        try {
+            return clazz.getDeclaredMethod(methodName, paramTypes);
+        } catch (NoSuchMethodException ex) {
+            if (clazz.getSuperclass() != null) {
+                return findDeclaredMethod(clazz.getSuperclass(), methodName, paramTypes);
+            }
+            return null;
+        }
+    }
+
+    public static Object getProperty(Object obj, String name) throws NoSuchFieldException {
+        Object value;
+        Field field = findField(obj.getClass(), name);
+        if (field == null) {
+            throw new NoSuchFieldException("no such field [" + name + "]");
+        }
+        boolean accessible = field.isAccessible();
+        field.setAccessible(true);
+        try {
+            value = field.get(obj);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        field.setAccessible(accessible);
+        return value;
+    }
+
+    public static void setProperty(Object obj, String name, Object value) throws NoSuchFieldException {
+        Field field = findField(obj.getClass(), name);
+        if (field == null) {
+            throw new NoSuchFieldException("no such field [" + name + "]");
+        }
+        boolean accessible = field.isAccessible();
+        field.setAccessible(true);
+        try {
+            field.set(obj, value);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        field.setAccessible(accessible);
+    }
+
+    public static Map<String, Object> obj2Map(Object obj, Map<String, Object> map) {
+        if (map == null) {
+            map = new HashMap<>(0);
+        }
+        if (obj != null) {
+            try {
+                Class<?> clazz = obj.getClass();
+                do {
+                    Field[] fields = clazz.getDeclaredFields();
+                    for (Field field : fields) {
+                        int mod = field.getModifiers();
+                        if (Modifier.isStatic(mod)) {
+                            continue;
+                        }
+                        boolean accessible = field.isAccessible();
+                        field.setAccessible(true);
+                        map.put(field.getName(), field.get(obj));
+                        field.setAccessible(accessible);
+                    }
+                    clazz = clazz.getSuperclass();
+                } while (clazz != null);
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+        }
+        return map;
+    }
+
+    /**
+     * 获得父类集合，包含当前class
+     *
+     * @param clazz 类型泛型
+     * @return 父类集合
+     */
+    public static List<Class<?>> getSuperclassList(Class<?> clazz) {
+        List<Class<?>> clazzes = new ArrayList<>(3);
+        clazzes.add(clazz);
+        clazz = clazz.getSuperclass();
+        while (clazz != null) {
+            clazzes.add(clazz);
+            clazz = clazz.getSuperclass();
+        }
+        return Collections.unmodifiableList(clazzes);
+    }
+}
diff --git a/monitor-spring-boot-starter/src/main/resources/META-INF/spring.factories b/monitor-spring-boot-starter/src/main/resources/META-INF/spring.factories
new file mode 100644
index 0000000..bba51d8
--- /dev/null
+++ b/monitor-spring-boot-starter/src/main/resources/META-INF/spring.factories
@@ -0,0 +1 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=com.hxuanyu.monitor.config.MonitorCoreConfiguration
\ No newline at end of file
diff --git a/network-spring-boot-starter/pom.xml b/network-spring-boot-starter/pom.xml
new file mode 100644
index 0000000..b37d289
--- /dev/null
+++ b/network-spring-boot-starter/pom.xml
@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
+        <groupId>com.hxuanyu</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>network-spring-boot-starter</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+    <dependencies>
+        <!--http客户端-->
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.hxuanyu</groupId>
+            <artifactId>common-spring-boot-starter</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file
diff --git a/network-spring-boot-starter/src/main/java/com/hxuanyu/network/config/NetworkConfiguration.java b/network-spring-boot-starter/src/main/java/com/hxuanyu/network/config/NetworkConfiguration.java
new file mode 100644
index 0000000..c895b4a
--- /dev/null
+++ b/network-spring-boot-starter/src/main/java/com/hxuanyu/network/config/NetworkConfiguration.java
@@ -0,0 +1,33 @@
+package com.hxuanyu.network.config;
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import com.hxuanyu.network.service.HttpService;
+import com.hxuanyu.network.service.impl.HttpServiceImpl;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.concurrent.*;
+
+/**
+ * 网络模块配置
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+@Configuration
+@ComponentScan("com.hxuanyu.network.service")
+public class NetworkConfiguration {
+    @Bean(name = "networkExecutorService")
+    public ExecutorService networkExecutorService() {
+        // 使用 ThreadFactoryBuilder 创建自定义线程名称的 ThreadFactory
+        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+                .setNameFormat("Default-pool-%d").build();
+        return new ThreadPoolExecutor(2,
+                10,
+                1, TimeUnit.MINUTES,
+                new ArrayBlockingQueue<>(5, true),
+                namedThreadFactory,
+                new ThreadPoolExecutor.AbortPolicy());
+    }
+}
diff --git a/network-spring-boot-starter/src/main/java/com/hxuanyu/network/service/HttpService.java b/network-spring-boot-starter/src/main/java/com/hxuanyu/network/service/HttpService.java
new file mode 100644
index 0000000..f8677a9
--- /dev/null
+++ b/network-spring-boot-starter/src/main/java/com/hxuanyu/network/service/HttpService.java
@@ -0,0 +1,329 @@
+package com.hxuanyu.network.service;
+
+import com.hxuanyu.common.message.Msg;
+import org.apache.http.HttpEntity;
+
+import java.util.Map;
+
+/**
+ * 网络请求服务，用于发起常规的Http请求，包括同步异步的方式，请求任务由线程池进行管理。
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+@SuppressWarnings("unused")
+public interface HttpService {
+
+    /**
+     * 获取原始HttpEntity对象
+     *
+     * @param url 请求地址
+     * @return 统一结果报文
+     */
+    Msg<HttpEntity> doGetWithEntity(String url);
+
+
+
+    /**
+     * 发送get请求；不带请求头和请求参数
+     *
+     * @param url 请求地址
+     * @return 统一请求报文
+     */
+    Msg<String> doGet(String url);
+
+
+    /**
+     * 异步Get请求
+     *
+     * @param url      请求地址
+     * @param listener 异步请求结果监听
+     */
+    void doGetSync(String url, NetWorkListener<String> listener);
+
+    /**
+     * 异步Get请求
+     *
+     * @param url      请求地址
+     * @param listener 异步请求结果监听
+     */
+    void doGetSyncWithEntity(String url, NetWorkListener<HttpEntity> listener);
+
+    /**
+     * 发送get请求；带请求参数
+     *
+     * @param url    请求地址
+     * @param params 请求参数集合
+     * @return 全局报文
+     */
+    Msg<String> doGet(String url, Map<String, String> params);
+
+
+    /**
+     * 发送get请求；带请求参数
+     *
+     * @param url    请求地址
+     * @param params 请求参数集合
+     * @return 全局报文
+     */
+    Msg<HttpEntity> doGetWithEntity(String url, Map<String, String> params);
+
+    /**
+     * 异步Get请求
+     *
+     * @param url      请求地址
+     * @param params   请求参数
+     * @param listener 异步请求结果监听
+     */
+    void doGetSync(String url, Map<String, String> params, NetWorkListener<String> listener);
+
+    /**
+     * 异步Get请求
+     *
+     * @param url      请求地址
+     * @param params   请求参数
+     * @param listener 异步请求结果监听
+     */
+    void doGetSyncWithEntity(String url, Map<String, String> params, NetWorkListener<HttpEntity> listener);
+
+    /**
+     * 发送get请求；带请求头和请求参数
+     *
+     * @param url     请求地址
+     * @param headers 请求头集合
+     * @param params  请求参数集合
+     * @return 全局报文
+     */
+    Msg<String> doGet(String url, Map<String, String> headers, Map<String, String> params);
+
+    /**
+     * 发送get请求；带请求头和请求参数
+     *
+     * @param url     请求地址
+     * @param headers 请求头集合
+     * @param params  请求参数集合
+     * @return 全局报文
+     */
+    Msg<HttpEntity> doGetWithEntity(String url, Map<String, String> headers, Map<String, String> params);
+
+    /**
+     * 异步Get请求
+     *
+     * @param url      请求地址
+     * @param headers  请求头
+     * @param params   请求体
+     * @param listener 异步结果监听器
+     */
+    void doGetSync(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<String> listener);
+
+    /**
+     * 异步Get请求
+     *
+     * @param url      请求地址
+     * @param headers  请求头
+     * @param params   请求体
+     * @param listener 异步结果监听器
+     */
+    void doGetSyncWithEntity(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<HttpEntity> listener);
+
+    /**
+     * 发送post请求；不带请求头和请求参数
+     *
+     * @param url 请求地址
+     * @return 统一报文
+     */
+    Msg<String> doPost(String url);
+
+    /**
+     * 发送post请求；不带请求头和请求参数
+     *
+     * @param url 请求地址
+     * @return 统一报文
+     */
+    Msg<HttpEntity> doPostWithEntity(String url);
+
+
+    /**
+     * 异步Post请求
+     *
+     * @param url      请求地址
+     * @param listener 请求参数
+     */
+    void doPostSync(String url, NetWorkListener<String> listener);
+
+    /**
+     * 异步Post请求
+     *
+     * @param url      请求地址
+     * @param listener 请求参数
+     */
+    void doPostSyncWithEntity(String url, NetWorkListener<HttpEntity> listener);
+
+    /**
+     * 同步Post请求
+     *
+     * @param url    请求地址
+     * @param params 请求参数
+     * @return 统一消息体
+     */
+    Msg<String> doPost(String url, Map<String, String> params);
+
+
+    /**
+     * 同步Post请求
+     *
+     * @param url    请求地址
+     * @param params 请求参数
+     * @return 统一消息体
+     */
+    Msg<HttpEntity> doPostWithEntity(String url, Map<String, String> params);
+
+    /**
+     * 异步Post请求
+     *
+     * @param url      请求地址
+     * @param params   请求参数
+     * @param listener 异步请求结果监听
+     */
+    void doPostSync(String url, Map<String, String> params, NetWorkListener<String> listener);
+
+    /**
+     * 异步Post请求
+     *
+     * @param url      请求地址
+     * @param params   请求参数
+     * @param listener 异步请求结果监听
+     */
+    void doPostSyncWithEntity(String url, Map<String, String> params, NetWorkListener<HttpEntity> listener);
+
+    /**
+     * 发送post请求；带请求头和请求参数
+     *
+     * @param url     请求地址
+     * @param headers 请求头集合
+     * @param params  请求参数集合
+     * @return 统一返回报文
+     */
+    Msg<String> doPost(String url, Map<String, String> headers, Map<String, String> params);
+
+    /**
+     * 发送post请求；带请求头和请求参数
+     *
+     * @param url     请求地址
+     * @param headers 请求头集合
+     * @param params  请求参数集合
+     * @return 统一返回报文
+     */
+    Msg<HttpEntity> doPostWithEntity(String url, Map<String, String> headers, Map<String, String> params);
+
+
+    /**
+     * 异步Post请求
+     *
+     * @param url      请求地址
+     * @param headers  请求头
+     * @param params   请求参数
+     * @param listener 异步请求结果监听
+     */
+    void doPostSync(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<String> listener);
+
+    /**
+     * 异步Post请求
+     *
+     * @param url      请求地址
+     * @param headers  请求头
+     * @param params   请求参数
+     * @param listener 异步请求结果监听
+     */
+    void doPostSyncWithEntity(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<HttpEntity> listener);
+
+    /**
+     * 发送put请求；不带请求参数
+     *
+     * @param url 请求地址
+     * @return 统一消息返回报文
+     */
+    Msg<String> doPut(String url);
+
+
+    /**
+     * 发送put请求；不带请求参数
+     *
+     * @param url 请求地址
+     * @return 统一消息返回报文
+     */
+    Msg<HttpEntity> doPutWithEntity(String url);
+
+    /**
+     * 发送put请求；带请求参数
+     *
+     * @param url    请求地址
+     * @param params 请求参数
+     * @return 统一消息报文
+     */
+    Msg<String> doPut(String url, Map<String, String> params);
+
+    /**
+     * 发送put请求；带请求参数
+     *
+     * @param url    请求地址
+     * @param params 请求参数
+     * @return 统一消息报文
+     */
+    Msg<HttpEntity> doPutWithEntity(String url, Map<String, String> params);
+
+    /**
+     * 发送delete请求；不带请求参数
+     *
+     * @param url 请求地址
+     * @return 统一返回报文
+     * @throws Exception 异常
+     */
+    Msg<String> doDelete(String url) throws Exception;
+
+    /**
+     * 发送delete请求；不带请求参数
+     *
+     * @param url 请求地址
+     * @return 统一返回报文
+     * @throws Exception 异常
+     */
+    Msg<HttpEntity> doDeleteWithEntity(String url) throws Exception;
+
+    /**
+     * 发送delete请求；带请求参数
+     *
+     * @param url    请求地址
+     * @param params 请求参数
+     * @return 统一返回报文
+     * @throws Exception 异常
+     */
+    Msg<String> doDelete(String url, Map<String, String> params) throws Exception;
+
+
+    /**
+     * 发送delete请求；带请求参数
+     *
+     * @param url    请求地址
+     * @param params 请求参数
+     * @return 统一返回报文
+     * @throws Exception 异常
+     */
+    Msg<HttpEntity> doDeleteWithEntity(String url, Map<String, String> params) throws Exception;
+
+    interface NetWorkListener<T> {
+        /**
+         * 网络请求成功后调用
+         *
+         * @param msg 统一返回消息
+         */
+        void onSuccess(Msg<T> msg);
+
+        /**
+         * 网络请求失败后调用
+         *
+         * @param msg 统一返回消息
+         */
+        void onFailed(Msg<T> msg);
+    }
+}
diff --git a/network-spring-boot-starter/src/main/java/com/hxuanyu/network/service/impl/HttpServiceImpl.java b/network-spring-boot-starter/src/main/java/com/hxuanyu/network/service/impl/HttpServiceImpl.java
new file mode 100644
index 0000000..92d45b1
--- /dev/null
+++ b/network-spring-boot-starter/src/main/java/com/hxuanyu/network/service/impl/HttpServiceImpl.java
@@ -0,0 +1,471 @@
+package com.hxuanyu.network.service.impl;
+
+import com.hxuanyu.common.message.Msg;
+import com.hxuanyu.network.service.HttpService;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpStatus;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.*;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.util.*;
+import java.util.concurrent.ExecutorService;
+
+
+/**
+ * @author hxuanyu
+ */
+@SuppressWarnings("unused")
+@Service
+public class HttpServiceImpl implements HttpService {
+    private final Logger logger = LoggerFactory.getLogger(HttpServiceImpl.class);
+    private ExecutorService executorService;
+
+    @Autowired
+    public void setExecutorService(@Qualifier("networkExecutorService") ExecutorService executorService) {
+        this.executorService = executorService;
+    }
+
+    /**
+     * 编码格式。发送编码格式统一用UTF-8
+     */
+    private static final String ENCODING = "UTF-8";
+
+    /**
+     * 设置连接超时时间，单位毫秒。
+     */
+    private static final int CONNECT_TIMEOUT = 10000;
+
+    /**
+     * 请求获取数据的超时时间(即响应时间)，单位毫秒。
+     */
+    private static final int SOCKET_TIMEOUT = 10000;
+
+
+    @Override
+    public Msg<HttpEntity> doGetWithEntity(String url) {
+
+        return doGetWithEntity(url, null, null);
+    }
+
+    @Override
+    public Msg<String> doGet(String url) {
+        return doGet(url, null, null);
+    }
+
+    @Override
+    public void doGetSync(String url, NetWorkListener<String> listener) {
+        doGetSync(url, null, listener);
+    }
+
+    @Override
+    public void doGetSyncWithEntity(String url, NetWorkListener<HttpEntity> listener) {
+        doGetSyncWithEntity(url, null, listener);
+    }
+
+
+    @Override
+    public Msg<String> doGet(String url, Map<String, String> params) {
+        return doGet(url, null, params);
+    }
+
+    @Override
+    public Msg<HttpEntity> doGetWithEntity(String url, Map<String, String> params) {
+        return doGetWithEntity(url, null, params);
+    }
+
+    @Override
+    public void doGetSync(String url, Map<String, String> params, NetWorkListener<String> listener) {
+        doGetSync(url, null, params, listener);
+    }
+
+    @Override
+    public void doGetSyncWithEntity(String url, Map<String, String> params, NetWorkListener<HttpEntity> listener) {
+        doGetSyncWithEntity(url, null, params, listener);
+    }
+
+
+    @Override
+    public Msg<String> doGet(String url, Map<String, String> headers, Map<String, String> params) {
+        Msg<HttpEntity> httpEntityMsg = doGetWithEntity(url, headers, params);
+        return getStringMsg(httpEntityMsg);
+    }
+
+    @Override
+    public Msg<HttpEntity> doGetWithEntity(String url, Map<String, String> headers, Map<String, String> params) {
+        // 创建httpClient对象
+        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
+
+            // 创建访问的地址
+            URIBuilder uriBuilder = new URIBuilder(url);
+            if (params != null) {
+                Set<Map.Entry<String, String>> entrySet = params.entrySet();
+                for (Map.Entry<String, String> entry : entrySet) {
+                    uriBuilder.setParameter(entry.getKey(), entry.getValue());
+                }
+            }
+
+            // 创建http对象
+            HttpGet httpGet = new HttpGet(uriBuilder.build());
+            /*
+             * setConnectTimeout：设置连接超时时间，单位毫秒。
+             * setConnectionRequestTimeout：设置从connect Manager(连接池)获取Connection
+             * 超时时间，单位毫秒。这个属性是新加的属性，因为目前版本是可以共享连接池的。
+             * setSocketTimeout：请求获取数据的超时时间(即响应时间)，单位毫秒。 如果访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。
+             */
+            RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
+            httpGet.setConfig(requestConfig);
+
+            // 设置请求头
+            packageHeader(headers, httpGet);
+
+            // 创建httpResponse对象
+            CloseableHttpResponse httpResponse = null;
+
+            try {
+                // 执行请求并获得响应结果
+                return getHttpClientResult(httpClient, httpGet);
+            } finally {
+                // 释放资源
+                release(httpClient);
+            }
+        } catch (Exception e) {
+            logger.error("请求过程出现异常: {}", e.getMessage());
+            return Msg.failed("网络请求发生异常：" + e.getMessage());
+        }
+    }
+
+
+    @Override
+    public void doGetSync(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<String> listener) {
+        executorService.execute(() -> {
+            try {
+                Msg<String> msg = doGet(url, headers, params);
+                logger.debug("异步请求结果：{}", msg);
+                if (msg.getCode().equals(Msg.MSG_CODE_SUCCESS)) {
+                    listener.onSuccess(msg);
+                } else if (msg.getCode().equals(Msg.MSG_CODE_FAILED)) {
+                    listener.onFailed(msg);
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+                listener.onFailed(Msg.failed("网络请求时发生异常"));
+            }
+        });
+    }
+
+    @Override
+    public void doGetSyncWithEntity(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<HttpEntity> listener) {
+        executorService.execute(() -> {
+            try {
+                Msg<HttpEntity> msg = doGetWithEntity(url, headers, params);
+                logger.debug("异步请求结果：{}", msg);
+                if (msg.getCode().equals(Msg.MSG_CODE_SUCCESS)) {
+                    listener.onSuccess(msg);
+                } else if (msg.getCode().equals(Msg.MSG_CODE_FAILED)) {
+                    listener.onFailed(msg);
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+                listener.onFailed(Msg.failed("网络请求时发生异常"));
+            }
+        });
+    }
+
+    @Override
+    public Msg<String> doPost(String url) {
+        return doPost(url, null, null);
+    }
+
+    @Override
+    public Msg<HttpEntity> doPostWithEntity(String url) {
+        return doPostWithEntity(url, null, null);
+    }
+
+    @Override
+    public void doPostSync(String url, NetWorkListener<String> listener) {
+        doPostSync(url, null, listener);
+    }
+
+    @Override
+    public void doPostSyncWithEntity(String url, NetWorkListener<HttpEntity> listener) {
+        doPostSyncWithEntity(url, null, listener);
+    }
+
+
+    @Override
+    public Msg<String> doPost(String url, Map<String, String> params) {
+        return doPost(url, null, params);
+    }
+
+    @Override
+    public Msg<HttpEntity> doPostWithEntity(String url, Map<String, String> params) {
+        return doPostWithEntity(url, null, params);
+    }
+
+    @Override
+    public void doPostSync(String url, Map<String, String> params, NetWorkListener<String> listener) {
+        doPostSync(url, null, params, listener);
+    }
+
+    @Override
+    public void doPostSyncWithEntity(String url, Map<String, String> params, NetWorkListener<HttpEntity> listener) {
+        doPostSyncWithEntity(url, null, params, listener);
+    }
+
+    @Override
+    public Msg<String> doPost(String url, Map<String, String> headers, Map<String, String> params) {
+        Msg<HttpEntity> httpEntityMsg = doPostWithEntity(url, headers, params);
+        return getStringMsg(httpEntityMsg);
+    }
+
+    @Override
+    public Msg<HttpEntity> doPostWithEntity(String url, Map<String, String> headers, Map<String, String> params) {
+        // 创建httpClient对象
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+
+        // 创建http对象
+        HttpPost httpPost = new HttpPost(url);
+        /*
+         * setConnectTimeout：设置连接超时时间，单位毫秒。
+         * setConnectionRequestTimeout：设置从connect Manager(连接池)获取Connection
+         * 超时时间，单位毫秒。这个属性是新加的属性，因为目前版本是可以共享连接池的。
+         * setSocketTimeout：请求获取数据的超时时间(即响应时间)，单位毫秒。 如果访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。
+         */
+        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
+        httpPost.setConfig(requestConfig);
+        // 设置请求头
+        httpPost.setHeader("Cookie", "");
+        httpPost.setHeader("Connection", "keep-alive");
+        httpPost.setHeader("Accept", "application/json");
+        httpPost.setHeader("Accept-Language", "zh-CN,zh;q=0.9");
+        httpPost.setHeader("Accept-Encoding", "gzip, deflate, br");
+        httpPost.setHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/65.0.3325.181 Safari/537.36");
+        packageHeader(headers, httpPost);
+
+        // 封装请求参数
+        try {
+            packageParam(params, httpPost);
+            // 执行请求并获得响应结果
+            return getHttpClientResult(httpClient, httpPost);
+        } catch (Exception e) {
+            e.printStackTrace();
+            logger.error("请求过程出现异常: {}", e.getMessage());
+            return Msg.failed("请求过程出现异常: " + e.getMessage());
+        } finally {
+            // 释放资源
+            try {
+                release(httpClient);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    @Override
+    public void doPostSync(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<String> listener) {
+        executorService.execute(() -> {
+            try {
+                Msg<String> msg = doPost(url, headers, params);
+                if (msg.getCode().equals(Msg.MSG_CODE_SUCCESS)) {
+                    listener.onSuccess(msg);
+                } else if (msg.getCode().equals(Msg.MSG_CODE_FAILED)) {
+                    listener.onFailed(msg);
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+                listener.onFailed(Msg.failed("网络请求时发生异常"));
+            }
+        });
+    }
+
+    @Override
+    public void doPostSyncWithEntity(String url, Map<String, String> headers, Map<String, String> params, NetWorkListener<HttpEntity> listener) {
+        executorService.execute(() -> {
+            try {
+                Msg<HttpEntity> msg = doPostWithEntity(url, headers, params);
+                if (msg.getCode().equals(Msg.MSG_CODE_SUCCESS)) {
+                    listener.onSuccess(msg);
+                } else if (msg.getCode().equals(Msg.MSG_CODE_FAILED)) {
+                    listener.onFailed(msg);
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+                listener.onFailed(Msg.failed("网络请求时发生异常"));
+            }
+        });
+    }
+
+
+    @Override
+    public Msg<String> doPut(String url) {
+        return doPut(url, null);
+    }
+
+    @Override
+    public Msg<HttpEntity> doPutWithEntity(String url) {
+        return doPutWithEntity(url, null);
+    }
+
+    @Override
+    public Msg<String> doPut(String url, Map<String, String> params) {
+        Msg<HttpEntity> httpEntityMsg = doPutWithEntity(url, params);
+        return getStringMsg(httpEntityMsg);
+    }
+
+    @Override
+    public Msg<HttpEntity> doPutWithEntity(String url, Map<String, String> params) {
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        HttpPut httpPut = new HttpPut(url);
+        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
+        httpPut.setConfig(requestConfig);
+
+        CloseableHttpResponse httpResponse = null;
+        try {
+            packageParam(params, httpPut);
+
+            return getHttpClientResult(httpClient, httpPut);
+        } catch (Exception e) {
+            e.printStackTrace();
+            logger.error("请求过程出现异常: {}", e.getMessage());
+            return Msg.failed("网络请求时发生异常: " + e.getMessage());
+        } finally {
+            try {
+                release(httpClient);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    private String parseEntityToString(HttpEntity httpEntity) throws IOException {
+        return EntityUtils.toString(httpEntity, ENCODING);
+    }
+
+    private Msg<String> getStringMsg(Msg<HttpEntity> httpEntityMsg) {
+        if (Msg.MSG_CODE_SUCCESS.equals(httpEntityMsg.getCode())) {
+            try {
+                String result = parseEntityToString(httpEntityMsg.getData());
+                return Msg.success(httpEntityMsg.getMsg(), result);
+            } catch (IOException e) {
+                e.printStackTrace();
+                return Msg.failed("转换字符串过程中发生异常：" + e.getMessage());
+            }
+        } else {
+            return Msg.failed(httpEntityMsg.getMsg());
+        }
+    }
+
+    @Override
+    public Msg<String> doDelete(String url) {
+        Msg<HttpEntity> httpEntityMsg = doDeleteWithEntity(url);
+        return getStringMsg(httpEntityMsg);
+    }
+
+    @Override
+    public Msg<HttpEntity> doDeleteWithEntity(String url) {
+        CloseableHttpClient httpClient = HttpClients.createDefault();
+        HttpDelete httpDelete = new HttpDelete(url);
+        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
+        httpDelete.setConfig(requestConfig);
+        try {
+            return getHttpClientResult(httpClient, httpDelete);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return Msg.failed("转换String时发生IO异常");
+        } finally {
+            try {
+                release(httpClient);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    @Override
+    public Msg<String> doDelete(String url, Map<String, String> params) {
+        Msg<HttpEntity> httpEntityMsg = doDeleteWithEntity(url, params);
+        return getStringMsg(httpEntityMsg);
+    }
+
+    @Override
+    public Msg<HttpEntity> doDeleteWithEntity(String url, Map<String, String> params){
+        if (params == null) {
+            params = new HashMap<>(0);
+        }
+
+        params.put("_method", "delete");
+        return doPostWithEntity(url, params);
+    }
+
+
+    private void packageHeader(Map<String, String> params, HttpRequestBase httpMethod) {
+        // 封装请求头
+        if (params != null) {
+            Set<Map.Entry<String, String>> entrySet = params.entrySet();
+            for (Map.Entry<String, String> entry : entrySet) {
+                // 设置到请求头到HttpRequestBase对象中
+                httpMethod.setHeader(entry.getKey(), entry.getValue());
+            }
+        }
+    }
+
+    private void packageParam(Map<String, String> params, HttpEntityEnclosingRequestBase httpMethod)
+            throws UnsupportedEncodingException {
+        // 封装请求参数
+        if (params != null) {
+            List<NameValuePair> nvps = new ArrayList<>();
+            Set<Map.Entry<String, String>> entrySet = params.entrySet();
+            for (Map.Entry<String, String> entry : entrySet) {
+                nvps.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
+            }
+
+            // 设置到请求的http对象中
+            httpMethod.setEntity(new UrlEncodedFormEntity(nvps, ENCODING));
+        }
+    }
+
+    private Msg<HttpEntity> getHttpClientResult(CloseableHttpClient httpClient, HttpRequestBase httpMethod) {
+        // 执行请求
+        CloseableHttpResponse httpResponse;
+        try {
+            logger.info("执行请求：{}，请求方式：{}", httpMethod.getURI().toString(), httpMethod.getMethod());
+            httpResponse = httpClient.execute(httpMethod);
+            // 获取返回结果
+            if (httpResponse != null && httpResponse.getStatusLine() != null) {
+                HttpEntity content;
+                if (httpResponse.getEntity() != null) {
+                    content = httpResponse.getEntity();
+                    return Msg.success(httpResponse.getStatusLine().getStatusCode() + "请求成功", content);
+                }
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+            logger.error("请求过程中出现异常: {}", e.getMessage());
+            return Msg.failed("请求过程出现异常" + e.getMessage());
+        }
+
+
+        return Msg.failed(HttpStatus.SC_INTERNAL_SERVER_ERROR + "请求失败");
+    }
+
+    private void release(CloseableHttpClient httpClient) throws IOException {
+        // 释放资源
+        if (httpClient != null) {
+            httpClient.close();
+        }
+    }
+}
\ No newline at end of file
diff --git a/network-spring-boot-starter/src/main/resources/META-INF/spring.factories b/network-spring-boot-starter/src/main/resources/META-INF/spring.factories
new file mode 100644
index 0000000..d1a73bd
--- /dev/null
+++ b/network-spring-boot-starter/src/main/resources/META-INF/spring.factories
@@ -0,0 +1 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=com.hxuanyu.network.config.NetworkConfiguration
\ No newline at end of file
diff --git a/notify-spring-boot-starter/pom.xml b/notify-spring-boot-starter/pom.xml
new file mode 100644
index 0000000..271b1e5
--- /dev/null
+++ b/notify-spring-boot-starter/pom.xml
@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
+        <groupId>com.hxuanyu</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>notify-spring-boot-starter</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-thymeleaf</artifactId>
+        </dependency>
+        <!--邮件发送-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-mail</artifactId>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/common/MailQueue.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/common/MailQueue.java
new file mode 100644
index 0000000..07f8b28
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/common/MailQueue.java
@@ -0,0 +1,78 @@
+package com.hxuanyu.notify.common;
+
+
+
+import com.hxuanyu.notify.model.Mail;
+
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
+
+/**
+ * 邮件队列
+ *
+ * @author 22521
+ */
+public class MailQueue {
+    /**
+     * 队列大小
+     */
+    static final int QUEUE_MAX_SIZE = 1000;
+
+    static BlockingQueue<Mail> blockingQueue = new LinkedBlockingQueue<>(QUEUE_MAX_SIZE);
+
+    /**
+     * 私有的默认构造子，保证外界无法直接实例化
+     */
+    private MailQueue() {
+    }
+
+
+    /**
+     * 类级的内部类，也就是静态的成员式内部类，该内部类的实例与外部类的实例
+     * 没有绑定关系，而且只有被调用到才会装载，从而实现了延迟加载
+     */
+    private static class SingletonHolder {
+        /**
+         * 静态初始化器，由JVM来保证线程安全
+         */
+        private static final MailQueue MAIL_QUEUE = new MailQueue();
+    }
+
+    /**
+     * 单例队列
+     *
+     * @return 队列实例
+     */
+    public static MailQueue getMailQueue() {
+        return SingletonHolder.MAIL_QUEUE;
+    }
+
+    /**
+     * 生产者入队
+     *
+     * @param mail 邮件
+     * @throws InterruptedException 异常
+     */
+    public void produce(Mail mail) throws InterruptedException {
+        blockingQueue.put(mail);
+    }
+
+    /**
+     * 消费出队
+     *
+     * @return 邮件
+     * @throws InterruptedException 异常
+     */
+    public Mail consume() throws InterruptedException {
+        return blockingQueue.take();
+    }
+
+    /**
+     * 获取队列大小
+     *
+     * @return 队列大小
+     */
+    public int size() {
+        return blockingQueue.size();
+    }
+}
\ No newline at end of file
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/config/NotifyConfiguration.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/config/NotifyConfiguration.java
new file mode 100644
index 0000000..6e3b07a
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/config/NotifyConfiguration.java
@@ -0,0 +1,31 @@
+package com.hxuanyu.notify.config;
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.concurrent.*;
+
+/**
+ * @author hxuanyu
+ */
+@Configuration
+@ComponentScan("com.hxuanyu.notify.service")
+public class NotifyConfiguration {
+    @Bean(name = "mailExecutorService")
+    public ExecutorService mailExecutorService() {
+        // 使用 ThreadFactoryBuilder 创建自定义线程名称的 ThreadFactory
+        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+                .setNameFormat("Mail-pool-%d").build();
+
+        // 创建线程池，其中任务队列需要结合实际情况设置合理的容量
+        return new ThreadPoolExecutor(1,
+                1,
+                0L,
+                TimeUnit.MILLISECONDS,
+                new LinkedBlockingQueue<>(1024),
+                namedThreadFactory,
+                new ThreadPoolExecutor.AbortPolicy());
+    }
+}
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/enums/NotifyType.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/enums/NotifyType.java
new file mode 100644
index 0000000..c60dd4a
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/enums/NotifyType.java
@@ -0,0 +1,27 @@
+package com.hxuanyu.notify.enums;
+
+/**
+ * 通知类型，目前只有邮件
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+public enum NotifyType {
+
+
+    /**
+     * 邮件类型
+     */
+    MAIL_TYPE("邮件"),
+    SMS_TYPE("短信");
+
+    private final String typeName;
+
+    NotifyType(String typeName) {
+        this.typeName = typeName;
+    }
+
+    public String getTypeName() {
+        return typeName;
+    }
+}
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/model/Mail.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/model/Mail.java
new file mode 100644
index 0000000..74bb18d
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/model/Mail.java
@@ -0,0 +1,108 @@
+package com.hxuanyu.notify.model;
+
+/**
+ * 邮件
+ *
+ * @author hxuanyu
+ */
+public class Mail {
+    private String from;
+    private String to;
+    private String cc;
+    private String subject;
+    private String content;
+
+    public Mail() {
+    }
+
+    public Mail(String from, String to, String cc, String subject, String content) {
+        this.from = from;
+        this.to = to;
+        this.cc = cc;
+        this.subject = subject;
+        this.content = content;
+    }
+
+    /**
+     * 不传入发送者时使用默认配置好的发件人
+     *
+     * @param to      收件人
+     * @param cc      抄送人
+     * @param subject 主题
+     * @param content 邮件内容
+     */
+    public Mail(String to, String cc, String subject, String content) {
+        this.from = null;
+        this.to = to;
+        this.cc = cc;
+        this.subject = subject;
+        this.content = content;
+    }
+
+
+    /**
+     * 不传入发送者时使用默认配置好的发件人
+     *
+     * @param to      收件人
+     * @param subject 主题
+     * @param content 邮件内容
+     */
+    public Mail(String to, String subject, String content) {
+        this.from = null;
+        this.to = to;
+        this.cc = to;
+        this.subject = subject;
+        this.content = content;
+    }
+
+    public String getFrom() {
+        return from;
+    }
+
+    public void setFrom(String from) {
+        this.from = from;
+    }
+
+    public String getTo() {
+        return to;
+    }
+
+    public void setTo(String to) {
+        this.to = to;
+    }
+
+    public String getCc() {
+        return cc;
+    }
+
+    public void setCc(String cc) {
+        this.cc = cc;
+    }
+
+    public String getSubject() {
+        return subject;
+    }
+
+    public void setSubject(String subject) {
+        this.subject = subject;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    @Override
+    public String toString() {
+        return "MailBean{" +
+                "from='" + from + '\'' +
+                ", to='" + to + '\'' +
+                ", cc='" + cc + '\'' +
+                ", subject='" + subject + '\'' +
+                ", content='" + content + '\'' +
+                '}';
+    }
+}
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/MailService.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/MailService.java
new file mode 100644
index 0000000..cfe1c4d
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/MailService.java
@@ -0,0 +1,21 @@
+package com.hxuanyu.notify.service;
+
+
+import com.hxuanyu.notify.model.Mail;
+
+/**
+ * 邮件服务
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+public interface MailService {
+
+    /**
+     * 发送简单邮件
+     *
+     * @param mail 发件人
+     * @throws InterruptedException 异常
+     */
+    void sendMail(Mail mail) throws InterruptedException;
+}
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/NotifyService.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/NotifyService.java
new file mode 100644
index 0000000..08727bb
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/NotifyService.java
@@ -0,0 +1,20 @@
+package com.hxuanyu.notify.service;
+
+import com.hxuanyu.notify.enums.NotifyType;
+import org.springframework.stereotype.Service;
+
+/**
+ * 通知服务
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+public interface NotifyService {
+    /**
+     * 向用户发送通知
+     *
+     * @param content    通知内容
+     * @param notifyType 通知类型
+     */
+    void notify(Object content, NotifyType notifyType);
+}
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/impl/MailServiceImpl.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/impl/MailServiceImpl.java
new file mode 100644
index 0000000..0c93051
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/impl/MailServiceImpl.java
@@ -0,0 +1,135 @@
+package com.hxuanyu.notify.service.impl;
+
+
+import com.hxuanyu.notify.common.MailQueue;
+import com.hxuanyu.notify.model.Mail;
+import com.hxuanyu.notify.service.MailService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.stereotype.Service;
+import org.thymeleaf.TemplateEngine;
+import org.thymeleaf.context.Context;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
+import javax.annotation.Resource;
+import javax.mail.MessagingException;
+import javax.mail.internet.MimeMessage;
+import java.util.concurrent.ExecutorService;
+
+/**
+ * @author 22521
+ */
+@Service
+public class MailServiceImpl implements MailService {
+    private static final Logger logger = LoggerFactory.getLogger(MailServiceImpl.class);
+    private static boolean isRunning = true;
+    ExecutorService executor;
+
+    private static JavaMailSender javaMailSender;
+    private static TemplateEngine templateEngine;
+
+
+    private static String defaultFrom;
+
+
+
+
+    @PostConstruct
+    public void startThread() {
+        executor.submit(new PollMail());
+    }
+
+    static class PollMail implements Runnable {
+        @Override
+        public void run() {
+            while (isRunning) {
+                try {
+                    logger.info("剩余邮件总数:{}", MailQueue.getMailQueue().size());
+                    Mail mail = MailQueue.getMailQueue().consume();
+                    if (mail != null) {
+                        //可以设置延时 以及重复校验等等操作
+                        sendMailSync(mail);
+                        Thread.sleep(10000);
+                    }
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+
+
+    @Override
+    public void sendMail(Mail mail) throws InterruptedException {
+        MailQueue.getMailQueue().produce(mail);
+    }
+
+
+    private static void sendMailSync(Mail mail) {
+        String from = mail.getFrom();
+        if (from == null) {
+            from = defaultFrom;
+            logger.info("未传入发件人，从配置中读取：{}", from);
+        }
+        MimeMessage mimeMessage;
+
+        try {
+            mimeMessage = javaMailSender.createMimeMessage();
+            // true 表示多部分，可添加内联资源
+            MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage, true);
+            // 设置邮件信息
+            mimeMessageHelper.setFrom(from);
+            mimeMessageHelper.setTo(mail.getTo());
+            mimeMessageHelper.setSubject(mail.getSubject());
+            // 利用 Thymeleaf 引擎渲染 HTML
+            Context context = new Context();
+            // 设置注入的变量
+            context.setVariable("templates/mail", mail);
+            // 模板设置为 "mail"
+            String content = templateEngine.process("templates/mail/mail", context);
+            // 设置邮件内容
+            // true 表示开启 html
+            mimeMessageHelper.setText(content, true);
+            javaMailSender.send(mimeMessage);
+        } catch (MessagingException e) {
+            logger.error("发送邮件出错：" + e.getMessage() + e.getCause());
+        }
+    }
+
+    public static void setIsRunning(boolean isRunning) {
+        MailServiceImpl.isRunning = isRunning;
+    }
+
+    @PreDestroy
+    public void stopThread() {
+        logger.info("destroy");
+    }
+
+
+    @Resource
+    public void setJavaMailSender(JavaMailSender javaMailSender) {
+        MailServiceImpl.javaMailSender = javaMailSender;
+    }
+
+    @Autowired
+    public void setExecutor(@Qualifier("mailExecutorService") ExecutorService executor) {
+        this.executor = executor;
+    }
+
+
+    @Autowired
+    public void setTemplateEngine(TemplateEngine templateEngine) {
+        MailServiceImpl.templateEngine = templateEngine;
+    }
+
+    @Value("${spring.mail.username}")
+    public void setDefaultFrom(String defaultFrom) {
+        MailServiceImpl.defaultFrom = defaultFrom;
+    }
+}
\ No newline at end of file
diff --git a/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/impl/NotifyServiceImpl.java b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/impl/NotifyServiceImpl.java
new file mode 100644
index 0000000..f2f952b
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/java/com/hxuanyu/notify/service/impl/NotifyServiceImpl.java
@@ -0,0 +1,53 @@
+package com.hxuanyu.notify.service.impl;
+
+import com.hxuanyu.notify.enums.NotifyType;
+import com.hxuanyu.notify.model.Mail;
+import com.hxuanyu.notify.service.MailService;
+import com.hxuanyu.notify.service.NotifyService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+/**
+ * 通知服务
+ *
+ * @author hanxuanyu
+ * @version 1.0
+ */
+@Service
+public class NotifyServiceImpl implements NotifyService {
+    private final Logger logger = LoggerFactory.getLogger(NotifyServiceImpl.class);
+
+    @Resource
+    MailService mailService;
+
+    @Override
+    public void notify(Object content, NotifyType notifyType) {
+        if (NotifyType.MAIL_TYPE.equals(notifyType)) {
+            sendMail(content);
+        } else if (NotifyType.SMS_TYPE.equals(notifyType)) {
+            sendSms(content);
+        } else {
+            logger.info("未匹配到通知类型：[{}]", content);
+        }
+    }
+
+    private void sendSms(Object content) {
+        logger.info("即将发送短信通知，通知内容：{}", content);
+    }
+
+    private void sendMail(Object content) {
+        logger.info("即将发送邮件通知，通知内容：{}", content);
+        if (content instanceof Mail) {
+            try {
+                mailService.sendMail((Mail) content);
+            } catch (InterruptedException e) {
+                logger.warn("邮件发送失败：{}", e.getLocalizedMessage());
+            }
+        } else {
+            logger.warn("通知内容格式不符");
+        }
+    }
+}
diff --git a/notify-spring-boot-starter/src/main/resources/META-INF/spring.factories b/notify-spring-boot-starter/src/main/resources/META-INF/spring.factories
new file mode 100644
index 0000000..094055e
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/resources/META-INF/spring.factories
@@ -0,0 +1 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=com.hxuanyu.notify.config.NotifyConfiguration
\ No newline at end of file
diff --git a/notify-spring-boot-starter/src/main/resources/config/application.yml b/notify-spring-boot-starter/src/main/resources/config/application.yml
new file mode 100644
index 0000000..39e166d
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/resources/config/application.yml
@@ -0,0 +1,14 @@
+spring:
+  mail:
+    host: smtp.domain
+    protocol: smtp
+    default-encoding: UTF-8
+    password: your_password
+    username: your_username
+    port: 587
+    properties:
+      mail:
+        debug: false
+      stmp:
+        socketFactory:
+          class: javax.net.ssl.SSLSocketFactory
\ No newline at end of file
diff --git a/notify-spring-boot-starter/src/main/resources/templates/mail/mail.html b/notify-spring-boot-starter/src/main/resources/templates/mail/mail.html
new file mode 100644
index 0000000..0cb7677
--- /dev/null
+++ b/notify-spring-boot-starter/src/main/resources/templates/mail/mail.html
@@ -0,0 +1,129 @@
+<!DOCTYPE html>
+<html lang="zh" xmlns:th="http://www.thymeleaf.org">
+<!--${government}-->
+<!--${title}-->
+<!--${suggestion}-->
+<!--${deadline}-->
+<!--${secret}-->
+<!--${url}-->
+<!--${officeName}-->
+<!--${createTime}-->
+<head>
+    <meta charset="utf-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0, shrink-to-fit=no">
+    <title>${title}</title>
+    <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/twitter-bootstrap/4.3.1/css/bootstrap.min.css">
+    <style>
+        .contact-clean {
+            background: #f1f7fc;
+            padding: 80px 0;
+        }
+
+        a {
+            text-decoration: none;
+        }
+
+        @media (max-width: 767px) {
+            .contact-clean {
+                padding: 20px 0;
+            }
+        }
+
+        .contact-clean form {
+            max-width: 480px;
+            width: 90%;
+            margin: 0 auto;
+            background-color: #ffffff;
+            padding: 40px;
+            border-radius: 4px;
+            color: #505e6c;
+            box-shadow: 1px 1px 5px rgba(0, 0, 0, 0.1);
+        }
+
+        @media (max-width: 767px) {
+            .contact-clean form {
+                padding: 30px;
+            }
+        }
+
+        .contact-clean h2 {
+            margin-top: 5px;
+            font-weight: bold;
+            font-size: 28px;
+            margin-bottom: 36px;
+            color: inherit;
+        }
+
+        .contact-clean .form-group:last-child {
+            margin-bottom: 5px;
+        }
+
+        .contact-clean form .form-control {
+            background: #fff;
+            border-radius: 2px;
+            box-shadow: 1px 1px 1px rgba(0, 0, 0, 0.05);
+            outline: none;
+            color: inherit;
+            padding-left: 12px;
+            height: 42px;
+        }
+
+        .contact-clean form .form-control:focus {
+            border: 1px solid #b2b2b2;
+        }
+
+        .contact-clean form textarea.form-control {
+            min-height: 100px;
+            max-height: 260px;
+            padding-top: 10px;
+            resize: vertical;
+        }
+
+        .contact-clean form .btn {
+            padding: 16px 32px;
+            border: none;
+            background: none;
+            box-shadow: none;
+            text-shadow: none;
+            opacity: 0.9;
+            text-transform: uppercase;
+            font-weight: bold;
+            font-size: 13px;
+            letter-spacing: 0.4px;
+            line-height: 1;
+            outline: none !important;
+        }
+
+        .contact-clean form .btn:hover {
+            opacity: 1;
+        }
+
+        .contact-clean form .btn:active {
+            transform: translateY(1px);
+        }
+
+        .contact-clean form .btn-primary {
+            background-color: #055ada !important;
+            margin-top: 15px;
+            color: #fff;
+        }
+    </style>
+</head>
+
+<body>
+<div class="contact-clean">
+    <form method="post">
+        <h2 class="text-center" th:text="${mail.getSubject()}"></h2>
+        <p th:utext="${mail.getContent()}"></p>
+        <div class="alert alert-danger" role="alert">
+            <span>
+                <strong>注意</strong>本邮件由系统自动发送，请勿回复本邮件，如果邮件内容您并不知情，请忽略本邮件
+            </span>
+        </div>
+    </form>
+</div>
+<script src="https://cdnjs.cloudflare.com/ajax/libs/jquery/3.4.1/jquery.min.js"></script>
+<script src="https://cdnjs.cloudflare.com/ajax/libs/twitter-bootstrap/4.3.1/js/bootstrap.bundle.min.js"></script>
+</body>
+
+</html>
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..5aff635
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,176 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.hxuanyu</groupId>
+    <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
+    <version>0.1.0</version>
+    <name>hxuanyu-spring-boot-starter-parent</name>
+    <description>MonitorPushingParent</description>
+    <packaging>pom</packaging>
+    <licenses>
+        <license>
+            <name>The Apache Software License, Version 2.0</name>
+            <url>https://www.apache.org/licenses/LICENSE-2.0.txt</url>
+        </license>
+    </licenses>
+    <url>https://github.com/hanxuanyu/hxuanyu-springboot-starter/</url>
+    <scm>
+        <connection>scm:git:git@github.com:hanxuanyu/hxuanyu-springboot-starter.git</connection>
+        <developerConnection>scm:git:git@github.com:hanxuanyu/hxuanyu-springboot-starter.git</developerConnection>
+        <url>git@github.com:hanxuanyu/hxuanyu-springboot-starter.git</url>
+    </scm>
+    <developers>
+        <developer>
+            <name>hxuanyu</name>
+            <email>2252193204@qq.com</email>
+            <timezone>+8</timezone>
+        </developer>
+    </developers>
+    <modules>
+        <!--        <module>MonitorCore</module>-->
+        <module>common-spring-boot-starter</module>
+        <module>network-spring-boot-starter</module>
+        <module>notify-spring-boot-starter</module>
+        <module>monitor-spring-boot-starter</module>
+    </modules>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.5.8</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+
+        <!--日志相关-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-logging</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <java.version>1.8</java.version>
+        <gpg.keyname>3A8B7559</gpg.keyname>
+    </properties>
+
+    <dependencyManagement>
+        <dependencies>
+            <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
+            <dependency>
+                <groupId>com.google.guava</groupId>
+                <artifactId>guava</artifactId>
+                <version>31.0.1-jre</version>
+            </dependency>
+            <!--项目包-->
+            <dependency>
+                <groupId>com.hxuanyu</groupId>
+                <artifactId>common-spring-boot-starter</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.hxuanyu</groupId>
+                <artifactId>network-spring-boot-starter</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.hxuanyu</groupId>
+                <artifactId>notify-spring-boot-starter</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.hxuanyu</groupId>
+                <artifactId>monitor-spring-boot-starter</artifactId>
+                <version>${project.version}</version>
+            </dependency>
+        </dependencies>
+
+    </dependencyManagement>
+
+    <profiles>
+        <profile>
+            <id>release</id>
+            <build>
+                <plugins>
+                    <!-- Source -->
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-source-plugin</artifactId>
+                        <version>2.2.1</version>
+                        <executions>
+                            <execution>
+                                <phase>package</phase>
+                                <goals>
+                                    <goal>jar-no-fork</goal>
+                                </goals>
+                            </execution>
+                        </executions>
+                    </plugin>
+                    <!-- Javadoc -->
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-javadoc-plugin</artifactId>
+                        <version>2.9.1</version>
+                        <executions>
+                            <execution>
+                                <phase>package</phase>
+                                <goals>
+                                    <goal>jar</goal>
+                                </goals>
+                            </execution>
+                        </executions>
+                    </plugin>
+                    <!-- GPG -->
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-gpg-plugin</artifactId>
+                        <version>1.5</version>
+                        <executions>
+                            <execution>
+                                <phase>verify</phase>
+                                <goals>
+                                    <goal>sign</goal>
+                                </goals>
+                                <configuration>
+                                    <keyname>${gpg.keyname}</keyname>
+                                </configuration>
+                            </execution>
+                        </executions>
+                    </plugin>
+                </plugins>
+            </build>
+            <distributionManagement>
+                <snapshotRepository>
+                    <id>ossrh</id>
+                    <url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
+                </snapshotRepository>
+                <repository>
+                    <id>ossrh</id>
+                    <url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
+                </repository>
+            </distributionManagement>
+        </profile>
+    </profiles>
+
+</project>
\ No newline at end of file