Rumah >Tutorial sistem >LINUX >Pengaturcaraan soket udp/ip IPC Linux: cara yang cekap untuk mencapai komunikasi rangkaian

Pengaturcaraan soket udp/ip IPC Linux: cara yang cekap untuk mencapai komunikasi rangkaian

王林
王林ke hadapan
2024-02-11 10:51:29416semak imbas

Sistem Linux ialah sistem pengendalian yang menyokong pelaksanaan serentak pelbagai tugas Ia boleh menjalankan berbilang proses pada masa yang sama, dengan itu meningkatkan penggunaan dan kecekapan sistem. Walau bagaimanapun, jika pertukaran data dan kerjasama diperlukan antara proses ini, beberapa kaedah komunikasi antara proses (IPC) perlu digunakan, seperti isyarat, baris gilir mesej, memori kongsi, semaphore, dsb. Antaranya, soket udp/ip ialah kaedah IPC yang agak cekap dan fleksibel Ia membenarkan dua atau lebih proses menghantar data melalui rangkaian tanpa mengambil berat tentang butiran dan protokol rangkaian.

Linux IPC udp/ip socket 编程:一种实现网络通信的高效方式rreeee

soket()

#include 
#include 
#include 
#include 
#include 
//服务器:    

socket()              //创建socket            
struct sockaddr_in    //准备通信地址
bind()                //绑定socket和addr 
sendto()/recvfrom     //进行通信
close()               //关闭socket

//客户端:

socket()              //创建socket:
//准备通信地址:服务器的地址
sendto()/recv()       //进行通信:
close()               //关闭socket:

domain: keluarga protokol (komunikasi rangkaian (IP) atau komunikasi setempat (xxx.socket))

  • AF_INET digunakan untuk melaksanakan protokol rangkaian yang diberikan kepada protokol rangkaian ipv4
    type: protokol (TCP atau UDP)
  • SOCK_DGRAM //Soket datagram, pelaksanaan termasuk tetapi tidak terhad kepada protokol UDP, iaitu parti komunikasi datagram tanpa sambungan yang tidak boleh dipercayai
    protokol: protokol khas, biasanya 0

Sediakan alamat surat-menyurat:

//创建网络端点,返回socket文件描述符,失败返回-1设errno

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

ikat()

struct sockaddr{    //主要用于函数的形参类型, 很少定义结构体变量使用, 叫做通用的通信地址类型//$man bind
    sa_family_t     sa_family;
    char            sa_data[14];
}
struct sockaddr_in{ //准备网络通信的通信地址   //$man in.h
    sa_family_t sin_family;     //协议族, 就是socket()的domain的AF_INET
    in_port_t       sin_port;   //端口号
    struct in_addr  sin_addr;   //IP地址,
                    //当前网段的最大ip地址是广播地址,即,xxx.xxx.xxx.255。
                    //255.255.255.255在所有网段都是广播地址
}
struct in_addr{ 
    in_addr_t   s_addr;     //整数类型的IP地址
}

sockfd: fd daripada fail soket (dikembalikan oleh socket())
addr: perlu dihantar ke socketaddr_un atau soketaddr_in, lihat di atas
addrlen: gunakan saiz komunikasi;

sendto()
//把通信地址和socket文件描述符绑定,用在服务器端,成功返回0,失败返回-1设errno

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

dest_addr: Alamat destinasi (maklumat penerima)
addrlen: Saiz alamat destinasi

