开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 网络编程 > 查看源码
MyUdpSocket.cpp
资源名称：multi_thread_udp.zip　[点击查看]
上传用户：deligs
上传日期：2007-01-08
资源大小：43k
文件大小：2k
源码类别：

网络编程

开发平台：

Visual C++

MyUdpSocket.cpp：源码内容
  1. // MyUdpSocket.cpp : implementation file
  2. //
  4. #include "stdafx.h"
  5. #include "MyMonitor.h"
  6. #include "MyUdpSocket.h"
  8. #ifdef _DEBUG
  9. #define new DEBUG_NEW
  10. #undef THIS_FILE
  11. static char THIS_FILE[] = __FILE__;
  12. #endif
  14. #define LOG(x) { if((m_pLogFile->m_uLogLevel) > 0) m_pLogFile->WriteLog(m_csModuleName+x); }
  15. #define INFO(x) { if((m_pLogFile->m_uLogLevel) > 1) m_pLogFile->WriteLog(m_csModuleName+x); }
  17. /////////////////////////////////////////////////////////////////////////////
  18. // CMyUdpSocket
  20. CMyUdpSocket::CMyUdpSocket()
  21. {
  22.  m_csModuleName = LOG_STR_SOCKET_NAME;
  23. }
  25. CMyUdpSocket::~CMyUdpSocket()
  26. {
  27. }
  30. // Do not edit the following lines, which are needed by ClassWizard.
  31. #if 0
  32. BEGIN_MESSAGE_MAP(CMyUdpSocket, CAsyncSocket)
  33. //{{AFX_MSG_MAP(CMyUdpSocket)
  34. //}}AFX_MSG_MAP
  35. END_MESSAGE_MAP()
  36. #endif // 0
  38. /////////////////////////////////////////////////////////////////////////////
  39. // CMyUdpSocket member functions
  41. BOOL CMyUdpSocket::ChecksumValid()
  42. {
  43. return TRUE;
  44. }
  46. void CMyUdpSocket::SendFirstPacket()
  47. {
  48. // Prepare the data packet here
  49. BYTE bData[8];
  51. //bData[0]=...
  52. //bData[1]=...
  53. //...
  55. Send((void*)&bData,8);
  56. }
  58. BOOL CMyUdpSocket::Initial() 
  59. {
  60. int iResult = Create(0,SOCK_DGRAM); // Create as a UDP port
  61. if(!iResult)
  62. {
  63. LOG(LOG_STR_SOCKET_CREATE_ERROR + m_csAddress);
  64. return FALSE;
  65. }
  67. iResult = Connect(m_csAddress, m_uRemotePort);
  68. if(!iResult)
  69. {
  70. LOG(LOG_STR_SOCKET_ERROR + m_csAddress);
  71. return FALSE;
  72. }
  74. // Get the local port that the system assigned for you
  75. CString socketAddress;
  76. GetSockName(socketAddress, m_uLocalPort);
  78. return TRUE;
  79. }
  82. void CMyUdpSocket::OnReceive(int nErrorCode) 
  83. {
  84. // TODO: Add your specialized code here and/or call the base class
  86. BYTE szBuf[100];
  87. int iReceived;
  89. // Receive the message
  90. iReceived = Receive(szBuf, sizeof(szBuf));
  92. // Did we receive anything?
  93. if(iReceived == 0)
  94. {
  95. // If nothing
  96. //...
  98. return;
  99. }
  100. else if(iReceived == SOCKET_ERROR)
  101. {
  102. // Get the error and handle it
  103. LOG(LOG_STR_SOCKET_RECEIVE_ERROR + m_csAddress);
  105. return;
  106. }
  107. else
  108. {
  109. // Else analyze the response data here
  110. //...
  111. if( ChecksumValid() )
  112. {
  113. if( m_dwState == STAT_MYUDPC_SENDFIRST )
  114. {
  115. m_dwState = STAT_MYUDPC_SENDSECOND;
  116. return;
  117. }
  118. }
  119. }
  121. CAsyncSocket::OnReceive(nErrorCode);
  122. }