Go 的并发模型堪称一场革命，但管理复杂的并发操作并非易事。这时，context 的传播与取消机制便成为了强有力的工具。通过这些机制，我们可以构建健壮的、可取消的操作，甚至跨越多个 goroutine 和网络边界。
基础知识
context 包提供了一种方法，用于在 API 边界和进程之间传递截止时间、取消信号以及请求范围的值。这是控制长时间运行操作和优雅关闭服务的关键。
以下是一个使用 context 实现取消操作的简单示例：
func longRunningOperation(ctx context.Context) error {
for {
select {
case <-ctx.Done():
return ctx.Err()
default:
// 执行一些工作
}
}
}
func main() {
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
if err := longRunningOperation(ctx); err != nil {
log.Printf("操作被取消: %v", err)
}
}
在这个示例中，我们创建了一个带有 5 秒超时的 context。如果操作未能在规定时间内完成，它将被自动取消。
跨 goroutine 的取消信号传播
context 的用途不仅限于超时控制，它还可以在多个 goroutine 之间传播取消信号，这在管理复杂工作流时尤为有用。
分布式事务中的应用
假设我们正在构建一个分布式事务系统，其中多个微服务参与同一个事务。如果某个部分失败，我们需要确保整个事务回滚。以下是使用 context 进行设计的示例：
func performTransaction(ctx context.Context) error {
// 开始事务
tx, err := db.BeginTx(ctx, nil)
if err != nil {
return err
}
defer tx.Rollback() // 如果 tx.Commit() 被调用，Rollback 将无效
// 执行多个操作
if err := operation1(ctx); err != nil {
return err
}
if err := operation2(ctx); err != nil {
return err
}
if err := operation3(ctx); err != nil {
return err
}
// 如果所有操作成功，提交事务
return tx.Commit()
}
func operation1(ctx context.Context) error {
req, err := http.NewRequestWithContext(ctx, "GET", "http://service1.example.com", nil)
if err != nil {
return err
}
resp, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
// 处理响应...
return nil
}
在这个示例中，context 被用于在数据库操作和 HTTP 请求之间传播取消信号。如果在任何时间点 context 被取消（例如超时或显式取消），所有操作都会终止，并释放资源。
自定义 Context 类型
如果需要更细粒度的控制，可以创建自定义的 context 类型，携带特定领域的取消信号或数据。例如，以下是一个携带“优先级”值的自定义 context：
type priorityKey struct{}
func WithPriority(ctx context.Context, priority int) context.Context {
return context.WithValue(ctx, priorityKey{}, priority)
}
func GetPriority(ctx context.Context) (int, bool) {
priority, ok := ctx.Value(priorityKey{}).(int)
return priority, ok
}
func priorityAwareOperation(ctx context.Context) error {
priority, ok := GetPriority(ctx)
if !ok {
priority = 0 // 默认优先级
}
// 根据优先级执行不同操作
switch priority {
case 1:
// 高优先级操作
case 2:
// 中优先级操作
default:
// 低优先级操作
}
return nil
}
通过这种方式，我们可以在传播取消信号的同时，传递额外的上下文信息，从而实现更精细的控制。
优雅关闭服务
在构建长时间运行的服务时，正确处理关闭信号至关重要，这可以确保不会留下未完成的操作或未释放的资源。
以下是使用 context 实现优雅关闭的示例：
func main() {
// 创建一个在接收到中断信号时取消的 context
ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt)
defer cancel()
// 启动主服务循环
errChan := make(chan error, 1)
go func() {
errChan <- runService(ctx)
}()
// 等待服务退出或接收到取消信号
select {
case err := <-errChan:
if err != nil {
log.Printf("服务退出时发生错误: %v", err)
}
case <-ctx.Done():
log.Println("接收到关闭信号，正在优雅关闭...")
cleanupCtx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()
if err := performCleanup(cleanupCtx); err != nil {
log.Printf("清理错误: %v", err)
}
}
}
func runService(ctx context.Context) error {
for {
select {
case <-ctx.Done():
return ctx.Err()
default:
// 执行服务逻辑
}
}
}
func performCleanup(ctx context.Context) error {
// 执行必要的清理操作，例如关闭数据库连接、刷新缓冲区等
return nil
}
这种设置确保服务在收到中断信号时能够优雅关闭，清理资源并完成任何正在进行的操作。
跨网络边界的取消信号传播
context 的一个强大功能是能够跨网络边界传播取消信号。这在构建分布式系统时尤为重要，因为操作可能涉及多个服务。
以下是一个示例，展示如何在微服务架构中实现这一点：
func handleRequest(w http.ResponseWriter, r *http.Request) {
timeout, _ := time.ParseDuration(r.URL.Query().Get("timeout"))
if timeout == 0 {
timeout = 10 * time.Second
}
ctx, cancel := context.WithTimeout(r.Context(), timeout)
defer cancel()
results, err := gatherResults(ctx)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
json.NewEncoder(w).Encode(results)
}
func gatherResults(ctx context.Context) ([]string, error) {
var results []string
var mu sync.Mutex
var wg sync.WaitGroup
for _, url := range []string{"http://service1", "http://service2", "http://service3"} {
wg.Add(1)
go func(url string) {
defer wg.Done()
result, err := makeRequest(ctx, url)
if err != nil {
log.Printf("来自 %s 的错误: %v", url, err)
return
}
mu.Lock()
results = append(results, result)
mu.Unlock()
}(url)
}
done := make(chan struct{})
go func() {
wg.Wait()
close(done)
}()
select {
case <-done:
return results, nil
case <-ctx.Done():
return nil, ctx.Err()
}
}
func makeRequest(ctx context.Context, url string) (string, error) {
req, err := http.NewRequestWithContext(ctx, "GET", url, nil)
if err != nil {
return "", err
}
resp, err := http.DefaultClient.Do(req)
if err != nil {
return "", err
}
defer resp.Body.Close()
body, err := ioutil.ReadAll(resp.Body)
if err != nil {
return "", err
}
return string(body), nil
}
在这个示例中，我们根据查询参数创建了一个带超时的 context，并将其传播到所有后续的 API 调用中。如果超时发生，所有正在进行的操作都会被取消，并向客户端返回错误。
结语
掌握 Go 的并发模型，包括 context 的传播与取消机制，是构建健壮、高效、可扩展应用的关键。通过合理使用这些工具，我们可以优雅地处理复杂的工作流、有效管理资源，并智能地应对变化的条件。
然而，context 并非万能工具。过度使用可能导致代码难以理解和维护。请谨慎设计 API，确保 context 的主要用途是传递截止时间、取消信号以及请求范围的值，而非用作通用的参数传递机制。
通过这些实践，你将能够在 Go 的并发编程中游刃有余，为构建高性能系统奠定坚实基础。
