许多同时查询 gocqlx

Question

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

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

Answer 1

一种可以同时运行 100 个查询的方法的建议是生成 100 个 goroutine，然后在它们全部运行后收集它们的结果。我不能说这是否会满足您的 1000 QPS 要求，但您可以尝试在您的硬件上以该 QPS 测试它以找出答案。这是它的样子（伪代码）：type queryResult struct { ... }func doQuery(qry MyQuery, resChan chan queryResult, wg *sync.WaitGroup) {&nbsp; &nbsp;result := // do query&nbsp; &nbsp;resChan <- result&nbsp; &nbsp;wg.Done()}// in main:resChan = make(chan queryResult, len(queries))var wg sync.WaitGroupfor _, query := range queries {&nbsp; go doQuery(query, resChan, &wg)&nbsp; wg.Add(1)}wg.Wait()close(resChan)for res := range resChan {&nbsp; // get results}如果您不需要结果，您可以sync.WaitGroup不使用结果通道来验证您的所有查询是否已完成。如果您不想用完与数据库的所有连接，或者出于任何原因不想拥有 1000 个 goroutine，则可以使用此处描述的工作池：https ://gobyexample.com/worker-游泳池

Answer 2

https://godoc.org/github.com/gocql/gocql#SessionSession是用户用来与数据库交互的接口。多个 goroutine 并发使用是安全的，典型的使用场景是让一个全局会话对象与整个 Cassandra 集群进行交互。典型的使用场景是一个 Session 被多个 goroutine 访问。