我的编程空间,编程开发者的网络收藏夹
学习永远不晚

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

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

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 示例。我已将其添加到我的主文件中

3994464714​​35

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

$  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知识!

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

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

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

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

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

服务器使用UDP通讯127.0.0.1测试成功连接服务器却通讯失败

首先看看本人情况 解释一下: 1:左边窗口是模拟服务程序,功能是收到消息后把消息打印出来,并把收到的消息再发回给发送消息的主机 2:右边窗口是模拟客户程序,功能是将输入的消息发送给服务程序的主机,并将接收的消息打印出来 3:程序均采用的是
2023-08-22

亚马逊测试服务器连接失败怎么回事儿

1.检查硬件故障:检查连接到亚马逊测试服务器的硬件设备是否正常工作,例如网卡、调制解调器、交换机等。2.检查网络故障:检查网络连接是否正常,确保您的设备与网络连接可靠,如果网络连接不稳定,可能会导致连接失败。3.检查软件配置:检查您的操作系统和应用程序是否安装正确,并且没有禁用不必要的服务和功能。4.升级软件:如果您的设备已经安装了新的软件,可能会影响连接性能,您可以尝试升级软件以解决问题。5.检查应用程序...
2023-10-27

编程热搜

  • Python 学习之路 - Python
    一、安装Python34Windows在Python官网(https://www.python.org/downloads/)下载安装包并安装。Python的默认安装路径是:C:\Python34配置环境变量:【右键计算机】--》【属性】-
    Python 学习之路 - Python
  • chatgpt的中文全称是什么
    chatgpt的中文全称是生成型预训练变换模型。ChatGPT是什么ChatGPT是美国人工智能研究实验室OpenAI开发的一种全新聊天机器人模型,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,并协助人类完成一系列
    chatgpt的中文全称是什么
  • C/C++中extern函数使用详解
  • C/C++可变参数的使用
    可变参数的使用方法远远不止以下几种,不过在C,C++中使用可变参数时要小心,在使用printf()等函数时传入的参数个数一定不能比前面的格式化字符串中的’%’符号个数少,否则会产生访问越界,运气不好的话还会导致程序崩溃
    C/C++可变参数的使用
  • css样式文件该放在哪里
  • php中数组下标必须是连续的吗
  • Python 3 教程
    Python 3 教程 Python 的 3.0 版本,常被称为 Python 3000,或简称 Py3k。相对于 Python 的早期版本,这是一个较大的升级。为了不带入过多的累赘,Python 3.0 在设计的时候没有考虑向下兼容。 Python
    Python 3 教程
  • Python pip包管理
    一、前言    在Python中, 安装第三方模块是通过 setuptools 这个工具完成的。 Python有两个封装了 setuptools的包管理工具: easy_install  和  pip , 目前官方推荐使用 pip。    
    Python pip包管理
  • ubuntu如何重新编译内核
  • 改善Java代码之慎用java动态编译

目录