go - 通过 SetDeadline() 为 TCP 监听器设置超时

coder 2024-07-10 原文

我正在尝试实现非阻塞 Accept()，目前为止最好的是以下代码片段(它是一个有效的 Go v1.6.2 程序):

package main

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

func createClient() {
    tcpConn, err := net.DialTCP("tcp4", nil, &net.TCPAddr{
        IP:     net.IPv4(127, 0, 0, 1),
        Port:   12819,
    })
    if err != nil {
        log.Fatalln("Error connecting to the server!")
    }
    log.Println("Managed to dial!")
    tcpConn.Close()
}

func main() {
    go createClient()
    l, err := net.ListenTCP("tcp4", &net.TCPAddr{
        IP:     net.IPv4(127, 0, 0, 1),
        Port:   12819,
    })
    if err != nil {
        log.Fatalln("Can't listen on provided IP/port!")
    }
    defer l.Close()
    if err = l.SetDeadline(time.Now().Add(time.Nanosecond)); err != nil {
        log.Fatalln("Can't set appropriate deadline!")
    }
    tcpConn, err := l.AcceptTCP()
    if err != nil {
        if opError, ok := err.(*net.OpError); ok && opError.Timeout() {
            log.Fatalln("Timeout error!")
        }
        log.Fatalln("Error while accepting connection!")
    }
    log.Println("Accepted new connection!")
    tcpConn.Close()
}

问题是我总是收到超时错误!。据我所知，这是因为在调用监听器的 AcceptTCP() 时，先前设置的截止日期已经过期。尝试将其更改为 time.Microsecond，您可能会得到相同的结果(除非您的 CPU 比我的慢)。只有当截止日期至少达到 time.Second 时，事情才会开始发生变化。那是我开始得到 Accepted new connection!/Managed to dial! 的时候。

所以我想我解决了这个问题。有什么想法吗？

最佳答案

Accept 应该是阻塞的。您不想在收听/接受时设置截止日期，因为您希望它永久收听新连接。

您需要将接受放在一个循环中，基本上启动一个新的 go 例程来处理连接并返回等待新的客户端连接(接受)。

这是 Go 中的典型服务器:

package main

import (
    "fmt"
    "log"
    "net"
    "os"
)

func main() {
    l, err := net.Listen("tcp", "localhost:12819")
    if err != nil {
        log.Fatalln("Can't listen on provided IP/port!")
    }
    defer l.Close()

    for {
        // Listen for an incoming connection.
        conn, err := l.Accept()
        if err != nil {
            fmt.Println("Error accepting: ", err.Error())
            os.Exit(1)
        }

        // Handle connections in a new goroutine.
        go handleRequest(conn)
    }
}

func handleRequest(conn net.Conn) {
    buf := make([]byte, 1024)
    if _, err := conn.Read(buf); err != nil {
        fmt.Println("Error reading:", err.Error())
    }
    conn.Write([]byte("Message received."))
    conn.Close()
}

您可以从您的 shell 中使用以下命令连接它:

telnet localhost 12819

键入命令，您的请求将被处理和处理。

如您所见，accept 命令是故意阻塞的。服务器上的 SetDeadline 通常在处理阶段进一步使用，以超时读取来自客户端的数据。

关于go - 通过 SetDeadline() 为 TCP 监听器设置超时，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37386303/

有关go - 通过 SetDeadline() 为 TCP 监听器设置超时的更多相关文章

