flex与C++多线程服务器端交互

// flexSocket1.cpp : 定义控制台应用程序的入口点。 // #include "stdafx.h" #include <winsock2.h> #include <stdio.h> #include <windows.h> #include <iostream> #pragma comment(lib,"ws2_32.lib") DWORD WINAPI AnswerThread(LPVOID lparam) { SOCKET ClientSocket = (SOCKET)(LPVOID)lparam; char buf1[20] = "11111111111111111"; char buf[4096] = ""; while(1) { if(send(ClientSocket,buf1,strlen(buf1)+1,0)==SOCKET_ERROR) { printf("发送数据失败！\n"); closesocket(ClientSocket); return 0; } //printf("Message to %s: %s\n",inet_ntoa(ClientSocket.sin_addr),buf); Sleep(2000); } return 0; } int main(int argc, char* argv[]) { //初始化WINSOCKET WSADATA wsaData; int iRet = WSAStartup(MAKEWORD(2, 2), &wsaData); if(iRet != NO_ERROR) printf("Error at WSAStartup()\n"); //创建一个Socket SOCKET m_socket; m_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if(m_socket == INVALID_SOCKET) { printf("Error at socket():%ld\n", WSAGetLastError()); WSACleanup(); return 0; } //绑定socket /**** sin_family指代协议族，在socket编程中只能是AF_INET sin_port存储端口号（使用网络字节顺序） sin_addr存储IP地址，使用in_addr这个数据结构 sin_zero是为了让sockaddr与sockaddr_in两个数据结构保持大小相同而保留的空字节。 s_addr按照网络字节顺序存储IP地址 ***/ sockaddr_in service; service.sin_family = AF_INET; service.sin_addr.s_addr = inet_addr("127.0.0.1"); service.sin_port = htons(1800); if(bind(m_socket, (SOCKADDR*)&service, sizeof(service)) == SOCKET_ERROR) { printf("bind() failed.\n"); closesocket(m_socket); return 0; } else printf("bind OK.\n"); //在socket上侦听 if(listen(m_socket, 20) == SOCKET_ERROR) printf("Error listening on socket.\n"); else printf("Listening ok.\n"); SOCKET AcceptSocket; printf("Waiting for a client to connect...\n"); char buf[4096] = ""; SOCKADDR_IN addrClient; while(1) { AcceptSocket = SOCKET_ERROR; while(AcceptSocket == SOCKET_ERROR) { AcceptSocket = accept(m_socket, (SOCKADDR*)&addrClient, NULL); } printf("Client Connected.\n"); int bytes; if((bytes=recv(AcceptSocket,buf,sizeof(buf),0))==SOCKET_ERROR) { printf("接收数据失败!\n"); exit(-1); } buf[bytes]='\0'; printf("Message from %s: %s\n",inet_ntoa(addrClient.sin_addr),buf); char rbuf[100]= "<cross-domain-policy> " "<allow-access-from domain=\"*\" to-ports=\"*\"/>" "</cross-domain-policy> ";//套接字策略文件 if (0 == strcmp(buf,"<policy-file-request/>")) { //发送数据 if(send(AcceptSocket,rbuf,strlen(rbuf)+1,0)==SOCKET_ERROR) { printf("发送数据失败！"); exit(-1); } printf("Message to %s: %s\n",inet_ntoa(addrClient.sin_addr),rbuf); closesocket(AcceptSocket); } else { DWORD dwThreadId; HANDLE hThread; hThread = CreateThread(NULL, NULL, AnswerThread, (LPVOID)AcceptSocket, 0, &dwThreadId); if(hThread == NULL) { printf("CreatThread AnswerThread() failed.\n"); } else { printf("CreateThread OK.\n"); } } } return 0; }