Compare commits
	
		
			10 Commits
		
	
	
		
			v1.0.2
			...
			0c074c046f
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 0c074c046f | |||
| ca65b5e8fc | |||
| baccb20c3c | |||
| 8c47f75673 | |||
| 16df08bbe8 | |||
| c100c89f5a | |||
| 45ab626751 | |||
| 58d2ce559d | |||
| 6febbb049d | |||
| dab1b9fa55 | 
							
								
								
									
										54
									
								
								README.md
									
									
									
									
									
								
							
							
						
						
									
										54
									
								
								README.md
									
									
									
									
									
								
							@@ -2,9 +2,63 @@
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
本项目基于springboot进行开发,实现了一系列的spring-boot-starter,可以作为开发中的工具包进行使用。
 | 
					本项目基于springboot进行开发,实现了一系列的spring-boot-starter,可以作为开发中的工具包进行使用。
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
### 模块划分
 | 
					### 模块划分
 | 
				
			||||||
 | 
					
 | 
				
			||||||
- common-spring-boot-starter:常用的基础类,比如用作消息流转的`Msg`以及一些工具类
 | 
					- common-spring-boot-starter:常用的基础类,比如用作消息流转的`Msg`以及一些工具类
 | 
				
			||||||
- monitor-spring-boot-starter:监控工具包,可以实现定时监控某些数据并在触发条件后实时通知
 | 
					- monitor-spring-boot-starter:监控工具包,可以实现定时监控某些数据并在触发条件后实时通知
 | 
				
			||||||
- network-spring-boot-starter:网络工具,实现了一系列http请求发送方法,引入后即可快速发送http请求
 | 
					- network-spring-boot-starter:网络工具,实现了一系列http请求发送方法,引入后即可快速发送http请求
 | 
				
			||||||
- notify-spring-boot-starter:通知工具,集成了邮件通知、短信通知等功能
 | 
					- notify-spring-boot-starter:通知工具,集成了邮件通知、短信通知等功能
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					## 快速开始
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					### 1. 引入maven依赖
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					本项目已经上传到中央仓库,使用时在pom文件中添加如下依赖即可:
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					- network-spring-boot-starter
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					```xml
 | 
				
			||||||
 | 
					<!--network-spring-boot-starter-->
 | 
				
			||||||
 | 
					<dependency>
 | 
				
			||||||
 | 
					    <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					    <artifactId>network-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					    <version>1.0.1</version>
 | 
				
			||||||
 | 
					</dependency>
 | 
				
			||||||
 | 
					```
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					- notify-spring-boot-starter
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					```xml
 | 
				
			||||||
 | 
					<!--notify-spring-boot-starter-->
 | 
				
			||||||
 | 
					<dependency>
 | 
				
			||||||
 | 
					    <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					    <artifactId>notify-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					    <version>1.0.1</version>
 | 
				
			||||||
 | 
					</dependency>
 | 
				
			||||||
 | 
					```
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					- monitor-spring-boot-starter
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					```xml
 | 
				
			||||||
 | 
					<!--monitor-spring-boot-starter-->
 | 
				
			||||||
 | 
					<dependency>
 | 
				
			||||||
 | 
					    <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					    <artifactId>monitor-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					    <version>1.0.1</version>
 | 
				
			||||||
 | 
					</dependency>
 | 
				
			||||||
 | 
					```
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					- monitor-spring-boot-starter
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					```xml
 | 
				
			||||||
 | 
					<!--monitor-spring-boot-starter-->
 | 
				
			||||||
 | 
					<dependency>
 | 
				
			||||||
 | 
					    <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					    <artifactId>monitor-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					    <version>1.0.1</version>
 | 
				
			||||||
 | 
					</dependency>
 | 
				
			||||||
 | 
					```
 | 
				
			||||||
