用C语言进行最基本的socket编程
什么是socket
你经常听到人们谈论着“socket”，或许你还不知道它的确切含义。现在让我告诉你：它是使用标准Unix文件描述符(filedescriptor)和其它程序通讯的方式。什么？你也许听到一些Unix高手(hacker)这样说过：“呀，Unix中的一切就是文件！”那个家伙也许正在说到一个事实：Unix程序在执行任何形式的I/O的时候，程序是在读或者写一个文件描述符。一个文件描述符只是一个和打开的文件相关联的整数。但是(注意后面的话)，这个文件可能是一个网络连接，FIFO，管道，终端，磁盘上的文件或者什么其它的东西。Unix中所有的东西就是文件！所以，你想和Internet上别的程序通讯的时候，你将要使用到文件描述符。你必须理解刚才的话。现在你脑海中或许冒出这样的念头：“那么我从哪里得到网络通讯的文件描述符呢？”，这个问题无论如何我都要回答：你利用系统调用socket()，它返回套接字描述符(socketdescriptor)，然后你再通过它来进行send()和recv()调用。“但是...”，你可能有很大的疑惑，“如果它是个文件描述符，那么为什么不用一般调用read()和write()来进行套接字通讯？”简单的答案是：“你可以使用！”。详细的答案是：“你可以，但是使用send()和recv()让你更好的控制数据传输。”存在这样一个情况：在我们的世界上，有很多种套接字。有DARPAInternet地址(Internet套接字)，本地节点的路径名(Unix套接字)，CCITTX.25地址(你可以将X.25套接字完全忽略)。也许在你的Unix机器上还有其它的。我们在这里只讲第一种：Internet套接字。
Internet套接字的两种类型：
什么意思？有两种类型的Internet套接字？是的。不，我在撒谎。其实还有很多，但是我可不想吓着你。我们这里只讲两种。除了这些,我打算另外介绍的"RawSockets"也是非常强大的，很值得查阅。
那么这两种类型是什么呢？一种是"StreamSockets"（流格式），另外一种是"DatagramSockets"（数据包格式）。我们以后谈到它们的时候也会用到"SOCK_STREAM"和"SOCK_DGRAM"。数据报套接字有时也叫“无连接套接字”(如果你确实要连接的时候可以用connect()。)流式套接字是可靠的双向通讯的数据流。如果你向套接字按顺序输出“1，2”，那么它们将按顺序“1，2”到达另一边。它们是无错误的传递的，有自己的错误控制，在此不讨论。
有什么在使用流式套接字？你可能听说过telnet，不是吗？它就使用流式套接字。你需要你所输入的字符按顺序到达，不是吗？同样，WWW浏览器使用的HTTP协议也使用它们来下载页面。实际上，当你通过端口80telnet到一个WWW站点，然后输入“GETpagename”的时候，你也可以得到HTML的内容。为什么流式套接字可以达到高质量的数据传输？这是因为它使用了“传输控制协议(TheTransmissionControlProtocol)”，也叫“TCP”(请参考RFC-793获得详细资料。)TCP控制你的数据按顺序到达并且没有错
误。你也许听到“TCP”是因为听到过“TCP/IP”。这里的IP是指“Internet协议”(请参考RFC-791。)IP只是处理Internet路由而已。
那么数据报套接字呢？为什么它叫无连接呢？为什么它是不可靠的呢？有这样的一些事实：如果你发送一个数据报，它可能会到达，它可能次序颠倒了。如果它到达，那么在这个包的内部是无错误的。数据报也使用IP作路由，但是它不使用TCP。它使用“用户数据报协议(UserDatagramProtocol)”，也叫“UDP”(请参考RFC-768。)
为什么它们是无连接的呢？主要是因为它并不象流式套接字那样维持一个连接。你只要建立一个包，构造一个有目标信息的IP头，然后发出去。无需连接。它们通常使用于传输包-包信息。简单的应用程序有：tftp,bootp等等。
你也许会想：“假如数据丢失了这些程序如何正常工作？”我的朋友，每个程序在UDP上有自己的协议。例如，tftp协议每发出的一个被接受到包，收到者必须发回一个包来说“我收到了！”(一个“命令正确应答”也叫“ACK”包)。如果在一定时间内(例如5秒)，发送方没有收到应答，它将重新发送，直到得到ACK。这一ACK过程在实现SOCK_DGRAM应用程序的时候非常重要。
简单的发送和接收实现
服务器端接收代码：
#include<Winsock2.h>
#pragmacomment(lib,"Ws2_32.lib")
#include<stdio.h>
#include<memory.h>
voidmain()
{
WSADatawsd;
WSAStartup(MAKEWORD(2,0),&wsd);
SOCKETs=NULL;
s=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
structsockaddr_inch;
memset(&ch,0,sizeof(ch));
ch.sin_family=AF_INET;
ch.sin_addr.s_addr=INADDR_ANY;
ch.sin_port=htons(1041);
intb=bind(s,(structsockaddr*)&ch,sizeof(ch));
#defineQUEUE_SIZE5
intl=listen(s,QUEUE_SIZE);
printf("正在监听本机的1041端口！\n");
SOCKETsc=accept(s,0,0);
printf("客户端已经连接到本机的1041端口！\n");
#defineBUF_SIZE4096
intreceByt=0;
while(1)
{
charbuf[BUF_SIZE];
receByt=recv(sc,buf,BUF_SIZE,0);
buf[receByt]='\0';
if(receByt>0)
{
printf("接收的消息是：%s\n",buf);
}
else
{
printf("接收消息结束！");
break;
}
}
intic=closesocket(sc);
intis=closesocket(s);
}
客户端发送的代码：
#include<Winsock2.h>
#pragmacomment(lib,"Ws2_32.lib")
#include<stdio.h>
#include<memory.h>
#include<string.h>
voidmain()
{
WSADatawsd;
WSAStartup(MAKEWORD(2,0),&wsd);
SOCKETs=NULL;
s=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
structsockaddr_inch;
memset(&ch,0,sizeof(ch));
ch.sin_family=AF_INET;
ch.sin_addr.s_addr=inet_addr("127.0.0.1");
ch.sin_port=htons(1041);
intc=connect(s,(structsockaddr*)&ch,sizeof(ch));
printf("已经连接到服务器的1041端口！现在可以向服务器发送消息了！\n");
#defineBUF_SIZE4096
charinfo[1024],buf[BUF_SIZE];
while(1)
{
gets(info);
if(info[0]=='\0')
break;
strcpy(buf,info);
intnsend=send(s,buf,strlen(buf),0);
}
intic=closesocket(s);
}
程序代码经过了优化，并且整合多线程，把接收和发送放到同一个文件中，使用参数模式调用发送和接收模块。增加了创建SOCKET的创建的时候s句柄（或对象）判断返回值是否为INVALID_SOCKET，以及socket的bind操作的返回值是否为SOCKET_ERROR，其他socket的操作应该也判断SOCKET_ERROR，以保证程序的稳定性，这里只是测试代码就不去写这么多了，剩下的就由你个人发挥。
#include<Winsock2.h>
#pragmacomment(lib,"Ws2_32.lib")
#include<stdio.h>
#include<memory.h>
#include<string.h>
#include<pthread.h>
voidReceive();
voidSend();
voidcreatThread();
SOCKETs=NULL;
pthread_tt[1000];
intthreadCount=0;
voidmain(intargc,char*argv[])
{
printf("本程序制作人学号：713901040041\n");
printf("程序说明：服务器端和客户端为同一个程序，请使用不同的参数运行.\n");
printf("接收程序请使用r参数；发送程序请使用s参数。\n");
//printf("len:%d\n",argc);
//printf("count%d\n",argc);
//printf("value:%s\n",argv[1]);
//printf("%d",argv[1][0]=='r');
if(argc<=1)
{
printf("pleaseinputprogramarguments...\n");
exit(0);
}
if(argc>1&&argv[1][0]=='r')
{
printf("runreceive...\n");
Receive();
}
if(argc>1&&argv[1][0]=='s')
{
printf("runsend...\n");
Send();
}
}
void*receiveWork(void*args)
{
SOCKETsc=accept(s,0,0);
if(sc==INVALID_SOCKET)
{
printf("scError");
}
creatThread();
printf("----------客户端已经连接到本机的%d线程连接！\n",threadCount-2);
#defineBUF_SIZE4096
intreceByt=0;
while(1)
{
charbuf[BUF_SIZE];
receByt=recv(sc,buf,BUF_SIZE,0);
buf[receByt]='\0';
if(receByt>0)
{
printf("线程接收的消息是：%s\n",buf);
}
else
{
printf("客户端已退出，");
break;
}
}
intic=closesocket(sc);
printf("服务器结束连接！\n");
returnNULL;
}
voidcreatThread()
{
pthread_create(&t[threadCount++],NULL,receiveWork,NULL);
}
voidReceive()
{
WSADatawsd;
WSAStartup(MAKEWORD(2,0),&wsd);
s=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
if(s==INVALID_SOCKET)
{
printf("socketcreatedError");
}
structsockaddr_inch;
memset(&ch,0,sizeof(ch));
ch.sin_family=AF_INET;
ch.sin_addr.s_addr=INADDR_ANY;
ch.sin_port=htons(1041);
intb=bind(s,(structsockaddr*)&ch,sizeof(ch));
if(b==SOCKET_ERROR)
{
printf("bind失败，出错代码是：%d\n",WSAGetLastError());
exit(0);
}
#defineQUEUE_SIZE5
intl=listen(s,QUEUE_SIZE);
printf("正在监听本机的1041端口！\n");
creatThread();
for(inti=0;i<1000;i++)
{
pthread_join(t[i],NULL);
}
intis=closesocket(s);
}
voidSend()
{
WSADatawsd;
WSAStartup(MAKEWORD(2,0),&wsd);
SOCKETs=NULL;
s=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
if(s==INVALID_SOCKET)
{
printf("socketcreatedError");
}
structsockaddr_inch;
memset(&ch,0,sizeof(ch));
ch.sin_family=AF_INET;
ch.sin_addr.s_addr=inet_addr("127.0.0.1");
ch.sin_port=htons(1041);
intc=connect(s,(structsockaddr*)&ch,sizeof(ch));
printf("已经连接到服务器的1041端口！现在可以向服务器发送消息了！\n");
#defineBUF_SIZE4096
charinfo[1024],buf[BUF_SIZE];
while(1)
{
gets(info);
if(info[0]=='\0')
break;
strcpy(buf,info);
intnsend=send(s,buf,strlen(buf),0);
}
intic=closesocket(s);
}