NOta

    hantar(sockfd, buf, len, bendera bersamaan dengan sendto(sockfd, buf, len, bendera, NULL, 0);
  • recv()/send() bermaksud menghantar dan menerima data melalui sockfd Kerana di bawah tcp, sockfd sudah disambungkan ke alamat yang sepadan sebelum menghantar dan menerima, jadi tidak perlu menentukan siapa untuk menghantar dan menerima/kepada siapa, tetapi udp. perlu nyatakan kerana tiada sambungan semasa menghantar dan menerima

recvfrom()
//向指定的socket和相应的地址发送消息,成功返回实际发送数据的大小,失败返回-1设errno
ssize_t sendto(int sockfd, const void *buf, size_t len, int flags, const struct 
sockaddr *dest_addr, socklen_t addrlen);

src_addr: Penunjuk struktur, digunakan untuk menyimpan alamat komunikasi pengirim data
addrlen: Jenis penunjuk, digunakan untuk menyimpan saiz alamat pengirim

Nota:

  • recv(sockfd, buf, len, flags); 等价于 recvfrom(sockfd, buf, len, flags, NULL, 0);
  • accept() and recvfrom() 后面的参数是用来提供来电显示的
  • 一个server对应多个client
  • server可以不知道client的地址, 但是client得知道server的地址
  • send data 一定要知道对方地址
  • receive data不需要知道对方地址
  • TCP/IP的socket都是SOCK_STREAM的,全程连接,通过socket就能找到对方地址, send data的话,直接丢给socket就行
  • UDP/IP的socket是SOCK_DGRAM的,不全程连接,不能通过socket找到对方,send data的话,server中需要使用recvfrom()来知道client的地址, 所以肯定要sendto();client本来就知道server的地址, 直接sendto()
  • recvfrom()的唯一意义就是在udp-server中配合sendto()使用
  • 因为不能通过socket找到对方, 只要是udp发消息, 就得通过sendto()
server client
TCP/IP send();recv() send();recv()
UDP/IP recvfrom();sendto() recv();sendto()

例子-一对一的upd/ip协议的服务器模型

//udp/ip server 五步走
#include
#include
#include
#include
#include
#include
#include
int main(){
    //1. 创建socket
    int sockfd=socket(AF_INET,SOCK_DGRAM,0);
    if(-1==sockfd)
        perror("socket"),exit(-1);
    
    //2. 准备通信地址
    struct sockaddr_in addr;
    addr.sin_family=AF_INET;
    addr.sin_port=htons(8888);
    addr.sin_addr.s_addr=inet_addr("176.43.11.211");

    //3. 绑定socket和通信地址
    int res=bind(sockfd,(struct sockaddr*)&addr,sizeof(addr));
    if(-1==res)
        perror("bind"),exit(-1);
    printf("bind success\n");

    //4. 进行通信
    char buf[100]={0};
    struct sockaddr_in recv_addr;       //为使用recvfrom得到client地址做准备, 
最终为sendto()做准备
    socklen_t len=sizeof(recv_addr);
    res=recvfrom(sockfd,buf,sizeof(buf),0,(struct sockaddr*)&recv_addr,&len);
    if(-1==res)
        perror("recvfrom"),exit(-1);

    char* ip=inet_ntoa(recv_addr.sin_addr);             
//将recvfrom获得client地址转换成点分十进制字符串
    printf("data received from client :%s is:%d\n",ip,res); 

    res=sendto(sockfd,"I received",sizeof("I received"),0,(struct sockaddr*)&recv_addr,len)
;//使用recvfrom获得的client地址
    if(-1==res)
        perror("sendto"),exit(-1);

    //5. 关闭socket
    res=close(sockfd);
    if(-1==res)
        perror("close"),exit(-1);
    printf("close success\n");
        
    return 0;
}
//udp/ip client
#include
#include
#include  //close()
#include
#include
#include
#include
int main(){
    int sockfd=socket(AF_INET,SOCK_DGRAM,0);
    if(-1==sockfd)
        perror("socket"),exit(-1);
    printf("create socket succesfully\n");
    struct sockaddr_in addr;
    addr.sin_family=AF_INET;
    addr.sin_port=htons(8888);
    addr.sin_addr.s_addr=inet_addr("176.43.11.211");    

//这个是server的地址, 虽然没有

connect, which means 不能通过socket找到这个地址, 但是我们还是知道这个地址的, sendto()是可以直接用的

    int res=sendto(sockfd,"hello",sizeof("hello"),0,(struct sockaddr*)&addr,sizeof(addr));
    if(-1==res)
        perror("sendto"),exit(-1);
    printf("data sent size:%d\n",res);
    char buf[100]={0};
    res=recv(sockfd,buf,sizeof(buf),0);
    if(-1==res)
        perror("recv"),exit(-1);
    printf("data received from server:%s\n",buf);
    res=close(sockfd);
    if(-1==res)
        perror("close"),exit(-1);

    return 0;
}

本文介绍了Linux系统中udp/ip socket编程的方法,包括socket的创建、绑定、发送、接收、关闭和设置等方面。通过了解和掌握这些知识,我们可以更好地使用udp/ip socket来实现进程间通信,提高系统的性能和可靠性。当然,Linux系统中udp/ip socket编程还有很多其他的特性和用法,需要我们不断地学习和探索。

Atas ialah kandungan terperinci Pengaturcaraan soket udp/ip IPC Linux: cara yang cekap untuk mencapai komunikasi rangkaian. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
Artikel ini dikembalikan pada:lxlinux.net. Jika ada pelanggaran, sila hubungi admin@php.cn Padam