Canvas is not supported in your browser.
首页 课程 文章
无痕注入 APC注入 线程注入 读写驱动 注入技术 句柄表 进程线程 系统调用 保护模式 内存管理 远程CALL 软件调试 驱动封装 云下发 驱动开发 FPS数据 方框透视 FPS方框 FPS自瞄 CE D3DHOOK D3D绘制 Imgui绘制 DWM
内核课程 驱动出租 学习路线 聊天室 免责声明 提问技巧

编程技术- 驱动通信：通过PIPE管道与内核层通信

推荐 原创

周杰伦

文章分类 游戏逆向 游戏开发 编程技术 加壳脱壳 阅读数 : 584 阅读时长 : 9分钟

在本人前一篇博文《驱动开发：通过ReadFile与内核层通信》详细介绍了如何使用应用层ReadFile系列函数实现内核通信，本篇将继续延申这个知识点，介绍利用PIPE命名管道实现应用层与内核层之间的多次通信方法。

  • 什么是PIPE管道?

在Windows编程中，数据重定向需要用到管道PIPE，管道是一种用于在进程间共享数据的机制，通常由两端组成，数据从一端流入则必须从令一端流出，也就是一读一写，利用这种机制即可实现进程间直接通信。管道的本质其实是一段共享内存区域，多数情况下管道是用于应用层之间的数据交换的，其实驱动中依然可以使用命名管道实现应用层与内核层的直接通信。

 

那么如何在内核中创建一个管道？请看以下代码片段，以及MSDN针对函数的解析。

  • InitializeObjectAttributes

    • 初始化一个OBJECT_ATTRIBUTES结构，它设置将被打开的对象句柄的属性。然后调用方可以将一个指向该结构的指针传递给实际打开句柄的例程。

  • ZwCreateFile

    • 该函数的作用时创建或打开一个已经存在的文件，在这里其实是打开objAttr这个文件。

  • KeInitializeEvent

    • 将事件对象初始化为同步 (单个服务) 或通知类型事件，并将其设置为已发出信号或未发出信号的状态。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
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类型的字符串传输给应用层。

1
2
3
4
5
6
7
8
9
/ / 将数据传到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( "写出错误" );
     }
}

内核层的核心代码就是如上这些，将这些整合在一起完整代码如下所示：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
#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函数读取管道中的数据，应用层核心代码如下所示：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
#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工具中的驱动列表输出等功能的实现。

 

驱动层完整代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
#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;
}

应用层完整代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
#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 ;
}

结构体一次性输出多个，效果如下所示：

 

图片描述



更多【 驱动通信：通过PIPE管道与内核层通信】相关视频教程：www.yxfzedu.com




相关文章推荐

记录自己的技术轨迹
文章规则：
1)：文章标题请尽量与文章内容相符
2)：严禁色情、血腥、暴力
3)：严禁发布任何形式的广告贴
4)：严禁发表关于中国的政治类话题
5)：严格遵守中国互联网法律法规
6)：有侵权,疑问可发邮件至service@yxfzedu.com
近期原创 更多
友情链接
内核结构 FAQ
免责声明
课程目录
Windows内核
游戏逆向(FPS)
技术交流QQ群
342478842 215039827 137189196
314055665 159620936
微信公众号
www.yxfzedu.com是一个分享游戏安全,游戏外挂与反外挂,游戏驱动保护的视频网站！
接各种驱动定制如：游戏读写驱动，软件内存保护，防止调试等功能定制。
出租读写驱动，调试驱动，无痕注入支持各种游戏。
邮箱：service@yxfzedu.com
QQ：851920120
特别说明：不接游戏数据分析，外挂编写，登陆协议等类似业务。