Golang如何开发基础的RSS订阅服务_Golang RSS订阅服务实践

答案：Go语言可通过标准库快速构建RSS订阅服务，定义RSS、Channel、Item等结构体解析XML内容，利用http.Get获取源数据并用xml.Unmarshal解析；通过net/http实现添加、列出订阅源的REST API；使用time.Ticker定时轮询更新，主函数注册路由并启动服务，后续可扩展持久化与推送功能。

构建一个基础的 RSS 订阅服务在 Go 语言中非常直观，得益于其标准库对 HTTP 和 XML 的良好支持。通过简单的路由、结构体定义和定时任务机制，就能实现一个可扩展的轻量级 RSS 聚合器。

定义数据结构与 RSS 解析

RSS 是基于 XML 的格式，因此需要先定义对应的结构体来解析内容。Go 的 encoding/xml 包可以直接将 RSS 源映射为结构体。

type RSS struct {
    XMLName xml.Name `xml:"rss"`
    Channel Channel  `xml:"channel"`
}
type Channel struct {
Title       string xml:"title"
Link        string xml:"link"
Description string xml:"description"
Items       []Item xml:"item"
}
type Item struct {
Title       string xml:"title"
Link        string xml:"link"
Description string xml:"description"
PubDate     string xml:"pubDate"
}

使用 http.Get 获取 RSS 源内容，再用 xml.Unmarshal 解析：

resp, err := http.Get(feedURL)
if err != nil {
    return nil, err
}
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
var rss RSS
err = xml.Unmarshal(body, &rss)
if err != nil {
return nil, err
}
return &rss, nil

实现订阅管理接口

使用 net/http 实现简单的 REST 风格 API，支持添加、列出订阅源。

立即学习“go语言免费学习笔记（深入）”；

var feeds []string
func addFeed(w http.ResponseWriter, r *http.Request) {
url := r.URL.Query().Get("url")
if url == "" {
http.Error(w, "missing url", http.StatusBadRequest)
return
}
feeds = append(feeds, url)
fmt.Fprintf(w, "Added: %s", url)
}

列出所有订阅源及其最新条目：

ClipDrop Relight

ClipDrop推出的AI图片图像打光工具

下载

func listFeeds(w http.ResponseWriter, r *http.Request) {
    var results []map[string]interface{}
    for _, url := range feeds {
        feed, err := fetchRSS(url)
        if err != nil {
            continue
        }
        results = append(results, map[string]interface{}{
            "source": url,
            "title":  feed.Channel.Title,
            "items":  feed.Channel.Items[:min(5, len(feed.Channel.Items))],
        })
    }
    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(results)
}

定时拉取更新（轮询机制）

使用 time.Ticker 定期抓取所有订阅源，避免手动刷新。

func startPolling() {
    ticker := time.NewTicker(30 * time.Minute)
    go func() {
        for range ticker.C {
            for _, url := range feeds {
                feed, err := fetchRSS(url)
                if err != nil {
                    log.Printf("failed to fetch %s: %v", url, err)
                    continue
                }
                // 可以在这里做去重、存储或通知
                processNewItems(feed.Channel.Items)
            }
        }
    }()
}

注意：实际项目中建议引入缓存（如内存 map 或 Redis）记录已处理的 item GUID 或链接，防止重复推送。

启动服务并注册路由

主函数中注册处理函数并启动服务器：

func main() {
    http.HandleFunc("/add", addFeed)
    http.HandleFunc("/feeds", listFeeds)
startPolling()

fmt.Println("Server starting on :8080")
http.ListenAndServe(":8080", nil)

}

运行后可通过浏览器或 curl 添加源：
curl "http://localhost:8080/add?url=https://example.com/feed"
基本上就这些。这个基础版本展示了如何用 Go 快速搭建 RSS 订阅服务的核心功能。后续可扩展数据库持久化、用户系统、Webhook 推送或生成自己的聚合 RSS 输出。不复杂但容易忽略的是错误处理和网络超时设置，生产环境建议加上 context 超时控制和重试机制。