Go gRPC 服务器使集成测试失败

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《Go gRPC 服务器使集成测试失败》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

我最近又开始玩 go，目前的任务是实现一个服务（将在 k8s 上运行），该服务应充当 grpc 服务器。

根据要求，目前，为了满足 k8s 上的 readinessprobe，我需要为我的服务实现一个运行状况检查端点，并且应该对此进行测试：我所做的是：

func main() {
    server := starthttpserver()
    defer server.close()

    c := make(chan os.signal, 1)
    signal.notify(c, os.interrupt, syscall.sigterm, syscall.sigint)

    <-c
    log.println("stopped")
}

func starthttpserver() *http.server {
    http.handlefunc("/", func(w http.responsewriter, r *http.request) {
        w.writeheader(http.statusok)
    })

    server := &http.server{
        addr: net.joinhostport("", strconv.itoa(livelinessport)),
    }

    go server.listenandserve()

    return server
}

我按照这篇文章以这种方式进行了测试：

func testmain(m *testing.m) {
    flag.parse()

    wg := setup()

    result := m.run()

    shutdown(wg)

    os.exit(result)
}

func shutdown(wg *sync.waitgroup) {
    syscall.kill(syscall.getpid(), syscall.sigint)
    wg.wait()
}

func setup() *sync.waitgroup{
    os.setenv("app_env", envtest)

    wg := &sync.waitgroup{}
    startmainprocess(wg)
    return wg
}

func startmainprocess(wg *sync.waitgroup) {
    go func() {
        wg.add(1)
        defer wg.done()
        main()
    }()
}

func testk8shealth(t *testing.t) {
    res, err := http.get("http://:8080/")
    if err != nil {
        t.errorf("unexpected api error: %s", err)
        return
    }

    defer res.body.close()

    if res.statuscode != http.statusok {
        t.errorf("unexpected status code: %d", res.statuscode)
        return
    }
}

到目前为止一切顺利：

$ go test
pass
2018/08/13 09:23:16 stopped
ok      github.com/...        0.015s

问题是当我尝试在主应用程序中添加 grpc 服务器时，遵循 gprc go 示例。我已将其添加到我的主文件中

但是现在当我运行测试时，在实际测试运行后，发送中断信号时，它失败了。

$  go test 
pass
signal: interrupt
fail    github.com/...        0.016s

我做了一些测试，这并不取决于实际测试（因为它通过了一个测试函数，即 return，并且它在使用 goland 运行测试套件时工作：

goroot=/usr/local/go #gosetup
gopath=/users/marco/documents/projects/go #gosetup
/usr/local/go/bin/go test -c -i -o /private/var/folders/jh/znhv9f090yb7y390dckb23s00000gn/t/[...] #gosetup
/usr/local/go/bin/go tool test2json -t /private/var/folders/jh/znhv9f090yb7y390dckb23s00000gn/t/[...] -test.v -test.run
^testk8shealth$ #gosetup
=== run   testk8shealth
--- pass: testk8shealth (0.00s)
pass

process finished with exit code 1

--- 编辑

我发现问题出在监听器周围。主函数中有：

func main() {
    net.listen("tcp", fmt.sprintf(":%d", serverport))
    c := make(chan os.signal, 1)
    signal.notify(c, os.interrupt, syscall.sigterm, syscall.sigint)

    <-c
    log.println("stopped")
}

并且仅包含返回值的测试（与前一个测试具有相同的设置）将导致测试失败：

$ go test -v
=== RUN   Test2
--- PASS: Test2 (0.00s)
PASS
signal: interrupt
FAIL    github.com/[...]        0.014s

解决方案

grpcServer.Serve(lis) 是阻塞调用。因此，就像您对 HTTP 服务器 go server.ListenAndServe() 所做的那样，您需要在 goroutine 中运行它。您能否尝试一下 go grpcServer.Serve(lis) 是否能够通过测试？

我不确定您的新编辑是否表明问题与侦听器有关。您可以检查 net.Listen("tcp", fmt.Sprintf(":%d", serverPort)) 是否返回或阻塞。

好了，本文到此结束，带大家了解了《Go gRPC 服务器使集成测试失败》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！