win32简单的sockeTCP协议通信

什么也不说了看代码

首先是服务端代码

 #include <stdio.h>

 #include <stdlib.h>

 #include <WinSock2.h>

 #include <Windows.h>

 #include <process.h>

 #include <string.h>

 #define  BUFFSIZE 1024

 #pragma comment(lib,"ws2_32.lib")    //lib库

 unsigned int WINAPI ThreadProc(LPVOID lpArgs);

 typedef struct _tagSOCKET

 {

     SOCKET m_clientSocket;

     SOCKET m_ServerSocket;

     sockaddr_in m_ClientAddr;

 }TAGSOCKET,*PTAGSOCKET;

 HANDLE g_Thread = NULL;

 int main(void)

 {

     WSADATA wsData;

     //建立一个服务器socket

     SOCKET hServer;

     int hError;

     WORD wVersion = MAKEWORD(,);

     if(WSAStartup(wVersion,&wsData))//初始化

     {

         WSACleanup();

         return ;

     }

     hServer = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);    //创建套接字

     hError = WSAGetLastError();

     if (hServer==INVALID_SOCKET)

     {

         printf("错误代码%d\r\n",hError);

         if(SOCKET_ERROR != closesocket(hServer))    //关闭套接字

             WSACleanup();    //终止使用流式网络连接

         return ;

     }

     //创建服务监听的地址端口

     sockaddr_in addrServer;

     addrServer.sin_family = AF_INET;

     addrServer.sin_port = htons();

     addrServer.sin_addr.S_un.S_addr = htonl(INADDR_ANY);    //INADDR_ANY     意思是接收当前机器上任何配置的本地ip连接

     //绑定与相关联的套接字本地地址

     if(SOCKET_ERROR == bind(hServer,(sockaddr*)&addrServer,sizeof(addrServer)))

     {

         printf("绑定失败\r\n");

         if(SOCKET_ERROR != closesocket(hServer))    //关闭套接字

             WSACleanup();    //终止使用流式网络连接

         return ;

     }

     //在socket上监听

     if(SOCKET_ERROR==listen(hServer,SOMAXCONN))

     {

         printf("监听失败\r\n");

         if(SOCKET_ERROR != closesocket(hServer))    //关闭套接字

             WSACleanup();    //终止使用流式网络连接

         return ;

     }

     //接收来自客户端的连接请求信息

     SOCKET cLientSocket;

     sockaddr_in clientAddr;

     int nLent = sizeof clientAddr;

     cLientSocket = accept(hServer,(sockaddr*)&clientAddr,&nLent);

     if(cLientSocket== SOCKET_ERROR)

     {

         printf("错误的客户socket连接\r\n");

         if (SOCKET_ERROR !=closesocket(hServer))

         {

             WSACleanup();

             return ;

         }

     }

     TAGSOCKET uSerdata;

     ZeroMemory(&uSerdata,sizeof(TAGSOCKET));

     uSerdata.m_clientSocket = cLientSocket;

     uSerdata.m_ServerSocket = hServer;

     uSerdata.m_ClientAddr = clientAddr;

     //循环接收客户端数据

     g_Thread = (HANDLE)_beginthreadex(NULL,NULL,ThreadProc,(LPVOID)&uSerdata,NULL,NULL);

     WaitForSingleObject(g_Thread,INFINITE);

     CloseHandle(g_Thread);

     /*in_addr addr;

     addr.S_un.S_addr = inet_addr("192.168.1.1");    //将字符串ip转换成in_addr

     //htonl() 主机转TCP 该 htonl函数可用于在主机字节顺序IPv4地址转换为网络字节顺序的IPv4地址。

     //该功能不会检查hostlong参数是否是有效的IPv4地址。

     // htons()

     //inet_ntoa函数 将in_addr类型转换成字符串格式

     //htons()    该 htons函数可用于将IP端口号主机字节顺序转换成网络字节顺序的IP端口号

     */

     system("pause");

     return ;

 }

 unsigned int WINAPI ThreadProc(LPVOID lpArgs)

 {

     //接收来自客户发送的数据

     PTAGSOCKET tempSocket = (PTAGSOCKET)lpArgs;

     if(tempSocket->m_clientSocket == SOCKET_ERROR || tempSocket->m_ServerSocket == SOCKET_ERROR)

     {

         closesocket(tempSocket->m_clientSocket);

         closesocket(tempSocket->m_ServerSocket);

         WSACleanup();

         return ;

     }

     char szbuf[BUFFSIZE];

     int nRecverror = SOCKET_ERROR;

     while(TRUE)

     {

         ZeroMemory(szbuf,BUFFSIZE);

         nRecverror = recv(tempSocket->m_clientSocket,szbuf,BUFFSIZE,NULL);

         if(nRecverror==SOCKET_ERROR)

         {

             closesocket(tempSocket->m_clientSocket);

             closesocket(tempSocket->m_ServerSocket);

             WSACleanup();

             break;

         }

         char sprintfbuf[BUFFSIZE];

         ZeroMemory(sprintfbuf,BUFFSIZE);

         sprintf_s(sprintfbuf,"Ip:%s:\t数据:%s\r\n",inet_ntoa(tempSocket->m_ClientAddr.sin_addr),szbuf);

         printf("%s\r\n",sprintfbuf);

         if (!_stricmp(szbuf,"close"))

         {

             nRecverror = send(tempSocket->m_clientSocket,"close",strlen("close")+,NULL);

             if (nRecverror== SOCKET_ERROR)

             {

                 closesocket(tempSocket->m_clientSocket);

                 closesocket(tempSocket->m_ServerSocket);

                 WSACleanup();

                 break;

             }

             break;

         }else

         {

             sprintf_s(sprintfbuf,"已经接收到您发送的信息:%s\r\n",szbuf);

             nRecverror = send(tempSocket->m_clientSocket,sprintfbuf,strlen(sprintfbuf),NULL);

             if (nRecverror== SOCKET_ERROR)

             {

                 closesocket(tempSocket->m_clientSocket);

                 closesocket(tempSocket->m_ServerSocket);

                 WSACleanup();

                 break;

             }

         }

     }

     printf("程序即将退出\r\n");

     closesocket(tempSocket->m_clientSocket);

     closesocket(tempSocket->m_ServerSocket);

     WSACleanup();

     return ;

 }

