C语言 Socket入门示例1—— 单工通信(客户端向服务器发送消息)

        如果对Windows API不太熟悉、对TCP/IP通信协议不太熟悉,或者对C语言本身不太熟悉的话,学习Socket会有点难受的。以前学习操作系统的时候,被API吓怕了,很多莫名其妙的API有着多如牛毛的参数,令人费解。学习计算机网络的时候,又有那么多的协议,并且很多协议本身比较复杂,什么三次握手建立连接,什么四次握手释放链接等等,也没有学得特别透彻。更遗憾的是,以前学C的时候,误以为自己把C学会了,误以为C就那么几个头文件而已,就一个黑框子而已。

        现在,经过一段时间的痛苦磨练,又有了一些新的认识:API并没有想象的那么难,只要把每个参数及返回值的含义以及各种数据类型之间的关系和转换方法弄明白了,API就可以灵活运用了。TCP/IP协议,其实对所有的通信协议都一样,不要忽略RFC文档,只要花足够的时间把协议的原理理解透了(最好自己能够随手画出来),接下来根据协议编写程序就顺理成章了。关于C/C++我过去低估了它的难度,也低估了它的功能,所以现在继续深入学习,以获得更多的精髓。

        下面将一个简单的C/S架构Socket程序程序贴出来,我也Request For 大家 Comments


1、服务端(Server):

#include <stdio.h>  
#include <winsock2.h>  
#pragma comment(lib,"ws2_32.lib")	//把ws2_32.lib加到Link页的连接库  
#define PORT 15001					//通信的端口(指服务器端)
#define ERROR 0  
#define BUFFER_SIZE 1024			//注意:此Server端数据接收缓冲区 >= Client端数据发送缓冲区 ,否则造成缓冲区溢出
/*
	服务端原理:
		1、服务器进程创建套接字
		2、将本地地址绑定到所创建的套接字上,以三元组{<通信协议>,<IP地址>,<端口号>}在网络上标识该套接字
		3、将套接字置入监听模式,并准备接受连接请求
*/
int main()  
{  
	WSADATA WSAData;  
	if(WSAStartup(MAKEWORD(2,0),&WSAData)==SOCKET_ERROR)  //启动winsock ,WSAStartup()函数对Winsock DLL进行初始化
	{  
		printf("Socket initialize fail!\n");  
		exit(1);  
	}  
	SOCKET sock;										//服务进程创建套接字句柄(用于监听)
	if((sock=socket(AF_INET,SOCK_STREAM,0))==ERROR)		//调用socket()函数创建一个流套接字,参数(网络地址类型,套接字类型,网络协议)
	{ 
		printf("Socket create!\n");  
		WSACleanup();  
		exit(1);  
	}  
	struct sockaddr_in ServerAddr;			//sockaddr_in结构用来标识TCP/IP协议下的地址,可强制转换为sockaddr结构
	ServerAddr.sin_family=AF_INET;			//sin_family字段必须设为AF_INET,表示该Socket处于Internet域
	ServerAddr.sin_port=htons(PORT);		//sin_port字段用于指定服务端口,注意避免冲突
	ServerAddr.sin_addr.s_addr=INADDR_ANY;  //sin_addr字段用于把一个IP地址保存为一个4字节的数,无符号长整型,根据不同用法还可表示本地或远程IP地址
	if(bind(sock,(LPSOCKADDR)&ServerAddr,sizeof(ServerAddr))==SOCKET_ERROR)  //调用bind()函数将本地地址绑定到所创建的套接字上,以在网络上标识该套接字
	{   
		printf("Bind fail!\n");  
		closesocket(sock);  
		WSACleanup();  
		exit(1);  
	}  
	printf("Server Socket Port:%d\n",ntohs(ServerAddr.sin_port));  
	if(listen(sock,10)==SOCKET_ERROR)		//调用listen()函数将套接字置入监听模式并准备接受连接请求,参数(已捆绑未连接的套接字描述字,正在等待连接的最大队列长度)
	{ 
		printf("Listen fail!\n");  
		closesocket(sock);  
		WSACleanup();  
		exit(1);  
	}  

	SOCKET msgsock;			//创建一个新的套接字(用于接收accept函数的返回值,即表示已经接受的那个客户端的连接,进而接收Client发来的数据)
	char buf[BUFFER_SIZE];  //数据接收缓冲区
	while(1)  
	{  
		if((msgsock=accept(sock,(LPSOCKADDR)0,(int *)0))==INVALID_SOCKET)  //进入监听状态后,调用accept()函数接收客户端的连接请求,并把连接传给msgsock套接字,原sock套接字继续监听其他客户机连接请求
		{  
			printf("Accept fail!\n");  
			continue;  
		}  
		memset(buf,0,sizeof(buf));											//初始化数据接收缓冲区
		recv(msgsock,buf,BUFFER_SIZE,0);									//接收客户端发送过来的数据  
		if(buf[0]==‘e‘ && buf[1]==‘x‘ && buf[2]==‘i‘ && buf[3]==‘t‘)		//"exit"命令,退出程序
		{  
			printf("The End.\n");  
			break;  
		}
		printf("C:\\Socket\\Server>%s",buf);  
		closesocket(msgsock);  
	}  

	closesocket(sock); //关闭套接字  
	WSACleanup();	   //终止对Winsock DLL的使用,并释放资源
	return 0;
}   



