jjzjj

C++ Winsock P2P

coder 2023-11-13 原文

设想
有没有人有使用 Winsock 在 C++ 中进行点对点 (p2p) 网络的好例子？
这是我对特别需要使用这项技术的客户的要求(天知道为什么)。
我需要确定这是否可行。
任何帮助将不胜感激。
编辑
我想避免使用库，以便我可以理解底层源代码并进一步了解我的知识。

最佳答案

由于我不知道您要查找什么信息，我将尝试描述如何设置套接字程序以及我遇到的陷阱。
首先，阅读 Winsock tutorial 来自 MSDN。这是连接、发送消息和断开连接的基本程序。非常适合了解套接字编程。
有了这个，让我们开始:
注意事项:
阻塞或非阻塞
首先，您需要确定您想要阻塞程序还是非阻塞程序。最大的区别在于，如果您有一个 GUI，您将需要使用非阻塞或线程，以免卡住程序。我这样做的方法是使用阻塞调用，但总是调用 select在调用阻塞函数之前(稍后将详细介绍选择)。这样我就避免了线程和互斥锁等等，但仍然使用基本的 accept , send和 receive调用。
您不能指望您的包裹会以您发送的方式到达!
你对此也没有影响。这是我遇到的最大问题，主要是因为网卡可以决定发送什么信息以及何时发送。我解决它的方法是制作一个 networkPackageStruct ，包含 size和 data ，其中 size 是该包中的数据总量。请注意，您发送的一条消息可以拆分为 2 条或更多条消息，也可以与您发送的另一条消息合并。
考虑以下:
你发了两条消息

"Hello"
"World!"
当您使用 send 发送这两条消息时功能您的 recv函数可能不会像这样得到它们。它可能看起来像这样:
"Hel"
"loWorld!"
也许
"HelloWorld!"
无论底层网络感觉如何..
记录(几乎)一切!
调试网络程序很困难，因为您无法完全控制它(因为它在两台计算机上)。如果您遇到阻塞操作，您也看不到它。这也可以称为“了解您的阻塞代码”。当一侧发送某些内容时，您不知道它是否会到达另一侧，因此请跟踪发送的内容和接收的内容。
注意socket错误
winsock 函数返回大量信息。了解您的 WSAGetLastError()功能。我不会在下面的示例中保留它，但请注意，它们往往会返回大量信息。每次收到 SOCKET_ERROR或 INVALID_SOCKET检查 Winsock Error Messages查一下
设置连接:
由于您不需要服务器，因此所有客户端都需要一个监听套接字来接受新连接。最简单的是:
SOCKET s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
sockaddr_in localAddress;
localAddress.sinfamily = AF_INET;
localAddress.sin_port = htons(10000);  // or whatever port you'd like to listen to
localAddress.sin_addr.s_addr = INADDR_ANY;
INADDR_ANY 很棒 - 它实际上使您的套接字监听所有网络，而不仅仅是一个 IP 地址。
bind(s, (SOCKADDR*)&localAddress, sizeof(localAddress));
listen(s, SOMAXCONN);
有趣的部分来了。 bind和 listen不会阻塞但accept将要。诀窍是使用 select检查是否有传入连接。所以上面的代码只是为了设置socket。在您的程序循环中，您检查套接字中的新数据。
交换数据
我解决的方法是使用 select很多。基本上，您会看到是否需要在任何套接字上响应任何内容。这是通过 FD_xxx 完成的职能。
// receiving data
fd_set mySet;
FD_ZERO(&mySet);
FD_SET(s, &mySet);
// loop all your sockets and add to the mySet like the call above
timeval zero = { 0, 0 };
int sel = select(0, &mySet, NULL, NULL, &zero);
if (FD_ISSET(s, &mySet)){
     // you have a new caller
     sockaddr_in remote;
     SOCKET newSocket = accept(s, (SOCKADDR*)&remote, sizeof(remote));
 }
 // loop through your sockets and check if they have the FD_ISSET() set
在 newSocket你现在有了一个新的同伴。所以那是为了接收数据。 但请注意! send还堵!我得到的“挠头错误”之一是 send阻止了我。然而，这也通过 select 解决了.
 // sending data
 // in: SOCKET sender
 fd_set mySet;
 FD_ZERO(&mySet);
 FD_SET(sender, &mySet);
 timeval zero = { 0, 0 };
 int sel = select(0, NULL, mySet, NULL, &zero);
 if (FD_ISSET(sender, &mySet)){
      // ok to send data
 }
