C语言socket循环监听,C语言编写Socket监听处理程序一例

//C语言编写Socket监听处理程序一例

//服务器端

//--------------------------------------------------------------------------------------------

#include

#include

#include

#include

#include

#include

#include

#include

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

#define MAX_PENDING_CONNECTS 4

//声明函数

void tt(void);

DWORD WINAPI HandleSocket(LPVOID lpParam);

//程序入口点

int _tmain(int argc, _TCHAR* argv[])

{

tt();

//stop screen method 1

char q;

cin>>q;

//stop screen method 2

//getchar();

return 0;

}

//#include //放在最顶端的.h中开头处

//#include

//#include

//#pragma comment(lib,"WS2_32.lib")

void tt(void)

{

WORD wVersionRequested;

WSADATA wsaData;

int err;

//版本请求

wVersionRequested = MAKEWORD( 1, 1 );

//初始化WinSock(WSAStartup函数)

err = WSAStartup( wVersionRequested, &wsaData);

if ( err != 0 )

{ //初始化出错了退出函数

return;

}

//初始化成功！但版本不一致! 退出函数

if ( LOBYTE( wsaData.wVersion ) != 1 ||

HIBYTE( wsaData.wVersion ) != 1 ) {

WSACleanup( ); //清除Socket

return; //退出函数

}

//生成一个socket(sockSrv变量)

//SOCK_STREAM 用于TCP协议

//SOCK_DGRAM 用于UDP协议

SOCKET sockSrv=socket(AF_INET,SOCK_STREAM,0); //使用TCP协议

//设置一个地址Socket(addrSrv变量)

SOCKADDR_IN addrSrv;

addrSrv.sin_addr.S_un.S_addr=inet_addr("192.168.1.232"); //本机IP地址

addrSrv.sin_family=AF_INET;

addrSrv.sin_port=htons(6000); //端口6000

//绑定函数(指定本地IP地址所使用的端口号时候使用)

//(把sockSrv变量与addrSrv变量绑定在一起)

bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));

//监听端口开始

if(listen(sockSrv,MAX_PENDING_CONNECTS)!=0)

{

printf("listen(sock) failed: %d\n ",::WSAGetLastError());

return;//ExitProcess(STATUS_FAILED);

}

printf("开始监听...");

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

SOCKET sockClient;

SOCKADDR_IN addrClient;//定义一个客户端Socket地址

int len=sizeof(SOCKADDR);

char recvBuf[100];

int recv_len=-1;

//

sockaddr_in acc_sin;

int acc_sin_len;

acc_sin_len=sizeof(acc_sin);

//

while(true)

{

//接收Socket请求 来自客户端的Connect

sockClient=accept(sockSrv,(struct sockaddr*)&acc_sin, &acc_sin_len);

if(sockClient>=0)

{

//创建一个线程来处理socket请求threadHandle

DWORD id;

HANDLE threadHandle = CreateThread(0, 0,(LPTHREAD_START_ROUTINE)HandleSocket,(LPVOID)sockClient, 0, &id);

接收数据并保存到recvBuf变量中

//recv_len=recv(sockClient,recvBuf,100,0);

recv_len=recvfrom(sockClient,recvBuf,100,0,(SOCKADDR*)&addrClient,&len);

//while(recv_len>=0)

//{

// if (recv_len==0)

// {

// printf("本次接收的没有数据，是响应客户端连接信息！\n ");

// }

// else

// {

// //输出数据

// recvBuf[recv_len]='\0'; //在末尾加入字符串结束符号 '\0 '

// printf("%s\n",recvBuf);

// printf("本次数据接收结束。\n ");

// }

// recv_len=recv(sockClient,recvBuf,100,0);//recvfrom(sockSrv,recvBuf,100,0,(SOCKADDR*)&addrClient,&len);

//}

}

else

{ //没有客户端接入

printf("没有客户端接入2\n");

}

Sleep(200);

}

//关闭Socket变量sockSrv

closesocket(sockSrv);

//清除Socket

WSACleanup();

}

DWORD WINAPI HandleSocket(LPVOID lpParam)

{

SOCKET sockClient=(SOCKET)lpParam;

//接收数据并保存到recvBuf变量中

char recvBuf[100];

int recv_len=-1;

while(1)

{

recv_len=recv(sockClient,recvBuf,100,0);

//recv_len=recvfrom(sockClient,recvBuf,100,0,(SOCKADDR*)&addrClient,&len);

if(recv_len>=0)

{

if (recv_len==0)

{

printf("本次接收的没有数据，是响应客户端连接信息！\n ");

}

else

{

//输出数据

recvBuf[recv_len]='\0'; //在末尾加入字符串结束符号 '\0 '

printf("%s\n",recvBuf);

printf("本次数据接收结束。\n ");

}

//recv_len=recv(sockClient,recvBuf,100,0);//recvfrom(sockSrv,recvBuf,100,0,(SOCKADDR*)&addrClient,&len);

}

}

}

//客户端

//--------------------------------------------------------------------------------------------

#pragma once

#include

#include

#include

#include "targetver.h"

#include

#include

#include

#include

#include

using namespace std;

#include "string.h"

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

void SendMessage(void);

int _tmain(int argc, _TCHAR* argv[])

{

SendMessage();

char q;

cin>>q;

return 0;

}

void SendMessage(void)

{

WORD wVersionRequested;

WSADATA wsaData;

int err;

//版本请求

wVersionRequested = MAKEWORD( 1, 1 );

//初始化WinSock(WSAStartup函数)

err = WSAStartup( wVersionRequested, &wsaData);

if ( err != 0 )

{ //初始化出错了退出函数

return;

}

//初始化成功！但版本不一致! 退出函数

if ( LOBYTE( wsaData.wVersion ) != 1 ||

HIBYTE( wsaData.wVersion ) != 1 ) {

WSACleanup( ); //清除Socket

return; //退出函数

}

//生成一个socket(sockSrv变量)

//SOCK_STREAM 用于TCP协议

//SOCK_DGRAM 用于UDP协议

SOCKET sockSrv=socket(AF_INET,SOCK_STREAM,0); //使用TCP协议

//设置一个地址Socket(addrSrv变量)

SOCKADDR_IN addrSrv;

memset(&addrSrv,0,sizeof(addrSrv));

addrSrv.sin_addr.S_un.S_addr=inet_addr("192.168.1.232");//要访问的IP地址

addrSrv.sin_family=AF_INET;

addrSrv.sin_port=htons(6000); //端口6000

//绑定函数(指定本地IP地址所使用的端口号时候使用)

//(把sockSrv变量与addrSrv变量绑定在一起)

bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));

if(connect(sockSrv, (sockaddr*)&addrSrv,sizeof( addrSrv ) ) != SOCKET_ERROR )

{

int i=0;

char strch[]={ "Client send OK!(from Client) "};

while(true)

{

//strch[strlen(strch)]=i;

if(send(sockSrv,strch,strlen(strch),0)==SOCKET_ERROR)

{

printf("WSAGetLastError: %d\n ",WSAGetLastError());

}

else

{

printf(strch);printf("\n");

}

Sleep(300);

}

}

else

{

printf("没连上!\n");

}

//关闭Socket变量sockSrv

closesocket(sockSrv);

//清除Socket

WSACleanup();

printf("已退出SendMessage函数!\n");

}

-----the----end-----