进程管道通讯-伪终端方式

发布时间：2026/8/8 15:00:40

进程管道通讯-伪终端方式
传统CreateProcess传递StdIN StdOUT 管道方式存在进程输出不能及时刷管道问题导致ReadFile阻塞传统解决方法是子进程强制进行fflush(stdout), 如果不能改变子进程就没办法了从win10开始 windows支持伪终端可以完全模拟终端管道的行为传统管道crt会使用GetFileType检测STDHANDLE 对于控制台调用检测到的是字符设备而对于改变后的STDHANDLE 检测到的是管道设备对发现管道设备时缓冲方式就变成了块缓冲方式遇到换行符也不会及时flush这就导致预期输出不能直接被ReadFile读取到Win10上的伪终端方式接管进程输入输出代码//Kernel32.dll #ifndef PROC_THREAD_ATTRIBUTE_PSEUDOCONSOLE #define PROC_THREAD_ATTRIBUTE_PSEUDOCONSOLE 0x20016 #endif typedef HRESULT(WINAPI* PFN_CreatePseudoConsole)( _In_ COORD size, _In_ HANDLE hInput, _In_ HANDLE hOutput, _In_ DWORD dwFlags, _Out_ HPCON* phPC ); HRESULT MyCreatePseudoConsole( _In_ COORD size, _In_ HANDLE hInput, _In_ HANDLE hOutput, _In_ DWORD dwFlags, _Out_ HPCON* phPC ) { static PFN_CreatePseudoConsole fn (PFN_CreatePseudoConsole)::GetProcAddress(GetModuleHandle(LKernel32.dll), CreatePseudoConsole); if (fn) return fn(size, hInput, hOutput, dwFlags, phPC); return E_FAIL; } typedef BOOL(WINAPI* PFN_InitializeProcThreadAttributeList)( LPPROC_THREAD_ATTRIBUTE_LIST lpAttributeList, DWORD dwAttributeCount, DWORD dwFlags, PSIZE_T lpSize ); BOOL MyInitializeProcThreadAttributeList( LPPROC_THREAD_ATTRIBUTE_LIST lpAttributeList, DWORD dwAttributeCount, DWORD dwFlags, PSIZE_T lpSize ) { static PFN_InitializeProcThreadAttributeList fn (PFN_InitializeProcThreadAttributeList)::GetProcAddress(GetModuleHandle(LKernel32.dll), InitializeProcThreadAttributeList); if (fn) return fn(lpAttributeList, dwAttributeCount, dwFlags, lpSize); return 0; } typedef BOOL(WINAPI* PFN_UpdateProcThreadAttribute)( LPPROC_THREAD_ATTRIBUTE_LIST lpAttributeList, DWORD dwFlags, DWORD_PTR Attribute, PVOID lpValue, SIZE_T cbSize, PVOID lpPreviousValue, PSIZE_T lpReturnSize ); BOOL MyUpdateProcThreadAttribute( LPPROC_THREAD_ATTRIBUTE_LIST lpAttributeList, DWORD dwFlags, DWORD_PTR Attribute, PVOID lpValue, SIZE_T cbSize, PVOID lpPreviousValue, PSIZE_T lpReturnSize ) { static PFN_UpdateProcThreadAttribute fn (PFN_UpdateProcThreadAttribute)::GetProcAddress(GetModuleHandle(LKernel32.dll), UpdateProcThreadAttribute); if (fn) return fn(lpAttributeList, dwFlags, Attribute, lpValue, cbSize, lpPreviousValue, lpReturnSize); return 0; } typedef void(WINAPI* PFN_ClosePseudoConsole)(_In_ HPCON hPC); void MyClosePseudoConsole(_In_ HPCON hPC) { static PFN_ClosePseudoConsole fn (PFN_ClosePseudoConsole)::GetProcAddress(GetModuleHandle(LKernel32.dll), ClosePseudoConsole); if (fn) fn(hPC); } typedef VOID(WINAPI*PFN_DeleteProcThreadAttributeList)( LPPROC_THREAD_ATTRIBUTE_LIST lpAttributeList ); VOID MyDeleteProcThreadAttributeList( LPPROC_THREAD_ATTRIBUTE_LIST lpAttributeList ) { static PFN_DeleteProcThreadAttributeList fn (PFN_DeleteProcThreadAttributeList)::GetProcAddress(GetModuleHandle(LKernel32.dll), DeleteProcThreadAttributeList); if (fn) fn(lpAttributeList); } typedef struct _MySTARTUPINFOEXW { STARTUPINFOW StartupInfo; LPPROC_THREAD_ATTRIBUTE_LIST lpAttributeList; } MySTARTUPINFOEXW; BidirectionalPipe::~BidirectionalPipe() { Cleanup(); } bool BidirectionalPipe::StartProcess(bool bPsConsole, const std::wstring command) { SECURITY_ATTRIBUTES sa { 0 }; sa.nLength sizeof(SECURITY_ATTRIBUTES); sa.bInheritHandle TRUE; sa.lpSecurityDescriptor NULL; // 创建输入管道父进程写子进程读 if (!CreatePipe(m_hChildStdinRead, m_hParentWrite, sa, 0)) { Cleanup(); return false; } // 创建输出管道父进程读子进程写 if (!CreatePipe(m_hParentRead, m_hChildStdoutWrite, sa, 0)) { Cleanup(); return false; } if (bPsConsole) { // 2. 创建伪控制台 (ConPTY) COORD consoleSize { 80, 25 }; // 初始控制台大小 HRESULT hr MyCreatePseudoConsole(consoleSize, m_hChildStdinRead, m_hChildStdoutWrite, 0, m_hPC); if (FAILED(hr)) { Cleanup(); return false; } } // 3. 准备 STARTUPINFOEXW 结构体 MySTARTUPINFOEXW si { 0 }; if (bPsConsole) { si.StartupInfo.cb sizeof(MySTARTUPINFOEXW); } else { si.StartupInfo.cb sizeof(STARTUPINFOW); } si.StartupInfo.dwFlags STARTF_USESTDHANDLES; if (bPsConsole) { // 关键将 ConPTY 句柄附加到 StartupInfo SIZE_T size 0; MyInitializeProcThreadAttributeList(NULL, 1, 0, size); m_lpAttributeList (LPPROC_THREAD_ATTRIBUTE_LIST)HeapAlloc(GetProcessHeap(), 0, size); MyInitializeProcThreadAttributeList(m_lpAttributeList, 1, 0, size); MyUpdateProcThreadAttribute(m_lpAttributeList, 0, PROC_THREAD_ATTRIBUTE_PSEUDOCONSOLE, m_hPC, sizeof(HPCON), NULL, NULL); si.lpAttributeList m_lpAttributeList; si.StartupInfo.wShowWindow SW_HIDE; si.StartupInfo.dwFlags STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES; } else { si.StartupInfo.wShowWindow SW_HIDE; si.StartupInfo.dwFlags STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES; si.StartupInfo.hStdError m_hChildStdoutWrite; si.StartupInfo.hStdOutput m_hChildStdoutWrite; si.StartupInfo.hStdInput m_hChildStdinRead; } // 启动进程 if (!CreateProcessW(NULL, const_castwchar_t*(command.c_str()), NULL, NULL, bPsConsole ? FALSE : TRUE, bPsConsole ? EXTENDED_STARTUPINFO_PRESENT : 0, NULL, NULL, si.StartupInfo, m_pi)) { Cleanup(); return false; } // 【至关重要】CreateProcess 成功后父进程必须关闭它不需要的管道句柄 // 否则 ReadFile 永远不会收到 EOF导致卡死。 if (m_hChildStdinRead) { CloseHandle(m_hChildStdinRead); m_hChildStdinRead 0; } if (m_hChildStdoutWrite) { CloseHandle(m_hChildStdoutWrite); m_hChildStdoutWrite 0; } return true; } void BidirectionalPipe::WriteInput(const std::string input) { if (m_hParentWrite NULL) return; DWORD bytesWritten; WriteFile(m_hParentWrite, input.c_str(), (DWORD)input.size(), bytesWritten, NULL); FlushFileBuffers(m_hParentWrite); } __declspec(noinline) CStringA BidirectionalPipe::ReadOutput() { CStringA strRet; const int bufMaxChars 4095; char buffer[bufMaxChars 10] { 0 }; DWORD bytesRead; //FlushFileBuffers(m_hChildStdoutWrite); // 第一次读取 if (!ReadFile(m_hParentRead, buffer, bufMaxChars, bytesRead, NULL) || bytesRead 0) { return strRet; // 读取失败或无数据 } buffer[bytesRead] \0; strRet buffer; //// 检查是否读取完所有数据 //if (bytesRead bufMaxChars) { // return strRet; // 缓冲区未满说明数据已读完 //} // 缓冲区已满检查管道内是否还有剩余数据 while (true) { DWORD bytesAvailable 0; BOOL peekResult PeekNamedPipe( m_hParentRead, NULL, // 不读取数据只查询状态 0, // 缓冲区大小为0 NULL, // 读取的字节数 bytesAvailable, // 可用字节数 NULL // 消息剩余字节数用于消息模式 ); if (!peekResult || bytesAvailable 0) { break; // 查询失败或无剩余数据 } // 动态分配缓冲区读取剩余数据最多读取bufMaxChars字节 DWORD readSize min(bytesAvailable, (DWORD)bufMaxChars); if (ReadFile(m_hParentRead, buffer, readSize, bytesRead, NULL) bytesRead 0) { buffer[bytesRead] \0; strRet buffer; // 如果读取的字节数等于缓冲区大小说明可能还有更多数据 if (bytesRead readSize) { break; // 数据已读完 } } else { break; // 读取失败 } } return strRet; } void BidirectionalPipe::Terminate() { if (m_pi.hProcess) { ::TerminateProcess(m_pi.hProcess, 0); WaitForSingleObject(m_pi.hProcess, 10000); } } void BidirectionalPipe::Cleanup() { if (m_hChildStdinRead) { CloseHandle(m_hChildStdinRead); m_hChildStdinRead 0; } if (m_hParentWrite) { CloseHandle(m_hParentWrite); m_hParentWrite 0; } if (m_hParentRead) { CloseHandle(m_hParentRead); m_hParentRead 0; } if (m_hChildStdoutWrite) { CloseHandle(m_hChildStdoutWrite); m_hChildStdoutWrite 0; } if (m_pi.hProcess) { CloseHandle(m_pi.hProcess); m_pi.hProcess 0; } if (m_pi.hThread) { CloseHandle(m_pi.hThread); m_pi.hThread 0; } if (m_lpAttributeList) { MyDeleteProcThreadAttributeList(m_lpAttributeList); HeapFree(GetProcessHeap(), 0, m_lpAttributeList); m_lpAttributeList 0; } if (m_hPC) { MyClosePseudoConsole(m_hPC); m_hPC 0; } } ///////////////////////////////////Header///////////////////////////// #pragma once typedef void* HPCON; class BidirectionalPipe { private: HANDLE m_hChildStdinRead NULL; HANDLE m_hParentWrite NULL; HANDLE m_hParentRead NULL; HANDLE m_hChildStdoutWrite NULL; PROCESS_INFORMATION m_pi { 0 }; LPPROC_THREAD_ATTRIBUTE_LIST m_lpAttributeList 0; HPCON m_hPC 0; public: ~BidirectionalPipe(); bool StartProcess(bool bPsConsole, const std::wstring command); void WriteInput(const std::string input); CStringA ReadOutput(); void Terminate(); private: void Cleanup(); };

