匿名管道实现重定向输入输出，执行adb命令

我想通过调用adb。exe 这个控制台程序多次执行shell 命令，但是执行完第二条命令，再次通过writefile输入的时候就无法执行，通过readFile 读出的数据是第三次写入的数据。

源码。。。
char szconmand[MAX_PATH]={0};
  HANDLE stdOutPipeRd,stdOutPipeWt,stdInPipeWt,stdInPipeRd;
STARTUPINFOA startUp;
SECURITY_ATTRIBUTES lpSecurity, lpSec2;
PROCESS_INFORMATION processInfo;


lpSecurity.nLength=sizeof(SECURITY_ATTRIBUTES);
lpSecurity.lpSecurityDescriptor=NULL;
lpSecurity.bInheritHandle=true;
if (!CreatePipe(&stdOutPipeRd,&stdOutPipeWt,&lpSecurity,0))
{
DWORD err=GetLastError();

return -1;
}
lpSec2.nLength=sizeof(SECURITY_ATTRIBUTES);
lpSec2.bInheritHandle=true;
lpSec2.lpSecurityDescriptor=NULL;
if (!CreatePipe(&stdInPipeRd,&stdInPipeWt,&lpSec2,0))
{
DWORD err=GetLastError();
return -1;
}

memset(&startUp,0,sizeof(STARTUPINFOA));
GetStartupInfoA(&startUp);
startUp.cb=sizeof(STARTUPINFOA);
startUp.dwFlags=STARTF_USESTDHANDLES|STARTF_USESHOWWINDOW;
startUp.wShowWindow=HIDE_WINDOW;
startUp.hStdInput=stdOutPipeRd;
startUp.hStdOutput=stdInPipeWt;
startUp.hStdError=stdInPipeWt;
char str[MAX_PATH]={0};
strcpy(str,"adb.exe shell");
  char *pdata=NULL;
pdata=(char*)malloc(strlen(str)+strlen(szconmand));
if (pdata==NULL)
{
return -1;
}
memset(pdata,0,strlen(str)+strlen(szconmand));
int n=0;
n=strlen(str);
int k=strlen(szconmand);
  memcpy(pdata,str,sizeof(str));
memcpy(pdata+n," ",sizeof(char));
memcpy(pdata+n+1,szconmand,k);
if (!CreateProcessA(NULL,str,NULL,NULL,TRUE,0,NULL,NULL,&startUp,&processInfo))
{  
DWORD err=GetLastError();

return -1;
}
DWORD stdlen=0;
char szbuffer[MAX_PATH]={0};
  while (true)
  {  
  if(!PeekNamedPipe(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL,0))
  {
  
  DWORD err=GetLastError();
  return -1;
  }
  
  if (stdlen)
  {
  break;
  }
  }
  
  if (!ReadFile(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL))
  {
  DWORD err=GetLastError();
  return -1;
  
  }
memset(szbuffer,0,MAX_PATH);
char sqlCommand[MAX_PATH]={0};
strcpy(sqlCommand,"sqlite3 /data/data/com.android.providers.telephony/databases/mmssms.db\r\n");//程序执行到这还是正常的
if (!WriteFile(stdOutPipeWt,sqlCommand,strlen(sqlCommand)+1,&stdlen,0))
{
DWORD erro=GetLastError();
return -1;
}
memset(szbuffer,0,MAX_PATH);
while (true)
{  
if(!PeekNamedPipe(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL,0))
{

DWORD err=GetLastError();
return -1;
}

if (stdlen)
{
break;
}
}

if (!ReadFile(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL))//独处正常执行结果
{
DWORD err=GetLastError();
return -1;

}
//memset(szbuffer,0,MAX_PATH);
memset(sqlCommand,0,MAX_PATH);
strcat(szbuffer,"select * from sms;\r\n");
if (!WriteFile(stdOutPipeWt,sqlCommand,strlen(sqlCommand),&stdlen,0))//这次写入的命令，在读的时候是原封不动的被读出来了，没有执行。只能执行两次命令，，，为什么？
{
DWORD erro=GetLastError();
return -1;
}

  Sleep(5000);
while (true)
{  
memset(szbuffer,0,MAX_PATH);
if(!PeekNamedPipe(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL,0))
{

DWORD err=GetLastError();
return -1;
}

if (stdlen)
{
  break;
}
}

if (!ReadFile(stdInPipeRd,szbuffer,1024,&stdlen,NULL))
{
DWORD err=GetLastError();
return -1;

}

一般是开2个管道，一个读，一个写。msdn有例子。

if (!CreatePipe(&hRead, &hWrite, &sa, 0)) 
{
return false;
}

STARTUPINFO si;
PROCESS_INFORMATION pi;
si.cb = sizeof(STARTUPINFO);
GetStartupInfo(&si);
si.hStdError = hWrite;
si.hStdOutput = hWrite;
si.wShowWindow = SW_HIDE;
si.dwFlags = STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES;
DWORD dwWriteSize = 0;

if (!CreateProcess(NULL, cmd
,NULL,NULL,TRUE,NULL,NULL,NULL,&si, &pi)) 
{
return false;
}
然后就可以使用readfile（hRead。。。。）了

对要开两个线程，一个读 一个写 这样才能进行文件的读写 必须要写两个线程

这么好的方法,学习