关闭
最后，有两种关闭方式。您可以通过关闭程序来断开连接，或者拨打 shutdown功能。
  • 调用shutdown会让你的peer select扳机。 recv但是不会接收任何数据，而是返回 0。我没有注意到任何其他情况 recv返回 0，因此可以(有点)安全地说这可以被视为关闭代码。调用 shutdown是最好的事情..
  • 在不调用 shutdown 的情况下关闭连接是冷酷的，但当然有效。即使您使用 shutdown，您仍然需要处理错误，因为关闭连接的可能不是您的程序。要记住的一个很好的错误代码是 10054，它是 WSAECONNRESET: Connection reset by peer..

    • 关于C++ Winsock P2P，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/2843277/

    ampWinsockcode套接字套接c++p2pdistributed-computingwinsockets

    有关C++ Winsock P2P的更多相关文章

    1. ruby-on-rails - 如何优雅地重启 thin + nginx？ - 2

      我的瘦服务器配置了nginx，我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例，但找不到好的解决方案。有没有人能做到这一点？ 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器，例如server{listen80;server

    2. ruby - 使用 `+=` 和 `send` 方法 - 2

      如何将send与+=一起使用？a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法，而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:

    3. ruby - 如何计算 Liquid 中的变量 +1 - 2

      我对如何计算通过{%assignvar=0%}赋值的变量加一完全感到困惑。这应该是最简单的任务。到目前为止，这是我尝试过的:{%assignamount=0%}{%forvariantinproduct.variants%}{%assignamount=amount+1%}{%endfor%}Amount:{{amount}}结果总是0。也许我忽略了一些明显的东西。也许有更好的方法。我想要存档的只是获取运行的迭代次数。 最佳答案 因为{{incrementamount}}将输出您的变量值并且不会影响{%assign%}定义的变量，我

    4. arrays - Ruby 数组 += vs 推送 - 2

      我有一个数组数组，想将元素附加到子数组。+=做我想做的，但我想了解为什么push不做。我期望的行为(并与+=一起工作):b=Array.new(3,[])b[0]+=["apple"]b[1]+=["orange"]b[2]+=["frog"]b=>[["苹果"],["橙子"],["Frog"]]通过推送，我将推送的元素附加到每个子数组(为什么？):a=Array.new(3,[])a[0].push("apple")a[1].push("orange")a[2].push("frog")a=>[[“苹果”、“橙子”、“Frog”]、[“苹果”、“橙子”、“Frog”]、[“苹果”、“

    5. += 的 Ruby 方法 - 2

      有没有办法让Ruby能够做这样的事情？classPlane@moved=0@x=0defx+=(v)#thisiserror@x+=v@moved+=1enddefto_s"moved#{@moved}times,currentxis#{@x}"endendplane=Plane.newplane.x+=5plane.x+=10putsplane.to_s#moved2times,currentxis15 最佳答案 您不能在Ruby中覆盖复合赋值运算符。任务在内部处理。您应该覆盖+，而不是+=。plane.a+=b与plane.a=

    6. ruby - Sinatra + Heroku + Datamapper 使用 dm-sqlite-adapter 部署问题 - 2

      出于某种原因，heroku尝试要求dm-sqlite-adapter，即使它应该在这里使用Postgres。请注意，这发生在我打开任何URL时-而不是在gitpush本身期间。我构建了一个默认的Facebook应用程序。gem文件:source:gemcuttergem"foreman"gem"sinatra"gem"mogli"gem"json"gem"httparty"gem"thin"gem"data_mapper"gem"heroku"group:productiondogem"pg"gem"dm-postgres-adapter"endgroup:development,:t

    7. ruby - Ruby 中字符串运算符 + 和 << 的区别 - 2

      我是Ruby和这个网站的新手。下面两个函数是不同的，一个在函数外修改变量，一个不修改。defm1(x)x我想确保我理解正确-当调用m1时，对str的引用被复制并传递给将其视为x的函数。运算符当调用m2时，对str的引用被复制并传递给将其视为x的函数。运算符+创建一个新字符串，赋值x=x+"4"只是将x重定向到新字符串，而原始str变量保持不变。对吧？谢谢 最佳答案 String#+::str+other_str→new_strConcatenation—ReturnsanewStringcontainingother_strconc

    8. ruby - rails 3.2.2(或 3.2.1)+ Postgresql 9.1.3 + Ubuntu 11.10 连接错误 - 2

      我正在使用PostgreSQL9.1.3(x86_64-pc-linux-gnu上的PostgreSQL9.1.3，由gcc-4.6.real(Ubuntu/Linaro4.6.1-9ubuntu3)4.6.1，64位编译)和在ubuntu11.10上运行3.2.2或3.2.1。现在，我可以使用以下命令连接PostgreSQLsupostgres输入密码我可以看到postgres=#我将以下详细信息放在我的config/database.yml中并执行“railsdb”，它工作正常。开发:adapter:postgresqlencoding:utf8reconnect:falsedat

    9. ruby - 在 Ruby + Chef 中检查现有目录失败 - 2

      这是我在ChefRecipe中的一blockRuby:#ifdatadirdoesn'texist,moveoverthedefaultoneif!File.exist?("/vol/postgres/data")execute"mv/var/lib/postgresql/9.1/main/vol/postgres/data"end结果是:Executingmv/var/lib/postgresql/9.1/main/vol/postgres/datamv:inter-devicemovefailed:`/var/lib/postgresql/9.1/main'to`/vol/post

    10. ruby-on-rails - 使用 Pow 作为服务器在 RubyMine 中调试 - Ruby 2.1.1 + Rails 4 - 2

      我已经开始使用RubyMine6。我正在处理Rails4、Ruby2.1.1项目。我无法找到如何使用Pow作为服务器调试到RubyMine。你能给我指明正确的方向吗？ 最佳答案 我能够使用远程调试从RubyMine进行调试。我正在使用RubyMine6、Rails3、Ruby2.1.1。首先创建一个.powenv文件并添加:exportRUBY_DEBUG_PORT=1234exportPOW_WORKERS=1将以下gem添加到您的Gemfile:gem'ruby-debug-ide'gem'debase'创建一个新的初始化器st

    随机推荐