很多人正在同时查询 gocqlx

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《很多人正在同时查询 gocqlx》，文章讲解的知识点主要包括，如果你对Golang方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

gocqlx 是否有内置方法可以同时执行多个查询？ 我考虑过使用 IN 来选择许多不同的记录，但根据这个答案，使用许多查询比使用 IN 子句更好。

如果 gocqlx 本身不具备并行运行多个查询的能力，我如何才能最有效地实现它？我需要使用它来进行最多 100 个同时查询，并且这个过程可能需要每秒运行最多 10 次，因此每秒大约 100 * 10 = 1000 个查询。

解决方案

关于运行 100 个并发查询的一个建议是生成 100 个 goroutine，然后在它们全部运行后收集它们的结果。我不能说这是否能满足您 1000 qps 的要求，但您可以尝试在您的硬件上以该 qps 进行测试来找出答案。

它看起来像这样（伪代码）：

type queryResult struct { ... }

func doQuery(qry MyQuery, resChan chan queryResult, wg *sync.WaitGroup) {
   result := // do query
   resChan <- result
   wg.Done()
}

// in main:

resChan = make(chan queryResult, len(queries))
var wg sync.WaitGroup

for _, query := range queries {
  go doQuery(query, resChan, &wg)
  wg.Add(1)
}

wg.Wait()
close(resChan)

for res := range resChan {
  // get results
}

如果您不需要结果，可以使用 sync.waitgroup（不带结果通道）来验证所有查询是否已完成。

如果您不想用完与数据库的所有连接，或者出于任何原因您只是不想拥有 1000 个 goroutine，则可以使用此处所述的工作池：https://gobyexample.com/worker-pools

https://godoc.org/github.com/gocql/gocql#Session

典型的使用场景是一个 session 被多个 goroutine 访问。

好了，本文到此结束，带大家了解了《很多人正在同时查询 gocqlx》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！