jjzjj

golang udp客户端无法从服务器接收消息

coder 2024-07-12 原文

我可以成功地从客户端向服务器发送消息。但是当我尝试回复消息给客户端时，客户端却无法接收到消息。

客户:

conn, _:= net.Dial("udp", serv_addr:port)
defer conn.close()
buf:= []byte("Hey, server")
conn.Write(buf)

recv:= make([]byte, 1024)
fmt.Println("Reading...\n")
conn.Read(recv)

服务器:

addr, _:= net.ResolveUDPAddr("udp", addr:port)
msg := make([]byte, 1024)

conn,_: net.ListenUDP("udp", addr)
_, ret_addr, _: conn.ReadFromUDP(msg)
//print msg
conn.WriteToUDP([]byte("got your msg", ret)

这是一个非常简单的udp 连接。服务器可以从客户端打印出消息，但在客户端，它在服务器完成其任务时一直在 conn.read() 之前等待。

我关注了this文章。我的实现几乎相同。

最佳答案

这是供您试用的最少代码。

在一个终端中启动服务器部分:

go run main.go server :53033

在另一个终端启动客户端:

go run main.go client :53033

现在在客户端 终端输入消息，您应该会看到客户端和服务器都在交换消息。您可以启动多个客户端(在新的终端窗口中)并与同一服务器通信。

package main

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

func server(url string) {
    log.Printf("serving on %s\n", url)
    addr, err := net.ResolveUDPAddr("udp", url)
    errcheck(err)

    conn, err := net.ListenUDP("udp", addr)
    errcheck(err)
    defer close(conn)

    msg := make([]byte, 1024)

    for {
        n, retAddr, err := conn.ReadFromUDP(msg)
        errcheck(err)

        log.Printf("received %v bytes, ret addr %v, msg %s", n, retAddr, string(msg[:n]))

        reply := []byte(fmt.Sprintf("received from you: %v bytes", n))
        n, err = conn.WriteToUDP(reply, retAddr)
        errcheck(err)

        log.Printf("sent reply %v bytes\n", n)
    }
}

func client(url string) {
    log.Printf("client for server url: %s\n", url)

    addr, err := net.ResolveUDPAddr("udp", url)
    errcheck(err)

    conn, err := net.DialUDP("udp", nil, addr)
    errcheck(err)
    defer close(conn)

    msg := make([]byte, 512)
    scanner := bufio.NewScanner(os.Stdin)
    for {
        if scanner.Scan() {
            line := scanner.Text()

            n, err := conn.Write([]byte(line))
            errcheck(err)
            log.Printf("sent %d bytes \n", n)

            n, err = conn.Read(msg)
            errcheck(err)
            log.Printf("server replied with: %s \n", string(msg[:n]))
        }
    }
}

func main() {
    args := os.Args[1:]

    if len(args) < 2 {
        log.Fatal("expecting 2 arguments client or server first followed by the address:port")
    }

    switch args[0] {
    case "server":
        server(args[1])

    case "client":
        client(args[1])

    default:
        log.Fatal("first argument must be server or client")
    }

}

func errcheck(err error) {
    if err != nil {
        log.Fatal(err)
    }
}

func close(c io.Closer) {
    err := c.Close()
    if err != nil {
        log.Fatal()
    }
}

玩得开心!

关于golang udp客户端无法从服务器接收消息，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47280837/

golangudp34errconngo

有关golang udp客户端无法从服务器接收消息的更多相关文章

  1. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封，在我看来soap请求没有正确的命名空间。任何人都可以建议我

  2. ruby-on-rails - 由于 "wkhtmltopdf"，PDFKIT 显然无法正常工作 - 2

    我在从html页面生成PDF时遇到问题。我正在使用PDFkit。在安装它的过程中，我注意到我需要wkhtmltopdf。所以我也安装了它。我做了PDFkit的文档所说的一切......现在我在尝试加载PDF时遇到了这个错误。这里是错误:commandfailed:"/usr/local/bin/wkhtmltopdf""--margin-right""0.75in""--page-size""Letter""--margin-top""0.75in""--margin-bottom""0.75in""--encoding""UTF-8""--margin-left""0.75in""-

  3. ruby - 具有身份验证的私有(private) Ruby Gem 服务器 - 2

    我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时，它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器？这是不可能的吗？谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..

  4. ruby-on-rails - 无法使用 Rails 3.2 创建插件？ - 2

    我对最新版本的Rails有疑问。我创建了一个新应用程序(railsnewMyProject)，但我没有脚本/生成，只有脚本/rails，当我输入ruby./script/railsgeneratepluginmy_plugin"Couldnotfindgeneratorplugin.".你知道如何生成插件模板吗？没有这个命令可以创建插件吗？PS:我正在使用Rails3.2.1和ruby​​1.8.7[universal-darwin11.0] 最佳答案 随着Rails3.2.0的发布，插件生成器已经被移除。查看变更日志here.现在

  5. ruby - 无法运行 Rails 2.x 应用程序 - 2

    我尝试运行2.x应用程序。我使用rvm并为此应用程序设置其他版本的ruby​​:$rvmuseree-1.8.7-head我尝试运行服务器，然后出现很多错误:$script/serverNOTE:Gem.source_indexisdeprecated,useSpecification.Itwillberemovedonorafter2011-11-01.Gem.source_indexcalledfrom/Users/serg/rails_projects_terminal/work_proj/spohelp/config/../vendor/rails/railties/lib/r

  6. ruby-on-rails - 无法在centos上安装therubyracer(V8和GCC出错) - 2

    我正在尝试在我的centos服务器上安装therubyracer，但遇到了麻烦。$geminstalltherubyracerBuildingnativeextensions.Thiscouldtakeawhile...ERROR:Errorinstallingtherubyracer:ERROR:Failedtobuildgemnativeextension./usr/local/rvm/rubies/ruby-1.9.3-p125/bin/rubyextconf.rbcheckingformain()in-lpthread...yescheckingforv8.h...no***e

  7. ruby - 无法让 RSpec 工作—— 'require' : cannot load such file - 2

    我花了三天的时间用头撞墙，试图弄清楚为什么简单的“rake”不能通过我的规范文件。如果您遇到这种情况:任何文件夹路径中都不要有空格!。严重地。事实上，从现在开始，您命名的任何内容都没有空格。这是我的控制台输出:(在/Users/*****/Desktop/LearningRuby/learn_ruby)$rake/Users/*******/Desktop/LearningRuby/learn_ruby/00_hello/hello_spec.rb:116:in`require':cannotloadsuchfile--hello(LoadError) 最佳

  8. ruby-on-rails - 启动 Rails 服务器时 ImageMagick 的警告 - 2

    最近，当我启动我的Rails服务器时，我收到了一长串警告。虽然它不影响我的应用程序，但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次？当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗？/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru

  9. ruby-on-rails - s3_direct_upload 在生产服务器中不工作 - 2

    在Rails4.0.2中，我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常，但在生产环境中它会抛出如下错误，ActionView::Template::Error(noimplicitconversionofnilintoString)在View中，create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo

  10. ruby - 无法覆盖 irb 中的 to_s - 2

    我在pry中定义了一个函数:to_s，但我无法调用它。这个方法去哪里了，怎么调用？pry(main)>defto_spry(main)*'hello'pry(main)*endpry(main)>to_s=>"main"我的ruby版本是2.1.2看了一些答案和搜索后，我认为我得到了正确的答案:这个方法用在什么地方？在irb或pry中定义方法时，会转到Object.instance_methods[1]pry(main)>defto_s[1]pry(main)*'hello'[1]pry(main)*end=>:to_s[2]pry(main)>defhello[2]pry(main)

随机推荐