Socket函数
#include <sys/types.h> #include <sys/socket.h> int socket(int domain, int type, int protocol);
创建一个套接字用于通信。
domain :指定通信协议族(protocolfamily)
type:指定socket类型,流式套接字SOCK_STREAM,数据报套接字SOCK_DGRAM,原始套接字SOCK_RAW
protocol :协议类型
TCP客户端/服务器流程图
bind函数
#include <sys/types.h> #include <sys/socket.h> int bind(int sockfd, const struct sockaddr *addr,socklen_t addrlen);
用于绑定一个本地地址到套接字。
参数说明(后面函数参数同此)
sockfd:socket函数返回的套接字
addr:要绑定的地址,并将其转化为通用地址结构
addrlen:地址长度listen函数
#include <sys/types.h> #include <sys/socket.h> int listen(int sockfd, int backlog);
listen函数应该在调用socket和bind函数之后,调用函数accept之前调用。
对于给定的监听套接字,内核要维护两个队列:
1、未完成链接队列:已由客户端发出并到达服务器,服务器正在等待完成相应的TCP三路握手过程,套接字处于SYN_RCVD状态
2、已完成链接队列:每个已完成TCP三路握手过程的客户端,套接字处于ESTABLISHED状态。
三路握手过程如图
accept函数
#include <sys/types.h> #include <sys/socket.h> int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
从已完成连接队列返回第一个连接,产生一个socket套接字用于与客户端进行通信,如果已完成连接队列为空,则阻塞。
connect函数
#include <sys/types.h> #include <sys/socket.h> int connect(int sockfd, const struct sockaddr *addr,socklen_t addrlen);
建立一个连接至addr所指定(客户端)的套接字。
代码实例
服务器端代码
#include<stdio.h> #include<unistd.h> #include<stdlib.h> #include<sys/types.h> #include<sys/socket.h> #include<netinet/in.h> #include<arpa/inet.h> #include<string.h> 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<stdio.h> #include<unistd.h> #include<stdlib.h> #include<sys/types.h> #include<sys/socket.h> #include<netinet/in.h> #include<arpa/inet.h> #include<string.h> 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; }
客户端中断关闭