草庐IT

sockets - Golang UDP 和 TCP 并排

coder 2024-07-14 原文

是否可以在一个脚本中同时使用 TCP 和 UDP？我需要我的一些包通过 TCP 发送和接收，一些通过 UDP 发送和接收

func main() {

//
// ─── TCP ────────────────────────────────────────────────────────────────────
//

// Listen for incoming connections.
l, err := net.Listen("tcp", "localhost"+":"+"3000")
if err != nil {
    fmt.Println("Error listening:", err.Error())
    os.Exit(1)
}

// Close the listener when the application closes.
defer l.Close()
fmt.Println("Listening on " + "localhost" + ":" + "3000")
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 gotcp.HandleRequest(conn)
    //go handler(conn)
}

//
// ─── UDP ────────────────────────────────────────────────────────────────────
//

// then we should check which struct is empty and fill them

/* Lets prepare a address at any address at port 10001*/
ServerAddr, err := net.ResolveUDPAddr("udp", ":3000")
goudp.CheckError(err)

/* Now listen at selected port */
ServerConn, err := net.ListenUDP("udp", ServerAddr)
goudp.CheckError(err)
defer ServerConn.Close()

buf := make([]byte, 1024)

for {
    n, addr, err := ServerConn.ReadFromUDP(buf)
    //fmt.Println("Received ", string(buf[0:n]), " from ", addr)
    if err != nil {
        fmt.Println("Error: ", err)
    }

    // *** broadcasting
    //start := time.Now()
    if v, ok := goudp.RRoom()[djr]; ok {
        //fmt.Println("get room name ", v)
        go goudp.BroadCast(string(buf[0:n]), djr, ServerConn, v)
        //delete(R, "x")
        //go sendResponse(ServerConn, v.UserAddr1)
    }
    //elapsed := time.Since(start)
    //log.Printf("Binomial took %s", elapsed)
}

}

编辑: 通过在函数中传递 tcp 部分或 udp 部分并像 go tcpServer() 一样调用它，我们可以同时使用 UDP 和 TCP

最佳答案

正如 putu 所指出的，您需要一些并发性才能使其正常工作。

NodeJS 默认使用回调，这意味着一旦您将函数作为参数传递给函数，它就会将主循环释放到下一条指令。这就是 NodeJS 应用程序具有 object.method(function(){}) 模式的原因。要在 Go 中实现类似的功能，您需要将程序的 TCP 和 UDP 部分包装在一个单独的 goroutine 中，每个 goroutine 都有一个无限循环。

为了简单地证明这个概念，做这样的事情:

...
go func(){
  // paste your tcp code here 
}()
...
go func(){
  // paste your udp code here
}()

“go”指令告诉编译器一部分代码应该并发运行。在实际项目中，您会将这部分代码放在适当的函数中，然后从主函数中按名称调用它:

...
go serveTCP();
go serve UDP();
...

这里有更多关于并发的信息 => https://tour.golang.org/concurrency/1

关于sockets - Golang UDP 和 TCP 并排，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/46642990/

并排sockets34sectionerrgotcp