相关新闻

计算机自学路线：从零基础到进阶的完整指南

计算机自学路线：从零基础到进阶的完整指南

1. 计算机课程自学路线规划作为一名在IT行业摸爬滚打十年的老程序员，我经常被问到"如何系统学习计算机知识"。市面上课程琳琅满目，但缺乏体系化的学习路径往往让初学者陷入"东一榔头西一棒子"的困境。这里分享我总结的计算机课程学习…

2026/8/8 14:59:56 阅读更多 →
单臂路由技术详解：原理、配置与故障排查实战指南

单臂路由技术详解：原理、配置与故障排查实战指南

1. 项目概述：为什么我们需要“单臂路由”？在网络工程师的日常里，经常会遇到一个经典场景：公司业务扩张，新租了一层办公楼，需要快速部署网络。预算有限，不可能为每个新部门都配置一台昂贵的三层核…

2026/8/8 5:05:26 阅读更多 →
视频孪生技术：核心原理与工业实践

视频孪生技术：核心原理与工业实践

1. 视频孪生技术的行业定位与价值解析视频孪生作为数字孪生技术在视觉维度的延伸，正在重塑工业制造、智慧城市等领域的数字化进程。这项技术通过将物理世界的动态场景实时映射到虚拟空间，构建起可交互、可分析的数字化镜像系统。与传统数字孪生相比&…

