如何在Golang中使用适配器模式_兼容不同接口的数据操作-Golang-PHP中文网

如何在Golang中使用适配器模式_兼容不同接口的数据操作

P粉602998670

发布： 2025-12-20 20:35:22

原创

153人浏览过

Go中适配器模式通过结构体嵌入或函数封装实现接口兼容，用于对接第三方库、迁移旧代码等；需保持职责单一，仅做协议转换，避免掺杂业务逻辑。

如何在golang中使用适配器模式_兼容不同接口的数据操作

在 Go 中实现适配器模式，核心是通过结构体嵌入或函数封装，让不兼容的接口“能一起工作”。它不改变原有类型，而是提供一个中间层，把旧接口的行为转换成新接口期望的样子——特别适合对接第三方库、迁移旧代码或统一多数据源操作。

用结构体嵌入实现接口适配

当已有类型实现了部分方法，但目标接口要求更多/不同的方法时，可定义新结构体，嵌入原类型，并补全缺失方法。

例如：你有一个 CSVReader 类型，只实现了 ReadLine() (string, error)，但业务需要满足通用的 DataReader 接口（含 Next() map[string]interface{} 和 Close()）：

// 原有类型
type CSVReader struct {
    file *os.File
    // ...
}
<p>func (c <em>CSVReader) ReadLine() (string, error) { /</em> ... */ }</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">go语言免费学习笔记（深入）</a>”；</p>
                    <div class="aritcle_card">
                        <a class="aritcle_card_img" href="/ai/1733">
                            <img src="https://img.php.cn/upload/ai_manual/000/969/633/68b6d1ec912e3543.png" alt="Spirit Me">
                        </a>
                        <div class="aritcle_card_info">
                            <a href="/ai/1733">Spirit Me</a>
                            <p>SpiritMe允许用户使用数字化身制作视频，这些化身可以模拟用户的声音和情感</p>
                            <div class="">
                                <img src="/static/images/card_xiazai.png" alt="Spirit Me">
                                <span>178</span>
                            </div>
                        </div>
                        <a href="/ai/1733" class="aritcle_card_btn">
                            <span>查看详情</span>
                            <img src="/static/images/cardxiayige-3.png" alt="Spirit Me">
                        </a>
                    </div>
                <p>// 目标接口
type DataReader interface {
Next() map[string]interface{}
Close() error
}</p><p>// 适配器：嵌入 + 补方法
type CSVAdapter struct {
*CSVReader
headers []string // 缓存表头
}</p><p>func (a *CSVAdapter) Next() map[string]interface{} {
line, err := a.ReadLine()
if err != nil || line == "" {
return nil
}
fields := strings.Split(line, ",")
row := make(map[string]interface{})
for i, v := range fields {
if i < len(a.headers) {
row[a.headers[i]] = strings.TrimSpace(v)
}
}
return row
}</p><p>func (a *CSVAdapter) Close() error {
return a.CSVReader.file.Close()
}

登录后复制

用函数式适配器解耦调用逻辑

当适配逻辑简单、或需动态切换行为时，直接返回闭包更轻量。尤其适合将回调函数、HTTP 处理器、日志写入等“行为”对齐统一接口。

比如把不同数据库驱动的查询函数，统一为 QueryFunc 类型：

type QueryFunc func(ctx context.Context, sql string, args ...interface{}) ([]map[string]interface{}, error)
<p>// 适配 MySQL 驱动（返回 <em>sql.Rows）
func MySQLToQueryFunc(db </em>sql.DB) QueryFunc {
return func(ctx context.Context, sql string, args ...interface{}) ([]map[string]interface{}, error) {
rows, err := db.QueryContext(ctx, sql, args...)
if err != nil {
return nil, err
}
defer rows.Close()
return scanRowsToMap(rows)
}
}</p><p>// 适配 Redis 的 HGETALL 结果（返回 []string）
func RedisHashToQueryFunc(client *redis.Client, key string) QueryFunc {
return func(ctx context.Context, <em> string, </em> ...interface{}) ([]map[string]interface{}, error) {
vals, err := client.HGetAll(ctx, key).Result()
if err != nil {
return nil, err
}
m := make(map[string]interface{})
for k, v := range vals {
m[k] = v
}
return []map[string]interface{}{m}, nil
}
}

登录后复制