Express实现定时发送邮件

在开发中我们有时候需要每隔 一段时间发送一次电子邮件，或者在某个特定的时间进行发送邮件，
无需手动去操作，基于这样的情况下我们需要用到了定时任务，一般可以写个定时器，来完成相应的需求，在 node.js 中自已实现也非常容易，接下来要介绍的是node-schedule来完成定时任务
用express.js实现 每个星期三中午12点 发送邮件给某个用户

1.安装第三方库 Node Schedule、nodemailer
npm i -s node-schedule nodemailer
2.新建一个 TaskScheduler 定时任务类

1. // 引入 node-schedule 模块
2. const schedule = require('node-schedule');
4. /*
5. * TODO:编写 Cron 表达式时，有五个占位符可以使用，分别表示分钟、小时、日期、月份和星期几。
6. *      每个占位符可以使用特定的值、值范围、逗号分隔的值列表和通配符等等
7. *
8. *       * * * * * *
9. *       | | | | | |
10. *       | | | | | day of week
11. *       | | | | month
12. *       | | | day of month
13. *       | | hour
14. *       | minute
15. *       second ( optional )
16. *
17. *      示例 Cron 表达式：
18. *           每分钟的第30秒触发： 30 * * * * *
19. *           每小时的1分30秒触发 ：30 1 * * * *
20. *           每天的凌晨1点1分30秒触发 ：30 1 1 * * *
21. *           每月的1日1点1分30秒触发 ：30 1 1 1 * *
22. *           每年的1月1日1点1分30秒触发 ：30 1 1 1 1 *
23. *           每周1的1点1分30秒触发 ：30 1 1 * * 1
24. * */
26. // 创建一个任务调度器类
27. class TaskScheduler {
28.     // 构造函数，接受 cron 表达式和要执行的任务作为参数
29.     constructor(cronExpression, task) {
30.         // 将传入的 cron 表达式和任务保存为成员变量
31.         this.cronExpression = cronExpression;
32.         this.task = task;
33.         // 初始化 job 为 null
34.         this.job = null;
35.     }
37.     // 启动任务
38.     start() {
39.         // 如果当前没有正在运行的任务，则创建新的任务
40.         if (!this.job) {
41.             this.job = schedule.scheduleJob(this.cronExpression, this.task);
42.             console.log(`定时任务启动： ${this.cronExpression}`);
43.         }
44.     }
46.     // 停止任务
47.     stop() {
48.         // 如果当前有正在运行的任务，则取消任务并将 job 设为 null
49.         if (this.job) {
50.             this.job.cancel();
51.             console.log(`定时任务停止： ${this.cronExpression}`);
52.             this.job = null;
53.         }
54.     }
55. }
57. // 导出任务调度器类
58. module.exports = TaskScheduler;

复制代码

3.创建一个发送邮件的方法

1. const nodemailer = require("nodemailer");
2. /**
3. * 邮箱发送
4. *
5. * @param  {string}  to 对方邮箱
6. * @param  {string}  content 发送内容
7. */
9. // 创建Nodemailer传输器 SMTP 或者 其他 运输机制
10. let transporter = nodemailer.createTransport(
11.     {
12.         service: 'QQ', // 使用内置传输发送邮件 查看支持列表：https://nodemailer.com/smtp/well-known/
13.         port: 465, // SMTP 端口
14.         secureConnection: true, // 使用 SSL
15.         auth: {
16.             user: '1840354092@qq.com', // 发送方邮箱的账号
17.             pass: '******', // 邮箱授权密码
18.         }
19.     }
20. );
22. exports.send = (to, content) => {
23.     return new Promise((resolve, reject) => {
24.         transporter.sendMail({
25.             from: `"ZY.API" <1840354092@qq.com>`, // 发送方邮箱的账号
26.             to: to, // 邮箱接受者的账号
27.             subject: "Welcome to ZY.API", // Subject line
28.             // text: '"MG'Blog ?"', // 文本内容
29.             html: `
30.         <img src="http://www.zhouyi.run:3001/api/v1/files/preview?p=pexels-photo-276452.jpeg&&mimetype=image/jpeg" alt=""   />
31.         <p >??? ZY.API</p>
32.         <p >${content}</p>
33.         <p >确认</p>
34.         <p >祝您工作顺利，心想事成</p>`
35.         }, (error, info) => {
36.             if (error) {
37.                 reject(error)
38.             }
39.             resolve(info)
40.         });
41.     })
42. }

复制代码

4.创建一个 每个星期三中午12点 发送邮件的任务实例并且引入发送邮件的方法

1. const TaskScheduler = require('./TaskScheduler')
2. const {send} = require('../../utils/utils.mailer')
5. const task = async function () {
6.     await send('1840354092@qq.com', '每个星期三中午12点 发送邮件')
7.     return console.log('允许定时任务每个星期三中午12点 发送邮件...' + new Date().getMinutes() + "-" + new Date().getSeconds());
8. };
10. // 创建一个 每个星期三中午12点 发送邮件
11. module.exports = new TaskScheduler('0 0 12 ? * WED', task);

复制代码

5.路由使用该定时发送邮件类

1. /**
2. *@author ZY
3. *@date 2023/4/10
4. *@Description:任务相关的接口
5. */
7. const express = require('express');
8. const router = express.Router();
9. const SendEmail = require('../../scheduler/task/SendEmail')
11. /****************************************************************************/
14. /**
15. * 开始发送邮件定时任务
16. * @route GET /v1/task/startSendEmail
17. * @group 定时任务 - 定时任务相关
18. * @returns {object} 200 - {"status": 1,"message": "登录成功.","data": {...},"time": 1680598858753}
19. * @returns {Error}  default - Unexpected error
20. */
22. router.get('/startSendEmail', function (req, res) {
23.     //用户的定时任务开始
24.     SendEmail.start();
25.     res.send('用户的定时任务开始!');
26. });
28. /**
29. * 停止发送邮件定时任务
30. * @route GET /v1/task/stopSendEmail
31. * @group 定时任务 - 定时任务相关
32. * @returns {object} 200 - {"status": 1,"message": "登录成功.","data": {...},"time": 1680598858753}
33. * @returns {Error}  default - Unexpected error
34. */
36. router.get('/stopSendEmail', function (req, res) {
37.     SendEmail.stop();
38.     res.send('用户的定时任务开始!');
39. });
41. module.exports = router;

复制代码

6.到这里差不多就可以开始定时任务和停止定时任务了，我这里是设置30秒发一次邮件

✨狂点这里查看完整项目代码

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！