概述与快速开始

# 安装 Asynq
go get github.com/hibiken/asynq

# 快速启动 Redis（Docker）
docker run --name redis -d -p 6379:6379 redis:7

package tasks

import (
    "context"
    "encoding/json"
    "fmt"
    "log"

    "github.com/hibiken/asynq"
)

// 任务类型常量（推荐 "domain:action" 命名格式）
const TypeEmailDelivery = "email:deliver"

// Payload 结构体
type EmailPayload struct {
    UserID     int    `json:"user_id"`
    TemplateID string `json:"template_id"`
}

// 创建任务（Client 端调用）
func NewEmailTask(userID int, tmplID string) (*asynq.Task, error) {
    payload, err := json.Marshal(EmailPayload{UserID: userID, TemplateID: tmplID})
    if err != nil {
        return nil, err
    }
    return asynq.NewTask(TypeEmailDelivery, payload), nil
}

// 任务处理器（Worker 端实现）
func HandleEmailTask(ctx context.Context, t *asynq.Task) error {
    var p EmailPayload
    if err := json.Unmarshal(t.Payload(), &p); err != nil {
        return fmt.Errorf("json.Unmarshal failed: %v: %w", err, asynq.SkipRetry)
    }
    log.Printf("Sending email to user_id=%d, template=%s", p.UserID, p.TemplateID)
    // TODO: 实际发送邮件逻辑
    return nil
}

func main() {
    client := asynq.NewClient(asynq.RedisClientOpt{Addr: "localhost:6379"})
    defer client.Close()

    task, err := tasks.NewEmailTask(42, "welcome")
    if err != nil {
        log.Fatal(err)
    }

    info, err := client.Enqueue(task)
    if err != nil {
        log.Fatal(err)
    }
    log.Printf("enqueued: id=%s queue=%s", info.ID, info.Queue)
}

func main() {
    srv := asynq.NewServer(
        asynq.RedisClientOpt{Addr: "localhost:6379"},
        asynq.Config{Concurrency: 10},
    )

    mux := asynq.NewServeMux()
    mux.HandleFunc(tasks.TypeEmailDelivery, tasks.HandleEmailTask)

    if err := srv.Run(mux); err != nil {
        log.Fatal(err)
    }
}

// 延迟 10 分钟
client.Enqueue(task, asynq.ProcessIn(10*time.Minute))

// 指定具体执行时间
client.Enqueue(task, asynq.ProcessAt(time.Date(2026, 7, 18, 9, 0, 0, 0, time.Local)))