# 对象存储 — 阿里云 OSS
go get github.com/LingByte/ling-base/stores/oss

# OCR — 腾讯云
go get github.com/LingByte/ling-base/providers/ocr/qcloud

# 内容审核 — 七牛
go get github.com/LingByte/ling-base/providers/censor/qiniu

# 消息队列 — RabbitMQ
go get github.com/LingByte/ling-base/common/mq/rabbitmq

import (
    "bytes"
    "github.com/LingByte/ling-base/stores"
    "github.com/LingByte/ling-base/stores/oss"
)

store, _ := oss.New(oss.Config{
    Endpoint:        "oss-cn-hangzhou.aliyuncs.com",
    AccessKeyID:     "...",
    AccessKeySecret: "...",
    Bucket:          "my-bucket",
})

key := "uploads/2026/photo.jpg"
_ = store.Write(key, bytes.NewReader(imageBytes))

rc, size, _ := store.Read(key)
defer rc.Close()

url, _ := stores.SignedURL(store, key, time.Hour) // 私有桶临时链接

import (
    "github.com/LingByte/ling-base/providers/ocr"
    "github.com/LingByte/ling-base/providers/ocr/aliyun"
)

p := aliyun.NewFromEnv()
ocr.RegisterProvider("aliyun", p)
_ = ocr.SetProviderByDriver("aliyun")

text, err := ocr.GetProvider().Recognize(ctx, imageBytes, &ocr.Options{Language: "zh"})

import qiniu "github.com/LingByte/ling-base/providers/censor/qiniu"

c, _ := qiniu.NewTextCensor(qiniu.Config{AccessKey: "...", SecretKey: "..."})
result, _ := c.CensorText(ctx, userComment)
if result.Suggestion == "block" {
    return ErrBlocked
}

import (
    "github.com/LingByte/ling-base/common/mq"
    "github.com/LingByte/ling-base/common/mq/factory"
    "github.com/LingByte/ling-base/common/mq/rabbitmq"
)

broker, _ := factory.NewBroker(mq.BrokerConfig{
    Type: mq.BrokerRabbitMQ,
    RabbitMQConfig: &rabbitmq.Config{URL: "amqp://guest:guest@localhost:5672/"},
})
_ = broker.Connect()
defer broker.Close()

producer, _ := broker.Producer("events", mq.PublishOptions{})
_ = producer.Publish(ctx, &mq.Message{Body: []byte(`{"event":"order.created"}`)})