golang : net. Conn 读取很慢？-6ren

golang : net. Conn 读取很慢？

转载作者：IT王子更新时间：2023-10-29 00:37:07

我正在将 net.Listen("tcp", addr) 用于一个小型服务器程序，该程序接受数据并将其存储在服务器上。在客户端，我有一个 C++ 程序，我只是将 4096000 BYTES 写入套接字(连接到我的服务器程序)客户端的写入不到一秒就完成了。使用连接 net.Conn 的 Read() 函数时，读取速度非常慢。

以下是 Read() for 循环:

  // Handle the reads
  var tbuf [81920]byte

  for {

    n, err := c.rwc.Read(tbuf[0:])

    // Was there an error in reading ?
    if err != nil {
        log.Printf("Could not read packet : %s", err.Error())
        break
    }

    log.Println(n)

}

return

c.rwc 是 net.Conn 类型

以上代码的输出结果如下:

2012/12/29 13:45:12 16384
2012/12/29 13:45:12 16018
2012/12/29 13:45:12 16384
2012/12/29 13:45:12 16016
2012/12/29 13:45:13 16384
2012/12/29 13:45:13 16016
2012/12/29 13:45:13 16384
2012/12/29 13:45:13 16016
2012/12/29 13:45:13 16384
2012/12/29 13:45:13 16016
2012/12/29 13:45:13 16384
2012/12/29 13:45:13 16016
2012/12/29 13:45:13 16384
2012/12/29 13:45:13 16016
2012/12/29 13:45:13 16384
2012/12/29 13:45:13 16016
2012/12/29 13:45:13 16384
2012/12/29 13:45:14 16016
2012/12/29 13:45:14 16384
2012/12/29 13:45:14 16016
2012/12/29 13:45:14 16384
2012/12/29 13:45:14 16016
2012/12/29 13:45:14 16384
2012/12/29 13:45:14 16016
2012/12/29 13:45:14 16384
2012/12/29 13:45:14 16016
2012/12/29 13:45:14 16384
2012/12/29 13:45:14 16016
2012/12/29 13:45:14 16384
2012/12/29 13:45:14 16016
2012/12/29 13:45:15 16384
2012/12/29 13:45:15 16016
2012/12/29 13:45:15 16384
2012/12/29 13:45:15 16016
2012/12/29 13:45:15 16384
2012/12/29 13:45:15 16016
2012/12/29 13:45:15 16384
2012/12/29 13:45:15 16016
2012/12/29 13:45:15 16384
2012/12/29 13:45:15 16016
2012/12/29 13:45:15 16384
2012/12/29 13:45:15 16016
2012/12/29 13:45:15 16384
2012/12/29 13:45:16 16016
2012/12/29 13:45:16 16384
2012/12/29 13:45:16 16016
2012/12/29 13:45:16 16384
2012/12/29 13:45:16 16016
2012/12/29 13:45:16 16384
2012/12/29 13:45:16 16016
2012/12/29 13:45:16 16384
2012/12/29 13:45:16 16016
2012/12/29 13:45:18 16384
2012/12/29 13:45:18 16016
2012/12/29 13:45:19 16384
2012/12/29 13:45:19 16016
2012/12/29 13:45:19 16384
2012/12/29 13:45:19 16016
2012/12/29 13:45:19 16384
2012/12/29 13:45:19 16016
2012/12/29 13:45:19 16384
2012/12/29 13:45:19 16016
2012/12/29 13:45:19 16384
2012/12/29 13:45:19 16016
2012/12/29 13:45:19 16384
2012/12/29 13:45:19 16016
2012/12/29 13:45:19 16384
2012/12/29 13:45:20 16016
2012/12/29 13:45:20 16384
2012/12/29 13:45:20 16016
2012/12/29 13:45:20 16384
2012/12/29 13:45:20 16016
2012/12/29 13:45:20 16384
2012/12/29 13:45:20 16016
2012/12/29 13:45:20 16384
2012/12/29 13:45:20 16016
2012/12/29 13:45:20 16384
2012/12/29 13:45:20 16016
2012/12/29 13:45:20 16384
2012/12/29 13:45:20 16016
2012/12/29 13:45:21 16384
2012/12/29 13:45:21 16016
2012/12/29 13:45:21 16384
2012/12/29 13:45:21 16016
2012/12/29 13:45:21 16384
2012/12/29 13:45:21 16016
2012/12/29 13:45:21 16384
2012/12/29 13:45:21 16016
2012/12/29 13:45:21 16384
2012/12/29 13:45:21 16016
2012/12/29 13:45:21 16384
2012/12/29 13:45:21 16016
2012/12/29 13:45:21 16384
2012/12/29 13:45:22 16016
2012/12/29 13:45:22 16384
2012/12/29 13:45:22 16016
2012/12/29 13:45:22 16384
2012/12/29 13:45:22 16016
2012/12/29 13:45:22 16384
2012/12/29 13:45:22 16016
2012/12/29 13:45:22 16384
2012/12/29 13:45:22 16016
2012/12/29 13:45:22 16384
2012/12/29 13:45:22 16016
2012/12/29 13:45:22 16384
2012/12/29 13:45:22 16016
2012/12/29 13:45:23 16384
2012/12/29 13:45:23 16016
2012/12/29 13:45:23 16384
2012/12/29 13:45:23 16016
2012/12/29 13:45:23 16384
2012/12/29 13:45:23 16016
2012/12/29 13:45:23 16384
2012/12/29 13:45:23 16016
2012/12/29 13:45:23 16384
2012/12/29 13:45:23 16016
2012/12/29 13:45:23 16384
2012/12/29 13:45:23 16016
2012/12/29 13:45:24 16384
2012/12/29 13:45:24 16016
2012/12/29 13:45:24 16384
2012/12/29 13:45:24 16016
2012/12/29 13:45:24 16384
2012/12/29 13:45:24 16016
2012/12/29 13:45:24 16384
2012/12/29 13:45:24 16016
2012/12/29 13:45:24 16384
2012/12/29 13:45:24 16016
2012/12/29 13:45:24 16384
2012/12/29 13:45:24 16016
2012/12/29 13:45:24 16384
2012/12/29 13:45:25 16016
2012/12/29 13:45:25 16384
2012/12/29 13:45:25 16016
2012/12/29 13:45:25 16384
2012/12/29 13:45:25 16016
2012/12/29 13:45:25 16384
2012/12/29 13:45:25 16016
2012/12/29 13:45:25 16384
2012/12/29 13:45:25 16016
2012/12/29 13:45:25 16384
2012/12/29 13:45:25 16016
2012/12/29 13:45:25 16384
2012/12/29 13:45:26 16016
2012/12/29 13:45:26 16384
2012/12/29 13:45:26 16016
2012/12/29 13:45:26 16384
2012/12/29 13:45:26 16016
2012/12/29 13:45:26 16384
2012/12/29 13:45:26 16016
2012/12/29 13:45:26 16384
2012/12/29 13:45:26 16016
2012/12/29 13:45:26 16384
2012/12/29 13:45:26 16016
2012/12/29 13:45:26 16384
2012/12/29 13:45:26 16016
2012/12/29 13:45:27 16384
2012/12/29 13:45:27 16016
2012/12/29 13:45:27 16384
2012/12/29 13:45:27 16016
2012/12/29 13:45:27 16384
2012/12/29 13:45:27 16016
2012/12/29 13:45:27 16384
2012/12/29 13:45:27 16016
2012/12/29 13:45:27 16384
2012/12/29 13:45:28 16016
2012/12/29 13:45:28 16384
2012/12/29 13:45:29 16016
2012/12/29 13:45:29 16384
2012/12/29 13:45:29 16016
2012/12/29 13:45:29 16384
2012/12/29 13:45:29 16016
2012/12/29 13:45:29 16384
2012/12/29 13:45:29 16016
2012/12/29 13:45:29 16384
2012/12/29 13:45:29 16016
2012/12/29 13:45:29 16384
2012/12/29 13:45:29 16016
2012/12/29 13:45:29 16384
2012/12/29 13:45:30 16016
2012/12/29 13:45:30 16384
2012/12/29 13:45:30 16016
2012/12/29 13:45:30 16384
2012/12/29 13:45:30 16016
2012/12/29 13:45:30 16384
2012/12/29 13:45:30 16016
2012/12/29 13:45:30 16384
2012/12/29 13:45:30 16016
2012/12/29 13:45:31 16384
2012/12/29 13:45:31 16016
2012/12/29 13:45:31 16384
2012/12/29 13:45:31 16016
2012/12/29 13:45:32 16384
2012/12/29 13:45:32 16016
2012/12/29 13:45:32 16384
2012/12/29 13:45:32 16016
2012/12/29 13:45:32 16384
2012/12/29 13:45:32 16016
2012/12/29 13:45:32 16384
2012/12/29 13:45:32 16016
2012/12/29 13:45:32 16384
2012/12/29 13:45:32 16016
2012/12/29 13:45:32 16384
2012/12/29 13:45:32 16016
2012/12/29 13:45:32 16384
2012/12/29 13:45:33 16016
2012/12/29 13:45:33 16384
2012/12/29 13:45:33 16016
2012/12/29 13:45:33 16384
2012/12/29 13:45:33 16016
2012/12/29 13:45:33 16384
2012/12/29 13:45:33 16016
2012/12/29 13:45:33 16384
2012/12/29 13:45:33 16016
2012/12/29 13:45:33 16384
2012/12/29 13:45:33 16016
2012/12/29 13:45:33 16384
2012/12/29 13:45:34 16016
2012/12/29 13:45:34 16384
2012/12/29 13:45:34 16016
2012/12/29 13:45:34 16384
2012/12/29 13:45:34 16016
2012/12/29 13:45:34 16384
2012/12/29 13:45:34 16016
2012/12/29 13:45:34 16384
2012/12/29 13:45:34 16016
2012/12/29 13:45:34 16384
2012/12/29 13:45:34 16016
2012/12/29 13:45:34 16384
2012/12/29 13:45:35 16016
2012/12/29 13:45:35 16384
2012/12/29 13:45:35 16016
2012/12/29 13:45:35 16384
2012/12/29 13:45:35 16016
2012/12/29 13:45:35 16384
2012/12/29 13:45:35 16016
2012/12/29 13:45:36 16384
2012/12/29 13:45:36 16016
2012/12/29 13:45:36 16384
2012/12/29 13:45:36 16016
2012/12/29 13:45:37 16384
2012/12/29 13:45:37 16016
2012/12/29 13:45:37 16384
2012/12/29 13:45:37 16016
2012/12/29 13:45:37 16384
2012/12/29 13:45:37 16016
2012/12/29 13:45:37 16384
2012/12/29 13:45:37 16016
2012/12/29 13:45:37 16384
2012/12/29 13:45:37 16016
2012/12/29 13:45:37 4048

