网络通信和文件传输简单示例程序（Win32）

#include "server.h" #include "serverwnd.h" #include "serverkrl.h" sockaddr_in client_addr; void GetError() { TCHAR text[50]; int err; err = GetLastError(); swprintf(text,TEXT("•ï‹
x:%d"),err); MessageBox(NULL,text,text,MB_OK); } int InitWSA() { WSADATA wsaData; WORD Version; int err; Version = MAKEWORD(2,2); err = WSAStartup(Version,&wsaData); if(err != 0) return -1; return 0; } int UninstWSA() { WSACleanup(); return 0; } SOCKET InitTextSocket() { int err; SOCKET textSock; textSock = socket(AF_INET,SOCK_DGRAM,0); SOCKADDR_IN addr; addr.sin_addr.s_addr =htonl(INADDR_ANY); addr.sin_family = AF_INET; addr.sin_port = htons(SERVERPORT); err = bind(textSock,(struct sockaddr*)&addr,sizeof addr); if(err != 0) return -1; return textSock; } SOCKET InitFileSocket() { int err; SOCKET fileSock; fileSock = socket(AF_INET,SOCK_STREAM,0); SOCKADDR_IN addr; addr.sin_addr.s_addr = htonl(INADDR_ANY); addr.sin_family = AF_INET; addr.sin_port = htons(SERVERPORT); err = bind(fileSock,(struct sockaddr*)&addr,sizeof addr); if(err != 0) return -1; return fileSock; } int SendText(SOCKET textSock, TCHAR* text) { int err; err = sendto(textSock, (char *)text, wcslen(text)*2, 0, (SOCKADDR*)&client_addr,sizeof(client_addr)); if(err == SOCKET_ERROR) { return -1; } return err; } int RecvText(SOCKET textSock, TCHAR* text) { int client_addr_length = sizeof(client_addr); int length; length = recvfrom(textSock,(char*)text,SENDTEXT_LENGTH*2,0,(sockaddr*)&client_addr,&client_addr_length); if(length > 0) return length; return -1; } DWORD RecvTextThread(LPVOID Param) { int length; HWND hwnd,hRecordEdit; hwnd = FindWindow(TEXT("chatserver"),NULL); hRecordEdit = GetDlgItem(hwnd,RECORD_EDIT); HANDLE hHeap = GetProcessHeap(); TCHAR *text = (TCHAR*)HeapAlloc(hHeap,HEAP_ZERO_MEMORY,SENDTEXT_LENGTH*2); TCHAR *editText = (TCHAR*)HeapAlloc(hHeap,HEAP_ZERO_MEMORY,30000); while(true) { length = RecvText(SOCKET(Param),text); GetWindowText(hRecordEdit,editText,30000 / 2); if(length > 0) { wcscat(editText,TEXT("¢[7bïz:")); wcscat(editText,text); wcscat(editText,TEXT("\r\n\r\n")); SetWindowText(hRecordEdit,editText); SendMessage(hRecordEdit,WM_VSCROLL,SB_BOTTOM,0); } else MessageBox(NULL,TEXT("¥c6eˆmo`•ï‹
ÿ"),TEXT("•ï‹"),MB_OK); ZeroMemory(text,SENDTEXT_LENGTH*2); } HeapFree(hHeap,HEAP_NO_SERIALIZE,text); return length; } DWORD RecvFileThread(LPVOID Param) { int err; HANDLE hHeap = GetProcessHeap(); TCHAR* cache = (TCHAR*)HeapAlloc(hHeap,HEAP_ZERO_MEMORY,4096); SOCKET fileSock = (SOCKET)Param; SOCKET clientSock; HANDLE hRecvFile; DWORD NumberOfBytes; while(true) { err = listen(fileSock,5); if(err == SOCKET_ERROR) return -1; clientSock = accept(fileSock,NULL,NULL); if(clientSock == INVALID_SOCKET) return -1; int i = 0; int id = 0; id = MessageBox(NULL,TEXT("/f&T¥c6e‡eöNÿ"),TEXT("åw"),MB_YESNO); if(id == IDNO) { closesocket(clientSock); break; } else { TCHAR Line[] = TEXT("\r\n."); err = recv(clientSock,(char*)cache,4096,0); for(int count = 0; count < MAX_PATH; count++) { if(cache[count] == Line[2]) cache[count - 1] = 0x30; if(cache[count] == Line[0]) if(cache[count+1] == Line[1]) { cache[count] = 0;