学步园

开发环境  Vs 2008  新建一个 win32 console  project

//  服务器端代码

// Server.cpp : Defines the entry point for the console application.<br /> //<br /> #include "stdafx.h"<br /> #include "winsock2.h"<br /> #pragma comment(lib, "ws2_32.lib")<br /> #include <iostream><br /> using namespace std;<br /> int _tmain(int argc, char* argv[])<br /> {<br /> const int BUF_SIZE = 64;<br /> WSADATA wsd; //WSADATA变量<br /> SOCKET sServer; //服务器套接字<br /> SOCKET sClient; //客户端套接字<br /> SOCKADDR_IN addrServ;; //服务器地址<br /> char buf[BUF_SIZE]; //接收数据缓冲区<br /> char sendBuf[BUF_SIZE];//返回给客户端得数据<br /> int retVal; //返回值<br /> //初始化套结字动态库<br /> if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)<br /> {<br /> cout << "WSAStartup failed!" << endl;<br /> return 1;<br /> }</p> <p> //创建套接字<br /> sServer = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);<br /> if(INVALID_SOCKET == sServer)<br /> {<br /> cout << "socket failed!" << endl;<br /> WSACleanup();//释放套接字资源;<br /> return -1;<br /> }</p> <p> //服务器套接字地址<br /> addrServ.sin_family = AF_INET;<br /> addrServ.sin_port = htons(4999);<br /> addrServ.sin_addr.s_addr = INADDR_ANY;<br /> //绑定套接字<br /> retVal = bind(sServer, (LPSOCKADDR)&addrServ, sizeof(SOCKADDR_IN));<br /> if(SOCKET_ERROR == retVal)<br /> {<br /> cout << "bind failed!" << endl;<br /> closesocket(sServer); //关闭套接字<br /> WSACleanup(); //释放套接字资源;<br /> return -1;<br /> }</p> <p> //开始监听<br /> retVal = listen(sServer, 1);<br /> if(SOCKET_ERROR == retVal)<br /> {<br /> cout << "listen failed!" << endl;<br /> closesocket(sServer); //关闭套接字<br /> WSACleanup(); //释放套接字资源;<br /> return -1;<br /> }</p> <p> //接受客户端请求<br /> sockaddr_in addrClient;<br /> int addrClientlen = sizeof(addrClient);<br /> sClient = accept(sServer,(sockaddr FAR*)&addrClient, &addrClientlen);<br /> if(INVALID_SOCKET == sClient)<br /> {<br /> cout << "accept failed!" << endl;<br /> closesocket(sServer); //关闭套接字<br /> WSACleanup(); //释放套接字资源;<br /> return -1;<br /> }</p> <p> while(true){<br /> //接收客户端数据<br /> ZeroMemory(buf, BUF_SIZE);<br /> retVal = recv(sClient, buf, BUF_SIZE, 0);<br /> if (SOCKET_ERROR == retVal)<br /> {<br /> cout << "recv failed!" << endl;<br /> closesocket(sServer); //关闭套接字<br /> closesocket(sClient); //关闭套接字<br /> WSACleanup(); //释放套接字资源;<br /> return -1;<br /> }<br /> if(buf[0] == '0')<br /> break;<br /> cout << "客户端发送的数据: " << buf <<endl;</p> <p> cout << "向客户端发送数据: " ;<br /> cin >> sendBuf;</p> <p> send(sClient, sendBuf, strlen(sendBuf), 0);<br /> }</p> <p> //退出<br /> closesocket(sServer); //关闭套接字<br /> closesocket(sClient); //关闭套接字<br /> WSACleanup(); //释放套接字资源;</p> <p> return 0;<br /> } 

//  客户端代码

// Client.cpp : Defines the entry point for the console application.<br /> //<br /> #include "stdafx.h"<br /> #include "winsock2.h"<br /> #include <iostream><br /> #pragma comment(lib, "ws2_32.lib")<br /> using namespace std;<br /> BOOL RecvLine(SOCKET s, char* buf); //读取一行数据<br /> int main(int argc, char* argv[])<br /> {<br /> const int BUF_SIZE = 64;<br /> WSADATA wsd; //WSADATA变量<br /> SOCKET sHost; //服务器套接字<br /> SOCKADDR_IN servAddr; //服务器地址<br /> char buf[BUF_SIZE]; //接收数据缓冲区<br /> char bufRecv[BUF_SIZE];<br /> int retVal; //返回值</p> <p> //初始化套结字动态库<br /> if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)<br /> {<br /> cout << "WSAStartup failed!" << endl;<br /> return -1;<br /> }</p> <p> //创建套接字<br /> sHost = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);<br /> if(INVALID_SOCKET == sHost)<br /> {<br /> cout << "socket failed!" << endl;<br /> WSACleanup();//释放套接字资源<br /> return -1;<br /> }<br /> //设置服务器地址<br /> servAddr.sin_family =AF_INET;<br /> servAddr.sin_addr.s_addr = inet_addr("127.0.0.1");<br /> servAddr.sin_port = htons((short)4999);<br /> int nServAddlen = sizeof(servAddr);<br /> //连接服务器<br /> retVal=connect(sHost,(LPSOCKADDR)&servAddr, sizeof(servAddr));<br /> if(SOCKET_ERROR == retVal)<br /> {<br /> cout << "connect failed!" << endl;<br /> closesocket(sHost); //关闭套接字<br /> WSACleanup(); //释放套接字资源<br /> return -1;<br /> }<br /> while(true){<br /> //向服务器发送数据<br /> ZeroMemory(buf, BUF_SIZE);<br /> cout << " 向服务器发送数据: ";<br /> cin >> buf;<br /> retVal = send(sHost, buf, strlen(buf), 0);<br /> if (SOCKET_ERROR == retVal)<br /> {<br /> cout << "send failed!" << endl;<br /> closesocket(sHost); //关闭套接字<br /> WSACleanup(); //释放套接字资源<br /> return -1;<br /> }<br /> //RecvLine(sHost, bufRecv);<br /> recv(sHost, bufRecv,5 , 0); // 接收服务器端的数据， 只接收5个字符<br /> cout << endl <<"从服务器接收数据：" << bufRecv;<br /> }<br /> //退出<br /> closesocket(sHost); //关闭套接字<br /> WSACleanup(); //释放套接字资源<br /> return 0;<br /> }