Socket套接字编程（TCP基本编程）

Socket函数

#include
#include
int socket(int domain, int type, int protocol);

创建一个套接字用于通信。

domain ：指定通信协议族（protocolfamily）

type：指定socket类型，流式套接字SOCK_STREAM，数据报套接字SOCK_DGRAM，原始套接字SOCK_RAW

protocol ：协议类型

TCP客户端/服务器流程图

bind函数

#include
#include
int bind(int sockfd, const struct sockaddr *addr,socklen_t addrlen);

用于绑定一个本地地址到套接字。

参数说明（后面函数参数同此）

sockfd：socket函数返回的套接字

addr：要绑定的地址，并将其转化为通用地址结构

listen函数

#include
#include
int listen(int sockfd, int backlog);

listen函数应该在调用socket和bind函数之后，调用函数accept之前调用。

对于给定的监听套接字，内核要维护两个队列：

1、未完成链接队列:已由客户端发出并到达服务器，服务器正在等待完成相应的TCP三路握手过程，套接字处于SYN_RCVD状态

2、已完成链接队列:每个已完成TCP三路握手过程的客户端，套接字处于ESTABLISHED状态。

三路握手过程如图

accept函数

#include
#include
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

从已完成连接队列返回第一个连接，产生一个socket套接字用于与客户端进行通信，如果已完成连接队列为空，则阻塞。

connect函数

#include
#include
int connect(int sockfd, const struct sockaddr *addr,socklen_t addrlen);

建立一个连接至addr所指定（客户端）的套接字。

代码实例

服务器端代码

#include
#include
#include
#include
#include
#include
#include
#include
int main(int argc,char * argv[])
{int listenfd,connfd;char sendbuf[100]= {"got your msg"},revbuf[100]= {};struct sockaddr_in ser,clt;socklen_t len=sizeof(clt);listenfd=socket(AF_INET,SOCK_STREAM,0);ser.sin_family = AF_INET;ser.sin_port = htons(8001);ser.sin_addr.s_addr = inet_addr("127.0.0.1");if(bind(listenfd,(struct sockaddr*)&ser,sizeof(ser))<0){printf("bind failed!\n");exit(0);}if(listen(listenfd,SOMAXCONN)<0){printf("listen failed!\n");exit(0);}cOnnfd=accept(listenfd,(struct sockaddr*)&clt,(socklen_t *)&len);if(cOnnfd==-1){printf("connect failed!\n");exit(0);}for(;;){int ret=read(connfd,revbuf,sizeof(revbuf));if(ret<0){printf("read failed!\n");exit(0);}else if(ret==0){printf("client closed\n");exit(0);}printf("server revmsg:%s\n",revbuf);write(connfd,sendbuf,sizeof(sendbuf));memset(revbuf,0,sizeof(revbuf));}close(listenfd);close(connfd);return 0;
}

客户端代码

#include
#include
#include
#include
#include
#include
#include
#include
int main(int argc,char *argv[])
{struct sockaddr_in user;int sockfd;char sendbuf[100],revbuf[100];sockfd=socket(AF_INET,SOCK_STREAM,0);if(sockfd==-1){printf("socket failed!\n");exit(0);}user.sin_family = AF_INET;user.sin_port = htons(8001);user.sin_addr.s_addr = inet_addr("127.0.0.1");if ( connect(sockfd, (struct sockaddr*) (&user), sizeof(user)) <0){perror("connect failed!\n");exit(0);}while(~scanf("%s",sendbuf)){write(sockfd,sendbuf,sizeof(sendbuf));read(sockfd,revbuf,sizeof(revbuf));printf("client revmsg:%s\n",revbuf);memset(sendbuf,0,sizeof(sendbuf));memset(sendbuf,0,sizeof(revbuf));}close(sockfd);return 0;
}

客户端中断关闭