@@ -3,7 +3,7 @@
 | 
				
			|||||||
    <parent>
 | 
					    <parent>
 | 
				
			||||||
        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
					        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
				
			||||||
        <groupId>com.hxuanyu</groupId>
 | 
					        <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
        <version>1.0.2</version>
 | 
					        <version>1.0.4-SNAPSHOT</version>
 | 
				
			||||||
    </parent>
 | 
					    </parent>
 | 
				
			||||||
    <modelVersion>4.0.0</modelVersion>
 | 
					    <modelVersion>4.0.0</modelVersion>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -3,7 +3,7 @@
 | 
				
			|||||||
    <parent>
 | 
					    <parent>
 | 
				
			||||||
        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
					        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
				
			||||||
        <groupId>com.hxuanyu</groupId>
 | 
					        <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
        <version>1.0.2</version>
 | 
					        <version>1.0.4-SNAPSHOT</version>
 | 
				
			||||||
    </parent>
 | 
					    </parent>
 | 
				
			||||||
    <modelVersion>4.0.0</modelVersion>
 | 
					    <modelVersion>4.0.0</modelVersion>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -91,7 +91,7 @@ public class MonitorItemBeanManager implements ApplicationListener<ContextRefres
 | 
				
			|||||||
            CheckResult checkResult = item.check();
 | 
					            CheckResult checkResult = item.check();
 | 
				
			||||||
            if (checkResult.isTriggered()) {
 | 
					            if (checkResult.isTriggered()) {
 | 
				
			||||||
                logger.info("定时任务[{}]触发成功,发送通知:[{}]", taskId, checkResult.getNotifyContent());
 | 
					                logger.info("定时任务[{}]触发成功,发送通知:[{}]", taskId, checkResult.getNotifyContent());
 | 
				
			||||||
                notifyService.notify(checkResult.getNotifyContent(), NotifyType.MAIL_TYPE);
 | 
					                notifyService.notify(checkResult.getNotifyContent(), NotifyType.TYPE_MAIL);
 | 
				
			||||||
            }
 | 
					            }
 | 
				
			||||||
        }, new CronTrigger(cron)));
 | 
					        }, new CronTrigger(cron)));
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -3,7 +3,7 @@
 | 
				
			|||||||
    <parent>
 | 
					    <parent>
 | 
				
			||||||
        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
					        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
				
			||||||
        <groupId>com.hxuanyu</groupId>
 | 
					        <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
        <version>1.0.2</version>
 | 
					        <version>1.0.4-SNAPSHOT</version>
 | 
				
			||||||
    </parent>
 | 
					    </parent>
 | 
				
			||||||
    <modelVersion>4.0.0</modelVersion>
 | 
					    <modelVersion>4.0.0</modelVersion>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -277,18 +277,16 @@ public interface HttpService {
 | 
				
			|||||||
     *
 | 
					     *
 | 
				
			||||||
     * @param url 请求地址
 | 
					     * @param url 请求地址
 | 
				
			||||||
     * @return 统一返回报文
 | 
					     * @return 统一返回报文
 | 
				
			||||||
     * @throws Exception 异常
 | 
					 | 
				
			||||||
     */
 | 
					     */
 | 
				
			||||||
    Msg<String> doDelete(String url) throws Exception;
 | 
					    Msg<String> doDelete(String url);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    /**
 | 
					    /**
 | 
				
			||||||
     * 发送delete请求;不带请求参数
 | 
					     * 发送delete请求;不带请求参数
 | 
				
			||||||
     *
 | 
					     *
 | 
				
			||||||
     * @param url 请求地址
 | 
					     * @param url 请求地址
 | 
				
			||||||
     * @return 统一返回报文
 | 
					     * @return 统一返回报文
 | 
				
			||||||
     * @throws Exception 异常
 | 
					 | 
				
			||||||
     */
 | 
					     */
 | 
				
			||||||
    Msg<HttpEntity> doDeleteWithEntity(String url) throws Exception;
 | 
					    Msg<HttpEntity> doDeleteWithEntity(String url);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    /**
 | 
					    /**
 | 
				
			||||||
     * 发送delete请求;带请求参数
 | 
					     * 发送delete请求;带请求参数
 | 
				
			||||||
@@ -296,9 +294,8 @@ public interface HttpService {
 | 
				
			|||||||
     * @param url    请求地址
 | 
					     * @param url    请求地址
 | 
				
			||||||
     * @param params 请求参数
 | 
					     * @param params 请求参数
 | 
				
			||||||
     * @return 统一返回报文
 | 
					     * @return 统一返回报文
 | 
				
			||||||
     * @throws Exception 异常
 | 
					 | 
				
			||||||
     */
 | 
					     */
 | 
				
			||||||
    Msg<String> doDelete(String url, Map<String, String> params) throws Exception;
 | 
					    Msg<String> doDelete(String url, Map<String, String> params);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    /**
 | 
					    /**
 | 
				
			||||||
@@ -307,9 +304,8 @@ public interface HttpService {
 | 
				
			|||||||
     * @param url    请求地址
 | 
					     * @param url    请求地址
 | 
				
			||||||
     * @param params 请求参数
 | 
					     * @param params 请求参数
 | 
				
			||||||
     * @return 统一返回报文
 | 
					     * @return 统一返回报文
 | 
				
			||||||
     * @throws Exception 异常
 | 
					 | 
				
			||||||
     */
 | 
					     */
 | 
				
			||||||
    Msg<HttpEntity> doDeleteWithEntity(String url, Map<String, String> params) throws Exception;
 | 
					    Msg<HttpEntity> doDeleteWithEntity(String url, Map<String, String> params);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    interface NetWorkListener<T> {
 | 
					    interface NetWorkListener<T> {
 | 
				
			||||||
        /**
 | 
					        /**
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -3,7 +3,7 @@
 | 
				
			|||||||
    <parent>
 | 
					    <parent>
 | 
				
			||||||
        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
					        <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
				
			||||||
        <groupId>com.hxuanyu</groupId>
 | 
					        <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
        <version>1.0.2</version>
 | 
					        <version>1.0.4-SNAPSHOT</version>
 | 
				
			||||||
    </parent>
 | 
					    </parent>
 | 
				
			||||||
    <modelVersion>4.0.0</modelVersion>
 | 
					    <modelVersion>4.0.0</modelVersion>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -0,0 +1,108 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.notify.config;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import java.nio.charset.Charset;
 | 
				
			||||||
 | 
					import java.nio.charset.StandardCharsets;
 | 
				
			||||||
 | 
					import java.util.HashMap;
 | 
				
			||||||
 | 
					import java.util.Map;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 | 
				
			||||||
 | 
					import org.springframework.boot.context.properties.ConfigurationProperties;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					/**
 | 
				
			||||||
 | 
					 * @author hxuanyu
 | 
				
			||||||
 | 
					 */
 | 
				
			||||||
 | 
					@ConfigurationProperties(prefix = "notify.mail")
 | 
				
			||||||
 | 
					@ConditionalOnProperty(prefix = "notify.mail", havingValue = "true")
 | 
				
			||||||
 | 
					public class MailProperties {
 | 
				
			||||||
 | 
					    private static final Charset DEFAULT_CHARSET;
 | 
				
			||||||
 | 
					    private String host;
 | 
				
			||||||
 | 
					    private Integer port;
 | 
				
			||||||
 | 
					    private String username;
 | 
				
			||||||
 | 
					    private String password;
 | 
				
			||||||
 | 
					    private String protocol = "smtp";
 | 
				
			||||||
 | 
					    private Charset defaultEncoding;
 | 
				
			||||||
 | 
					    private Map<String, String> properties;
 | 
				
			||||||
 | 
					    private String jndiName;
 | 
				
			||||||
 | 
					    private Integer interval = 10000;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public MailProperties() {
 | 
				
			||||||
 | 
					        this.defaultEncoding = DEFAULT_CHARSET;
 | 
				
			||||||
 | 
					        this.properties = new HashMap();
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setProperties(Map<String, String> properties) {
 | 
				
			||||||
 | 
					        this.properties = properties;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public Integer getInterval() {
 | 
				
			||||||
 | 
					        return interval;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setInterval(Integer interval) {
 | 
				
			||||||
 | 
					        this.interval = interval;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public String getHost() {
 | 
				
			||||||
 | 
					        return this.host;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setHost(String host) {
 | 
				
			||||||
 | 
					        this.host = host;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public Integer getPort() {
 | 
				
			||||||
 | 
					        return this.port;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setPort(Integer port) {
 | 
				
			||||||
 | 
					        this.port = port;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public String getUsername() {
 | 
				
			||||||
 | 
					        return this.username;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setUsername(String username) {
 | 
				
			||||||
 | 
					        this.username = username;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public String getPassword() {
 | 
				
			||||||
 | 
					        return this.password;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setPassword(String password) {
 | 
				
			||||||
 | 
					        this.password = password;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public String getProtocol() {
 | 
				
			||||||
 | 
					        return this.protocol;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setProtocol(String protocol) {
 | 
				
			||||||
 | 
					        this.protocol = protocol;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public Charset getDefaultEncoding() {
 | 
				
			||||||
 | 
					        return this.defaultEncoding;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setDefaultEncoding(Charset defaultEncoding) {
 | 
				
			||||||
 | 
					        this.defaultEncoding = defaultEncoding;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public Map<String, String> getProperties() {
 | 
				
			||||||
 | 
					        return this.properties;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public void setJndiName(String jndiName) {
 | 
				
			||||||
 | 
					        this.jndiName = jndiName;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    public String getJndiName() {
 | 
				
			||||||
 | 
					        return this.jndiName;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    static {
 | 
				
			||||||
 | 
					        DEFAULT_CHARSET = StandardCharsets.UTF_8;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -1,18 +1,57 @@
 | 
				
			|||||||
package com.hxuanyu.notify.config;
 | 
					package com.hxuanyu.notify.config;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import com.google.common.util.concurrent.ThreadFactoryBuilder;
 | 
					import com.google.common.util.concurrent.ThreadFactoryBuilder;
 | 
				
			||||||
import org.springframework.context.annotation.Bean;
 | 
					import org.springframework.beans.factory.annotation.Autowired;
 | 
				
			||||||
import org.springframework.context.annotation.ComponentScan;
 | 
					import org.springframework.boot.context.properties.EnableConfigurationProperties;
 | 
				
			||||||
import org.springframework.context.annotation.Configuration;
 | 
					import org.springframework.context.annotation.*;
 | 
				
			||||||
 | 
					import org.springframework.mail.javamail.JavaMailSenderImpl;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import java.util.Map;
 | 
				
			||||||
 | 
					import java.util.Properties;
 | 
				
			||||||
import java.util.concurrent.*;
 | 
					import java.util.concurrent.*;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
/**
 | 
					/**
 | 
				
			||||||
 * @author hxuanyu
 | 
					 * @author hxuanyu
 | 
				
			||||||
 */
 | 
					 */
 | 
				
			||||||
@Configuration
 | 
					@Configuration
 | 
				
			||||||
@ComponentScan("com.hxuanyu.notify.service")
 | 
					@ComponentScan("com.hxuanyu.notify")
 | 
				
			||||||
 | 
					@EnableConfigurationProperties(MailProperties.class)
 | 
				
			||||||
public class NotifyConfiguration {
 | 
					public class NotifyConfiguration {
 | 
				
			||||||
 | 
					    @Autowired
 | 
				
			||||||
 | 
					    MailProperties mailProperties;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Bean
 | 
				
			||||||
 | 
					    JavaMailSenderImpl mailSender(MailProperties properties) {
 | 
				
			||||||
 | 
					        JavaMailSenderImpl sender = new JavaMailSenderImpl();
 | 
				
			||||||
 | 
					        this.applyProperties(properties, sender);
 | 
				
			||||||
 | 
					        return sender;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private void applyProperties(MailProperties properties, JavaMailSenderImpl sender) {
 | 
				
			||||||
 | 
					        sender.setHost(properties.getHost());
 | 
				
			||||||
 | 
					        if (properties.getPort() != null) {
 | 
				
			||||||
 | 
					            sender.setPort(properties.getPort());
 | 
				
			||||||
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        sender.setUsername(properties.getUsername());
 | 
				
			||||||
 | 
					        sender.setPassword(properties.getPassword());
 | 
				
			||||||
 | 
					        sender.setProtocol(properties.getProtocol());
 | 
				
			||||||
 | 
					        if (properties.getDefaultEncoding() != null) {
 | 
				
			||||||
 | 
					            sender.setDefaultEncoding(properties.getDefaultEncoding().name());
 | 
				
			||||||
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        if (!properties.getProperties().isEmpty()) {
 | 
				
			||||||
 | 
					            sender.setJavaMailProperties(this.asProperties(properties.getProperties()));
 | 
				
			||||||
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private Properties asProperties(Map<String, String> source) {
 | 
				
			||||||
 | 
					        Properties properties = new Properties();
 | 
				
			||||||
 | 
					        properties.putAll(source);
 | 
				
			||||||
 | 
					        return properties;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    @Bean(name = "mailExecutorService")
 | 
					    @Bean(name = "mailExecutorService")
 | 
				
			||||||
    public ExecutorService mailExecutorService() {
 | 
					    public ExecutorService mailExecutorService() {
 | 
				
			||||||
        // 使用 ThreadFactoryBuilder 创建自定义线程名称的 ThreadFactory
 | 
					        // 使用 ThreadFactoryBuilder 创建自定义线程名称的 ThreadFactory
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -12,8 +12,9 @@ public enum NotifyType {
 | 
				
			|||||||
    /**
 | 
					    /**
 | 
				
			||||||
     * 邮件类型
 | 
					     * 邮件类型
 | 
				
			||||||
     */
 | 
					     */
 | 
				
			||||||
    MAIL_TYPE("邮件"),
 | 
					    TYPE_LOG("日志输出"),
 | 
				
			||||||
    SMS_TYPE("短信");
 | 
					    TYPE_MAIL("邮件"),
 | 
				
			||||||
 | 
					    TYPE_MSG("短信");
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    private final String typeName;
 | 
					    private final String typeName;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -2,18 +2,19 @@ package com.hxuanyu.notify.service.impl;
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import com.hxuanyu.notify.common.MailQueue;
 | 
					import com.hxuanyu.notify.common.MailQueue;
 | 
				
			||||||
 | 
					import com.hxuanyu.notify.config.MailProperties;
 | 
				
			||||||
import com.hxuanyu.notify.model.Mail;
 | 
					import com.hxuanyu.notify.model.Mail;
 | 
				
			||||||
import com.hxuanyu.notify.service.MailService;
 | 
					import com.hxuanyu.notify.service.MailService;
 | 
				
			||||||
import org.slf4j.Logger;
 | 
					import org.slf4j.Logger;
 | 
				
			||||||
import org.slf4j.LoggerFactory;
 | 
					import org.slf4j.LoggerFactory;
 | 
				
			||||||
import org.springframework.beans.factory.annotation.Autowired;
 | 
					import org.springframework.beans.factory.annotation.Autowired;
 | 
				
			||||||
import org.springframework.beans.factory.annotation.Qualifier;
 | 
					import org.springframework.beans.factory.annotation.Qualifier;
 | 
				
			||||||
import org.springframework.beans.factory.annotation.Value;
 | 
					import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 | 
				
			||||||
 | 
					import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 | 
				
			||||||
import org.springframework.mail.javamail.JavaMailSender;
 | 
					import org.springframework.mail.javamail.JavaMailSender;
 | 
				
			||||||
 | 
					import org.springframework.mail.javamail.JavaMailSenderImpl;
 | 
				
			||||||
import org.springframework.mail.javamail.MimeMessageHelper;
 | 
					import org.springframework.mail.javamail.MimeMessageHelper;
 | 
				
			||||||
import org.springframework.stereotype.Service;
 | 
					import org.springframework.stereotype.Service;
 | 
				
			||||||
import org.thymeleaf.TemplateEngine;
 | 
					 | 
				
			||||||
import org.thymeleaf.context.Context;
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
import javax.annotation.PostConstruct;
 | 
					import javax.annotation.PostConstruct;
 | 
				
			||||||
import javax.annotation.PreDestroy;
 | 
					import javax.annotation.PreDestroy;
 | 
				
			||||||
@@ -27,15 +28,14 @@ import java.util.concurrent.ExecutorService;
 | 
				
			|||||||
 */
 | 
					 */
 | 
				
			||||||
@Service
 | 
					@Service
 | 
				
			||||||
public class MailServiceImpl implements MailService {
 | 
					public class MailServiceImpl implements MailService {
 | 
				
			||||||
 | 
					    @Resource
 | 
				
			||||||
 | 
					    MailProperties mailProperties;
 | 
				
			||||||
    private static final Logger logger = LoggerFactory.getLogger(MailServiceImpl.class);
 | 
					    private static final Logger logger = LoggerFactory.getLogger(MailServiceImpl.class);
 | 
				
			||||||
    private static boolean isRunning = true;
 | 
					    private static boolean isRunning = true;
 | 
				
			||||||
    ExecutorService executor;
 | 
					    ExecutorService executor;
 | 
				
			||||||
 | 
					    @Resource
 | 
				
			||||||
 | 
					    private JavaMailSender javaMailSender;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    private static JavaMailSender javaMailSender;
 | 
					 | 
				
			||||||
    private static TemplateEngine templateEngine;
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
    private static String defaultFrom;
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@@ -45,7 +45,7 @@ public class MailServiceImpl implements MailService {
 | 
				
			|||||||
        executor.submit(new PollMail());
 | 
					        executor.submit(new PollMail());
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    static class PollMail implements Runnable {
 | 
					    class PollMail implements Runnable {
 | 
				
			||||||
        @Override
 | 
					        @Override
 | 
				
			||||||
        public void run() {
 | 
					        public void run() {
 | 
				
			||||||
            while (isRunning) {
 | 
					            while (isRunning) {
 | 
				
			||||||
@@ -55,7 +55,7 @@ public class MailServiceImpl implements MailService {
 | 
				
			|||||||
                    if (mail != null) {
 | 
					                    if (mail != null) {
 | 
				
			||||||
                        //可以设置延时 以及重复校验等等操作
 | 
					                        //可以设置延时 以及重复校验等等操作
 | 
				
			||||||
                        sendMailSync(mail);
 | 
					                        sendMailSync(mail);
 | 
				
			||||||
                        Thread.sleep(10000);
 | 
					                        Thread.sleep(mailProperties.getInterval());
 | 
				
			||||||
                    }
 | 
					                    }
 | 
				
			||||||
                } catch (Exception e) {
 | 
					                } catch (Exception e) {
 | 
				
			||||||
                    e.printStackTrace();
 | 
					                    e.printStackTrace();
 | 
				
			||||||
@@ -71,10 +71,14 @@ public class MailServiceImpl implements MailService {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    private static void sendMailSync(Mail mail) {
 | 
					    private void sendMailSync(Mail mail) {
 | 
				
			||||||
 | 
					        if (mailProperties == null){
 | 
				
			||||||
 | 
					            logger.error("未配置邮件信息,请在配置文件中添加配置信息后再发送邮件");
 | 
				
			||||||
 | 
					            return;
 | 
				
			||||||
 | 
					        }
 | 
				
			||||||
        String from = mail.getFrom();
 | 
					        String from = mail.getFrom();
 | 
				
			||||||
        if (from == null) {
 | 
					        if (from == null) {
 | 
				
			||||||
            from = defaultFrom;
 | 
					            from = mailProperties.getUsername();
 | 
				
			||||||
            logger.info("未传入发件人,从配置中读取:{}", from);
 | 
					            logger.info("未传入发件人,从配置中读取:{}", from);
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
        MimeMessage mimeMessage;
 | 
					        MimeMessage mimeMessage;
 | 
				
			||||||
@@ -87,12 +91,7 @@ public class MailServiceImpl implements MailService {
 | 
				
			|||||||
            mimeMessageHelper.setFrom(from);
 | 
					            mimeMessageHelper.setFrom(from);
 | 
				
			||||||
            mimeMessageHelper.setTo(mail.getTo());
 | 
					            mimeMessageHelper.setTo(mail.getTo());
 | 
				
			||||||
            mimeMessageHelper.setSubject(mail.getSubject());
 | 
					            mimeMessageHelper.setSubject(mail.getSubject());
 | 
				
			||||||
            // 利用 Thymeleaf 引擎渲染 HTML
 | 
					            String content = mail.getContent();
 | 
				
			||||||
            Context context = new Context();
 | 
					 | 
				
			||||||
            // 设置注入的变量
 | 
					 | 
				
			||||||
            context.setVariable("templates/mail", mail);
 | 
					 | 
				
			||||||
            // 模板设置为 "mail"
 | 
					 | 
				
			||||||
            String content = templateEngine.process("templates/mail/mail", context);
 | 
					 | 
				
			||||||
            // 设置邮件内容
 | 
					            // 设置邮件内容
 | 
				
			||||||
            // true 表示开启 html
 | 
					            // true 表示开启 html
 | 
				
			||||||
            mimeMessageHelper.setText(content, true);
 | 
					            mimeMessageHelper.setText(content, true);
 | 
				
			||||||
@@ -112,24 +111,9 @@ public class MailServiceImpl implements MailService {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    @Resource
 | 
					 | 
				
			||||||
    public void setJavaMailSender(JavaMailSender javaMailSender) {
 | 
					 | 
				
			||||||
        MailServiceImpl.javaMailSender = javaMailSender;
 | 
					 | 
				
			||||||
    }
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
    @Autowired
 | 
					    @Autowired
 | 
				
			||||||
    public void setExecutor(@Qualifier("mailExecutorService") ExecutorService executor) {
 | 
					    public void setExecutor(@Qualifier("mailExecutorService") ExecutorService executor) {
 | 
				
			||||||
        this.executor = 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;
 | 
					 | 
				
			||||||
    }
 | 
					 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
@@ -25,10 +25,12 @@ public class NotifyServiceImpl implements NotifyService {
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
    @Override
 | 
					    @Override
 | 
				
			||||||
    public void notify(Object content, NotifyType notifyType) {
 | 
					    public void notify(Object content, NotifyType notifyType) {
 | 
				
			||||||
        if (NotifyType.MAIL_TYPE.equals(notifyType)) {
 | 
					        if (NotifyType.TYPE_MAIL.equals(notifyType)) {
 | 
				
			||||||
            sendMail(content);
 | 
					            sendMail(content);
 | 
				
			||||||
        } else if (NotifyType.SMS_TYPE.equals(notifyType)) {
 | 
					        } else if (NotifyType.TYPE_MSG.equals(notifyType)) {
 | 
				
			||||||
            sendSms(content);
 | 
					            sendSms(content);
 | 
				
			||||||
 | 
					        } else if (NotifyType.TYPE_LOG.equals(notifyType)) {
 | 
				
			||||||
 | 
					            logger.info("新通知:{}", content);
 | 
				
			||||||
        } else {
 | 
					        } else {
 | 
				
			||||||
            logger.info("未匹配到通知类型:[{}]", content);
 | 
					            logger.info("未匹配到通知类型:[{}]", content);
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -0,0 +1,48 @@
 | 
				
			|||||||
 | 
					{
 | 
				
			||||||
 | 
					  "properties": [
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.host",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.host."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.protocol",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.protocol."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.default-encoding",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.default-encoding."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.password",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.password."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.username",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.username."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.port",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.port."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.properties.mail.debug",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.properties.mail.debug."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.properties.mail.interval",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.properties.mail.debug."
 | 
				
			||||||
 | 
					    },
 | 
				
			||||||
 | 
					    {
 | 
				
			||||||
 | 
					      "name": "notify.mail.properties.stmp.socketFactory.class",
 | 
				
			||||||
 | 
					      "type": "java.lang.String",
 | 
				
			||||||
 | 
					      "description": "Description for notify.mail.properties.stmp.socketFactory.class."
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					  ] }
 | 
				
			||||||
@@ -1,129 +0,0 @@
 | 
				
			|||||||
<!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>
 | 
					 | 
				
			||||||
							
								
								
									
										7
									
								
								pom.xml
									
									
									
									
									
								
							
							
						
						
									
										7
									
								
								pom.xml
									
									
									
									
									
								
							@@ -4,7 +4,7 @@
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
    <groupId>com.hxuanyu</groupId>
 | 
					    <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
    <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
					    <artifactId>hxuanyu-spring-boot-starter-parent</artifactId>
 | 
				
			||||||
    <version>1.0.2</version>
 | 
					    <version>1.0.4-SNAPSHOT</version>
 | 
				
			||||||
    <name>hxuanyu-spring-boot-starter-parent</name>
 | 
					    <name>hxuanyu-spring-boot-starter-parent</name>
 | 
				
			||||||
    <description>MonitorPushingParent</description>
 | 
					    <description>MonitorPushingParent</description>
 | 
				
			||||||
    <packaging>pom</packaging>
 | 
					    <packaging>pom</packaging>
 | 
				
			||||||
@@ -19,7 +19,7 @@
 | 
				
			|||||||
        <connection>scm:git:https://git.hxuanyu.com/hxuanyu/hxuanyu-spring-boot-starter.git</connection>
 | 
					        <connection>scm:git:https://git.hxuanyu.com/hxuanyu/hxuanyu-spring-boot-starter.git</connection>
 | 
				
			||||||
        <developerConnection>scm:git:https://git.hxuanyu.com/hxuanyu/hxuanyu-spring-boot-starter.git</developerConnection>
 | 
					        <developerConnection>scm:git:https://git.hxuanyu.com/hxuanyu/hxuanyu-spring-boot-starter.git</developerConnection>
 | 
				
			||||||
        <url>https://git.hxuanyu.com/hxuanyu/hxuanyu-spring-boot-starter</url>
 | 
					        <url>https://git.hxuanyu.com/hxuanyu/hxuanyu-spring-boot-starter</url>
 | 
				
			||||||
        <tag>v1.0.2</tag>
 | 
					        <tag>v1.0.0</tag>
 | 
				
			||||||
    </scm>
 | 
					    </scm>
 | 
				
			||||||
    <developers>
 | 
					    <developers>
 | 
				
			||||||
        <developer>
 | 
					        <developer>
 | 
				
			||||||
@@ -34,6 +34,7 @@
 | 
				
			|||||||
        <module>network-spring-boot-starter</module>
 | 
					        <module>network-spring-boot-starter</module>
 | 
				
			||||||
        <module>notify-spring-boot-starter</module>
 | 
					        <module>notify-spring-boot-starter</module>
 | 
				
			||||||
        <module>monitor-spring-boot-starter</module>
 | 
					        <module>monitor-spring-boot-starter</module>
 | 
				
			||||||
 | 
					        <module>test</module>
 | 
				
			||||||
    </modules>
 | 
					    </modules>
 | 
				
			||||||
    <parent>
 | 
					    <parent>
 | 
				
			||||||
        <groupId>org.springframework.boot</groupId>
 | 
					        <groupId>org.springframework.boot</groupId>
 | 
				
			||||||
@@ -165,7 +166,7 @@
 | 
				
			|||||||
                            <tagNameFormat>v@{project.version}</tagNameFormat>
 | 
					                            <tagNameFormat>v@{project.version}</tagNameFormat>
 | 
				
			||||||
                            <autoVersionSubmodules>true</autoVersionSubmodules>
 | 
					                            <autoVersionSubmodules>true</autoVersionSubmodules>
 | 
				
			||||||
                            <password>${git.password}</password>
 | 
					                            <password>${git.password}</password>
 | 
				
			||||||
                            <username>hxuanyu</username>
 | 
					                            <username>${git.username}</username>
 | 
				
			||||||
                        </configuration>
 | 
					                        </configuration>
 | 
				
			||||||
                    </plugin>
 | 
					                    </plugin>
 | 
				
			||||||
                </plugins>
 | 
					                </plugins>
 | 
				
			||||||
 
 | 
				
			|||||||
							
								
								
									
										66
									
								
								test/pom.xml
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										66
									
								
								test/pom.xml
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,66 @@
 | 
				
			|||||||
 | 
					<?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.4-SNAPSHOT</version>
 | 
				
			||||||
 | 
					    </parent>
 | 
				
			||||||
 | 
					    <modelVersion>4.0.0</modelVersion>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    <artifactId>test</artifactId>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    <dependencies>
 | 
				
			||||||
 | 
					        <dependency>
 | 
				
			||||||
 | 
					            <groupId>org.springframework.boot</groupId>
 | 
				
			||||||
 | 
					            <artifactId>spring-boot-starter-web</artifactId>
 | 
				
			||||||
 | 
					        </dependency>
 | 
				
			||||||
 | 
					        <dependency>
 | 
				
			||||||
 | 
					            <groupId>org.springframework.boot</groupId>
 | 
				
			||||||
 | 
					            <artifactId>spring-boot-starter-test</artifactId>
 | 
				
			||||||
 | 
					            <scope>test</scope>
 | 
				
			||||||
 | 
					        </dependency>
 | 
				
			||||||
 | 
					        <dependency>
 | 
				
			||||||
 | 
					            <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					            <artifactId>notify-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					        </dependency>
 | 
				
			||||||
 | 
					        <dependency>
 | 
				
			||||||
 | 
					            <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					            <artifactId>common-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					        </dependency>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        <dependency>
 | 
				
			||||||
 | 
					            <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					            <artifactId>monitor-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					        </dependency>
 | 
				
			||||||
 | 
					        <dependency>
 | 
				
			||||||
 | 
					            <groupId>com.hxuanyu</groupId>
 | 
				
			||||||
 | 
					            <artifactId>network-spring-boot-starter</artifactId>
 | 
				
			||||||
 | 
					        </dependency>
 | 
				
			||||||
 | 
					        <dependency>
 | 
				
			||||||
 | 
					            <groupId>junit</groupId>
 | 
				
			||||||
 | 
					            <artifactId>junit</artifactId>
 | 
				
			||||||
 | 
					            <scope>test</scope>
 | 
				
			||||||
 | 
					        </dependency>
 | 
				
			||||||
 | 
					    </dependencies>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    <properties>
 | 
				
			||||||
 | 
					        <maven.compiler.source>8</maven.compiler.source>
 | 
				
			||||||
 | 
					        <maven.compiler.target>8</maven.compiler.target>
 | 
				
			||||||
 | 
					    </properties>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    <build>
 | 
				
			||||||
 | 
					        <plugins>
 | 
				
			||||||
 | 
					            <plugin>
 | 
				
			||||||
 | 
					                <groupId>org.apache.maven.plugins</groupId>
 | 
				
			||||||
 | 
					                <artifactId>maven-deploy-plugin</artifactId>
 | 
				
			||||||
 | 
					                <version>2.8.2</version>
 | 
				
			||||||
 | 
					                <configuration>
 | 
				
			||||||
 | 
					                    <skip>true</skip>
 | 
				
			||||||
 | 
					                </configuration>
 | 
				
			||||||
 | 
					            </plugin>
 | 
				
			||||||
 | 
					        </plugins>
 | 
				
			||||||
 | 
					    </build>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					</project>
 | 
				
			||||||
							
								
								
									
										17
									
								
								test/src/main/java/com/hxuanyu/test/MainApplication.java
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										17
									
								
								test/src/main/java/com/hxuanyu/test/MainApplication.java
									
									
									
									
									
										Normal file
									
								
							@@ -0,0 +1,17 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.test;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import org.springframework.boot.SpringApplication;
 | 
				
			||||||
 | 
					import org.springframework.boot.autoconfigure.SpringBootApplication;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					/**
 | 
				
			||||||
 | 
					 * TODO
 | 
				
			||||||
 | 
					 *
 | 
				
			||||||
 | 
					 * @author hanxuanyu
 | 
				
			||||||
 | 
					 * @version 1.0
 | 
				
			||||||
 | 
					 */
 | 
				
			||||||
 | 
					@SpringBootApplication
 | 
				
			||||||
 | 
					public class MainApplication {
 | 
				
			||||||
 | 
					    public static void main(String[] args) {
 | 
				
			||||||
 | 
					        SpringApplication.run(MainApplication.class, args);
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,72 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.test.controller;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import com.hxuanyu.common.message.Msg;
 | 
				
			||||||
 | 
					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.Controller;
 | 
				
			||||||
 | 
					import org.springframework.web.bind.annotation.*;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import javax.annotation.Resource;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					/**
 | 
				
			||||||
 | 
					 * 测试控制器
 | 
				
			||||||
 | 
					 *
 | 
				
			||||||
 | 
					 * @author hanxuanyu
 | 
				
			||||||
 | 
					 * @version 1.0
 | 
				
			||||||
 | 
					 */
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					@RestController
 | 
				
			||||||
 | 
					public class TestController {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private final Logger logger = LoggerFactory.getLogger(TestController.class);
 | 
				
			||||||
 | 
					    @Resource
 | 
				
			||||||
 | 
					    MailService mailService;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @RequestMapping("/testMail")
 | 
				
			||||||
 | 
					    public Msg<Mail> testMail() {
 | 
				
			||||||
 | 
					        Mail mail = new Mail();
 | 
				
			||||||
 | 
					        mail.setContent("邮件内容");
 | 
				
			||||||
 | 
					        mail.setSubject("邮件主题");
 | 
				
			||||||
 | 
					        mail.setTo("2252193204@qq.com");
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        try {
 | 
				
			||||||
 | 
					            mailService.sendMail(mail);
 | 
				
			||||||
 | 
					        } catch (InterruptedException e) {
 | 
				
			||||||
 | 
					            e.printStackTrace();
 | 
				
			||||||
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        return Msg.success("发送邮件成功", mail);
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @ResponseBody
 | 
				
			||||||
 | 
					    @GetMapping("/")
 | 
				
			||||||
 | 
					    public Msg<String> testGet() {
 | 
				
			||||||
 | 
					        logger.info("收到GET请求");
 | 
				
			||||||
 | 
					        return Msg.success("GET 测试");
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @ResponseBody
 | 
				
			||||||
 | 
					    @PostMapping("/")
 | 
				
			||||||
 | 
					    public Msg<String> testPost() {
 | 
				
			||||||
 | 
					        logger.info("收到POST请求");
 | 
				
			||||||
 | 
					        return Msg.success("POST 测试");
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @ResponseBody
 | 
				
			||||||
 | 
					    @PutMapping("/")
 | 
				
			||||||
 | 
					    public Msg<String> testPut() {
 | 
				
			||||||
 | 
					        logger.info("收到PUT请求");
 | 
				
			||||||
 | 
					        return Msg.success("PUT 测试");
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @ResponseBody
 | 
				
			||||||
 | 
					    @DeleteMapping("/")
 | 
				
			||||||
 | 
					    public Msg<String> testDelete() {
 | 
				
			||||||
 | 
					        logger.info("收到DELETE请求");
 | 
				
			||||||
 | 
					        return Msg.success("DELETE 测试");
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,20 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.test.monitor;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import com.hxuanyu.monitor.annotation.MonitorItem;
 | 
				
			||||||
 | 
					import com.hxuanyu.monitor.base.BaseMonitorItem;
 | 
				
			||||||
 | 
					import com.hxuanyu.monitor.common.CheckResult;
 | 
				
			||||||
 | 
					import com.hxuanyu.notify.enums.NotifyType;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					/**
 | 
				
			||||||
 | 
					 * 定时任务监控测试
 | 
				
			||||||
 | 
					 *
 | 
				
			||||||
 | 
					 * @author hxuanyu
 | 
				
			||||||
 | 
					 */
 | 
				
			||||||
 | 
					@MonitorItem(cron = "0/5 * * * * *")
 | 
				
			||||||
 | 
					public class TestMonitorItem extends BaseMonitorItem {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Override
 | 
				
			||||||
 | 
					    public CheckResult check() {
 | 
				
			||||||
 | 
					        return CheckResult.triggered("Hello", NotifyType.TYPE_LOG);
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -1,10 +1,10 @@
 | 
				
			|||||||
spring:
 | 
					notify:
 | 
				
			||||||
  mail:
 | 
					  mail:
 | 
				
			||||||
    host: smtp.domain
 | 
					    host: smtp.qq.com
 | 
				
			||||||
    protocol: smtp
 | 
					    protocol: smtp
 | 
				
			||||||
    default-encoding: UTF-8
 | 
					    default-encoding: UTF-8
 | 
				
			||||||
    password: your_password
 | 
					    password: your pwd
 | 
				
			||||||
    username: your_username
 | 
					    username: your account
 | 
				
			||||||
    port: 587
 | 
					    port: 587
 | 
				
			||||||
    properties:
 | 
					    properties:
 | 
				
			||||||
      mail:
 | 
					      mail:
 | 
				
			||||||
@@ -12,3 +12,4 @@ spring:
 | 
				
			|||||||
      stmp:
 | 
					      stmp:
 | 
				
			||||||
        socketFactory:
 | 
					        socketFactory:
 | 
				
			||||||
          class: javax.net.ssl.SSLSocketFactory
 | 
					          class: javax.net.ssl.SSLSocketFactory
 | 
				
			||||||
 | 
					    interval: 5000
 | 
				
			||||||
@@ -0,0 +1,22 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.starter.test.common;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import com.hxuanyu.common.message.Msg;
 | 
				
			||||||
 | 
					import org.junit.jupiter.api.Test;
 | 
				
			||||||
 | 
					import org.slf4j.Logger;
 | 
				
			||||||
 | 
					import org.slf4j.LoggerFactory;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					public class MsgTest {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private final Logger logger = LoggerFactory.getLogger(MsgTest.class);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Test
 | 
				
			||||||
 | 
					    public void test() {
 | 
				
			||||||
 | 
					        Msg<String> msg = Msg.success("测试内容", "测试体");
 | 
				
			||||||
 | 
					        logger.info(msg.toString());
 | 
				
			||||||
 | 
					        assert msg.isSuccess();
 | 
				
			||||||
 | 
					        msg = Msg.failed("失败消息");
 | 
				
			||||||
 | 
					        logger.info(msg.toString());
 | 
				
			||||||
 | 
					        assert msg.isFailed();
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,25 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.starter.test.monitor;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import com.hxuanyu.monitor.base.BaseMonitorItem;
 | 
				
			||||||
 | 
					import com.hxuanyu.monitor.manager.MonitorItemBeanManager;
 | 
				
			||||||
 | 
					import com.hxuanyu.test.MainApplication;
 | 
				
			||||||
 | 
					import org.junit.jupiter.api.Test;
 | 
				
			||||||
 | 
					import org.slf4j.Logger;
 | 
				
			||||||
 | 
					import org.slf4j.LoggerFactory;
 | 
				
			||||||
 | 
					import org.springframework.beans.factory.annotation.Autowired;
 | 
				
			||||||
 | 
					import org.springframework.boot.test.context.SpringBootTest;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					@SpringBootTest(classes = MainApplication.class)
 | 
				
			||||||
 | 
					public class MonitorTest {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private final Logger logger = LoggerFactory.getLogger(MonitorTest.class);
 | 
				
			||||||
 | 
					    @Autowired
 | 
				
			||||||
 | 
					    MonitorItemBeanManager monitorItemBeanManager;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Test
 | 
				
			||||||
 | 
					    public void testMonitorItemScan() {
 | 
				
			||||||
 | 
					        BaseMonitorItem testMonitorItem = monitorItemBeanManager.getMonitorItemMap().get("ScheduledTask-TestMonitorItem");
 | 
				
			||||||
 | 
					        assert testMonitorItem.getMonitorItemName() != null;
 | 
				
			||||||
 | 
					        logger.info("获取到的Bean:{}", testMonitorItem.toString());
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,56 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.starter.test.network;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import com.hxuanyu.common.message.Msg;
 | 
				
			||||||
 | 
					import com.hxuanyu.network.service.HttpService;
 | 
				
			||||||
 | 
					import com.hxuanyu.test.MainApplication;
 | 
				
			||||||
 | 
					import org.junit.jupiter.api.Test;
 | 
				
			||||||
 | 
					import org.junit.jupiter.api.Timeout;
 | 
				
			||||||
 | 
					import org.junit.runner.RunWith;
 | 
				
			||||||
 | 
					import org.slf4j.Logger;
 | 
				
			||||||
 | 
					import org.slf4j.LoggerFactory;
 | 
				
			||||||
 | 
					import org.springframework.beans.factory.annotation.Autowired;
 | 
				
			||||||
 | 
					import org.springframework.boot.test.context.SpringBootTest;
 | 
				
			||||||
 | 
					import org.springframework.test.context.web.WebAppConfiguration;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import static java.lang.Thread.sleep;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					@SpringBootTest(classes = MainApplication.class)
 | 
				
			||||||
 | 
					public class NetworkTest {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Autowired
 | 
				
			||||||
 | 
					    HttpService httpService;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    private final Logger logger = LoggerFactory.getLogger(NetworkTest.class);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Test
 | 
				
			||||||
 | 
					    @Timeout(3000)
 | 
				
			||||||
 | 
					    public void testGet() throws InterruptedException {
 | 
				
			||||||
 | 
					        Msg<String> msg = httpService.doGet("https://baidu.com");
 | 
				
			||||||
 | 
					        logger.info("GET测试:{}", msg);
 | 
				
			||||||
 | 
					        assert msg.isSuccess();
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Test
 | 
				
			||||||
 | 
					    @Timeout(3000)
 | 
				
			||||||
 | 
					    public void testPost() {
 | 
				
			||||||
 | 
					        Msg<String> msg = httpService.doPost("https://baidu.com");
 | 
				
			||||||
 | 
					        logger.info("POST测试:{}", msg);
 | 
				
			||||||
 | 
					        assert msg.isSuccess();
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Test
 | 
				
			||||||
 | 
					    @Timeout(3000)
 | 
				
			||||||
 | 
					    public void testDelete() {
 | 
				
			||||||
 | 
					        Msg<String> msg = httpService.doDelete("https://baidu.com");
 | 
				
			||||||
 | 
					        logger.info("DELETE测试:{}", msg);
 | 
				
			||||||
 | 
					        assert msg.isSuccess();
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Test
 | 
				
			||||||
 | 
					    @Timeout(3000)
 | 
				
			||||||
 | 
					    public void testPut() {
 | 
				
			||||||
 | 
					        Msg<String> msg = httpService.doPut("https://baidu.com");
 | 
				
			||||||
 | 
					        logger.info("PUT测试:{}", msg);
 | 
				
			||||||
 | 
					        assert msg.isSuccess();
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
@@ -0,0 +1,27 @@
 | 
				
			|||||||
 | 
					package com.hxuanyu.starter.test.notify;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import com.hxuanyu.notify.enums.NotifyType;
 | 
				
			||||||
 | 
					import com.hxuanyu.notify.model.Mail;
 | 
				
			||||||
 | 
					import com.hxuanyu.notify.service.NotifyService;
 | 
				
			||||||
 | 
					import com.hxuanyu.test.MainApplication;
 | 
				
			||||||
 | 
					import org.junit.jupiter.api.Test;
 | 
				
			||||||
 | 
					import org.springframework.beans.factory.annotation.Autowired;
 | 
				
			||||||
 | 
					import org.springframework.boot.test.context.SpringBootTest;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import static java.lang.Thread.sleep;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					@SpringBootTest(classes = MainApplication.class)
 | 
				
			||||||
 | 
					public class NotifyTest {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Autowired
 | 
				
			||||||
 | 
					    NotifyService notifyService;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    @Test
 | 
				
			||||||
 | 
					    public void testNotify() throws InterruptedException {
 | 
				
			||||||
 | 
					        notifyService.notify(new Mail("2252193204@qq.com", "test subject", "test success"), NotifyType.TYPE_MAIL);
 | 
				
			||||||
 | 
					        sleep(2000);
 | 
				
			||||||
 | 
					        notifyService.notify("短信通知方式", NotifyType.TYPE_MSG);
 | 
				
			||||||
 | 
					        notifyService.notify("日志输出方式", NotifyType.TYPE_LOG);
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
		Reference in New Issue
	
	Block a user