2026/8/3 23:39:32 阅读更多 →

最新新闻

如何在3分钟内使用BPfold预测microRNA二级结构？初学者必备教程

如何在3分钟内使用BPfold预测microRNA二级结构？初学者必备教程

vFlow容器化部署终极指南：Docker与Kubernetes配置实战 【免费下载链接】vflow 项目地址: https://gitcode.com/gh_mirrors/vfl/vflow vFlow容器化部署是现代化网络流量监控系统的关键步骤，通过Docker和Kubernetes技术实现高可用、可扩展的网络流…

2026/8/8 14:59:48 阅读更多 →
洛雪音乐音源终极配置指南：3步解锁全网无损音乐

洛雪音乐音源终极配置指南：3步解锁全网无损音乐

洛雪音乐音源终极配置指南：3步解锁全网无损音乐 【免费下载链接】lxmusic- lxmusic(洛雪音乐)全网最新最全音源 项目地址: https://gitcode.com/gh_mirrors/lx/lxmusic- 想要在洛雪音乐中免费收听全网音乐吗？掌握洛雪音乐音源配置技巧是关键&…

2026/8/8 14:59:48 阅读更多 →
GitHub镜像站搭建指南：Nginx反向代理实战

GitHub镜像站搭建指南：Nginx反向代理实战

