Go语言RSS/Atom解析：go-pkg-rss库标题获取异常及替代方案

package main

import (
    "fmt"
    rss "github.com/jteeuwen/go-pkg-rss"
    "net/http"
    "os"
)

var items []*rss.Item
var channels []*rss.Channel

// chanHandler 处理新的频道信息
func chanHandler(feed *rss.Feed, newchannels []*rss.Channel) {
    channels = newchannels
}

// itemHandler 处理新的条目信息
func itemHandler(feed *rss.Feed, ch *rss.Channel, newitems []*rss.Item) {
    // 注意：这里直接覆盖了全局的items变量，实际应用中可能需要更复杂的合并逻辑
    items = newitems
}

// hello 是HTTP请求的处理函数
func hello(w http.ResponseWriter, r *http.Request) {
    // 初始化rss解析器，设置回调函数
    feed := rss.New(5, true, chanHandler, itemHandler)
    url := "http://stackoverflow.com/feeds" // Stack Overflow 的 Atom 订阅源

    // 抓取订阅源
    err := feed.Fetch(url, nil)
    if err != nil {
        fmt.Fprintf(w, "Error fetching feed: %v\n", err)
        return
    }

    fmt.Printf("Sent fetch for %s\n", url)
    fmt.Fprintf(w, "There are %d items in %s\n\n", len(items), url)

    // 遍历并打印条目标题
    for key, value := range items {
        fmt.Fprintf(w, "%d: %s\n\n", key, value.Title)
    }
}

func main() {
    http.HandleFunc("/", hello)
    port := os.Getenv("PORT")
    if port == "" {
        port = "8080" // 默认端口
    }
    fmt.Printf("Server listening on :%s\n", port)
    http.ListenAndServe(":"+port, nil)
}

package main

import (
    "fmt"
    "github.com/SlyMarbo/rss" // 引入新的RSS库
    "net/http"
    "os"
)

// hello 是HTTP请求的处理函数
func hello(w http.ResponseWriter, r *http.Request) {
    url := "http://stackoverflow.com/feeds" // Stack Overflow 的 Atom 订阅源

    // 使用SlyMarbo/rss库直接抓取并解析订阅源
    feed, err := rss.Fetch(url)
    if err != nil {
        fmt.Fprintf(w, "Error fetching feed: %v\n", err)
        return
    }

    fmt.Printf("Sent fetch for %s\n", url)
    fmt.Fprintf(w, "There are %d items in %s\n\n", len(feed.Items), url)

    // 遍历并打印条目标题
    for key, value := range feed.Items {
        fmt.Fprintln(w, key, value.Title) // 使用Fprintln更简洁
    }
}

func main() {
    http.HandleFunc("/", hello)
    port := os.Getenv("PORT")
    if port == "" {
        port = "8080" // 默认端口
    }
    fmt.Printf("Server listening on :%s\n", port)
    http.ListenAndServe(":"+port, nil)
}