li199773/SMTP-POP3-IMAP-Analysis

MyCat+MySQL+Python MySQL分布式集群存储

SMTP POP3 IMAP mail parsing MySQL distributed storage

---

一.项目重要步骤：

1.判断是否指定日期路径传入

sys.argv[2]指定格式 例如20211231
sys.argv[2] == null时 默认处理当天数据

2.mysql数据库建立

建立格式：年月日

3.遍历目标文件夹下面的全部pcapng文件

4.dpkt解析

(1) 以太网数据包
(1) 网络层:ip、len、ttl、source_ip、target_ip
(2) 传输层:tcp、sport、dport

5.正则表达式提取邮件文字信息解析

host_name:主机名
mail_from:邮件发送方
mail_to:邮件接收方
x_mail:邮件客户端
mail_subject:邮件主题
mail_priority:邮件设置等级
message_id:邮件id
mail_content:邮件内容

6.图片信息判断并且单独存储

if tmp["mail_image"] != '':
    mail_image_str = tmp["mail_image"].split(">")[1]
    mail_image_download(mail_image_str, file_name)

8.mysql数据库存储

9.开启多线程处理函数

---

二.MySQL分库分表

按照SMTP POP3 IMAP分成3个数据库存储在不同服务器，并且按照月份进行存储，每月按照日期分表

详情见Distributed-MySQL

---

三.定时调度

crontab按照每10分钟进行调度一次，因为数据推送间隔并不是固定的。

---

四.Program monitoring

MyCat涉及全局序列的问题，所以每天0时要重启Mycat服务

    # 因为grep查看程序名也是进程，会混到查询信息里
    programIsRunningCmd = "ps -ef|grep demo1.py|grep -v grep"
    programIsRunningCmdAns = execCmd(programIsRunningCmd)
    ansLine = programIsRunningCmdAns.split('\n')
    # 判断如果返回行数>2则说明python脚本程序已经在运行，打印提示信息结束程序，否则运行脚本代码doSomething()
    if len(ansLine) > 2:
        print("programName have been Running")
    else:
        mycat_restart()
        break