1. GitHub镜像站搭建全攻略 国内开发者在使用GitHub时经常遇到访问速度慢、下载失败等问题。作为一名长期与GitHub打交道的开发者，我深知这种痛苦。今天就来分享一套完整的GitHub镜像站搭建方案，帮助团队解决这个痛点。 这个方案适合： 需要…

2026/8/8 14:59:48 阅读更多 →
JeecgBoot企业级全文检索架构深度解析：Elasticsearch集成方案与最佳实践

JeecgBoot企业级全文检索架构深度解析：Elasticsearch集成方案与最佳实践

JeecgBoot企业级全文检索架构深度解析：Elasticsearch集成方案与最佳实践 【免费下载链接】jeecg-boot 【低代码迈入v2.0时代，一句话即可生成整个系统】企业级AI低代码平台，一键生成前后端代码甚至整个系统。 AI Skills 一句话画流程、设计表单…

2026/8/8 14:59:48 阅读更多 →
PDF补丁丁：5大核心功能让你彻底掌握免费PDF处理技巧

PDF补丁丁：5大核心功能让你彻底掌握免费PDF处理技巧

PDF补丁丁：5大核心功能让你彻底掌握免费PDF处理技巧 【免费下载链接】PDFPatcher PDF补丁丁——PDF工具箱，可以编辑书签、剪裁旋转页面、解除限制、提取或合并文档，探查文档结构，提取图片、转成图片等等 项目地址: https://gitc…

2026/8/8 14:59:48 阅读更多 →
如何快速生成MobaXterm激活文件：开源密钥生成器完整指南

如何快速生成MobaXterm激活文件：开源密钥生成器完整指南

如何快速生成MobaXterm激活文件：开源密钥生成器完整指南 【免费下载链接】MobaXterm-Keygen MobaXterm Keygen Originally by DoubleLabyrinth 项目地址: https://gitcode.com/gh_mirrors/mob/MobaXterm-Keygen 你是否在使用Windows远程桌面工具时遇到了Moba…

2026/8/8 14:58:48 阅读更多 →

日新闻

AI多智能体时代来临，读懂MCP与A2A架构，抢占企业数字化新风口

AI多智能体时代来临，读懂MCP与A2A架构，抢占企业数字化新风口

当下AI应用飞速普及，无数企业下场搭建智能体系统，可落地阶段难题接踵而至：上下文无限堆积频繁爆栈、AI工具调用准确率低下、Token成本居高不下、企业数据权限混乱暗藏安全隐患……很多团队卡在架构搭建环节，空有前沿技术概念&…

