当前位置:首页 > 文章列表 > Golang > Go问答 > 改为:为何 net.Conn.close() 在不恰当的时机关闭?

改为:为何 net.Conn.close() 在不恰当的时机关闭?

来源:stackoverflow 2024-03-18 19:18:36 0浏览 收藏

**为什么 net.Conn.close() 在不恰当时机关闭?** 在使用 Go 语言编写 TCP 客户端程序时,开发者可能遇到 net.Conn.close() 在不恰当的时机关闭连接的问题。这会导致客户端无法与服务器通信,即使程序仍在运行。 问题的原因在于 Go 语言中的 goroutine 是异步执行的。在主函数中调用 go handleconn(conn) 后,主函数继续执行并关闭连接,而 handleconn 函数仍在后台运行。因此,在 handleconn 函数完成其工作之前,连接就被关闭了。 为了解决这个问题,开发者需要将 conn.close() 调用移到 handleconn 函数内,确保在 handleconn 函数完成其工作后才关闭连接。此外,开发者还可以通过使用通道或其他同步机制来确保主函数在 handleconn 函数完成工作之前不会继续执行。

问题内容

我正在尝试从 tcp 客户端读取和写入一些命令。我想在执行最后一个函数后关闭连接,但由于某种原因,即使在之后显式放置,服务器似乎也会在函数中间断开连接。

package main
    
    import (
        "bufio"
        "fmt"
        "io"
        "log"
        "net"
        "strconv"
        "strings"
        "time"
    )
    
    
    
    func main() {
        listener, err := net.listen("tcp", "localhost:8000")
        if err != nil {
            log.fatal(err)
        }
        for {
            conn, err := listener.accept()
            if err != nil {
                log.print(err)
            }
            go handleconn(conn)
            conn.close()
        }
    
    }
    
    func handleconn(someconnection net.conn) {
        func1(someconnection)
        func2(someconnection) //connection drops in the middle of executing this part
    }
func func2(someconnection net.conn) {

    //send message(a string)
    _, err := io.writestring(someconnection, dosomething)
    if err != nil {
        log.fatal(err)
    }
    //await reply
    //send another message
    _, err = io.writestring(someconnection, dosomething)
    if err != nil {
        log.fatal(err)
    }
   //await reply

    //send another message, connection tends to close somewhere here
    _, err = io.writestring(someconnection, dosomething)
    if err != nil {
        log.fatal(err)
    }

    //await,send
    _, err = io.writestring(someconnection, do something)
    if err != nil {
        log.fatal(err)
    }

    //await, read and print message
    c := bufio.newreader(someconnection)
    buff1 := make([]byte, maxclientmessagelength)
    buff1, err = c.readbytes(delimiter)

    fmt.printf("\n%s\n", buff1)

    _, err = io.writestring(someconnection, dosomething)
    if err != nil {
        log.fatal(err)
    }
}

这意味着试图向后通信的客户端根本无法通信,但程序会运行到最后。

更新 1:

通过将延迟关闭语句放置在首次获取连接时取得了一些进展。

func main() {
listener, err := net.Listen("tcp", "localhost:8000")
if err != nil {
    log.Fatal(err)
}
for {
    conn, err := listener.Accept()
    if err != nil {
        log.Print(err)
    }
    defer conn.Close()
    go handleConn(conn)
}}

现在它不一定会在我希望它关闭的那一秒内关闭,但至少现在它会一直运行。


正确答案


goroutines 是异步的,因此在此处调用 handleconn 后:

go handleconn(conn)
conn.close()

main函数继续执行并关闭连接。 尝试定期调用handleconn函数(不使用go)。

conn.close需要在handleconn完成其工作后完成。您可以使用通道与主线程进行通信,但这会太复杂(并且还会阻止主线程的执行)。应该这样做

func main() {
    listener, err := net.listen("tcp", "localhost:8000")
    if err != nil {
        log.fatal(err)
    }
    for {
        conn, err := listener.accept()
        if err != nil {
            log.print(err)
        }
        go handleconn(conn)
        // remove below line
        // conn.close()
    }
}

handleconn内添加conn.close

func handleConn(someconnection net.Conn) {
    // ADD BELOW LINE
    defer someconnection.Close()
    func1(someconnection)
    func2(someconnection)
}

这确保 conn.closefunc1func2 执行完毕后被调用

今天关于《改为:为何 net.Conn.close() 在不恰当的时机关闭?》的内容就介绍到这里了,是不是学起来一目了然!想要了解更多关于的内容请关注golang学习网公众号!

版本声明
本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
字符串模板和函数连接字符串模板和函数连接
上一篇
字符串模板和函数连接
在 for 循环初始化中使用 uint8 声明的方法
下一篇
在 for 循环初始化中使用 uint8 声明的方法
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    542次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    511次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    498次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    484次学习
查看更多
AI推荐
  • 千音漫语:智能声音创作助手,AI配音、音视频翻译一站搞定!
    千音漫语
    千音漫语,北京熠声科技倾力打造的智能声音创作助手,提供AI配音、音视频翻译、语音识别、声音克隆等强大功能,助力有声书制作、视频创作、教育培训等领域,官网:https://qianyin123.com
    164次使用
  • MiniWork:智能高效AI工具平台,一站式工作学习效率解决方案
    MiniWork
    MiniWork是一款智能高效的AI工具平台,专为提升工作与学习效率而设计。整合文本处理、图像生成、营销策划及运营管理等多元AI工具,提供精准智能解决方案,让复杂工作简单高效。
    159次使用
  • NoCode (nocode.cn):零代码构建应用、网站、管理系统,降低开发门槛
    NoCode
    NoCode (nocode.cn)是领先的无代码开发平台,通过拖放、AI对话等简单操作,助您快速创建各类应用、网站与管理系统。无需编程知识,轻松实现个人生活、商业经营、企业管理多场景需求,大幅降低开发门槛,高效低成本。
    166次使用
  • 达医智影:阿里巴巴达摩院医疗AI影像早筛平台,CT一扫多筛癌症急慢病
    达医智影
    达医智影,阿里巴巴达摩院医疗AI创新力作。全球率先利用平扫CT实现“一扫多筛”,仅一次CT扫描即可高效识别多种癌症、急症及慢病,为疾病早期发现提供智能、精准的AI影像早筛解决方案。
    168次使用
  • 智慧芽Eureka:更懂技术创新的AI Agent平台,助力研发效率飞跃
    智慧芽Eureka
    智慧芽Eureka,专为技术创新打造的AI Agent平台。深度理解专利、研发、生物医药、材料、科创等复杂场景,通过专家级AI Agent精准执行任务,智能化工作流解放70%生产力,让您专注核心创新。
    179次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码