驅動通信：通過PIPE管道與內核層通信

来源:https://www.cnblogs.com/LyShark/archive/2022/10/01/16746250.html
-Advertisement-
Play Games

在本人前一篇博文`《驅動開發：通過ReadFile與內核層通信》`詳細介紹瞭如何使用應用層`ReadFile`系列函數實現內核通信，本篇將繼續延申這個知識點，介紹利用`PIPE`命名管道實現應用層與內核層之間的多次通信方法。 ...


在本人前一篇博文《驅動開發：通過ReadFile與內核層通信》詳細介紹瞭如何使用應用層ReadFile系列函數實現內核通信，本篇將繼續延申這個知識點，介紹利用PIPE命名管道實現應用層與內核層之間的多次通信方法。

  • 什麼是PIPE管道?

在Windows編程中，數據重定向需要用到管道PIPE，管道是一種用於在進程間共用數據的機制，通常由兩端組成，數據從一端流入則必須從令一端流出，也就是一讀一寫，利用這種機制即可實現進程間直接通信。管道的本質其實是一段共用記憶體區域，多數情況下管道是用於應用層之間的數據交換的，其實驅動中依然可以使用命名管道實現應用層與內核層的直接通信。

那麼如何在內核中創建一個管道？請看以下代碼片段，以及MSDN針對函數的解析。

  • InitializeObjectAttributes

    • 初始化一個OBJECT_ATTRIBUTES結構，它設置將被打開的對象句柄的屬性。然後調用方可以將一個指向該結構的指針傳遞給實際打開句柄的常式。

  • ZwCreateFile

    • 該函數的作用時創建或打開一個已經存在的文件，在這裡其實是打開objAttr這個文件。

  • KeInitializeEvent

    • 將事件對象初始化為同步 (單個服務) 或通知類型事件，並將其設置為已發出信號或未發出信號的狀態。
HANDLE g_hClient;
IO_STATUS_BLOCK g_ioStatusBlock;
KEVENT g_event;

VOID NdisMSleep(IN ULONG  MicrosecondsToSleep);

// 初始化管道
void init()
{
	UNICODE_STRING uniName;
	OBJECT_ATTRIBUTES objAttr;

	RtlInitUnicodeString(&uniName, L"\\DosDevices\\Pipe\\LySharkPipeConn");
	InitializeObjectAttributes(&objAttr, &uniName, OBJ_CASE_INSENSITIVE | OBJ_KERNEL_HANDLE, NULL, NULL);

	ZwCreateFile(&g_hClient, GENERIC_READ | GENERIC_WRITE, &objAttr, &g_ioStatusBlock, NULL, FILE_ATTRIBUTE_NORMAL, 0, FILE_OPEN, FILE_SYNCHRONOUS_IO_NONALERT, NULL, 0);
	if (!g_hClient)
	{
		return;
	}
	KeInitializeEvent(&g_event, SynchronizationEvent, TRUE);
}

原理就是打開\\DosDevices\\Pipe\\LySharkPipeConn文件，然後將事件對象初始化為同步狀態。

接下來就是如何將數據發送給應用層的問題，發送問題可以調用ZwWriteFile這個內核函數，如下我們實現的效果是將一個char類型的字元串傳輸給應用層。

// 將數據傳到R3應用層
// LyShark
VOID ReportToR3(char* m_parameter, int lent)
{
	if (!NT_SUCCESS(ZwWriteFile(g_hClient, NULL, NULL, NULL, &g_ioStatusBlock, (void*)m_parameter, lent, NULL, NULL)))
	{
		DbgPrint("寫出錯誤");
	}
}

內核層的核心代碼就是如上這些，將這些整合在一起完整代碼如下所示：

#include <ntifs.h>
#include <ndis.h>
#include <stdio.h>

HANDLE g_hClient;
IO_STATUS_BLOCK g_ioStatusBlock;
KEVENT g_event;

VOID NdisMSleep(IN ULONG  MicrosecondsToSleep);

