V1

Author: Boomboomdunce

.dockerignore

@@ -0,0 +1,20 @@
+# Git
+.git
+.gitignore
+
+# Rust
+target/
+**/*.rs.bk
+Cargo.lock
+
+# Docker
+Dockerfile
+.dockerignore
+
+# IDE
+.idea/
+.vscode/
+
+# Data
+data/
+*.eml

.github/workflows/build.yaml

@@ -0,0 +1,38 @@
+name: ci
+
+on:
+  push:
+    branches:
+      - "main"
+
+jobs:
+  docker:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      # 添加 QEMU 支持，用于多架构构建
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v3
+      
+      - name: Log in to Docker Hub
+        uses: docker/login-action@v3
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+      
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v3
+        with:
+          version: "lab:latest"
+          driver: cloud
+          endpoint: "relaxcloud/dev"
+      
+      - name: Build and push
+        uses: docker/build-push-action@v5
+        with:
+          context: .
+          platforms: linux/amd64,linux/arm64/v8  # 指定构建平台
+          tags: "relaxcloud/rsendmail:${{ github.ref_name }}"
+          outputs: ${{ github.event_name == 'pull_request' && 'type=cacheonly' || 'type=registry,push=true' }}

.gitignore

@@ -18,4 +18,6 @@ Cargo.lock
 #  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore
 #  and can be added to the global gitignore or merged into this file.  For a more nuclear
 #  option (not recommended) you can uncomment the following to ignore the entire idea folder.
-#.idea/
+#.idea/
+
+test_data/*

Dockerfile

@@ -0,0 +1,34 @@
+# 第一阶段：依赖缓存层
+FROM rust:1.75-slim as cacher
+WORKDIR /usr/src/app/rsendmail
+COPY rsendmail/Cargo.* ./
+RUN rm -f Cargo.lock && \
+    mkdir src && \
+    echo "fn main() {}" > src/main.rs && \
+    cargo fetch
+
+# 第二阶段：构建层
+FROM rust:1.75-slim as builder
+WORKDIR /usr/src/app/rsendmail
+COPY --from=cacher /usr/local/cargo /usr/local/cargo
+COPY rsendmail .
+RUN rm -f Cargo.lock && \
+    cargo build --release --offline
+
+# 第三阶段：运行层
+FROM debian:bookworm-slim
+RUN apt-get update && \
+    apt-get install -y --no-install-recommends \
+    libssl3 \
+    ca-certificates \
+    && rm -rf /var/lib/apt/lists/* && \
+    useradd -r -s /bin/false rsendmail && \
+    mkdir /data && \
+    chown rsendmail:rsendmail /data
+
+# 只复制必要的二进制文件
+COPY --from=builder /usr/src/app/rsendmail/target/release/rsendmail /usr/local/bin/
+
+USER rsendmail
+WORKDIR /data
+ENTRYPOINT ["rsendmail"]

README.md

@@ -1,2 +1,83 @@
 # RSendMail
 Used for batch sending emails for testing
+
+## Features
+
+- Batch process and send multiple emails
+- Multi-threaded processing for improved performance
+- Support for custom SMTP server configuration
+- Detailed logging and statistics
+- Docker support for easy deployment
+
+## Building
+
+### Local Build
+```bash
+cd rsendmail
+cargo build --release
+```
+
+### Docker Build
+```bash
+docker build -t rsendmail .
+```
+
+## Usage
+
+### Local Usage
+```bash
+rsendmail -s <smtp_server> -P <port> -f <from_addr> -t <to_addr> -d <email_dir> -p <parallel>
+```
+
+### Docker Usage
+```bash
+docker run --rm -v /path/to/emails:/data rsendmail -s <smtp_server> -P <port> -f <from_addr> -t <to_addr> -d /data -p <parallel>
+```
+
+### Parameters
+
+- `-s, --smtp`: SMTP server address
+- `-P, --port`: SMTP server port
+- `-f, --from`: From email address
+- `-t, --to`: To email address
+- `-d, --dir`: Directory containing email files (.eml)
+- `-p, --parallel`: Number of parallel processes (default: 10)
+
+## Example
+
+```bash
+# Local example
+rsendmail -s 192.168.1.100 -P 25 -f sender@example.com -t recipient@example.com -d ./emails -p 10
+
+# Docker example
+docker run --rm -v $(pwd)/emails:/data rsendmail -s 192.168.1.100 -P 25 -f sender@example.com -t recipient@example.com -d /data -p 10
+```
+
+## Docker Container
+
+The Docker container is designed with security and efficiency in mind:
+
+- Based on debian:bookworm-slim for minimal size
+- Runs as non-root user
+- Includes only necessary runtime dependencies
+- Uses volume mounting for email files
+- Stateless operation
+
+### Container Structure
+
+- `/usr/local/bin/rsendmail`: Application binary
+- `/data`: Mount point for email files (volume)
+
+## Performance
+
+- Multi-threaded processing
+- Efficient memory usage
+- Fast email parsing and sending
+- Detailed performance statistics output
+
+## Security
+
+- Non-root user execution
+- Minimal container footprint
+- Isolated runtime environment
+- No persistent storage

rsendmail/Cargo.toml

@@ -0,0 +1,20 @@
+[package]
+name = "rsendmail"
+version = "0.1.0"
+edition = "2021"
+authors = ["RSendMail Contributors"]
+description = "A high-performance bulk email sending CLI tool"
+
+[dependencies]
+mail-send = "0.4.0"
+mail-parser = "0.9.2"
+mail-builder = "0.3.2"
+tokio = { version = "1.35.1", features = ["full"] }
+clap = { version = "4.4.12", features = ["derive"] }
+anyhow = "1.0.79"
+walkdir = "2.4.0"
+log = "0.4.20"
+env_logger = "0.10.1"
+chrono = "0.4.31"
+num_cpus = "1.16.0"
+futures = "0.3.30"

rsendmail/src/config.rs

@@ -0,0 +1,52 @@
+use clap::Parser;
+
+#[derive(Debug, Clone)]
+pub enum ProcessMode {
+    Auto,
+    Fixed(usize),
+}
+
+#[derive(Parser, Debug, Clone)]
+#[command(author, version, about, long_about = None)]
+pub struct Config {
+    /// SMTP服务器地址
+    #[arg(short = 's', long)]
+    pub smtp_server: String,
+
+    /// SMTP服务器端口
+    #[arg(short = 'P', long, default_value_t = 25)]
+    pub port: u16,
+
+    /// 发件人邮箱
+    #[arg(short = 'f', long)]
+    pub from: String,
+
+    /// 收件人邮箱
+    #[arg(short = 't', long)]
+    pub to: String,
+
+    /// 邮件文件目录
+    #[arg(short = 'd', long)]
+    pub dir: String,
+
+    /// 邮件文件扩展名
+    #[arg(short = 'e', long, default_value = "eml")]
+    pub extension: String,
+
+    /// 并发进程数，使用 "auto" 自动设置
+    #[arg(short = 'p', long, default_value = "auto")]
+    processes_str: String,
+}
+
+impl Config {
+    pub fn processes(&self) -> ProcessMode {
+        if self.processes_str == "auto" {
+            ProcessMode::Auto
+        } else {
+            match self.processes_str.parse() {
+                Ok(n) => ProcessMode::Fixed(n),
+                Err(_) => ProcessMode::Auto,
+            }
+        }
+    }
+}