一、sockaddr_un簡介
Socket是一個在計算機網(wǎng)絡(luò)中能夠?qū)崿F(xiàn)進(jìn)程間通信的一種機制。它通過網(wǎng)絡(luò)將進(jìn)程之間的數(shù)據(jù)進(jìn)行交換,從而實現(xiàn)一些必要的功能。而sockaddr_un則是Socket地址結(jié)構(gòu)之一,它用于Unix域協(xié)議。
Unix域協(xié)議又稱為IPC(InterProcess Communication),可以通過UNIX文件系統(tǒng)維護(hù)一個虛擬的數(shù)據(jù)傳輸域,進(jìn)程在域內(nèi)以Socket方式進(jìn)行通信,無需通過計算機網(wǎng)絡(luò)。
sockaddr_un是一個結(jié)構(gòu)體,既包含了類型(sun_family),又包括了路徑名稱(sun_path)。其中sun_family的值通常設(shè)置為AF_UNIX。
struct sockaddr_un {
sa_family_t sun_family; // AF_UNIX
char sun_path[108];
};
二、sockaddr_un的使用場景
因為sockaddr_un是一種在本機之間進(jìn)行通信的協(xié)議,所以它適用于很多本機通信的場景。比如下面這些場景:
1. 本機內(nèi)進(jìn)程通信
在同一臺計算機上,不同的進(jìn)程如果需要進(jìn)行通信,就可以通過Sockaddr_un來實現(xiàn)通信。
2. web服務(wù)器
可以使用Socket作為客戶端和服務(wù)器之間的通信方式,這種方式通常用于實現(xiàn)Web服務(wù)器的頁面渲染,并對客戶端的請求進(jìn)行響應(yīng)。
3. 進(jìn)程監(jiān)控
當(dāng)一個服務(wù)已經(jīng)存在時,我們希望能夠?qū)υ摲?wù)進(jìn)行監(jiān)控和管理。Sockaddr_un可以實現(xiàn)讓該服務(wù)監(jiān)聽某個特定的端口,從而更好地實現(xiàn)進(jìn)程監(jiān)控。
三、sockaddr_un的使用案例
1. 創(chuàng)建Unix域套接字
#include
#include
#include
#include
#include
int main() {
int sockfd;
struct sockaddr_un addr;
sockfd = socket(AF_UNIX, SOCK_STREAM, 0);
if (sockfd == -1) {
perror("socket error");
exit(EXIT_FAILURE);
}
memset(&addr, 0, sizeof(addr));
addr.sun_family = AF_UNIX;
strncpy(addr.sun_path, "/tmp/my_socket", sizeof(addr.sun_path) - 1);
if (bind(sockfd, (struct sockaddr*)&addr, sizeof(addr)) == -1) {
perror("bind error");
exit(EXIT_FAILURE);
}
return 0;
}
上述代碼首先調(diào)用socket創(chuàng)建一個套接字,sockaddr_un有兩個域:sun_family和sun_path,sun_family表示所使用的協(xié)議族,sun_path指向碼路徑名。在這個例子中,也是我們最常見的本地套接字。
然后使用bind將套接字綁定到指定的路徑名,此處指定的路徑名為/tmp/my_socket。
2. 進(jìn)行Unix域套接字通信
接下來,我們可以用create_socket()函數(shù)創(chuàng)建一個Socket連接,來模擬進(jìn)程之間的通信。在這個例子中,我們向套接字中寫入一些數(shù)據(jù),然后從套接字中讀取出來:
#include
#include
#include
#include
#include
#include
#include
#define MAX_BUFFER_SIZE 512
int create_socket() {
int sockfd;
struct sockaddr_un addr;
sockfd = socket(AF_UNIX, SOCK_STREAM, 0);
if (sockfd == -1) {
perror("socket error");
exit(EXIT_FAILURE);
}
memset(&addr, 0, sizeof(addr));
addr.sun_family = AF_UNIX;
strncpy(addr.sun_path, "/tmp/my_socket", sizeof(addr.sun_path) - 1);
if (connect(sockfd, (struct sockaddr*)&addr, sizeof(addr)) == -1) {
perror("connect error");
exit(EXIT_FAILURE);
}
return sockfd;
}
int main() {
int sockfd;
char buf[MAX_BUFFER_SIZE];
memset(buf, 0, sizeof(buf));
sockfd = create_socket();
//寫入數(shù)據(jù)
const char* msg = "Hello, Unix Domain Socket";
if (write(sockfd, msg, strlen(msg)) == -1) {
perror("write error");
exit(EXIT_FAILURE);
}
//讀取數(shù)據(jù)
int n = read(sockfd, buf, MAX_BUFFER_SIZE);
if (n == -1) {
perror("read error");
exit(EXIT_FAILURE);
}
else {
printf("received msg: %s\n", buf);
}
close(sockfd);
return 0;
}
在上述代碼中,我們通過create_socket()函數(shù)創(chuàng)建了一個Socket連接。然后往它里面寫入了一些數(shù)據(jù),最后從Socket連接中讀取出數(shù)據(jù)。如果讀取到數(shù)據(jù),就輸出該數(shù)據(jù)。