// 初始化管道
void init()
{
	UNICODE_STRING uniName;
	OBJECT_ATTRIBUTES objAttr;

	RtlInitUnicodeString(&uniName, L"\\DosDevices\\Pipe\\LySharkPipeConn");
	InitializeObjectAttributes(&objAttr, &uniName, OBJ_CASE_INSENSITIVE | OBJ_KERNEL_HANDLE, NULL, NULL);

	ZwCreateFile(&g_hClient, GENERIC_READ | GENERIC_WRITE, &objAttr, &g_ioStatusBlock, NULL, FILE_ATTRIBUTE_NORMAL, 0, FILE_OPEN, FILE_SYNCHRONOUS_IO_NONALERT, NULL, 0);
	if (!g_hClient)
	{
		return;
	}
	KeInitializeEvent(&g_event, SynchronizationEvent, TRUE);
}

// 將數據傳到R3應用層
// LyShark
VOID ReportToR3(char* m_parameter, int lent)
{
	if (!NT_SUCCESS(ZwWriteFile(g_hClient, NULL, NULL, NULL, &g_ioStatusBlock, (void*)m_parameter, lent, NULL, NULL)))
	{
		DbgPrint("寫出錯誤");
	}
}

VOID UnDriver(PDRIVER_OBJECT driver)
{
	DbgPrint("驅動卸載成功 \n");
}

NTSTATUS DriverEntry(IN PDRIVER_OBJECT Driver, PUNICODE_STRING RegistryPath)
{
	init();

	// 延時3秒
	NdisMSleep(3000000);

	DbgPrint("hello lyshark \n");
	for (int x = 0; x < 10; x++)
	{
		// 分配空間
		char *report = (char*)ExAllocatePoolWithTag(NonPagedPool, 4096, 'lysh');
		if (report)
		{
			RtlZeroMemory(report, 4096);

			RtlCopyMemory(report, "hello lyshark", 13);

			// 發送到應用層
			ReportToR3(report, 4096);
			ExFreePool(report);
		}
	}

	DbgPrint("驅動載入成功 \n");
	Driver->DriverUnload = UnDriver;
	return STATUS_SUCCESS;
}

內核中創建了命名管道，客戶端就需要創建一個相同名稱的管道，並通過ReadFile函數讀取管道中的數據，應用層核心代碼如下所示：

#include <iostream>
#include <windows.h>

int main(int argc, char *argv[])
{
	HANDLE hPipe = CreateNamedPipe(TEXT("\\\\.\\Pipe\\LySharkPipeConn"), PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED, PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, 0, 0, NMPWAIT_WAIT_FOREVER, NULL);
	if (INVALID_HANDLE_VALUE == hPipe)
	{
		return false;
	}

	const int size = 1024 * 10;
	char buf[size];
	DWORD rlen = 0;
	while (true)
	{
		//if (ConnectNamedPipe(hPipe, NULL) != NULL)
		// PowerBy: LyShark.com
		if (1)
		{
			if (ReadFile(hPipe, buf, size, &rlen, NULL) == FALSE)
			{
				continue;
			}
			else
			{
				//接收信息
				char* buffer_tmp = (char*)&buf;

				// 拷貝前半部分,不包括 buffer_data
				char* buffer = (char*)malloc(size);
				memcpy(buffer, buffer_tmp, size);

				printf("內核層數據: %s \n", buffer);

				free(buffer_tmp);
				free(buffer);
			}
		}
	}

	system("pause");
	return 0;
}

至此將驅動簽名後運行，並迅速打開應用層程式等待同步發送事件，即可得到如下返回結果。

此處有必要解釋一下為什麼會寫出錯誤，很簡單這段代碼並沒有控制何時觸發事件，導致兩邊不同步，因為只是一個案例用於演示管道的應用方法，所以大家不要太較真，如果不想出錯誤這段代碼還有很多需要改進的地方。

管道不僅可以傳輸字元串完全可以傳輸結構體數據，如下我們定義一個Networkreport結構體，並通過管道的方式多次傳輸給應用層，這部分傳輸模式適合用於驅動中一次性突出多個結構體，例如進程列表的輸出，ARK工具中的驅動列表輸出等功能的實現。

驅動層完整代碼

#include <ntifs.h>
#include <ndis.h>
#include <stdio.h>

HANDLE g_hClient;
IO_STATUS_BLOCK g_ioStatusBlock;
KEVENT g_event;

typedef struct
{
  int type;
  unsigned long address;
  unsigned long buffer_data_len;
  char buffer_data[0];
}Networkreport;

