Linux進程通信 | 管道與FIFO

来源:https://www.cnblogs.com/Wayne123/archive/2023/03/15/17218327.html
-Advertisement-
Play Games

Linux進程間通信通常使用的方式有很多種,其中比較常用的包括管道(pipe)和 FIFO(命名管道)。本文將介紹這兩種通信方式的基本概念,並用C語言編寫示例代碼,來說明如何在兩個進程之間使用這些IPC機制進行通信。 管道(pipe) 管道是一種半雙工的通信方式,用於父進程和子進程之間的通信。在 L ...


Linux進程間通信通常使用的方式有很多種,其中比較常用的包括管道(pipe)和 FIFO(命名管道)。本文將介紹這兩種通信方式的基本概念,並用C語言編寫示例代碼,來說明如何在兩個進程之間使用這些IPC機制進行通信。

管道(pipe)

管道是一種半雙工的通信方式,用於父進程和子進程之間的通信。在 Linux 中,管道是一種特殊的文件,有兩個端點,一個讀端和一個寫端。管道的基本操作包括創建管道、關閉文件描述符、讀取數據和寫入數據等。

創建管道

在 Linux 中,我們可以使用 pipe() 系統調用來創建管道。pipe() 函數的原型如下:

#include <unistd.h>
int pipe(int pipefd[2]);

其中,pipefd 是一個數組,用於存儲管道的讀端和寫端的文件描述符。pipe() 函數成功時返回 0,失敗時返回 -1。

下麵是一個創建管道的示例代碼:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

int main()
{
    int pipefd[2];
    
    // 創建管道
    if (pipe(pipefd) == -1) {
        perror("pipe");
        exit(EXIT_FAILURE);
    }
    
    printf("讀端文件描述符:%d\n", pipefd[0]);
    printf("寫端文件描述符:%d\n", pipefd[1]);
    
    exit(EXIT_SUCCESS);
}

  • 編譯並運行,列印如下
讀端文件描述符:3
寫端文件描述符:4

管道的讀寫

在使用管道進行通信時,父進程和子進程可以通過管道進行數據的讀取和寫入。在 C 語言中,我們可以使用 read()函數和 write() 函數來讀取和寫入數據。read() 函數用於從管道中讀取數據,write() 函數用於向管道中寫入數據,使用 close() 函數關閉文件描述符。在管道的使用中,我們應該在不需要的時候關閉管道的讀端和寫端,以避免資源浪費。

這三個函數的原型分別如下:

#include <unistd.h>
ssize_t read(int fd, void *buf, size_t count);
ssize_t write(int fd, const void *buf, size_t count);
int close(int fd);

下麵是一個父進程向子進程寫入數據並讀取返回結果的示例代碼:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/wait.h>

#define BUF_SIZE 1024

int main()
{
    int pipefd[2];
    pid_t pid;
    char buf[BUF_SIZE];
    int status;
    
    // 創建管道
    if (pipe(pipefd) == -1) {
        perror("pipe");
        exit(EXIT_FAILURE);
    }
    
    // 創建子進程
    pid = fork();
    if (pid == -1) {
        perror("fork");
        exit(EXIT_FAILURE);
    }
    
    if (pid == 0) { // 子進程        
        // 從管道中讀取數據
        if (read(pipefd[0], buf, BUF_SIZE) == -1) {
            perror("read");
            exit(EXIT_FAILURE);
        }
        
        printf("子進程收到消息:%s\n", buf);
        
        // 發送消息給父進程
        const char* message = "Hello, parent!";
        if (write(pipefd[1], message, strlen(message) + 1) == -1) {
            perror("write");
            exit(EXIT_FAILURE);
        }
        close(pipefd[1]); // 關閉寫端
        exit(EXIT_SUCCESS);
    } else { // 父進程 
        // 發送消息給子進程
        const char* message = "Hello, child!";
        if (write(pipefd[1], message, strlen(message) + 1) == -1) {
            perror("write");
            exit(EXIT_FAILURE);
        }
        
        // 等待子進程退出
        wait(&status);
        if (WIFEXITED(status)) {
            printf("子進程退出,返回值:%d\n", WEXITSTATUS(status));
        }
        
        // 從管道中讀取數據
        if (read(pipefd[0], buf, BUF_SIZE) == -1) {
            perror("read");
            exit(EXIT_FAILURE);
        }
        printf("父進程收到消息:%s\n", buf);
        close(pipefd[0]); // 關閉讀端
        
        exit(EXIT_SUCCESS);
    }
}

