socket编程介绍
Socket接口是TCP/IP网络的API,Socket接口定义了许多函数或例程,可以用它们来开发TCP/IP网络上的应用程序。
Socket接口设计者最先是将接口放在Unix操作系统里面的。如果了解Unix系统的输入和输出的话,就很容易了解Socket了。网络的 Socket数据传输是一种特殊的I/O,Socket也是一种文件描述符。Socket也具有一个类似于打开文件的函数调用Socket(),该函数返回一个整型的Socket描述符,随后的连接建立、数据传输等操作都是通过该Socket实现的。
常用的Socket类型有两种:流式Socket (SOCK_STREAM)和数据报式Socket(SOCK_DGRAM)。流式是一种面向连接的Socket,针对于面向连接的TCP服务应用;数据报式Socket是一种无连接的Socket,对应于无连接的UDP服务应用。
client/server通信模型
在客户/服务器模式中我们将请求服务的一方称为客户(client),将提供某种服务的一方称为服务器(server)。
一个服务程序通常在一个众所周知的地址监听对服务的请求,也就是说服务进程一直处于休眠状态,直到一个客户对这个服务的地址提出了连接请求。在这个时刻,服务程序被“唤醒”并且为客户提供服务—对客户的请求作出适当的反应。
套接字
套接字是一个通信终结点,它是Socket应用程序用来在网络上发送或接收数据包的对象。
套接字具有类型,与正在运行的进程相关联,并且可以有名称。
套接字一般只与使用网际协议组的同一“通信域”中的其他套接字交换数据。
流式套接字编程流程
客户端
1.创建套接字
client_sockfd=socket(PF_INET,SOCK_STREAM,0)
用socket函数创建套接字,返回套接字描述符
2.定义服务器端地址
struct sockaddr_in remote_addr; //服务器端网络地址结构体memset(&remote_addr,0,sizeof(remote_addr)); //数据初始化--清零 remote_addr.sin_family=AF_INET; //设置为IP通信 remote_addr.sin_addr.s_addr=inet_addr("127.0.0.1");//服务器IP地址 remote_addr.sin_port=htons(8000); //服务器端口
3.与服务器建立连接
connect(client_sockfd,(struct sockaddr *)&remote_addr,sizeof(struct sockaddr)
用于tcp/ip应用的地址结构类型是socketsddr_in,而套接字socket中应用的地址类型为socketaddr,所以需要进行强制类型转换。
4.发送接收数据
len=send(client_sockfd,buf,strlen(buf),0); len=recv(client_sockfd,buf,BUFSIZ,0);
发送数据时已知数据的长度,用strlen(buf)计算;而接收数据时不知道接收数据的长度,就必须将接收长度设为定义的数组的最大值,再通过接收函数的返回值来确定数组的实际大小。
5.关闭套接字
close(client_sockfd);//关闭套接字
没有数据可发送就关闭套接字
服务器端
1.创建套接字,定义自身的地址
int server_sockfd=socket(PF_INET,SOCK_STREAM,0);//服务器端套接字struct sockaddr_in my_addr; //服务器网络地址结构体 memset(&my_addr,0,sizeof(my_addr)); //数据初始化--清零 my_addr.sin_family=AF_INET; //设置为IP通信 my_addr.sin_addr.s_addr=INADDR_ANY;//服务器IP地址--允许连接到所有本地地址上 my_addr.sin_port=htons(8000); //服务器端口号
2.将套接字与地址绑定
bind(server_sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr)
3.监听是否有客户请求
listen(server_sockfd,5);
4接受客户端请求
client_sockfd=accept(server_sockfd,(struct sockaddr *)&remote_addr,&sin_size)
accept函数返回新的连接的套接字描述符。为每个新的连接请求创建了一个新的套接字,服务器只对新的连接使用该套接字,原来的监听套接字接受其他的连接请求。新的连接上传输数据使用新的套接字,使用完毕,服务器将关闭这个套接字。
5.接收并发送数据
while((len=recv(client_sockfd,buf,BUFSIZ,0))>0) { buf[len]=‘\0‘; printf("recieved:%s\n",buf); printf("Enter string to send: "); scanf("%s",buf); if(send(client_sockfd,buf,strlen(buf),0)<0) { perror("write"); return 1; } }
6关闭套接字
close(client_sockfd); close(server_sockfd);
实现代码
客户端
1 #include <stdio.h> 2 #include <string.h> 3 #include <sys/types.h> 4 #include <sys/socket.h> 5 #include <netinet/in.h> 6 #include <arpa/inet.h> 7 #include <unistd.h> 8 9 int main(int argc, char *argv[]) 10 { 11 int client_sockfd; 12 int len; 13 struct sockaddr_in remote_addr; //服务器端网络地址结构体 14 char buf[BUFSIZ]; //数据传送的缓冲区 15 memset(&remote_addr,0,sizeof(remote_addr)); //数据初始化--清零 16 remote_addr.sin_family=AF_INET; //设置为IP通信 17 remote_addr.sin_addr.s_addr=inet_addr("127.0.0.1");//服务器IP地址 18 remote_addr.sin_port=htons(8000); //服务器端口号 19 20 /*创建客户端套接字--IPv4协议,面向连接通信,TCP协议*/ 21 if((client_sockfd=socket(PF_INET,SOCK_STREAM,0))<0) 22 { 23 perror("socket"); 24 return 1; 25 } 26 27 /*将套接字绑定到服务器的网络地址上*/ 28 if(connect(client_sockfd,(struct sockaddr *)&remote_addr,sizeof(struct sockaddr))<0) 29 { 30 perror("connect"); 31 return 1; 32 } 33 printf("connected to server\n"); 34 len=recv(client_sockfd,buf,BUFSIZ,0);//接收服务器端信息 35 buf[len]=‘\0‘; 36 printf("%s",buf); //打印服务器端信息 37 38 /*循环的发送接收信息并打印接收信息--recv返回接收到的字节数,send返回发送的字节数*/ 39 while(1) 40 { 41 printf("Enter string to send:"); 42 scanf("%s",buf); 43 if(!strcmp(buf,"quit")) 44 break; 45 len=send(client_sockfd,buf,strlen(buf),0); 46 len=recv(client_sockfd,buf,BUFSIZ,0); 47 buf[len]=‘\0‘; 48 printf("received:%s\n",buf); 49 } 50 close(client_sockfd);//关闭套接字 51 return 0; 52 }
服务器端
1 #include <stdio.h> 2 #include <string.h> 3 #include <sys/types.h> 4 #include <sys/socket.h> 5 #include <netinet/in.h> 6 #include <arpa/inet.h> 7 #include <unistd.h> 8 9 int main(int argc, char *argv[]) 10 { 11 int server_sockfd;//服务器端套接字 12 int client_sockfd;//客户端套接字 13 int len; 14 struct sockaddr_in my_addr; //服务器网络地址结构体 15 struct sockaddr_in remote_addr; //客户端网络地址结构体 16 int sin_size; 17 char buf[BUFSIZ]; //数据传送的缓冲区 18 memset(&my_addr,0,sizeof(my_addr)); //数据初始化--清零 19 my_addr.sin_family=AF_INET; //设置为IP通信 20 my_addr.sin_addr.s_addr=INADDR_ANY;//服务器IP地址--允许连接到所有本地地址上 21 my_addr.sin_port=htons(8000); //服务器端口号 22 23 /*创建服务器端套接字--IPv4协议,面向连接通信,TCP协议*/ 24 if((server_sockfd=socket(PF_INET,SOCK_STREAM,0))<0) 25 { 26 perror("socket"); 27 return 1; 28 } 29 30 /*将套接字绑定到服务器的网络地址上*/ 31 if (bind(server_sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))<0) 32 { 33 perror("bind"); 34 return 1; 35 } 36 37 /*监听连接请求--监听队列长度为5*/ 38 listen(server_sockfd,5); 39 40 sin_size=sizeof(struct sockaddr_in); 41 42 /*等待客户端连接请求到达*/ 43 if((client_sockfd=accept(server_sockfd,(struct sockaddr *)&remote_addr,&sin_size))<0) 44 { 45 perror("accept"); 46 return 1; 47 } 48 printf("accept client %s\n",inet_ntoa(remote_addr.sin_addr)); 49 len=send(client_sockfd,"Welcome to my server\n",21,0);//发送欢迎信息 50 51 /*接收客户端的数据并将其发送给客户端--recv返回接收到的字节数,send返回发送的字节数*/ 52 while((len=recv(client_sockfd,buf,BUFSIZ,0))>0) 53 { 54 buf[len]=‘\0‘; 55 printf("recieved:%s\n",buf); 56 printf("Enter string to send: "); 57 scanf("%s",buf); 58 if(send(client_sockfd,buf,strlen(buf),0)<0) 59 { 60 perror("write"); 61 return 1; 62 } 63 } 64 close(client_sockfd); 65 close(server_sockfd); 66 return 0; 67 }
运行结果
跟踪分析到系统调用
当用户进程使用socket API 的时候,会产生向量为0x80的编程异常,系统执行系统调用。
进程传递系统调用号到寄存器eax,指明需要哪个系统调用,同时会将系统调用需要的参数存入相关寄存器。
系统调用处理函数system_call是Linux中所有系统调用的入口点,通过进程存在eax寄存器中的系统调用号决定调用哪个系统调用,而所有的socket系统调用的总入口时sys_socketcall()。
对如下代码跟踪分析
int socket(int domain, int type, int protocol);
用户进程将sys_socket()的系统调用号198存入eax中,并将socket()函数中的三个参数分别存入ebx,ecx,edx寄存器,产生一个0x80的编程异常。系统调用处理函数根据系统调用号,执行sys_socket()。
sys_socket在内核中的源码为:
SYSCALL_DEFINE3(socket, int, family, int, type, int, protocol) { int retval; struct socket *sock; int flags; ... retval = sock_create(family, type, protocol, &sock); if (retval < 0) goto out; retval = sock_map_fd(sock, flags & (O_CLOEXEC | O_NONBLOCK)); if (retval < 0) goto out_release; out: /* It may be already another descriptor 8) Not kernel problem. */ return retval; out_release: sock_release(sock); return retval; }
可以看到,socket函数主要由sock_create和sock_map_fd这两个函数完成。
sock_create函数用于创建socket。sock_create() 实际调用的是 __sock_create(),其中比较重要的是sock_alloc()和pf->create()两个函数。
sock_map_fd函数用于得到一个文件号。这个函数主要有两个部分,一个是创建file文件结构,fd文件描述符,另一部分是将file文件结构和fd文件描述符关联,同时将上一步返回的socket也一起绑定,形成一个完整的逻辑。
socket系统调用的操作概述为:首先在内核生成一个socket_alloc 和tcp_sock类型的对象,其中sock_alloc对象中的socket和tcp_sock对象的sock绑定,sock_alloc对象中的inode和file类型对象绑定。然后将分配的文件描述符fd和file对象关联,最后将这个文件描述符fd返回给用户使用。
原文地址:https://www.cnblogs.com/qfdzztt/p/12012056.html