Golang如何实现模板方法模式_Golang 模板方法模式实践

package main

// 定义数据处理步骤接口
type DataProcessor interface {
    Load() string
    Parse(data string) []string
    Save(results []string) error
}

// 模板结构体，包含通用流程
type DataPipeline struct {
    processor DataProcessor
}

// 模板方法：定义执行流程
func (dp *DataPipeline) Execute() error {
    rawData := dp.processor.Load()

    parsedData := dp.processor.Parse(rawData)

    err := dp.processor.Save(parsedData)
    if err != nil {
        return err
    }

    return nil
}

type JSONProcessor struct{}

func (jp *JSONProcessor) Load() string {
    return `{"users": ["alice", "bob"]}`
}

func (jp *JSONProcessor) Parse(data string) []string {
    // 简化处理，实际可用 json.Unmarshal
    return []string{"alice", "bob"} // 模拟解析结果
}

func (jp *JSONProcessor) Save(results []string) error {
    println("Saving JSON results:", len(results), "entries")
    for _, r := range results {
        println(" - ", r)
    }
    return nil
}

type CSVProcessor struct{}

func (cp *CSVProcessor) Load() string {
    return "alice,bob,carol"
}

func (cp *CSVProcessor) Parse(data string) []string {
    return []string{"alice", "bob", "carol"} // 模拟 CSV 分割
}

func (cp *CSVProcessor) Save(results []string) error {
    println("Saving CSV results:", len(results), "entries")
    for _, r := range results {
        println(" - ", r)
    }
    return nil
}

func main() {
    // 使用 JSON 处理器
    jsonProc := &JSONProcessor{}
    pipeline := &DataPipeline{processor: jsonProc}
    pipeline.Execute()

    println("---")

    // 使用 CSV 处理器
    csvProc := &CSVProcessor{}
    pipeline = &DataPipeline{processor: csvProc}
    pipeline.Execute()
}

Saving JSON results: 2 entries
 -  alice
 -  bob
---
Saving CSV results: 3 entries
 -  alice
 -  bob
 -  carol