VOID NdisMSleep(IN ULONG  MicrosecondsToSleep);

// 初始化管道
void init()
{
  UNICODE_STRING uniName;
  OBJECT_ATTRIBUTES objAttr;

  RtlInitUnicodeString(&uniName, L"\\DosDevices\\Pipe\\LySharkPipeConn");
  InitializeObjectAttributes(&objAttr, &uniName, OBJ_CASE_INSENSITIVE | OBJ_KERNEL_HANDLE, NULL, NULL);

  ZwCreateFile(&g_hClient, GENERIC_READ | GENERIC_WRITE, &objAttr, &g_ioStatusBlock, NULL, FILE_ATTRIBUTE_NORMAL, 0, FILE_OPEN, FILE_SYNCHRONOUS_IO_NONALERT, NULL, 0);
  if (!g_hClient)
  {
    return;
  }
  KeInitializeEvent(&g_event, SynchronizationEvent, TRUE);
}

// 將數據傳到R3應用層
// PowerBy: LyShark.com
VOID ReportToR3(Networkreport* m_parameter, int lent)
{
  if (!NT_SUCCESS(ZwWriteFile(g_hClient, NULL, NULL, NULL, &g_ioStatusBlock, (void*)m_parameter, lent, NULL, NULL)))
  {
    DbgPrint("寫出錯誤");
  }
}

VOID UnDriver(PDRIVER_OBJECT driver)
{
  DbgPrint("驅動卸載成功 \n");
}

NTSTATUS DriverEntry(IN PDRIVER_OBJECT Driver, PUNICODE_STRING RegistryPath)
{
  init();

  // 延時3秒
  NdisMSleep(3000000);
  DbgPrint("hello lyshark \n");

  for (int x = 0; x < 10; x++)
  {
    // 分配空間
    Networkreport *report = (Networkreport*)ExAllocatePoolWithTag(NonPagedPool, 4096, 'lysh');
    if (report)
    {
      RtlZeroMemory(report, 4096);

      report->type = x;
      report->address = 401000 + x;
      report->buffer_data_len = 13;

      // 定位到結構體最後一個元素上
      unsigned char * tmp = (unsigned char *)report + sizeof(Networkreport);
      memcpy(tmp, "hello lyshark", 13);

      // 發送到應用層
      ReportToR3(report, 4096);
      ExFreePool(report);
    }
  }

  DbgPrint("驅動載入成功 \n");
  Driver->DriverUnload = UnDriver;
  return STATUS_SUCCESS;
}

應用層完整代碼

#include <iostream>
#include <windows.h>

typedef struct
{
	int type;
	unsigned long address;
	unsigned long buffer_data_len;
	char *buffer_data;
}Networkreport;

int main(int argc, char *argv[])
{
	HANDLE hPipe = CreateNamedPipe(TEXT("\\\\.\\Pipe\\LySharkPipeConn"), PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED, PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, 0, 0, NMPWAIT_WAIT_FOREVER, NULL);
	if (INVALID_HANDLE_VALUE == hPipe)
	{
		return false;
	}

	const int size = 1024 * 10;
	char buf[size];
	DWORD rlen = 0;
	while (true)
	{
		//if (ConnectNamedPipe(hPipe, NULL) != NULL)
		if (1 == 1)
		{
			if (ReadFile(hPipe, buf, size, &rlen, NULL) == FALSE)
			{
				continue;
			}
			else
			{
				//接收信息
				Networkreport* buffer_tmp = (Networkreport*)&buf;
				SIZE_T buffer_len = sizeof(Networkreport) + buffer_tmp->buffer_data_len;

				// 拷貝前半部分,不包括 buffer_data
				Networkreport* buffer = (Networkreport*)malloc(buffer_len);
				memcpy(buffer, buffer_tmp, buffer_len);

				// 對後半部 分配空間
				// By: LyShark
				char* data = (char*)malloc(buffer->buffer_data_len);
				unsigned char* tmp = (unsigned char *)buffer + sizeof(Networkreport) - 4;
				memcpy(data, tmp, buffer->buffer_data_len);

				printf("輸出數據: %s \n", data);
				printf("地址: %d \n", buffer_tmp->address);
				printf("長度: %d \n", buffer_tmp->type);
				printf("輸出長度: %d \n", buffer_tmp->buffer_data_len);

				free(data);
				free(buffer);
			}
		}
	}
	system("pause");
	return 0;
}

