如何在Golang中使用net包实现TCP通信

使用net包实现TCP通信,服务器通过net.Listen监听端口,accept连接后用goroutine处理;客户端用net.Dial连接,通过Read/Write收发数据,注意消息边界与错误处理。

如何在golang中使用net包实现tcp通信

在Golang中,net包提供了对网络I/O的支持,包括TCP、UDP和Unix域套接字等。实现TCP通信主要依赖于net.Listennet.Dial两个核心函数。下面介绍如何使用net包完成一个简单的TCP客户端与服务器通信。

创建TCP服务器

TCP服务器需要监听指定的地址和端口,等待客户端连接。每当有新连接建立时,启动一个协程处理该连接,保证服务器可以同时服务多个客户端。

示例代码:

package mainimport (    "bufio"    "fmt"    "net"    "strings")func main() {    // 监听本地8080端口    listener, err := net.Listen("tcp", ":8080")    if err != nil {        fmt.Println("监听失败:", err)        return    }    defer listener.Close()    fmt.Println("服务器已启动,监听 :8080...")    for {        // 接受客户端连接        conn, err := listener.Accept()        if err != nil {            fmt.Println("接受连接失败:", err)            continue        }        // 启动协程处理连接        go handleConnection(conn)    }}func handleConnection(conn net.Conn) {    defer conn.Close()    scanner := bufio.NewScanner(conn)    for scanner.Scan() {        message := strings.TrimSpace(scanner.Text())        fmt.Printf("收到消息: %sn", message)        // 回显消息给客户端        response := fmt.Sprintf("你发送的是: %sn", message)        conn.Write([]byte(response))    }}

创建TCP客户端

客户端通过net.Dial连接到服务器,然后可以发送数据并读取响应。

示例代码:

package mainimport (    "bufio"    "fmt"    "net"    "os")func main() {    // 连接到本地8080端口    conn, err := net.Dial("tcp", "127.0.0.1:8080")    if err != nil {        fmt.Println("连接失败:", err)        return    }    defer conn.Close()    fmt.Println("已连接到服务器")    // 从标准输入读取用户输入    input := bufio.NewScanner(os.Stdin)    for {        fmt.Print("请输入消息: ")        if !input.Scan() {            break        }        line := input.Text()        if line == "quit" {            break        }        // 发送数据到服务器        _, err := conn.Write([]byte(line + "n"))        if err != nil {            fmt.Println("发送失败:", err)            break        }        // 读取服务器响应        buffer := make([]byte, 1024)        n, err := conn.Read(buffer)        if err != nil {            fmt.Println("读取响应失败:", err)            break        }        fmt.Printf("服务器回复: %s", string(buffer[:n]))    }}

运行说明

先启动服务器程序,再运行客户端。客户端输入任意文本后,服务器会回显处理结果。输入quit可退出客户端。

立即学习“go语言免费学习笔记(深入)”;

服务器使用net.Listen("tcp", ":8080")监听所有IP的8080端口每个连接由独立的goroutine处理,避免阻塞其他客户端客户端通过net.Dial发起连接,并使用WriteRead进行通信注意:TCP是字节流协议,需自行处理消息边界(本例以换行符分隔)基本上就这些。不复杂但容易忽略细节,比如连接关闭和错误处理。

以上就是如何在Golang中使用net包实现TCP通信的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1416028.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月16日 10:08:34
下一篇 2025年12月16日 10:08:42

相关推荐

  • 如何在Golang中使用匿名结构体

    匿名结构体无需预先定义类型,可直接声明使用。user := struct { Name string Age int }{ Name: “Alice”, Age: 30 },适用于临时数据场景;在切片中结合使用如 users := []struct { ID int Emai…

    好文分享 2025年12月16日
    000
  • 如何在Golang中实现微服务错误监控

    通过zap记录错误日志并在中间件中捕获panic;2. 使用OpenTelemetry注入trace_id实现链路追踪;3. 上报error_count至Prometheus并用Sentry收集异常;4. 实现/health接口与告警规则,结合Alertmanager通知。 在Golang中实现微服…

    2025年12月16日
    000
  • 如何在Golang中使用text/template渲染模板

    Golang的text/template用于动态生成文本,支持数据绑定、条件循环控制、自定义函数及模板嵌套。通过{{.}}引用数据,if/range实现逻辑判断与遍历,FuncMap注册函数如upper,define/template实现模块化复用,适用于配置、日志等文本生成场景。 在Golang中…

    2025年12月16日
    000
  • 如何在Golang中实现文件流传输

    使用io.Copy配合os.File与网络连接实现Golang文件流传输,避免内存溢出。通过HTTP可直接用http.ServeFile或手动设置响应头并流式输出;TCP场景下服务端监听接收连接后发送文件,客户端读取写入本地。示例代码展示HTTP下载处理器及TCP收发逻辑。默认32KB缓冲区可通过i…

    2025年12月16日
    000
  • Go 语言中字符、字节与数字转换的机制解析

    本文深入探讨 go 语言中字符、字节和数字之间的转换机制。通过分析 `stringofdigits[column] – ‘0’` 表达式,揭示了 go 如何将字符串索引得到的字节值与字符字面量进行算术运算,从而高效地提取数字。文章还区分了 `byte`、`rune…

    2025年12月16日
    000
  • Go 语言中高效管理临时存储:缓冲区复用与内存优化

    本文探讨了在 Go 语言中,当包内部需要大量使用缓冲区进行临时存储时,如何避免因用户不再使用包而导致的内存浪费问题。文章分析了几种常见的解决方案,并推荐了通过客户端传递缓冲区或使用缓存/池来管理缓冲区的方法,旨在降低 GC 压力,提升程序性能。 在 Go 语言开发中,尤其是在编写需要处理大量数据的包…

    2025年12月16日
    000
  • Go HTTP服务器中Goroutine与文件服务最佳实践

    本文深入探讨了在go语言http服务器中不当使用goroutine处理文件请求时遇到的常见问题,即响应提前发送导致空白页。文章详细解释了http处理器同步返回的机制,并指出了`ioutil.readfile`的潜在性能瓶颈。随后,提供了两种高效、规范的文件服务解决方案:利用`os.open`和`io…

    2025年12月16日
    000
  • 如何在Golang中实现文件读取缓存优化

    使用sync.Map实现内存缓存,首次读取文件后将内容存入缓存,后续请求直接从内存获取以减少I/O;通过cachedFile结构体添加TTL过期机制防止内存泄漏;根据文件类型选择缓存策略,配置文件可长时缓存并提供手动刷新,动态文件则短TTL或不缓存;大文件可分块缓存热点部分;推荐使用go-cache…

    2025年12月16日
    000
  • Go 包内部缓冲区管理最佳实践:优化内存分配与GC负载

    本文探讨go包内部高效管理缓冲区分配的策略,旨在避免内存浪费和降低垃圾回收(gc)压力。核心方案包括允许调用方提供缓冲区,以实现内存复用和外部控制;以及采用缓冲区池化技术,通过集中管理和回收来提升程序性能和内存利用率。 引言:Go 包内部缓冲区管理的挑战 在开发高性能的 Go 包时,内部对临时存储(…

    2025年12月16日
    000
  • Golang 并发安全地读取带互斥锁的哈希表

    本文旨在探讨在 Golang 中,如何并发安全地从一个带有互斥锁的哈希表中读取数据,避免数据竞争。文章将详细解释数据竞争的概念,并提供使用读写互斥锁(`sync.RWMutex`)的正确方法,以确保在读取哈希表时不会阻塞写入操作,从而提高程序的并发性能和数据一致性。 在并发编程中,当多个 gorou…

    2025年12月16日
    000
  • Go语言中将函数返回值作为条件判断表达式:正确实践与技巧

    本文探讨了在go语言中如何将函数的返回值作为`if`语句的条件表达式。核心在于确保作为条件的函数必须返回一个布尔类型的值。通过示例代码,文章详细阐述了正确的函数签名和调用方式,并提供了相关最佳实践,以帮助开发者编写出更清晰、更符合go语言习惯的条件逻辑,尤其适用于http请求处理等场景中的权限或状态…

    2025年12月16日
    000
  • 使用高效方法在 Go 语言中迭代数组并创建字符串

    本文介绍了在 Go 语言中如何更高效地迭代数组并从数组元素的值创建字符串。通过使用 `bytes.Buffer` 或 `[]byte` 切片,可以避免字符串连接带来的多次内存分配,从而提高代码性能。文章提供了详细的代码示例,展示了两种优化方案的具体实现,并分析了其优势。 在 Go 语言中,当需要遍历…

    2025年12月16日
    000
  • Go语言中大规模数据流的JSON编码策略:避免内存溢出

    本文探讨了在go语言中对大规模数据流(特别是来自通道的数据)进行json编码的策略,旨在避免一次性将所有数据加载到内存中。我们将介绍一种当前最实用的手动流式编码方法,并深入探讨通过修改encoding/json标准库实现原生支持的可能性,以帮助开发者高效处理大型数据集。 在Go语言中处理大规模数据流…

    2025年12月16日
    000
  • Golang如何在Linux中配置Go workspace

    Go语言从1.11起推荐使用Go Modules,GOPATH模式主要用于旧项目;配置GOPATH需设置环境变量并创建src、pkg、bin目录结构,现代开发建议使用go mod init初始化项目。 Go 语言从 1.11 版本开始引入了 Go Modules,因此传统的 GOPATH 工作区模式…

    2025年12月16日
    000
  • Go语言中大型数据流的JSON渐进式编码实践

    本文探讨了在go语言中,如何对大型数据流(特别是来自通道的数据)进行json编码,而无需一次性将所有数据加载到内存中。由于标准库`encoding/json`不支持直接对通道类型进行流式编码,文章详细介绍了手动构建json结构并逐个编码元素的方法,并提供了一个高效且内存友好的实现方案,以应对大数据量…

    2025年12月16日
    000
  • 如何在Golang中理解值类型与指针类型

    值类型存储实际数据,赋值时复制副本,修改不影响原变量;指针类型存储地址,可间接修改原值。小型数据用值类型,大型结构体或需修改原值时用指针。方法接收者根据是否需修改或对象大小选择值或指针。Go自动处理调用转换,理解传值与传地址是高效编程关键。 在Golang中,理解值类型和指针类型是掌握内存管理和函数…

    2025年12月16日
    000
  • Golang如何处理RPC服务返回错误

    Go的RPC错误处理需区分底层错误和业务错误:call.Error表示网络或序列化问题,reply中的Error字段表示业务逻辑错误;2. 服务端应优先将错误信息放入reply结构体而非仅返回error;3. 客户端必须同时检查call.Error和reply内容以完整处理错误。 在Go语言中处理R…

    2025年12月16日
    000
  • Golang如何使用观察者模式处理事件

    观察者模式通过Subject和Observer接口实现事件驱动,Go中可用接口与切片维护订阅关系,配合sync.RWMutex保证并发安全,示例中EventBus注册、注销并通知观察者,Logger与Notifier响应事件,主函数演示注册、触发与移除流程。 在Go语言中,观察者模式常用于实现事件处…

    2025年12月16日
    000
  • 如何在Golang中优化日志收集和输出效率

    答案:通过异步写入、缓冲机制和高性能日志库提升Golang日志性能。使用带缓冲channel解耦主流程与日志写入,后台goroutine批量处理;结合bufio.Writer降低I/O开销,定期Flush()保数据不丢失;选用zap等高效库,启用结构化日志与分级输出,控制日志量并分离目标文件,避免阻…

    2025年12月16日
    000
  • Go HTTPS 客户端连接复用问题详解与解决方案

    本文旨在解决 Go 语言中使用 HTTPS 客户端时连接无法复用的问题。通过分析常见原因,例如未正确关闭响应体以及未读取完整响应,提供详细的代码示例和最佳实践,帮助开发者确保连接复用,提升程序性能并避免资源浪费。同时,针对需要限制请求速率的场景,也提供了基于 time.Tick 的流量控制方案。 在…

    2025年12月16日
    000

发表回复

登录后才能评论
关注微信