Golang：使用 Go Routines 和 JSON 进行 HTTP 调用和解析 JSON

Question

我对 golang 比较陌生，我想创建一种方法来同时调用多个 URL，并解析 JSON 文档。但是，我真的不确定我是否正确使用了 go 例程和通道。在这一点上，我不确定我是否不正确 "thinking in Go" 或者我的 goroutines 和 channels understanding/approach 是否不准确。

另外，在解析的时候，我想解析body中的results 属性，它是一个数组，results中的每个元素包含一个doc 属性我想过滤掉。

目标是同时执行多个提取，并仅针对响应正文结果数组中的 doc 属性解析响应。

非常感谢任何有助于更好地理解事物的见解或建议。提前致谢。

package operations

import (
    "encoding/json"
    "fmt"
    "io/ioutil"
    "net/http"
    "os"
    "strings"
)

// CouchbaseDoc parses .doc property from sync gateway documents
type CouchbaseDoc struct {
    Doc map[string]string `json:"doc"`
}

// Results deconstruct... results is a property of body, and is an array of obects
type Results struct {
    Results []byte `json:"results"`
}

func createURLs(channels []string) map[string]string {
    urlMap := make(map[string]string)

    domain := "swap" + strings.TrimSpace(os.Getenv("env"))
    bucket := strings.TrimSpace(os.Getenv("bucket"))
    for _, doctype := range channels {
        urlMap[doctype] = fmt.Sprintf("https://%s.endpoint.com/%s/_changes?filter=sync_gateway/bychannel&channels=%s&include_docs=true", domain, bucket, doctype)
    }

    return urlMap
}

func getChangesFeed(url string, ch chan map[string]string) {
    resp, _ := http.Get(url)

    body, _ := ioutil.ReadAll(resp.Body)

    go parseBody(body, ch)
}

func parseBody(body []byte, ch chan map[string]string) {
    var results Results
    var doc CouchbaseDoc
    json.Unmarshal(body, &results)
    json.Unmarshal(results.Results, &doc)
    // write to responses
    ch <- doc.Doc
}

func fetchDocs(channels []string) {
    urls := createURLs(channels)

    // Response channel is where all go routines will do the dirty
    responses := make(chan map[string]string)
    for _, url := range urls {
        go getChangesFeed(url, responses)
    }

    // Read from responses channel
    docs := <-responses
    for doc := range docs {
        fmt.Println(doc) // This should print results ??
    }
}

Answer 1

修复

这一行：

docs := <-responses

只会从频道接收一个元素，而不是所有元素。但是，您可以在通道上每次预期发送时调用一次接收操作，这将是对您的代码最简单的修复：

responses := make(chan map[string]string)
for _, url := range urls {
    go getChangesFeed(url, responses)
}

for x := 0; x < len(urls); x++ {
    fmt.Println(<-responses)
}

可运行的演示

这里有一个完整的、可运行的示例来演示原理：

package main

import(
    "fmt"
    "time"
)

func Sleep1(ch chan int) {
    time.Sleep(time.Second)
    ch <- 1
}

func Sleep3(ch chan int) {
    time.Sleep(time.Second * 3)
    ch <- 3
}

func Sleep5(ch chan int) {
    time.Sleep(time.Second * 5)
    ch <- 5
}

func main() {
    ch := make(chan int)
    go Sleep1(ch)
    go Sleep3(ch)
    go Sleep5(ch)
    for x := 0; x < 3; x++ {
        fmt.Println(<-ch)
    }
}

Golang：使用 Go Routines 和 JSON 进行 HTTP 调用和解析 JSON

Golang: Make HTTP call and parse JSON with Go Routines and JSON

json

channel

go

goroutine

修复

更多信息

可运行的演示