結構體一次性輸出多個，效果如下所示：

文章作者：lyshark (王瑞)
文章出處：https://www.cnblogs.com/LyShark/p/16746250.html
版權聲明：本博客文章與代碼均為學習時整理的筆記，文章 [均為原創] 作品，轉載請 [添加出處] ，您添加出處是我創作的動力！
轉載文章，請遵守《中華人民共和國著作權法》相關規定或遵守《署名CC BY-ND 4.0國際》禁止演繹規範，合理合規，攜帶原創出處轉載。
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 學習筆記——Django項目中的請求與響應
    2022-10-01 ALLOWED_HOSTS "ALLOWED_HOSTS"的含義： 它是指允許放在“ALLOWED_HOSTS”的主機進行訪問後端 “ALLOWED_HOSTS”的說明： 它一般預設是“127.0.0.1”，如果添加上其他的主機的話，其他主機也可訪問此項目的view，但是此時， ...
  • 學習筆記——Django項目中的結果集、分頁
    2022-10-01 結果集的含義： 結果集就是在查詢過程中，返回的一個列表的集合。 常見的結果集在一些函數中查詢會返回，具體包括的函數有： filter、exclude、order_by 結果集的兩大特性： （1）惰性 指的是查詢時，如果不用則在mysql日誌中不會有查詢記錄。反之，如果使用（一般 ...
  • Java之POI導出Excel(二)：多個sheet
    相信在大部分的web項目中都會有導出導入Excel的需求，之前我也寫過一篇導出單個sheet工作表的文章，沒看過的小伙伴可以去看哈，鏈接也給大家放出來了：導出單個sheet 但是在我們日常的工作中，需求往往沒這麼簡單，可能需要將數據按類型分類導出或者數據量過大，需要分多張表導出等等。遇到類似的需求該 ...
  • Java之POI導出Excel(一)：單sheet
    相信在大部分的web項目中都會有導出導入Excel的需求，今天我們就來看看如何用Java代碼去實現 用POI導出Excel表格。 一、pom引用 pom文件中，添加以下依賴 查看代碼 <!--Excel工具--> <dependency> <groupId>org.apache.poi</group ...
  • 集合框架——LinkedList集合源碼分析
    總結： LinkedList繼承自List，具備有序性 LinkedList繼承自Deque，具備鏈表關聯性 LinkedList集合進行增刪改查操作底層實際是操作Node節點的前後鏈接關係 LinkedList進行增刪操作時，僅需要操作節點的前後鏈接關係，因此效率較ArrayList高 Linke ...
  • python截取字元串(字元串切片)
    python中使用[]來截取字元串，語法： 字元串[起始位置:結束位置] 一、起始位置:結束位置 先看幾個例子： s = 'python' print(s) #輸出 python 直接輸出字元串 #從前面截取 print(s[1]) #輸出 y 根據下標取字元 print(s[:]) #輸出 pyt ...
  • 將側邊欄製成inclusion_tag
    在開發過程中，像側邊欄這種功能的版塊，我們在很多頁面都需要使用到的時候，我們則需要在視圖函數中書寫重覆的代碼，這樣很繁瑣，我們可以將側邊欄製成inclusion_tag,後面我們需要用到側邊欄功能時，只需要導入即可！ 將側邊欄製成inclusion_tag的步驟： 1.在應用下創建一個名字必須叫te ...
  • 學習筆記——Django項目中關聯查詢以及關聯查詢的篩選
    2022-10-01 關聯查詢： 在Django項目中使用ORM模式設置表後，進行關聯查詢，即兩個表直接有聯繫的查詢。 方式： 可以通過主表查詢從表，也可以通過從表查詢主表。 方式一實例： （1）查詢編號為1的圖書中的人物 前提環境，進入pycharm，進入虛擬環境、進入shell環境。 首先，需要 ...