有关sockets - Golang UDP 和 TCP 并排的更多相关文章

  1. 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

  2. 计算机网络笔记：TCP三次握手和四次挥手过程 - 2

    TCP是面向连接的协议，连接的建立和释放是每一次面向连接的通信中必不可少的过程。TCP连接的管理就是使连接的建立和释放都能正常地进行。三次握手TCP连接的建立—三次握手建立TCP连接①若主机A中运行了一个客户进程，当它需要主机B的服务时，就发起TCP连接请求，并在所发送的分段中用SYN=1表示连接请求，并产生一个随机发送序号x，如果连接成功，A将以x作为其发送序号的初始值：seq=x。主机B收到A的连接请求报文，就完成了第一次握手。客户端发送SYN=1表示连接请求客户端发送一个随机发送序号x，如果连接成功，A将以x作为其发送序号的初始值：seq=x②主机B如果同意建立连接，则向主机A发送确认报

  3. 已解决socket.timeout : The read operation timed out - 2

    已解决（pip安装模块超时，利用四种国内镜像源完美解决）WARENTING:Retrying(Retry(total=4,connect=None，read=None，redirect=None，status=None))afterconnectionbrokenby‘ConnectTimeoutError(pip._vendor.urllib3.connection.HTTPSConnectionobjectatOx00001D6OE4F4A940>,‘Connectiontopypi.orgtimedout.(connecttimeout=15)’)’':/simple/pip/socke

  4. ruby - Cucumber 测试无法启动，错误为 "Display socket is taken but lock file is missing.." - 2

    运行cucumber后bundleexeccucumberfeatures/emails.feature:20我遇到了错误Displaysocketistakenbutlockfileismissing-checktheHeadlesstroubleshootingguide(Headless::Exception)/Users/me/.rbenv/versions/2.3.1/lib/ruby/gems/2.3.0/gems/headless-2.2.0/lib/headless.rb:195:inensure_xvfb_is_running'/Users/me/.rbenv/ver

  5. ruby-on-rails - 子域约束并排除某些子域 - 2

    在我的routes.rb文件中，我想使用rails3中的子域约束功能，但是我想从catchall路由中排除某些域。我不想在特定的子域中有特定的Controller。这样做的最佳做法是什么。#thissubdomainidontwantallofthecatchallroutesconstraints:subdomain=>"signup"doresources:usersend#hereIwanttocatchallbutexcludethe"signup"subdomainconstraints:subdomain=>/.+/doresources:carsresources:sta

  6. ruby - Interface Builder 看不到 MacRuby 的 socket - 2

    我正在尝试使用XCode和InterfaceBuilder构建一个基本的helloworld应用程序。但是，在InterfaceBuilder中，我看不到我的socket可以连接起来。我转到对象检查器Pane的连接选项卡，它显示“NewReferencingOutlet”。我想知道我的代码是否有误。在这里classHelloWorldControllerattr_accessor:hello_label,:hello_button,:hellodefawakeFromNib@hello=trueenddefchangeLabel(sender)if@hello@hello_label.

  7. ruby - yarn 未初始化常量 Socket::SOL_TCP - 2

    我在这里尝试使用yarn，遇到了一个可能与ruby​​相关的问题。在执行任何yarn命令，我收到错误.../.rvm/gems/ruby-2.3.0/gems/yarn-0.1.1/lib/yarn/server.rb:14:in':uninitializedconstantSocket::SOL_TCP(NameError)错误堆栈:$yarn.../.rvm/gems/ruby-2.3.0/gems/yarn-0.1.1/lib/yarn/server.rb:14:in':uninitializedconstantSocket::SOL_TCP(NameError)Didyoume

  8. ruby - 你如何使用 Ruby 找到空闲的 TCP 服务器端口？ - 2

    我正在尝试创建一个使用一次的HTTP服务器来处理单个回调，并且需要帮助在Ruby中找到一个空闲的TCP端口。这是我正在做的事情的框架:require'socket't=STDIN.readport=8081whiles=TCPServer.new('127.0.0.1',port).acceptputss.getss.print"HTTP/1.1200/OK\rContent-type:text/plain\r\n\r\n"+ts.closeexitend(它回显标准输入到第一个连接然后死掉。)如何自动找到空闲端口进行监听？这似乎是在远程服务器上启Action业然后使用唯一作业ID回调

  9. 多线程问题：为什么不应该使用多线程读写同一个socket连接？ - 2

    问题的产生经典的单reactor多线程模式采用的是用主线程处理连接事件以及socket读写事件，业务逻辑的处理则是让线程池里的线程各自竞争处理。既然多线程这么方便，为什么不让线程池里的线程也参与到read和send这个过程中呢？在发送数据的过程中，即使TCP的发送缓存满了，我们也可以记录下当前成功发送了多少字节，然后再次注册一个EPOLLOUT事件，只需等待下次可写事件，继续让子线程发送数据即可，岂不是美哉？解释陈硕大佬的解释对于TCP，通常多线程读写同一个socket是错误的设计，因为有shortwrite的可能。假如你加锁，而又发生shortwrite，你是不是要一直等到整条消息发送完才解

  10. ruby-on-rails - postgresql 数据库错误 : Is the server running locally and accepting connections on Unix domain socket "/var/run/postgresql/.s.PGSQL.5432"? - 2

    当我运行rakedb:migrate或运行railss命令时，我得到同样的错误:Error:couldnotconnecttoserver:NosuchfileordirectoryIstheserverrunninglocallyandacceptingconnectionsonUnixdomainsocket"/var/run/postgresql/.s.PGSQL.5432"?当我尝试railss时，浏览器出现错误。这是我的database.ymldefault:&defaultadapter:postgresqlencoding:unicodepool:5development

随机推荐