subject_62716.htm

vc

<hr size=1>
<blockquote><p>
回复者：柯阳 回复日期：2003-11-28 13:03:02
<br>内容：谢谢zzjhsj兄弟。我另开一个线程在侦听连接的客户。<BR>DWORD WINAPI ListenThread(LPVOID lpParameter)&nbsp;&nbsp;//侦听线程并初始化接收<BR>{<BR>&nbsp;&nbsp;&nbsp;&nbsp;SOCKADDR_IN saRemote;<BR>&nbsp;&nbsp;&nbsp;&nbsp;int nRemoteLen;<BR>&nbsp;&nbsp;&nbsp;&nbsp;SOCKET Accept;<BR><BR>&nbsp;&nbsp;&nbsp;&nbsp;LPPER_HANDLE_DATA PerHandleData;<BR>&nbsp;&nbsp;&nbsp;&nbsp;DWORD Flags;<BR>&nbsp;&nbsp;&nbsp;&nbsp;DWORD RecvBytes;<BR><BR>&nbsp;&nbsp;&nbsp;&nbsp;CIocpFrame* iocp_frame = (CIocpFrame*)lpParameter;<BR><BR>&nbsp;&nbsp;&nbsp;&nbsp;// Accept connections and assign to the completion port.<BR>&nbsp;&nbsp;&nbsp;&nbsp;while(g_bStartListen)<BR>&nbsp;&nbsp;&nbsp;&nbsp;{<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;nRemoteLen = sizeof(saRemote);<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if ((Accept = WSAAccept(g_sdListen, (SOCKADDR *)&amp;saRemote,&amp;nRemoteLen, NULL, 0)) == SOCKET_ERROR)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (WSAGetLastError() != ERROR_IO_PENDING)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return 0;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; PerHandleData=iocp_frame-&gt;AssociateDeviceWithCompletionPort((HANDLE)Accept);<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(PerHandleData==NULL)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; continue;<BR><BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; memcpy(&amp;PerHandleData-&gt;ClientAddr,&amp;saRemote,nRemoteLen);<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //接收客户端发送的请求<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Flags=0;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (WSARecv(Accept, &amp;(PerHandleData-&gt;pIOContext-&gt;DataBuf), 1, &amp;RecvBytes, &amp;Flags,<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &amp;(PerHandleData-&gt;pIOContext-&gt;Overlapped), NULL) == SOCKET_ERROR)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (WSAGetLastError() != ERROR_IO_PENDING)<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return FALSE;<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}<BR>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<BR>&nbsp;&nbsp;&nbsp;&nbsp;}<BR>&nbsp;&nbsp;&nbsp;&nbsp;return 0;<BR>}<BR><BR>因为是实时发送数据，每天有大量的数据在传输，你说的具体问题在哪里？<BR>“系统维护每个线程的i/o申请，如果这些申请没有执行前线程停止了，那么这些i/o申请会被系统cancel掉，所以建议把你的所有的I/O申请放到放到一个专门的i/o thread去完成；”哪些的io操作？
<br>
<a href="javascript:history.go(-1)">返回上页</a><br><a href=http://www.copathway.com/cndevforum/>访问论坛</a></p></blockquote>
<hr size=1>
<blockquote><p>
回复者：zzjhsj 回复日期：2003-11-28 13:25:59
<br>内容：A 线程在调用 Write(SOCKET) 返回PENDING，然后线程Exit,那么最后的这次调用可能不会传递到对方；<BR><BR>你的 ListenThread 不能说明什么，也不能解决你说的丢包的问题——大家差不多都是这么用。<BR><BR>我还是推荐你代码一下我的思路，30分钟搞定没问题。
<br>
<a href="javascript:history.go(-1)">返回上页</a><br><a href=http://www.copathway.com/cndevforum/>访问论坛</a></p></blockquote>
<hr size=1>
<blockquote><p>
回复者：柯阳 回复日期：2003-11-28 14:50:37
<br>内容：谢谢zzjhsj兄的热心帮助，我一直在揣摩你的提示，但还是不大明白。能否给个详细的提示或者代码示例。让我等下好好做个试验，谢谢。
<br>
<a href="javascript:history.go(-1)">返回上页</a><br><a href=http://www.copathway.com/cndevforum/>访问论坛</a></p></blockquote>
<hr size=1>
<blockquote><p>
回复者：柯阳 回复日期：2003-11-28 14:52:04
<br>内容：顺便问一下，老兄在互联网应用上，每个包长也是4096吗
<br>
<a href="javascript:history.go(-1)">返回上页</a><br><a href=http://www.copathway.com/cndevforum/>访问论坛</a></p></blockquote>
<hr size=1>
<blockquote><p>
回复者：zzjhsj 回复日期：2003-11-28 14:59:02
<br>内容：TCP 作为一种数据流协议，好像没有包的概念吧？你怎么老讲包呢？讲得我晕晕的<BR>你要例子？我可以帮你找，但是不一定还在:)<BR><BR>
<br>
<a href="javascript:history.go(-1)">返回上页</a><br><a href=http://www.copathway.com/cndevforum/>访问论坛</a></p></blockquote>
<hr size=1>
<blockquote><p>
回复者：柯阳 回复日期：2003-11-28 15:09:25
<br>内容：呵呵， 哦，以前我都用UDP发广播包，老毛病。看来我基础不够扎实，呵呵。我的邮箱 [e-mail]&nbsp;&nbsp;，找到发一份给我，或者贴出来，谢谢。
<br>
<a href="javascript:history.go(-1)">返回上页</a><br><a href=http://www.copathway.com/cndevforum/>访问论坛</a></p></blockquote>
<hr size=1>
<blockquote><p>
回复者：zzjhsj 回复日期：2003-11-28 15:21:04
<br>内容：1<BR>2003-11-28 18:27:02