一周排行
    -Advertisement-
    Play Games
  • .net下優秀的MQTT框架MQTTnet使用方法，物聯網通訊必備
    MQTTnet 是一個高性能的MQTT類庫，支持.NET Core和.NET Framework。 MQTTnet 原理： MQTTnet 是一個用於.NET的高性能MQTT類庫，實現了MQTT協議的各個層級，包括連接、會話、發佈/訂閱、QoS（服務質量）等。其原理涉及以下關鍵概念： MqttCli ...
  • WPF 綁定binding都有哪些事件
    在WPF中，源屬性（Source Property）指的是提供數據的屬性，通常是數據模型或者其他控制項的屬性，而目標屬性（Target Property）則是數據綁定的目標，通常是綁定到控制項的屬性，例如TextBlock的Text屬性。數據綁定將源屬性的值自動更新到目標屬性中。 主要包含以下幾個事件： ...
  • C#中await /async 的使用場景，優點，使用方法介紹
    async/await 是 C# 中非同步編程的關鍵特性，它使得非同步代碼編寫更為簡單和直觀。下麵深入詳細描述了 async/await 的使用場景、優點以及一些高級使用方法，並提供了相應的實例源代碼。 使用場景： I/O 操作： 非同步編程特別適用於涉及 I/O 操作（如文件讀寫、網路請求等）的場景。在 ...
  • 淺談WPF之控制項拖拽與拖動
    使用過office的visio軟體畫圖的小伙伴都知道，畫圖軟體分為兩部分，左側圖形庫，存放各種圖標，右側是一個畫布，將左側圖形庫的圖標控制項拖拽到右側畫布，就會生成一個新的控制項，並且可以自由拖動。那如何在WPF程式中，實現類似的功能呢？今天就以一個簡單的小例子，簡述如何在WPF中實現控制項的拖拽和拖動，... ...
  • 在winform中使用blazor hybrid構建頁面
    1、Blazor Hybrid簡介 Blazor Hybrid 使開發人員能夠將桌面和移動本機客戶端框架與 .NET 和 Blazor 結合使用。在 Blazor Hybrid 應用中，Razor 組件在設備上是本機運行的。 這些組件通過本地互操作通道呈現到嵌入式 Web 視圖控制項。 組件不在瀏覽器 ...
  • 【scikit-learn基礎】--『數據載入』之樣本生成器
    除了內置的數據集，scikit-learn還提供了隨機樣本的生成器。通過這些生成器函數，可以生成具有特定特性和分佈的隨機數據集，以幫助進行機器學習演算法的研究、測試和比較。 目前，scikit-learn庫（v1.3.0版）中有20個不同的生成樣本的函數。本篇重點介紹其中幾個具有代表性的函數。 1. ...
  • 從0到1，手把手帶你開發截圖工具ScreenCap------002實現設置預設保存的圖片位置
    從0到1，手把手帶你開發截圖工具ScreenCap------002實現通過文件對話框，選擇合適的文件夾，自定義預設的圖片保存位置，簡單易學 ...
  • 快速認識什麼是：Kubernetes
    每次談到容器的時候，除了Docker之外，都會說起 Kubernetes，那麼什麼是 Kubernetes呢？今天就來一起學快速入門一下 Kubernetes 吧！希望本文對您有所幫助。 Kubernetes，一種用於管理和自動化雲中容器化工作負載的工具。 想象一下你有一個管弦樂隊，將每個音樂家視為 ...
  • Windows伺服器，通過Nginx部署VUE+Django前後端分離項目
    目錄 基本說明 安裝 Nginx 部署 VUE 前端 部署 Django 後端 Django admin 靜態文件（CSS，JS等）丟失的問題 總結 1. 基本說明 本文介紹了在 windows 伺服器下，通過 Nginx 部署 VUE + Django 前後端分離項目。本項目前端運行在 80 埠 ...
  • 從0到1，手把手帶你開發截圖工具ScreenCap------003實現最小化程式到托盤運行
    從0到1，手把手帶你開發截圖工具ScreenCap------003實現最小化程式到托盤運行，- 為了方便截圖乾凈，實現最小化程式到托盤運行，簡潔，勿擾，實現最小化程式到托盤運行， 實現托盤菜單功能，實現回顯主窗體， 實現托盤開始截屏， 實現氣泡信息提示，實現托盤程式提示，實現托盤退出程式， 封裝完... ...
所有分類