在這個示例代碼中,父進程先向子進程發送一條消息,子進程收到消息後向父進程發送一條消息,並退出。父進程在等待子進程退出後再從管道中讀取子進程發送的消息。

  • 編譯並運行,列印如下
子進程收到消息:Hello, child!
子進程退出,返回值:0
父進程收到消息:Hello, parent!

FIFO(命名管道)

FIFO(命名管道)是一種文件系統對象,與管道類似,也可以用於進程間通信。FIFO 是一種特殊類型的文件,它可以在文件系統中被創建,並且進程可以通過文件描述符來讀取和寫入數據。

與管道不同的是,FIFO 可以被多個進程打開,並且可以在文件系統中以路徑的形式存在,因此不像管道那樣只能在具有親緣關係的進程之間使用。任何進程只要有相應的許可權就可以打開 FIFO 併進行通信。

FIFO 的創建和使用

FIFO 的創建和使用也比較簡單。首先需要使用 mkfifo() 函數創建 FIFO 文件,其原型如下

#include <sys/types.h>
#include <sys/stat.h>

int mkfifo(const char *pathname, mode_t mode);

其中,pathname 是 FIFO 文件的路徑名,mode 是文件的許可權。

創建 FIFO 文件後,就可以像使用普通文件一樣打開它,並使用 read() 和 write() 函數進行數據的讀寫。

下麵是一個使用 FIFO 進行進程間通信的示例代碼:

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

#define FIFO_PATH "/tmp/myfifo"
#define BUF_SIZE 1024

int main()
{
    int fd;
    char buf[BUF_SIZE];
    
    // 創建 FIFO 文件
    if (mkfifo(FIFO_PATH, 0666) == -1) {
        perror("mkfifo");
        exit(EXIT_FAILURE);
    }
    
    // 打開 FIFO 文件
    fd = open(FIFO_PATH, O_RDWR);
    if (fd == -1) {
        perror("open");
        exit(EXIT_FAILURE);
    }
    
    // 向 FIFO 中寫入數據
    const char* message = "Hello, world!";
    if (write(fd, message, strlen(message) + 1) == -1) {
        perror("write");
        exit(EXIT_FAILURE);
    }
    
    // 從 FIFO 中讀取數據
    if (read(fd, buf, BUF_SIZE) == -1) {
        perror("read");
        exit(EXIT_FAILURE);
    }
    
    printf("收到消息:%s\n", buf);
    
    // 關閉文件描述符並刪除 FIFO 文件
    close(fd);
    if (unlink(FIFO_PATH) == -1) {
        perror("unlink");
        exit(EXIT_FAILURE);
    }
    
    exit(EXIT_SUCCESS);
}

在這個示例代碼中,程式先創建了一個 FIFO 文件 /tmp/myfifo,然後打開該文件並向其中寫入一條消息。接下來從 FIFO 文件中讀取數據,並將其列印出來。最後關閉文件描述符並刪除 FIFO 文件。

  • 編譯並運行,列印如下
收到消息:Hello, world!

小結

Linux 中管道和 FIFO 是進程間通信的重要方式。管道只能用於親緣關係的進程間通信,而 FIFO 可以被多個進程打開,不受進程之間關係的限制。無論是管道還是 FIFO,它們的使用方式都與普通文件類似,需要使用文件描述符和 read()、write() 函數來進行數據的讀寫。