下面是客户端代码

 #include <stdio.h>

 #include <stdlib.h>

 #include <WinSock2.h>

 #include <Windows.h>

 #pragma comment(lib,"ws2_32.lib")

 #define BUFFSIZE 1024

 int main(void)

 {

     WSADATA wSdata;

 //    char hostName[256]={0};

     SOCKET hClientSocket;

     WORD wVerison = MAKEWORD(,);

     sockaddr_in sockeaddr;

 //    PHOSTENT hoStent;

     if(WSAStartup(wVerison,&wSdata))

     {

         WSACleanup();

         return ;

     }

      hClientSocket = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);

      if(hClientSocket==INVALID_SOCKET)

      {

          WSACleanup();

          return ;

      }

     /* gethostname(hostName,256);

      hoStent = gethostbyname(hostName);

      if(!hoStent)

      {

          closesocket(hClientSocket);

          WSACleanup();

          return 0;

      }*/

      ZeroMemory(&sockeaddr,sizeof(sockaddr_in));

      sockeaddr.sin_family = AF_INET;

     // printf("%s\r\n",inet_ntoa(*(in_addr*)hoStent->h_addr));

      sockeaddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");

      sockeaddr.sin_port = htons();

      //然后链接远程服务器

      if(SOCKET_ERROR == connect(hClientSocket,(sockaddr*)&sockeaddr,sizeof(sockaddr_in)))

      {

          closesocket(hClientSocket);

          WSACleanup();

          return ;

      }

      char szbuf[BUFFSIZE];

      int Nerror = SOCKET_ERROR;

      while(TRUE)

      {

          ZeroMemory(szbuf,BUFFSIZE);

          char sztemp[BUFFSIZE]={};

          ZeroMemory(sztemp,BUFFSIZE);

          printf("请输入你要发送的内容:\r\n");

          scanf("%s",sztemp);

          Nerror = send(hClientSocket,sztemp,strlen(sztemp)+,);

          if (Nerror==SOCKET_ERROR)

          {

              break;

          }

          Nerror = recv(hClientSocket,szbuf,BUFFSIZE,);

          if (Nerror==SOCKET_ERROR)

          {

              break;

          }else

          {

              printf("接收到的数据:%s\r\n",szbuf);

          }

          if (!_stricmp(szbuf,"close"))

          {

              printf("即将关闭程序\r\n");

              break;

          }

      }

      closesocket(hClientSocket);

      WSACleanup();

     system("pause");

     return ;

 }

最后的效果就是这样

巴特西

win32简单的sockeTCP协议通信

最新文章

热门文章