建站
咨詢
售后
建站咨詢
新聞中心
在操作系統(tǒng)中，進程通信是非常重要的，而Linux系統(tǒng)的進程通信方式有很多種，其中一種非常高效的方式就是通過管道進行進程間的數(shù)據(jù)交換。
站在用戶的角度思考問題，與客戶深入溝通，找到呼中網(wǎng)站設(shè)計與呼中網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗，讓設(shè)計與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個性化、用戶體驗好的作品，建站類型包括：成都做網(wǎng)站、成都網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣、域名注冊、網(wǎng)頁空間、企業(yè)郵箱。業(yè)務(wù)覆蓋呼中地區(qū)。
那么什么是管道呢？管道是一種進程間通信方式，它只能用于有親緣關(guān)系的進程之間的通信，即父子進程或兄弟進程之間的通信，管道將一個進程的輸出和另一個進程的輸入連接起來，形成一個管道傳輸數(shù)據(jù)，數(shù)據(jù)在管道中是一個流式的過程。
Linux系統(tǒng)中管道的創(chuàng)建和使用非常方便，使用系統(tǒng)調(diào)用pipe可以創(chuàng)建一個無名管道，它返回兩個文件描述符，一個代表管道的讀端，一個代表寫端，通過這兩個文件描述符，父子進程或兄弟進程可以進行數(shù)據(jù)的讀寫。
使用管道進行進程通信的一個典型的例子是shell的管道符“|”，在shell中，一個命令的輸出通?？梢酝ㄟ^管道符“|”連接到另一個命令的輸入，這時候之一個命令的輸出就會被傳遞給第二個命令進行處理。
使用管道進行進程通信的好處是非常明顯的，首先它非常高效，因為管道是基于內(nèi)存的，數(shù)據(jù)在進程間的傳遞非?？焖?，其次管道可以支持單向流動的數(shù)據(jù)傳輸，這就可以很方便地將一個進程的輸出傳遞給另一個進程進行處理，極大地降低了進程之間的耦合性。
在Linux系統(tǒng)中，管道不僅可以用于父子進程或兄弟進程之間的通信，還可以用于線程之間的通信，而且管道還可以進行多路復(fù)用，這極大地方便了進程之間的多路數(shù)據(jù)交換。
但是，使用管道進行進程通信也存在一些問題，例如管道的容量有限，過大的數(shù)據(jù)無法進行傳輸，而且當(dāng)寫入管道的數(shù)據(jù)量超過管道的容量時，進程會被阻塞，直到管道中的數(shù)據(jù)被消耗掉。
另外，管道的雙方必須同時存在，否則數(shù)據(jù)無法進行傳輸，而且管道一旦被創(chuàng)建就無法刪除，這會導(dǎo)致一些占用管道資源的進程退出之后，管道資源還是被占用的問題。
總體來說，Linux系統(tǒng)中的管道是一種非常高效的進程間通信方式，它具有快速、輕量、靈活等優(yōu)點，但是也存在一些局限性，使用過程中需要注意管道容量的限制，以及管道資源無法被釋放的問題。針對以上問題，Linux系統(tǒng)還提供了其他的進程通信方式，如共享內(nèi)存、消息隊列等，根據(jù)實際需求選擇適當(dāng)?shù)倪M程通信方式，可以極大地提高程序的性能和可靠性。
相關(guān)問題拓展閱讀：
- linux下c的兩個進程如何實現(xiàn)通信？一個進程給另一個進程發(fā)送消息，另一個接受并顯示出來。求大神啊
linux下c的兩個進程如何實現(xiàn)通信？一個進程給另一個進程發(fā)送消息，另一個接受并顯示出來。求大神啊
linux中的進程通信分為三個部分：低級通信，管道通信和進程間通信IPC（inter process communication）。linux的低級通信主要用來傳遞進程的控制信號——文件鎖和軟中斷信號機制。linux的進程間通信IPC有三個部分——①信號量，②共享內(nèi)存和③消息隊列。以下是我編寫的linux進程通信的C語言實現(xiàn)代碼。操作系統(tǒng)為redhat9.0，編輯器為vi，編譯器采用gcc。下面所有實現(xiàn)代碼均已經(jīng)通過測試，運行無誤。
一.低級通信–信號通信
signal.c
#include 鎮(zhèn)碰
#include
#include 御笑談
/*捕捉到信號sig之后，執(zhí)行預(yù)先預(yù)定的動作函數(shù)*/
void sig_alarm(int sig)
{
printf(“—the signal received is %d. /n”, sig);
signal(SIGINT, SIG_DFL); //SIGINT終端中斷信號，SIG_DFL：恢復(fù)默認(rèn)行為，SIN_IGN：忽略信號
}
int main()
{
signal(SIGINT, sig_alarm);//捕升賣捉終端中斷信號
while(1)
{
printf(“waiting here!/n”);
sleep(1);
}
return 0;
}
二.管道通信
pipe.c
#include
#define BUFFER_SIZE 30
int main()
{
int x;
int fd;
char buf;
char s;
pipe(fd);//創(chuàng)建管道
while((x=fork())==-1);//創(chuàng)建管道失敗時，進入循環(huán)
/*進入子進程，子進程向管道中寫入一個字符串*/
if(x==0)
{
sprintf(buf,”This is an example of pipe!/n”);
write(fd,buf,BUFFER_SIZE);
exit(0);
}
/*進入父進程，父進程從管道的另一端讀出剛才寫入的字符串*/
else
{
wait(0);//等待子進程結(jié)束
read(fd,s,BUFFER_SIZE);//讀出字符串，并將其儲存在char s中
printf(“%s”,s);//打印字符串
}
return 0;
}
三.進程間通信——IPC
①信號量通信
sem.c
#include
#include
#include
#include
#include
#include
/*聯(lián)合體變量*/
union semun
{
int val; //信號量初始值
struct semid_ds *buf;
unsigned short int *array;
struct seminfo *__buf;
};
/*函數(shù)聲明，信號量定義*/
static int set_semvalue(void); //設(shè)置信號量
static void del_semvalue(void);//刪除信號量
static int semaphore_p(void); //執(zhí)行P操作
static int semaphore_v(void); //執(zhí)行V操作
static int sem_id;//信號量標(biāo)識符
int main(int argc, char *argv)
{
int i;
int pause_time;
char op_char = ‘O’;
srand((unsigned int)getpid());
sem_id = semget((key_t)1234, 1, 0666 | IPC_CREAT);//創(chuàng)建一個信號量,IPC_CREAT表示創(chuàng)建一個新的信號量
/*如果有參數(shù)，設(shè)置信號量，修改字符*/
if (argc > 1)
{
if (!set_semvalue())
{
fprintf(stderr, “Failed to initialize semaphore/n”);
exit(EXIT_FAILURE);
}
op_char = ‘X’;
sleep(5);
}
for(i = 0; i 1)
{
sleep(10);
del_semvalue(); //刪除信號量
}
exit(EXIT_SUCCESS);
}
/*設(shè)置信號量*/
static int set_semvalue(void)
{
union semun sem_union;
sem_union.val = 1;
if (semctl(sem_id, 0, SETVAL, sem_union) == -1)
return(0);
return(1);
}
/*刪除信號量*/
static void del_semvalue(void)
{
union semun sem_union;
if (semctl(sem_id, 0, IPC_RMID, sem_union) == -1)
fprintf(stderr, “Failed to delete semaphore/n”);
}
/*執(zhí)行P操作*/
static int semaphore_p(void)
{
struct sembuf sem_b;
sem_b.sem_num = 0;
sem_b.sem_op = -1; /* P() */
sem_b.sem_ = SEM_UNDO;
if (semop(sem_id, &sem_b, 1) == -1)
{
fprintf(stderr, “semaphore_p failed/n”);
return(0);
}
return(1);
}
/*執(zhí)行V操作*/
static int semaphore_v(void)
{
struct sembuf sem_b;
sem_b.sem_num = 0;
sem_b.sem_op = 1; /* V() */
sem_b.sem_ = SEM_UNDO;
if (semop(sem_id, &sem_b, 1) == -1)
{
fprintf(stderr, “semaphore_v failed/n”);
return(0);
}
return(1);
}
②消息隊列通信
send.c
#include
#include
#include
#include
#include
#include
#include
#include
#define MAX_TEXT 512
/*用于消息收發(fā)的結(jié)構(gòu)體–my_msg_type：消息類型，some_text：消息正文*/
struct my_msg_st
{
long int my_msg_type;
char some_text;
};
int main()
{
int running = 1;//程序運行標(biāo)識符
struct my_msg_st some_data;
int msgid;//消息隊列標(biāo)識符
char buffer;
/*創(chuàng)建與接受者相同的消息隊列*/
msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
if (msgid == -1)
{
fprintf(stderr, “msgget failed with error: %d/n”, errno);
exit(EXIT_FAILURE);
}
/*向消息隊列中發(fā)送消息*/
while(running)
{
printf(“Enter some text: “);
fgets(buffer, BUFSIZ, stdin);
some_data.my_msg_type = 1;
strcpy(some_data.some_text, buffer);
if (msgsnd(msgid, (void *)&some_data, MAX_TEXT, 0) == -1)
{
fprintf(stderr, “msgsnd failed/n”);
exit(EXIT_FAILURE);
}
if (strncmp(buffer, “end”, 3) == 0)
{
running = 0;
}
}
exit(EXIT_SUCCESS);
}
receive.c
#include
#include
#include
#include
#include
#include
#include
#include
/*用于消息收發(fā)的結(jié)構(gòu)體–my_msg_type：消息類型，some_text：消息正文*/
struct my_msg_st
{
long int my_msg_type;
char some_text;
};
int main()
{
int running = 1;//程序運行標(biāo)識符
int msgid; //消息隊列標(biāo)識符
struct my_msg_st some_data;
long int msg_to_receive = 0;//接收消息的類型–0表示msgid隊列上的之一個消息
/*創(chuàng)建消息隊列*/
msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
if (msgid == -1)
{
fprintf(stderr, “msgget failed with error: %d/n”, errno);
exit(EXIT_FAILURE);
}
/*接收消息*/
while(running)
{
if (msgrcv(msgid, (void *)&some_data, BUFSIZ,msg_to_receive, 0) == -1)
{
fprintf(stderr, “msgrcv failed with error: %d/n”, errno);
exit(EXIT_FAILURE);
}
printf(“You wrote: %s”, some_data.some_text);
if (strncmp(some_data.some_text, “end”, 3) == 0)
{
running = 0;
}
}
/*刪除消息隊列*/
if (msgctl(msgid, IPC_RMID, 0) == -1)
{
fprintf(stderr, “msgctl(IPC_RMID) failed/n”);
exit(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
③共享內(nèi)存通信
share.h
#define TEXT_SZ 2023 //申請共享內(nèi)存大小
struct shared_use_st
{
int written_by_you; //written_by_you為1時表示有數(shù)據(jù)寫入，為0時表示數(shù)據(jù)已經(jīng)被消費者提走
char some_text;
};
producer.c
#include
#include
#include
#include
#include
#include
#include
#include “share.h”
int main()
{
int running = 1; //程序運行標(biāo)志位
void *shared_memory = (void *)0;
struct shared_use_st *shared_stuff;
char buffer;
int shmid; //共享內(nèi)存標(biāo)識符
/*創(chuàng)建共享內(nèi)存*/
shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666 | IPC_CREAT);
if (shmid == -1)
{
fprintf(stderr, “shmget failed/n”);
exit(EXIT_FAILURE);
}
/*將共享內(nèi)存連接到一個進程的地址空間中*/
shared_memory = shmat(shmid, (void *)0, 0);//指向共享內(nèi)存之一個字節(jié)的指針
if (shared_memory == (void *)-1)
{
fprintf(stderr, “shmat failed/n”);
exit(EXIT_FAILURE);
}
printf(“Memory attached at %X/n”, (int)shared_memory);
shared_stuff = (struct shared_use_st *)shared_memory;
/*生產(chǎn)者寫入數(shù)據(jù)*/
while(running)
{
while(shared_stuff->written_by_you == 1)
{
sleep(1);
printf(“waiting for client…/n”);
}
printf(“Enter some text: “);
fgets(buffer, BUFSIZ, stdin);
strncpy(shared_stuff->some_text, buffer, TEXT_SZ);
shared_stuff->written_by_you = 1;
if (strncmp(buffer, “end”, 3) == 0)
{
running = 0;
}
}
/*該函數(shù)用來將共享內(nèi)存從當(dāng)前進程中分離,僅使得當(dāng)前進程不再能使用該共享內(nèi)存*/
if (shmdt(shared_memory) == -1)
{
fprintf(stderr, “shmdt failed/n”);
exit(EXIT_FAILURE);
}
printf(“producer exit./n”);
exit(EXIT_SUCCESS);
}
customer.c
#include
#include
#include
#include
#include
#include
#include
#include “share.h”
int main()
{
int running = 1;//程序運行標(biāo)志位
void *shared_memory = (void *)0;
struct shared_use_st *shared_stuff;
int shmid; //共享內(nèi)存標(biāo)識符
srand((unsigned int)getpid());
/*創(chuàng)建共享內(nèi)存*/
shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666 | IPC_CREAT);
if (shmid == -1)
{
fprintf(stderr, “shmget failed/n”);
exit(EXIT_FAILURE);
}
/*將共享內(nèi)存連接到一個進程的地址空間中*/
shared_memory = shmat(shmid, (void *)0, 0);//指向共享內(nèi)存之一個字節(jié)的指針
if (shared_memory == (void *)-1)
{
fprintf(stderr, “shmat failed/n”);
exit(EXIT_FAILURE);
}
printf(“Memory attached at %X/n”, (int)shared_memory);
shared_stuff = (struct shared_use_st *)shared_memory;
shared_stuff->written_by_you = 0;
/*消費者讀取數(shù)據(jù)*/
while(running)
{
if (shared_stuff->written_by_you)
{
printf(“You wrote: %s”, shared_stuff->some_text);
sleep( rand() % 4 );
shared_stuff->written_by_you = 0;
if (strncmp(shared_stuff->some_text, “end”, 3) == 0)
{
running = 0;
}
}
}
/*該函數(shù)用來將共享內(nèi)存從當(dāng)前進程中分離,僅使得當(dāng)前進程不再能使用該共享內(nèi)存*/
if (shmdt(shared_memory) == -1)
{
fprintf(stderr, “shmdt failed/n”);
exit(EXIT_FAILURE);
}
/*將共享內(nèi)存刪除,所有進程均不能再訪問該共享內(nèi)存*/
if (shmctl(shmid, IPC_RMID, 0) == -1)
{
fprintf(stderr, “shmctl(IPC_RMID) failed/n”);
exit(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
摘自：
關(guān)于linux進程管道通信的介紹到此就結(jié)束了，不知道你從中找到你需要的信息了嗎 ？如果你還想了解更多這方面的信息，記得收藏關(guān)注本站。
香港服務(wù)器選創(chuàng)新互聯(lián)，2H2G首月10元開通。
創(chuàng)新互聯(lián)（www.cdcxhl.com）互聯(lián)網(wǎng)服務(wù)提供商,擁有超過10年的服務(wù)器租用、服務(wù)器托管、云服務(wù)器、虛擬主機、網(wǎng)站系統(tǒng)開發(fā)經(jīng)驗。專業(yè)提供云主機、虛擬主機、域名注冊、VPS主機、云服務(wù)器、香港云服務(wù)器、免備案服務(wù)器等。
名稱欄目：Linux進程管道通信：高效實現(xiàn)進程間數(shù)據(jù)交換(linux進程管道通信)
本文鏈接：http://m.5511xx.com/article/djsgsge.html
