• Linux进程间通信方式之socket使用实例


    TCP/IP协议族包括运输层、网络层、链路层,而socket所在位置如图,Socket是应用层与TCP/IP协议族通信的中间软件抽象层。

    下面是网络socket通信的基本流程:

    在这里插入图片描述

    socket函数

    int socket(int domain, int type, int protocol);
    
    • 1

    socket函数对应于普通文件的打开操作。普通文件的打开操作返回一个文件描述字,而socket()用于创建一个socket描述符,它唯一标识一个socket。这个socket描述字跟文件描述字一样,后续的操作都有用到它,把它作为参数,通过它来进行一些读写操作。创建socket的时候,也可以指定不同的参数创建不同的socket描述符,socket函数的三个参数
    分别为:
    domain:即协议域,又称为协议族(family)。常用的协议族有AF_INET(ipv4网络)、AF_INET6(ipv6网络)、AF_LOCAL(本地通信)(或称AF_UNIX,Unix域socket)等等。

    type:指定socket类型。常用的socket类型有,
    SOCK_STREAM(TCP):流套接字(在某些方面类似域标准的输入/输出流)提供的是一个有序,可靠,双向字节流的连接
    SOCK_DGRAM(UDP):数据包套接字不建立和维持一个连接。它对可以发送的数据包的长度有限制。数据报作为一个单独的网络消息被传输,它可能会丢失,复制或乱序到达
    SOCK_RAW、SOCK_PACKET等等。
    protocol:是指定协议。常用的协议有,IPPROTO_TCP(TCP)、IPPTOTO_UDP(UDP)、IPPROTO_SCTP(STCP)、IPPROTO_TIPC(TIPC)等,当protocol为0时,会自动选择type类型对应的默认协议。

    bind()函数

    int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
    
    • 1

    sockfd:即socket描述字,它是通过socket()函数创建了,唯一标识一个socket。bind()函数就是将给这个描述字绑定一个名字。

    addr:一个const struct sockaddr *指针,指向要绑定给sockfd的协议地址。这个地址结构根据地址创建socket时的地址协议族的不同而不同,但最终都会强制转换后赋值给sockaddr这种类型的指针传给内核。

    addrlen:对应的是地址的长度。

    listen()函数

    socket()函数创建的socket默认是一个主动类型的,如果作为一个服务器,在调用socket()、bind()之后就会调用listen()来监听这个socket,该函数socket变为被动类型的,等待客户的连接请求。

    int listen(int sockfd, int backlog);
    
    • 1

    sockefd: socket()系统调用创建的要监听的socket描述字;

    backlog: 相应socket可以在内核里排队的最大连接个数;

    accept()函数

    TCP服务器端依次调用socket()、bind()、listen()之后,就会监听指定socket地址了。服务器之后就会调用accpet()接受来自客户端的连接请求,这个函数默认是一个阻塞函数,这也意味着如果没有客户端连接服务器的话该程序将一直阻塞着不会返回,直到有一个客户端连过来为止。一旦客户端调用connect()函数就会触发服务器的accept()返回,这时整个TCP链接就建立好
    了。

    int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
    
    • 1

    sockfd: 服务器开始调用socket()函数生成的,称为监听socket描述字;

    *addr: 用于返回客户端的协议地址,这个地址里包含有客户端的IP和端口信息等;

    addrlen: 返回客户端协议地址的长度;

    accept函数的返回值是由内核自动生成的一个全新的描述字(fd),代表与返回客户的TCP连接。如果想发送数据给该客户端,则我们可以调用write()等函数往该fd里写内容即可;而如果想从该客户端读内容则调用read()等函数从该fd里读数据即可。

    connect(函数)

    TCP客户端程序调用socket()创建socket fd之后,就可以调用connect()函数来连接服务器。

    int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
    
    • 1

    sockfd: 客户端的socket()创建的描述字;
    addr: 要连接的服务器的socket地址信息,这里面包含有服务器的IP地址和端口等信息;
    addrlen: socket地址的长度;

     服务端:
    //s_unix.c
    #include 
    #include 
    #include 
    #include  
    #define UNIX_DOMAIN "/tmp/UNIX.domain"
    int main(void)
    {
      socklen_t clt_addr_len;
      int listen_fd;
      int com_fd;
      int ret;
      int i;
      static char recv_buf[1024]; 
      int len;
      struct sockaddr_un clt_addr;
      struct sockaddr_un srv_addr;
      listen_fd=socket(PF_UNIX,SOCK_STREAM,0);//创建socket文件描述符,
      if(listen_fd<0)
      {
        perror("cannot create communication socket");
        return 1;
      } 
      //set server addr_param
      srv_addr.sun_family=AF_UNIX;
      strncpy(srv_addr.sun_path,UNIX_DOMAIN,sizeof(srv_addr.sun_path)-1);
      unlink(UNIX_DOMAIN);
      //bind sockfd & addr
      ret=bind(listen_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));
      if(ret==-1)
      {
        perror("cannot bind server socket");
        close(listen_fd);
        unlink(UNIX_DOMAIN);
        return 1;
      }
      //listen sockfd 
      ret=listen(listen_fd,1);
      if(ret==-1)
      {
        perror("cannot listen the client connect request");
        close(listen_fd);
        unlink(UNIX_DOMAIN);
        return 1;
      }
      //have connect request use accept
      len=sizeof(clt_addr);
      com_fd=accept(listen_fd,(struct sockaddr*)&clt_addr,&len);
      if(com_fd<0)
      {
        perror("cannot accept client connect request");
        close(listen_fd);
        unlink(UNIX_DOMAIN);
        return 1;
      }
      //read and printf sent client info
      printf("/n=====info=====/n");
      for(i=0;i<4;i++)
      {
        memset(recv_buf,0,1024);
        int num=read(com_fd,recv_buf,sizeof(recv_buf));
        printf("Message from client (%d)) :%s/n",num,recv_buf); 
      }
      close(com_fd);
      close(listen_fd);
      unlink(UNIX_DOMAIN);
      return 0; 
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
  • 相关阅读:
    MindSpore新型轻量级神经网络GhostNet,在ImageNet分类、图像识别和目标检测等多个应用场景效果优异!
    LeetCode·每日一题·593.有效的正方形·数学
    GenICam GenTL 标准 ver1.5(1)
    async 和await和promise
    常用工具 | 使用API Monitor监测到目标程序对系统API函数的调用
    进程与线程
    【IoT】从马斯克造火箭到产品开发,快速失败很重要
    关于windows的文件监控管理系统(Java)
    Go 语言 iota 的神奇力量
    哈希方法总结
  • 原文地址:https://blog.csdn.net/weixin_44939146/article/details/136446938