基于socket简易聊天程序.doc

简单的socket程序2010-01-13 22:18虽然很简单，但还是调试了很长时间。本科时候接触过socket那个帅帅的刘老师的课，现在重新再捡起来。程序中专门建立一个FunThread线程用来接收数据，实现双向通信，也可以连续发送、连续接收。代码贴上来，如果还能保留VA View那样的颜色区别就好看了，但是试了好几遍都不行server:#include #include #define PORT 6000 /服务器端口#define MSGSIZE 1024 /收发缓冲区的大小#pragma comment(lib, ws2_32.lib) /链接静态库DWORD WINAPI FunThread(LPVOID); /创建一个线程，专门用来接收数据SOCKET sClient; /连接所用套节字SOCKET sListen; /监听套接字SOCKADDR_IN client; /保存客户的地址信息int iaddrSize = sizeof(SOCKADDR_IN); int main()WSADATA wsaData;SOCKADDR_IN local;char s_MessageMSGSIZE; /收发缓冲区WSAStartup(0x0202, &wsaData); /Initialize Windows socket librarysListen = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);/创建服务器监听套节字。TCP协议local.sin_family = AF_INET; /AF_INET指明使用TCP/IP协议族local.sin_port = htons(PORT);/指明连接服务器的端口号local.sin_addr.s_addr = htonl(INADDR_ANY);/自动获取本机地址bind(sListen, (struct sockaddr *)&local, sizeof(SOCKADDR_IN);/地址绑定到套接字listen(sListen, 1);/开始监听sClient = accept(sListen, (struct sockaddr *)&client, &iaddrSize);/建立连接printf(Accepte client:%s:%dn, inet_ntoa(client.sin_addr), ntohs(client.sin_port);HANDLE hThread=CreateThread(NULL,0,FunThread,0,0,0);/创建接收线程CloseHandle(hThread);while (TRUE) printf(Server Send:); /从键盘输入 gets(s_Message); /发送数据 send(sClient, s_Message, strlen(s_Message), 0); return 0; DWORD WINAPI FunThread(LPVOID) char c_MessageMSGSIZE; /收发缓冲区int ret; /接收字节的个数while (TRUE) ret = recv(sClient, c_Message, MSGSIZE, 0);/接收数据 if(ret=SOCKET_ERROR) printf(nclient is closed!); sClient = accept(sListen, (struct sockaddr *)&client, &iaddrSize);/重新开始监听 printf(nAccepte new client:%s:%d, inet_ntoa(client.sin_addr), ntohs(client.sin_port); memset(c_Message,0,1024);/将原来的client message归零 continue; c_Messageret = 0; printf(nReceived: %sn, c_Message); return 0; client:#include #include #define SERVER_ADDRESS 127.0.0.1 /服务器端IP地址#define PORT 6000 #define MSGSIZE 1024#pragma comment(lib, ws2_32.lib) DWORD WINAPI FunThread(LPVOID); SOCKET sClient; SOCKADDR_IN server;int main() WSADATA wsaData; char c_MessageMSGSIZE; WSAStartup(0x0202, &wsaData);sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); memset(&server, 0, sizeof(SOCKADDR_IN); /先将保存地址的server置为全0server.sin_family = PF_INET; /声明地址格式是TCP/IP地址格式server.sin_port = htons(PORT); /指明连接服务器的端口号server.sin_addr.s_addr = inet_addr(SERVER_ADDRESS); /指明连接服务器的IP地址connect(sClient, (struct sockaddr *)&server, sizeof(SOCKADDR_IN); /连到刚才指明的服务器上HANDLE hThread=CreateThread(NULL,0,FunThread,0,0,0);CloseHandle(hThread);while (TRUE) printf(Client Send:); gets(c_Message); send(sClient, c_Message, strlen(c_Message), 0); if(!strcmp(c_Message,exit)/client自身退出 exit(1);/ 释放连接和进行结束工作closesocket(sClient);WSACleanup();return 0;DWORD WINAPI FunThread(LPVOID)char s_MessageMSGSIZE;int ret; while (TRUE) ret = recv(sClient, s_Message, MSGSIZE, 0); if(ret=SOCKET_ERROR) printf(nServer is closed!n); exit(1); s_Messageret = 0; printf(nReceived: %sn, s_Message); if(!strcmp(s_Message,exit)/server让client退出 exit(1);return 0;程序在VC+ 6.0环境下编译通过。先运行server端，再运行clien