如您所见，读取操作花费了将近 21-25 秒来读取 4096000 个字节，这非常慢，因为服务器和客户端在同一台计算机上。读取操作错误吗？我无法理解为什么这么慢？

最佳答案

我把你的例子做了一个完整的客户端和服务器的例子。在 Linux 上对其进行测试，它可以在 20 毫秒左右的时间内传输数据，没有意外的停顿。

如果在您的计算机上尝试，您会得到相同的结果吗？如果是这样，那么怀疑您系统的 C++ 部分。如果出现与您的原始帖子相同的停顿，则怀疑您的设置。

服务器代码

package main

import (
    "io"
    "log"
    "net"
    "time"
)

func handle(c net.Conn) {
    // Handle the reads
    start := time.Now()
    tbuf := make([]byte, 81920)
    totalBytes := 0

    for {
        n, err := c.Read(tbuf)
        totalBytes += n
        // Was there an error in reading ?
        if err != nil {
            if err != io.EOF {
                log.Printf("Read error: %s", err)
            }
            break
        }
        log.Println(n)
    }
    log.Printf("%d bytes read in %s", totalBytes, time.Now().Sub(start))
    c.Close()
}

func main() {
    srv, err := net.Listen("tcp", ":2000")
    if err != nil {
        log.Fatal(err)
    }
    log.Println("Listening on localhost:2000")
    for {
        conn, err := srv.Accept()
        if err != nil {
            log.Fatal(err)
        }
        go handle(conn)
    }
}

