WinSock API实现UDP协议的详细代码

复制#include <afxsock.h> if (!AfxSocketInit()) { AfxMessageBox("Windows 通信端口初始化失败！"); } 1.2.3.4.5.

复制WSADATA wsaData; if (WSAStartup(MAKEWORD(1,1), &wsaData) != 0) { AfxMessageBox("加载Windows Sockets DLL失败！"); WSACleanup(); } 1.2.3.4.5.6.

复制AF_UNIX： UNIX内部协议族 AF_INET： Iternet协议 AF_NS： XeroxNs协议 AF_IMPLINK： IMP链接层 1.2.3.4.

复制SOCK_STREAM： 流式套接字 SOCK_DGRAM： 数据报套接字 SOCK_RAW： 原始套接字 SOCK_SEQPACKET： 定序分组套接字1.2.3.4.

复制SOCKET m_Socket; m_Socket = INVALID_SOCKET; if ((m_Socket=socket(AF_INET, SOCK_DGRAM,0))== INVALID_SOCKET) { AfxMessageBox("创建套接字失败！"); } 1.2.3.4.5.6.

复制

struct sockaddr { u_short sa_family;   // 地址族地址族 address family address family char sa_data[14];

// 14字节的协议地址 up to 14 bytes of direct address }; typedef struct sockaddr SOCKADDR; typedef struct sockaddr *PSOCKADDR; typedef struct sockaddr FAR *LPSOCKADDR;

struct sockaddr_in { short sin_family;// 地址族 u_short sin_port;// 端口号 struct in_addr sin_addr; // IP地址 char sin_zero[8];// 填充0 }; typedef struct sockaddr_in SOCKADDR_IN; typedef struct sockaddr_in *PSOCKADDR_IN; typedef struct sockaddr_in FAR *LPSOCKADDR_IN;

1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.

复制

htons()："Host to Network Short" htonl()："Host to Network long" ntohs()："Network to Host Short" ntohl()："Network to Host Long"

SOCKADDR_IN m_saAddr; u_short m_nPort = 20049;// 端口号 ZeroMemory(&m_saAddr, sizeof(m_saAddr)); m_saAddr.sin_family  = AF_INET; m_saAddr.sin_port= htons(m_nPort); // 如果此值为0，系统将随机选择一个未被使用的端口号 m_saAddr.sin_addr.s_addr = INADDR_ANY;  // 填入本机IP地址 if (bind(m_Socket, (LPSOCKADDR) &m_saAddr, sizeof(m_saAddr)) == SOCKET_ERROR) { AfxMessageBox("绑定端口失败！"); }

1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.

复制FD_READ： 网络数据包到达 FD_WRITE： 发送网络数据 FD_OOB： OOB数据到达 FD_ACCEPT： 收到连接请求 FD_CONNECT： 已建立连接 FD_CLOSE： 断开连接 FD_QOS： 服务质量(QoS)发生变化 FD_GROUP_QOS： 保留事件 FD_ROUTING_INTERFACE_CHANGE： 指定地址的路由接口发生变化 FD_ADDRESS_LIST_CHANGE： 本地地址变化1.2.3.4.5.6.7.8.9.10.

复制#define WM_NETWORK_EVENT WM_USER + 102 if (WSAAsyncSelect(m_Socket, m_hWnd, WM_NETWORK_EVENT, FD_READ) == SOCKET_ERROR) { AfxMessageBox("注册网络事件失败！"); } 1.2.3.4.5.

复制

afx_msg LRESULT OnNetworkEvent(WPARAM wParam, LPARAM lParam); ON_MESSAGE(WM_NETWORK_EVEN, OnNetworkEvent)

LRESULT OnNetworkEvent(WPARAM wParam, LPARAM lParam) { switch (WSAGETSELECTEVENT(lParam)) { case FD_READ: // 接收数据 break; } return 0L; }

1.2.3.4.5.6.7.8.9.10.11.12.13.

复制

BOOL Read(void) { int nBytesRead; int nBufferLength; int nEnd; int nSpaceRemaining; char chIncomingDataBuffer[4096]; SOCKADDR_IN m_saFromAddr; int nLenght = sizeof(m_saFromAddr); ZeroMemory(&m_saFromAddr, sizeof(SOCKADDR_IN)); nEnd = 0; nBufferLength = sizeof(chIncomingDataBuffer); nSpaceRemaining = sizeof(chIncomingDataBuffer); nSpaceRemaining -= nEnd;

nBytesRead = recvfrom(m_Socket, (LPSTR) (chIncomingDataBuffer + nEnd), nSpaceRemaining, 0, (LPSOCKADDR) &m_saFromAddr, &nLenght); nEnd += nBytesRead; if (nBytesRead == SOCKET_ERROR) { AfxMessageBox("读取数据出错!") return FALSE; } // IP地址：inet_ntoa(m_saFromAddr.sin_addr); // 端口号：ntohs(m_saFromAddr.sin_port); chIncomingDataBuffer[nEnd] = \0; if (lstrlen(chIncomingDataBuffer) != 0) { AfxMessageBox(chIncomingDataBuffer); } return TRUE; }

1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.

复制BOOL Send(CString sIP, u_short nPort, CString sSendData) { DWORDdwIP; SOCKADDR_IN saAddr; if (m_Socket == INVALID_SOCKET) { AfxMessageBox("套接字不可用！"); return FALSE; } if ((dwIP = inet_addr(sIP)) == INADDR_NONE) { AfxMessageBox("无法获取目标IP！"); return FALSE; } saAddr.sin_family  = AF_INET; saAddr.sin_port= htons(nPort); saAddr.sin_addr.s_addr = dwIP; if (sendto(m_Socket, sSendData, sSendData.GetLength(), 0, (LPSOCKADDR) &saAddr, sizeof(saAddr)) == SOCKET_ERROR) { AfxMessageBox("发送数据失败！"); return FALSE; } return TRUE; } 1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.

复制if (m_Socket != INVALID_SOCKET) { closesocket(m_Socket); } m_Socket = INVALID_SOCKET; WSACleanup(); 1.2.3.4.5.6.