在阿里云和树莓派上编写一个守护进程程序

目录

一、阿里云邮件守护进程

1. 安装必要库

2. 创建邮件发送脚本 mail_daemon.py

3. 设置后台运行

二、树莓派串口守护进程

1. 启用树莓派串口

2. 安装依赖库

3. 创建串口输出脚本 serial_daemon.py

4. 设置开机自启

5. 使用串口助手接收

---

一、阿里云邮件守护进程

1. 安装必要库

pip3 install smtplib email schedule

2. 创建邮件发送脚本 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 = '[e-mail]'
SENDER_PASSWORD = 'your_password'   # 或授权码
RECEIVER_EMAIL = '[e-mail]'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 -> ttyAMA0

2. 安装依赖库

sudo apt-get install python3-serial

3. 创建串口输出脚本 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 "[e-mail]"
#define SENDER_PASSWORD "your_auth_code"
#define RECEIVER_EMAIL "[e-mail]"
#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);}// 第二次forkpid = 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;// 初始化OpenSSLSSL_library_init();OpenSSL_add_all_algorithms();SSL_load_error_strings();ctx = SSL_CTX_new(SSLv23_client_method());// 创建socketsock = 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.target

5. 使用串口助手接收

sudo apt-get install minicom
minicom -b 115200 -o -D /dev/serial0

实验结果：