客户端代码

package main

import (
    "log"
    "net"
    "time"
)

func handle(c net.Conn) {
    start := time.Now()
    tbuf := make([]byte, 4096)
    totalBytes := 0
    for i := 0; i < 1000; i++ {
        n, err := c.Write(tbuf)
        totalBytes += n
        // Was there an error in writing?
        if err != nil {
            log.Printf("Write error: %s", err)
            break
        }
        log.Println(n)
    }
    log.Printf("%d bytes written in %s", totalBytes, time.Now().Sub(start))
    c.Close()
}

func main() {
    conn, err := net.Dial("tcp", ":2000")
    if err != nil {
        log.Fatal(err)
    }
    log.Println("Sending to localhost:2000")
    handle(conn)
}

关于golang : net. Conn 读取很慢？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/14080024/

文章推荐： android - Android 是如何执行权限的？

文章推荐： linux - 绑定(bind)到快捷键的 xdotool 命令不起作用

Elixir/Phoenix - 访问用户的 cookie : conn. cookies vs conn.req_cookies vs conn.req_headers
所以我正在尝试实现类似 Imgur 的功能，非网站成员(member)的用户可以上传并继续编辑该上传内容(直到 cookie 被重置)。当查看conn结构时，有3个地方出现了用户的cookie。 c
sockets - conn (net.Conn) 并不总是写在套接字上
我已经用服务器和客户端完成了一个应用程序，以使用套接字 TCP 发送信息问题是，如果函数 zfs.ReceiveSnapshot(在服务器端)没有返回错误(err == nil)，conn.Writ
rs.open sql,conn,1,1与rs.open sql,conn,1.3还有rs.open sql,conn,3,2区别
经常开发asp但对于细致的说法，真实不太清楚，这里简单的介绍下。一般情况下读取数据都是用rs.open sql,conn,1,1 修改数据:rs.open sql,conn,1,3 删除
terminal - Phoenix : How to get conn %Plug. Conn{} 在控制台中
后 iex -S mix phx.server 我想在 iex 终端做一些快速测试，但有些函数需要 struct %Plug.Conn{} 作为参数，例如我想得到表达式的结果: MyAppWeb.Ro
java - 这种代码增强或实践称为什么？ (null == conn) 相对于 (conn == null)
我正在尝试报告一些代码增强，但是，我不太确定这个项目叫什么。基本上，它不是执行 conn == null，而是执行 null == conn 以提高可读性。之前: if (conn
go - 'sconn, ok:= conn.(*tls.Conn)' 是什么意思？
这个问题在这里已经有了答案: Is this casting in golang? (1 个回答) What does "i.(string)" actually mean in golang syn
go - conn.Read 在通过其他 go 例程关闭 conn 时进入无限循环
我的代码有点复杂，但简单来说，它有多个 go 例程，所有都调用不同的 TCP 服务器，并在流中出现可读消息时在 for 循环中读取输入。到目前为止，一切都很好。现在有另一个 go 例程来管理之前的一堆
java - JDBC 和 Oracle conn.commit 和 conn.setAutocommit 无法正常工作
我创建了一个 DBManager 类，如下所示 public class DBManager { public static String DRIVER = "oracle.jdbc.dr
node.js - node-mysql2 使用 conn.release() 与 conn.end()
在此处查看 Async/Await 示例: https://github.com/sidorares/node-mysql2/blob/master/documentation/Promise-Wra
elixir - (RuntimeError) 预期 action/2 返回一个 Plug.Conn，所有的 Plugs 都必须接收一个连接 (conn) 并返回一个连接
在我的一个 Controller 中，我有以下代码(摘录): case HTTPoison.get("https://*****.zendesk.com/api/v2/users/search.jso
python - SQLAlchemy 中的 conn.execute ('some string' ) 和 conn.execute(text ('some string' )) 有什么区别？
conn.execute('some string') 和 SQLAlchemy 中的 conn.execute(text('some string')) 有什么区别？上面conn是通过conn =
Why calling btmgmt conn-info on a connected device returns with: status 0x02 (Not Connected)(为什么在已连接的设备上调用btmgmt conn-info时返回状态0x02(未连接))
我正在尝试使用btmgmt rust库读取连接的BLE设备的RSSI值，但总是得到127。。我确信该设备已连接，并已解决服务问题，下面是BluToothctl输出：。我尝试使用CLI呼叫btmgmt，
mysql - 在 VB.NET 中，调用 conn.close 或 conn.dispose 甚至使用 USING 后，MySQL 连接不会关闭
我正在使用MySQL Workbench 。如果我打开一个到 MySQL 的连接(在 Visual Basic 中)，它将显示连接已打开。如果我关闭连接(在 MySQL Workbench 中)，它会
java - NoSuchMethodError : org. apache.http.conn.scheme.Scheme.(Ljava/lang/String;ILorg/apache/http/conn/scheme/SchemeSocketFactory;)V
我在 maven 项目中运行 selenium 测试。这个项目是 GWT Web 应用程序。在 pom.xml 中有 GWT 依赖项，hibernate 依赖项。我在测试包中创建了一个新类来运行 se
java.lang.NoSuchMethodError : org/apache/http/conn/scheme/Scheme. (Ljava/lang/String;ILorg/apache/http/conn/scheme/SchemeSocketFactory;)V
我尝试使用 HttpComponentsMessageSender 在 Spring WebServiceTemplate 中设置 ConnectionTimeout 和 ReadTimeout。但是
php - 如何避免在每个查询中都使用 $conn？
我刚刚将我的代码从 mysql 更改为 mysqli 并且最好是: 如何避免在每个查询或某些 mysqli 函数中使用 $conn？ $conn = mysqli_connect("localhost
javascript - conn.query结果的访问ID
执行一条sql查询后，我想访问返回事件的id(主键)，以便我可以在另一个sql中使用它。我尝试使用 result.insertId 访问它，但返回的事件对象似乎为 null。我什至控制台记录了 res
Asp Conn.execute的参数与返回值总结
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界. 这篇CFSDN的博客文章Asp Conn.execute的参数与返回值总结由作者收集整理，如果你
go - 无法使用net.Conn.Read从UNIX套接字读取
我正在尝试使用GO与服务进行简单的UNIX套接字通信。为了测试，我创建了一个socket，如下所示: $ nc -vlU /tmp/sock Bound on /tmp/sock Listening
elixir - 在测试过程中丢失 conn.assigns
我很难对失败的测试进行故障排除，其中 conn.assigns 都是同一测试语句的一部分，但在测试的两行之间被清空。我正在阅读“Programming Phoenix”，并重新编写代码以使其与 Ph

IT王子

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

golang : net. Conn 读取很慢？