在使用管道和 FIFO 進行進程間通信時,需要註意以下幾點:

  1. 管道和 FIFO 只能用於同一主機上的進程間通信,不能用於跨主機通信。
  2. 管道和 FIFO 的讀寫操作是阻塞的,這意味著當一個進程嘗試從一個空管道或 FIFO 中讀取數據時,它會被阻塞,直到有數據可用為止。同樣,當一個進程嘗試將數據寫入一個滿的管道或 FIFO 時,它也會被阻塞,直到有空閑空間為止。
  3. 在使用管道和 FIFO 進行進程間通信時,需要註意文件描述符的關閉順序。
  4. 管道和 FIFO 只能傳輸位元組流,不能傳輸其他類型的數據,如結構體或指針。
  5. 如果使用管道或 FIFO 進行進程間通信時,數據量較大,需要進行分段傳輸,否則可能會導致阻塞或緩衝區溢出等問題。
  6. 管道和 FIFO 都是單向的,如果需要雙向通信,則需要建立兩個管道或 FIFO。

以上,如果覺得對你有幫助,點個贊再走吧,這樣@知微之見也有更新下去的動力!

也歡迎私信我,一起交流!


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 簡介 官方定義:MessagePack是一種高效的二進位序列化格式。它允許您像JSON一樣在多個語言之間交換數據。但是它更快並且更小。 MessagePack是一種開源的序列化反序列化組件,可支持JAVA,C#等主流語言。在 C# 中使用 MessagePack,需要添加 MessagePack-C ...
  • 本文檔參考了Git提交規範,旨在規範使用SVN進行代碼版本管理時的提交操作。 提交前的準備 1. 檢查代碼 在提交代碼前,請先進行必要的代碼檢查,確保代碼的正確性、可讀性和可維護性。可以使用代碼質量管理工具進行自動化檢查,也可以手動檢查。 2. 編寫提交信息 在提交代碼時,需要編寫提交信息來描述本次 ...
  • Stopwatch ...
  • 在學習依賴屬性之前,我們首先要知道屬性是什麼?屬性呢其實就是為了保護數據!避免數據直接暴漏給外界。什麼是依賴屬性呢?依賴屬性和屬性又有什麼區別呢?依賴屬性是一種可以自己沒有值,並能通過使用Binding從數據源獲得值的屬性。言簡意賅,就是依靠著別人賦值的屬性。至於區別是什麼,我們接下來說完依賴屬性之 ...
  • 一:背景 1. 講故事 前段時間有位朋友在微信上找到我,說他的程式會出現一些偶發卡死的情況,讓我幫忙看下是怎麼回事,剛好朋友也抓到了dump,就讓朋友把 dump 丟給我,接下來用 windbg 探究下到底咋回事。 二:WinDbg 分析 1. 程式真的卡死嗎 因為是一個 winform 程式,驗證 ...
  • 最近公司增加了一些UVC協議的攝像頭介面,下麵是一些資料整理(感謝項目組內志宇同學的耐心指導) 攝像頭插件為AForge,所以IKsControl介面對象AForge.FilterInfo。(IKsControl介面:提供了控制 KS 過濾器或 KS 引腳的用戶模式方法。參考:https://lea ...
  • 代碼編譯器是將一段源代碼(C#或VisualBasic)編譯成程式集,它的工作方式與 Emit 不一樣。從 .net standard 開始,代碼編譯器就採用了 Roslyn 來編譯源代碼,前幾篇文章里提到的 SourceGenerator 也正是基於此。 ...
  • 很多時候,在linux我們源碼編譯庫代碼時候會自定義安裝路徑,這使得man查詢的時候無法找到庫文檔,預設的man搜索路徑可以使用下麵命令查看: $ man -w /usr/local/share/man:/usr/share/man 我們可以通過修改man的命令搜索配置文件/etc/man_db.c ...
一周排行
    -Advertisement-
    Play Games
  • Timer是什麼 Timer 是一種用於創建定期粒度行為的機制。 與標準的 .NET System.Threading.Timer 類相似,Orleans 的 Timer 允許在一段時間後執行特定的操作,或者在特定的時間間隔內重覆執行操作。 它在分散式系統中具有重要作用,特別是在處理需要周期性執行的 ...
  • 前言 相信很多做WPF開發的小伙伴都遇到過表格類的需求,雖然現有的Grid控制項也能實現,但是使用起來的體驗感並不好,比如要實現一個Excel中的表格效果,估計你能想到的第一個方法就是套Border控制項,用這種方法你需要控制每個Border的邊框,並且在一堆Bordr中找到Grid.Row,Grid. ...
  • .NET C#程式啟動閃退,目錄導致的問題 這是第2次踩這個坑了,很小的編程細節,容易忽略,所以寫個博客,分享給大家。 1.第一次坑:是windows 系統把程式運行成服務,找不到配置文件,原因是以服務運行它的工作目錄是在C:\Windows\System32 2.本次坑:WPF桌面程式通過註冊表設 ...
  • 在分散式系統中,數據的持久化是至關重要的一環。 Orleans 7 引入了強大的持久化功能,使得在分散式環境下管理數據變得更加輕鬆和可靠。 本文將介紹什麼是 Orleans 7 的持久化,如何設置它以及相應的代碼示例。 什麼是 Orleans 7 的持久化? Orleans 7 的持久化是指將 Or ...
  • 前言 .NET Feature Management 是一個用於管理應用程式功能的庫,它可以幫助開發人員在應用程式中輕鬆地添加、移除和管理功能。使用 Feature Management,開發人員可以根據不同用戶、環境或其他條件來動態地控制應用程式中的功能。這使得開發人員可以更靈活地管理應用程式的功 ...
  • 在 WPF 應用程式中,拖放操作是實現用戶交互的重要組成部分。通過拖放操作,用戶可以輕鬆地將數據從一個位置移動到另一個位置,或者將控制項從一個容器移動到另一個容器。然而,WPF 中預設的拖放操作可能並不是那麼好用。為瞭解決這個問題,我們可以自定義一個 Panel 來實現更簡單的拖拽操作。 自定義 Pa ...
  • 在實際使用中,由於涉及到不同編程語言之間互相調用,導致C++ 中的OpenCV與C#中的OpenCvSharp 圖像數據在不同編程語言之間難以有效傳遞。在本文中我們將結合OpenCvSharp源碼實現原理,探究兩種數據之間的通信方式。 ...
  • 一、前言 這是一篇搭建許可權管理系統的系列文章。 隨著網路的發展,信息安全對應任何企業來說都越發的重要,而本系列文章將和大家一起一步一步搭建一個全新的許可權管理系統。 說明:由於搭建一個全新的項目過於繁瑣,所有作者將挑選核心代碼和核心思路進行分享。 二、技術選擇 三、開始設計 1、自主搭建vue前端和. ...
  • Csharper中的表達式樹 這節課來瞭解一下表示式樹是什麼? 在C#中,表達式樹是一種數據結構,它可以表示一些代碼塊,如Lambda表達式或查詢表達式。表達式樹使你能夠查看和操作數據,就像你可以查看和操作代碼一樣。它們通常用於創建動態查詢和解析表達式。 一、認識表達式樹 為什麼要這樣說?它和委托有 ...
  • 在使用Django等框架來操作MySQL時,實際上底層還是通過Python來操作的,首先需要安裝一個驅動程式,在Python3中,驅動程式有多種選擇,比如有pymysql以及mysqlclient等。使用pip命令安裝mysqlclient失敗應如何解決? 安裝的python版本說明 機器同時安裝了 ...