目录
一、阿里云邮件守护进程
1. 安装必要库
pip3 install smtplib email schedule2. 创建邮件发送脚本 mail_daemon.py
import smtplib
import schedule
import time
from email.mime.text import MIMEText
from email.header import Header
# 配置信息（替换为你的信息）
SMTP_SERVER = 'smtp.163.com' # 例如163邮箱
SMTP_PORT = 465 # SSL端口
SENDER_EMAIL = 'your_email@163.com'
SENDER_PASSWORD = 'your_password' # 或授权码
RECEIVER_EMAIL = 'receiver@example.com'
def send_email():
message = MIMEText('守护进程正在运行中....', 'plain', 'utf-8')
message['From'] = Header(SENDER_EMAIL)
message['To'] = Header(RECEIVER_EMAIL)
message['Subject'] = Header('阿里云守护进程状态')
try:
smtp = smtplib.SMTP_SSL(SMTP_SERVER, SMTP_PORT)
smtp.login(SENDER_EMAIL, SENDER_PASSWORD)
smtp.sendmail(SENDER_EMAIL, [RECEIVER_EMAIL], message.as_string())
smtp.quit()
print("邮件发送成功")
except Exception as e:
print(f"邮件发送失败: {str(e)}")
def job():
send_email()
if __name__ == '__main__':
schedule.every(1).minutes.do(job)
while True:
schedule.run_pending()
time.sleep(1)3. 设置后台运行
nohup python3 mail_daemon.py > /dev/null 2>&1 &二、树莓派串口守护进程
1. 启用树莓派串口
# 禁用蓝牙占用串口
sudo raspi-config
# 选择 Interfacing Options -> Serial -> No 关闭登录shell -> Yes 启用硬件串口
sudo reboot
# 验证串口
ls -l /dev/serial* # 应显示 /dev/serial0 -> ttyAMA02. 安装依赖库
sudo apt-get install python3-serial3. 创建串口输出脚本 serial_daemon.py
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <fcntl.h>
#include <signal.h>
#include <time.h>
#include <openssl/ssl.h>
#include <openssl/err.h>
#define SMTP_SERVER "smtp.qq.com"
#define SMTP_PORT 465
#define SENDER_EMAIL "your_email@qq.com"
#define SENDER_PASSWORD "your_auth_code"
#define RECEIVER_EMAIL "receiver@example.com"
#define LOG_FILE "/tmp/daemon_email.log"
// 守护进程初始化
void daemonize() {
pid_t pid = fork();
if (pid < 0) {
perror("First fork failed");
exit(EXIT_FAILURE);
}
if (pid > 0) exit(EXIT_SUCCESS); // 父进程退出
// 创建新会话
if (setsid() < 0) {
perror("setsid failed");
exit(EXIT_FAILURE);
}
// 第二次fork
pid = fork();
if (pid < 0) {
perror("Second fork failed");
exit(EXIT_FAILURE);
}
if (pid > 0) exit(EXIT_SUCCESS);
// 设置文件权限掩码
umask(0);
// 改变工作目录
chdir("/");
// 关闭标准文件描述符
close(STDIN_FILENO);
close(STDOUT_FILENO);
close(STDERR_FILENO);
}
// 日志记录函数
void log_message(const char* message) {
time_t now;
time(&now);
char* dt = ctime(&now);
dt[strlen(dt)-1] = '\0'; // 去除换行符
FILE* log_file = fopen(LOG_FILE, "a");
if (log_file) {
fprintf(log_file, "%s - %s\n", dt, message);
fclose(log_file);
}
}
// Base64编码（简化版，实际应使用完整实现）
char* base64_encode(const char* input) {
BIO *bio, *b64;
BUF_MEM *bufferPtr;
b64 = BIO_new(BIO_f_base64());
bio = BIO_new(BIO_s_mem());
bio = BIO_push(b64, bio);
BIO_write(bio, input, strlen(input));
BIO_flush(bio);
BIO_get_mem_ptr(bio, &bufferPtr);
char* output = (char*)malloc(bufferPtr->length + 1);
memcpy(output, bufferPtr->data, bufferPtr->length);
output[bufferPtr->length] = '\0';
BIO_free_all(bio);
return output;
}
// 发送SMTP命令并检查响应
int smtp_command(SSL* ssl, const char* cmd, const char* expect_code, int log) {
char buffer[1024];
if (cmd) SSL_write(ssl, cmd, strlen(cmd));
SSL_read(ssl, buffer, sizeof(buffer));
if (log) {
log_message(buffer);
}
return (strstr(buffer, expect_code) != NULL);
}
// 发送邮件函数
int send_email() {
struct sockaddr_in addr;
int sock;
SSL_CTX* ctx;
SSL* ssl;
// 初始化OpenSSL
SSL_library_init();
OpenSSL_add_all_algorithms();
SSL_load_error_strings();
ctx = SSL_CTX_new(SSLv23_client_method());
// 创建socket
sock = socket(AF_INET, SOCK_STREAM, 0);
addr.sin_family = AF_INET;
addr.sin_port = htons(SMTP_PORT);
inet_pton(AF_INET, SMTP_SERVER, &addr.sin_addr);
// 连接服务器
if (connect(sock, (struct sockaddr*)&addr, sizeof(addr)) {
log_message("Connection failed");
return -1;
}
// 创建SSL连接
ssl = SSL_new(ctx);
SSL_set_fd(ssl, sock);
if (SSL_connect(ssl) <= 0) {
log_message("SSL connection failed");
return -1;
}
// SMTP协议交互
if (!smtp_command(ssl, NULL, "220", 1)) goto error; // 读取欢迎消息
if (!smtp_command(ssl, "EHLO localhost\r\n", "250", 1)) goto error;
// 认证
char auth_cmd[256];
sprintf(auth_cmd, "AUTH LOGIN\r\n");
if (!smtp_command(ssl, auth_cmd, "334", 1)) goto error;
char* encoded_user = base64_encode(SENDER_EMAIL);
sprintf(auth_cmd, "%s\r\n", encoded_user);
if (!smtp_command(ssl, auth_cmd, "334", 1)) goto error;
free(encoded_user);
char* encoded_pass = base64_encode(SENDER_PASSWORD);
sprintf(auth_cmd, "%s\r\n", encoded_pass);
if (!smtp_command(ssl, auth_cmd, "235", 1)) goto error;
free(encoded_pass);
// 构造邮件
sprintf(auth_cmd, "MAIL FROM:<%s>\r\n", SENDER_EMAIL);
if (!smtp_command(ssl, auth_cmd, "250", 1)) goto error;
sprintf(auth_cmd, "RCPT TO:<%s>\r\n", RECEIVER_EMAIL);
if (!smtp_command(ssl, auth_cmd, "250", 1)) goto error;
if (!smtp_command(ssl, "DATA\r\n", "354", 1)) goto error;
const char* email_body = "From: \"Daemon\" <" SENDER_EMAIL ">\r\n"
"To: " RECEIVER_EMAIL "\r\n"
"Subject: Status Report\r\n\r\n"
"Daemon is running...\r\n.\r\n";
SSL_write(ssl, email_body, strlen(email_body));
if (!smtp_command(ssl, NULL, "250", 1)) goto error;
// 退出
smtp_command(ssl, "QUIT\r\n", "221", 1);
SSL_free(ssl);
close(sock);
SSL_CTX_free(ctx);
return 0;
error:
SSL_free(ssl);
close(sock);
SSL_CTX_free(ctx);
return -1;
}
int main() {
daemonize();
log_message("Daemon started");
while(1) {
if (send_email() == 0) {
log_message("Email sent successfully");
} else {
log_message("Failed to send email");
}
sleep(60); // 每分钟发送一次
}
return 0;
}4. 设置开机自启
创建 /etc/systemd/system/serial_daemon.service：
[Unit]
Description=Serial Daemon Service
[Service]
ExecStart=/usr/bin/python3 /home/pi/serial_daemon.py
Restart=always
User=pi
[Install]
WantedBy=multi-user.target5. 使用串口助手接收
sudo apt-get install minicom
minicom -b 115200 -o -D /dev/serial0实验结果：
