偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《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 示例。我已将其添加到我的主文件中
399446471435但是现在当我运行测试时，在实际测试运行后，发送中断信号时，它失败了。
$ 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知识！