2、客户端(Client):

#include <winsock2.h>  
#include <stdio.h>  
#pragma comment(lib,"ws2_32.lib")	//把ws2_32.lib加到Link页的连接库  
//#define IP "172.18.68.243"			//在两台计算机上测试,IP为Server端的IP地址  
#define IP "127.0.0.1"				//在一台计算机上测试,IP为本地回送地址
#define PORT 15001					//注意:客户端设置通信的端口 = 服务端的端口
#define BUFFER_SIZE 1024			//数据发送缓冲区大小

int main()  
{  
	char buf[BUFFER_SIZE];								//buf数组存放客户端发送的消息  
	int inputLen;										//用于输入字符自增变量
	while(1)  
	{  
		printf("C:\\Socket\\Client>");  
		inputLen=0;  
		memset(buf,0,sizeof(buf));  
		while((buf[inputLen++]=getchar())!=‘\n‘)		//输入以回车键为结束标识
		{
			;
		}
		if(buf[0]==‘e‘ && buf[1]==‘x‘ && buf[2]==‘i‘ && buf[3]==‘t‘)  
		{  
			printf("The End.\n");  
			break;   
		}  

		WSADATA WSAData;  
		if(WSAStartup(MAKEWORD(2,0),&WSAData)==SOCKET_ERROR)  //WSAStartup()函数对Winsock DLL进行初始化
		{  
			printf("Socket initialize fail!\n");  
			continue;  
		}  
		SOCKET sock;											//客户端进程创建套接字
		if((sock=socket(AF_INET,SOCK_STREAM,0))==SOCKET_ERROR)  //创建流套接字(与服务端保持一致)
		{  
			printf("Socket create fail!\n");  
			WSACleanup();  
			continue;  
		}  

		struct sockaddr_in ClientAddr;				//sockaddr_in结构用来标识TCP/IP协议下的地址,可强制转换为sockaddr结构
		ClientAddr.sin_family=AF_INET;				//指Internet域
		ClientAddr.sin_port=htons(PORT);			//指定服务端所预留的端口
		ClientAddr.sin_addr.s_addr=inet_addr(IP);	//指定服务端所绑定的IP地址
		if(connect(sock,(LPSOCKADDR)&ClientAddr,sizeof(ClientAddr))==SOCKET_ERROR)  //调用connect()函数,向服务器进程发出连接请求  
		{ 
			printf("Connect fail!\n");  
			closesocket(sock);  
			WSACleanup();  
			continue;  
		}  
		send(sock,buf,BUFFER_SIZE,0);				 //向服务器发送数据 
		closesocket(sock);							 //关闭套接字
		WSACleanup();								//终止对Winsock DLL的使用,并释放资源,以备下一次使用
	}  
	return 0;
}  

运行效果图:

(1)客户端发送

C语言 Socket入门示例1—— 单工通信(客户端向服务器发送消息)

(2)服务端接收

C语言 Socket入门示例1—— 单工通信(客户端向服务器发送消息)

C语言 Socket入门示例1—— 单工通信(客户端向服务器发送消息),布布扣,bubuko.com

C语言 Socket入门示例1—— 单工通信(客户端向服务器发送消息)

上一篇:C语言的观察者模式


下一篇:java多线程创建方法