30分钟实现node批量定时发送邮件
在年前摸鱼的时候, 想着怎么把天气等信息定时发送到我的邮箱, 让我每天早上起床能准时收到今天天气, 同时我也想让关心的人同样收到, 于是整理了一下思路:
需求一: 开通SMTP服务;
需求二: 天气信息获取;
需求三: 批量发送邮件功能;
需求四: 定时发送;
我这里使用的egg框架, 因为简单好用, 接下来就开始一步一步实现
EggJS - 企业级 Node.js 开发框架
快速创建一个egg项目, 我使用的官方推荐:
我们推荐直接使用脚手架，只需几条简单指令，即可快速生成项目（npm >=6.1.0), 框架默认启动端口7001
$ mkdir egg-example && cd egg-example
$ npm init egg --type=simple
$ npm i
启动项目:
$ npm run dev
$ open http://localhost:7001
一.开通SMTP服务
我这里用的是qq邮箱
具体流程我就不多说, 可参考【SMTP服务】开启邮箱smtp服务教程
二. 天气信息的获取
去高德开放平台免费注册一个开发者, 创建应用, 申请key, 然后就拥有了很多api接口权限, 这里我使用的是v3接口高德开放平台https://lbs.amap.com/
因为本人目前在深圳, 所以就直接在高德拿到了城市的代码: 440300; 其他地区请通过高德接口自行获取;
获取天气信息接口为: https://restapi.amap.com/v3/weather/weatherInfo
参数: key和city 完整请求路径: https://restapi.amap.com/v3/weather/weatherInfo?key=你的key&city=440300
具体返回内容请以高德为准.
三. 批量发送邮件功能;
需要用到 nodemailer 插件和 smtpTransport 方法来实现批量邮件发送, 我这里将主要代码放在了 业务逻辑层 Service目录, 创建weather.js
const Service = require('egg').Service;
const nodemailer = require('nodemailer')
const smtpTransport = require('nodemailer-smtp-transport');
class WeatherService extends Service {
async send(data) {
const transporter = nodemailer.createTransport(smtpTransport({
host: 'smtp.qq.com', //邮件服务供应商
pool: true,
port: 465,
secure: true, // use TLS使用HTTPS port可以是 465 也可以是 994
auth: {
user: 'xxx@qq.com', //发送方
pass: 'xxx'//密码或授权码
}
}));
// 发送给谁以及发送内容
const mailOptions = {
from: 'xxx@qq.com',//发送方
to: '123456789@qq.com,987654321@qq.com',//接收方
subject: '请注意查收天气信息!', // 标题
html: `<div>
<h1>今日天气</h1>
<p>省份: ${data.province}</p>
<p>城市: ${data.city}</p>
<p>温度: ${data.temperature}°C</p>
<p>天气: ${data.weather}</p>
<p>风向: ${data.winddirection}</p>
<p>风力: ${data.windpower}级</p>
<p>湿度: ${data.humidity}RH</p>
<p>天气时间: ${data.reporttime}</p>
</div>`
}
async function sendEmails(transporter,mailOptions) {
try {
const verifypass = await transporter.verify();//验证邮件发送者transporter是否配置正确
const sendSucess = await transporter.sendMail(mailOptions);//配置无误，发送发送邮件
if (sendSucess) {
console.log('发送成功');
}
} catch (error) {
console.log(error);
}
}
sendEmails(transporter,mailOptions);
}
}
module.exports = WeatherService;
通过router输出一个api可测试是否发送成功
四. 定时发送
这里用到了egg自带的插件schedule, 在schedule目录创建update_cache.js; 想要了解更多请参考 egg定时任务
主要逻辑就是定时执行 从高德获取到的天气信息, 然后批量发送邮件
const Subscription = require('egg').Subscription;
class UpdateCache extends Subscription {
// 通过 schedule 属性来设置定时任务的执行间隔等配置
static get schedule() {
return {
cron: '0 0 8 * * *',
type: 'all', // 指定所有的 worker 都需要执行
};
}
// subscribe 是真正定时任务执行时被运行的函数
async subscribe() {
const res = await this.ctx.curl('https://restapi.amap.com/v3/weather/weatherInfo?key=你的key&city=440300', {
dataType: 'json',
});
if(res){
const data = res.data.lives[0] || {}
const info = await this.ctx.service.weather.send(data);
console.log('发送成功',info);
}
}
}
module.exports = UpdateCache;