ruby - 使用 RubyZip 生成 ZIP 文件时设置压缩级别 - 2
我有一个Ruby程序，它使用rubyzip压缩XML文件的目录树。gem。我的问题是文件开始变得很重，我想提高压缩级别，因为压缩时间不是问题。我在rubyzipdocumentation中找不到一种为创建的ZIP文件指定压缩级别的方法。有人知道如何更改此设置吗？是否有另一个允许指定压缩级别的Ruby库？最佳答案这是我通过查看rubyzip内部创建的代码。level=Zlib::BEST_COMPRESSIONZip::ZipOutputStream.open(zip_file)do|zip|Dir.glob("**/*")d
ruby-openid:执行发现时未设置@socket - 2
我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时，我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb，在下面的代码片段中:moduleNetclass
ruby - 通过 rvm 升级 rubygems 的问题 - 2
尝试通过RVM将RubyGems升级到版本1.8.10并出现此错误:$rvmrubygemslatestRemovingoldRubygemsfiles...Installingrubygems-1.8.10forruby-1.9.2-p180...ERROR:Errorrunning'GEM_PATH="/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/ruby-1.9.2-p180@global:/Users/foo/.rvm/gems/ruby-1.9.2-p180:/Users/foo/.rvm/gems/rub
ruby - 通过 erb 模板输出 ruby 数组 - 2
我正在使用puppet为ruby程序提供一组常量。我需要提供一组主机名，我的程序将对其进行迭代。在我之前使用的bash脚本中，我只是将它作为一个puppet变量hosts=>"host1,host2"我将其提供给bash脚本作为HOSTS=显然这对ruby不太适用——我需要它的格式hosts=["host1","host2"]自从phosts和putsmy_array.inspect提供输出["host1","host2"]我希望使用其中之一。不幸的是，我终其一生都无法弄清楚如何让它发挥作用。我尝试了以下各项:我发现某处他们指出我需要在函数调用前放置“function_”……这
ruby-on-rails - 如何使用 instance_variable_set 正确设置实例变量？ - 2
我正在查看instance_variable_set的文档并看到给出的示例代码是这样做的:obj.instance_variable_set(:@instnc_var,"valuefortheinstancevariable")然后允许您在类的任何实例方法中以@instnc_var的形式访问该变量。我想知道为什么在@instnc_var之前需要一个冒号:。冒号有什么作用？最佳答案我的第一直觉是告诉你不要使用instance_variable_set除非你真的知道你用它做什么。它本质上是一种元编程工具或绕过实例变量可见性的黑客攻击
ruby - 通过 ruby 进程共享变量 - 2
我正在编写一个gem，我必须在其中fork两个启动两个webrick服务器的进程。我想通过基类的类方法启动这个服务器，因为应该只有这两个服务器在运行，而不是多个。在运行时，我想调用这两个服务器上的一些方法来更改变量。我的问题是，我无法通过基类的类方法访问fork的实例变量。此外，我不能在我的基类中使用线程，因为在幕后我正在使用另一个不是线程安全的库。所以我必须将每个服务器派生到它自己的进程。我用类变量试过了，比如@@server。但是当我试图通过基类访问这个变量时，它是nil。我读到在Ruby中不可能在分支之间共享类变量，对吗？那么，还有其他解决办法吗？我考虑过使用单例，但我不确定这是
ruby - 通过 RVM (OSX Mountain Lion) 安装 Ruby 2.0.0-p247 时遇到问题 - 2
我的最终目标是安装当前版本的RubyonRails。我在OSXMountainLion上运行。到目前为止，这是我的过程:已安装的RVM$\curl-Lhttps://get.rvm.io|bash-sstable检查已知(我假设已批准)安装$rvmlistknown我看到当前的稳定版本可用[ruby-]2.0.0[-p247]输入命令安装$rvminstall2.0.0-p247注意:我也试过这些安装命令$rvminstallruby-2.0.0-p247$rvminstallruby=2.0.0-p247我很快就无处可去了。结果:$rvminstall2.0.0-p247Search
ruby-on-rails - Enumerator.new 如何处理已通过的 block ？ - 2
我在理解Enumerator.new方法的工作原理时遇到了一些困难。假设文档中的示例:fib=Enumerator.newdo|y|a=b=1loopdoy[1,1,2,3,5,8,13,21,34,55]循环中断条件在哪里，它如何知道循环应该迭代多少次(因为它没有任何明确的中断条件并且看起来像无限循环)？最佳答案 Enumerator使用Fibers在内部。您的示例等效于:require'fiber'fiber=Fiber.newdoa=b=1loopdoFiber.yieldaa,b=b,a+bendend10.times.m
ruby-on-rails - date_field_tag，如何设置默认日期？ [ rails 上的 ruby ] - 2
我想设置一个默认日期，例如实际日期，我该如何设置？还有如何在组合框中设置默认值顺便问一下，date_field_tag和date_field之间有什么区别？最佳答案试试这个:将默认日期作为第二个参数传递。youcorrectlysetthedefaultvalueofcomboboxasshowninyourquestion. 关于ruby-on-rails-date_field_tag，如何设置默认日期？[rails上的ruby]，我们在StackOverflow上找到一个类似的问
ruby - 简单获取法拉第超时 - 2
有没有办法在这个简单的get方法中添加超时选项？我正在使用法拉第3.3。Faraday.get(url)四处寻找，我只能先发起连接后应用超时选项，然后应用超时选项。或者有什么简单的方法？这就是我现在正在做的:conn=Faraday.newresponse=conn.getdo|req|req.urlurlreq.options.timeout=2#2secondsend 最佳答案试试这个:conn=Faraday.newdo|conn|conn.options.timeout=20endresponse=conn.get(url

go - 通过 SetDeadline() 为 TCP 监听器设置超时

有关go - 通过 SetDeadline() 为 TCP 监听器设置超时的更多相关文章

随机推荐