2026/8/8 0:00:07 阅读更多 →
PHP二维码生成终极指南：用chillerlan/php-qrcode打造专业级二维码

PHP二维码生成终极指南：用chillerlan/php-qrcode打造专业级二维码

PHP二维码生成终极指南：用chillerlan/php-qrcode打造专业级二维码 【免费下载链接】php-qrcode A PHP QR Code generator and reader with a user-friendly API. 项目地址: https://gitcode.com/gh_mirrors/ph/php-qrcode 在当今数字时代，二维码已…

2026/8/8 0:00:08 阅读更多 →
UniApp微信小程序隐私保护组件开发：从原理到实战

UniApp微信小程序隐私保护组件开发：从原理到实战

1. 项目缘起：为什么我们需要一个隐私保护通用组件？最近在维护一个基于uniapp开发的微信小程序矩阵时，我遇到了一个非常棘手的问题。随着平台对用户隐私保护的要求越来越严格，几乎每一个新版本发布，或者在某些特定机型&…

2026/8/8 0:00:08 阅读更多 →

周新闻

最大流算法详解：从水管网络到Ford-Fulkerson与Dinic实战

最大流算法详解：从水管网络到Ford-Fulkerson与Dinic实战

1. 从水管网络到最大流：一个核心问题的诞生想象一下，你是一个城市供水系统的总工程师。你的城市有多个水源（水库），需要通过一个复杂的地下管道网络，将水输送到各个居民区。每条管道都有其最大通水能力&…

2026/8/6 22:02:27 阅读更多 →
基于Springboot的企业门户网站(源码+LW+调试文档+讲解)

基于Springboot的企业门户网站(源码+LW+调试文档+讲解)

温馨提示：本人主页置顶文章(点我)开头有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：本人主页置顶文章(点我)开头有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：本人主页置顶文章(点我)开头有 CSDN 平台…

2026/8/8 8:58:26 阅读更多 →
MATLAB xcorr函数详解：从互相关原理到四大实战应用

MATLAB xcorr函数详解：从互相关原理到四大实战应用

1. 从一次信号“找茬”说起：为什么我们需要互相关几年前，我在处理一组声学传感器数据时遇到了一个棘手的问题。我有两个麦克风记录了一段相同的音频信号，理论上它们接收到的声音波形应该非常相似，只是由于麦克风位置不同&#xff…

2026/8/7 23:24:08 阅读更多 →

月新闻

免费解锁百度网盘SVIP加速：macOS用户必备的下载提速终极指南

免费解锁百度网盘SVIP加速：macOS用户必备的下载提速终极指南

免费解锁百度网盘SVIP加速：macOS用户必备的下载提速终极指南 【免费下载链接】BaiduNetdiskPlugin-macOS For macOS.百度网盘 破解SVIP、下载速度限制~ 项目地址: https://gitcode.com/gh_mirrors/ba/BaiduNetdiskPlugin-macOS 还在为百度网盘macOS版的龟速下…

2026/8/7 17:02:37 阅读更多 →
终极ncmdump指南：3分钟实现网易云NCM音乐解密与格式转换

终极ncmdump指南：3分钟实现网易云NCM音乐解密与格式转换

终极ncmdump指南：3分钟实现网易云NCM音乐解密与格式转换 【免费下载链接】ncmdump 项目地址: https://gitcode.com/gh_mirrors/ncmd/ncmdump 还在为网易云音乐下载的NCM格式文件无法在其他播放器播放而烦恼吗？ncmdump解密工具帮你轻松解决这个困…

2026/8/7 23:54:54 阅读更多 →
HarmonyOS 应用开发《掌上英语》第81篇: 智能体卡片：为英语学习 App 打造桌面级学习助手

HarmonyOS 应用开发《掌上英语》第81篇: 智能体卡片：为英语学习 App 打造桌面级学习助手

AgentCard 智能体卡片：为英语学习 App 打造桌面级学习助手适用平台：HarmonyOS 7.0 (API 26 Beta)一、引言 HarmonyOS 7.0（API 26 Beta）新增了 AgentCard 智能体卡片能力，这是继 HMAF（鸿蒙智能体框架&#x…

2026/8/7 17:02:36 阅读更多 →