経緯

GoでHTTPのRESTAPIサービスを作っていて、その中でRedisのコネクションをプールして使いまわす機能を作りました。
そうするとやっぱ、サービスが終了（HTTPサーバが停止）するときにコネクションをちゃんと開放しなきゃですよ。

「でも、http.ListenAndServeを実行してるところにdefer funcを仕掛けりゃいいだけッスよね？ちょろいちょろい♪」

とナメていたら…

defer funcが実行されない！！

どうやらos.Exit(code int)が発動すると、deferがかき消されてしまうとのこと。なんてこったい

そこで見つけたのがこちらになります。

用例

例えばこんな感じで、シグナルを受け取ったときに発動するコールバック関数に、好きな後始末処理を仕込むだけ

私の場合は、プールしてるRedisのコネクションをClose()してます。

package main

import (
	"context"
	"fmt"
	"github.com/go-redis/redis"
	"net/http"
	"os"
	"github.com/nasa9084/syg"
)

var pooledKVSConnectionsMap = make(map[*redis.Options]*redis.Client)

func main() {
	s := &http.Server{Addr: ":8080"}
	waitCh := make(chan struct{})

	cancel := syg.Listen(func(os.Signal) {
		s.Shutdown(context.Background())
		destruct() // <--- 仕込み！
		close(waitCh)
	}, os.Interrupt)
	defer cancel()

	if err := s.ListenAndServe(); err != http.ErrServerClosed {
		fmt.Print("listening server error:" + err.Error())
	}
	<-waitCh
}

func destruct() {
	for _, kvsCon := range pooledKVSConnectionsMap {
		cerr := kvsCon.Close()
		if cerr != nil {
			fmt.Print(cerr)
		} else {
			fmt.Print(kvsCon, " ... closed.")
		}
	}
}

ご注意

github.com/nasa9084/sygのREADME.mdがちょっと古いのか、そちらの例ではdefer cancel()のコードが抜けているので、作者様サイトの例コードやsyg_example_test.goなどを参照されると良いかと思います。

さいごに

・・・
というか、そもそも間違ってました・・・

いえ、この記事そのものではないのですが、go-redis/redisはあらかじめコネクションプールの仕組みを内包しており、使い手側は気にせずNewClient(), Close()をして良いそうです

実際goroutineを使ってNewClient(), Close()を毎度呼ぶコードと比較したのですが、全く問題ありませんでした。

・・・まあ、勉強になったからよし！