//.h#include <QtGui/QMainWindow>#include <windows.h>#include <stdio.h>#include <conio.h>#include <QTimer>#include <QString>#include <QThread>#include <QProcess>#include <QTextCodec>#define BUFFER_SIZE 512class channel: public QThread {Q_OBJECTpublic: channel(); ~channel(); OVERLAPPED StrOverlapp; OVERLAPPED StrOverlappW; QString Data_pipe; bool Flag_ext_proc; LPCTSTR PipeName; int N_pipe; void run(); void createChannel(); //void analize_data(char buff[BUFFER_SIZE]); void disconnect_pipe(); void WriteChannel(); };
//.cpp#include "channel.h"QString str;// Флаг успешного создания каналаBOOL fConnected;// Идентификатор событияHANDLE hEvent;// Идентификатор канала PipeHANDLE hNamedPipe;// Имя создаваемого канала PipeLPCTSTR lpszPipeName =L"\\\\.\\pipe\\$cv_r$";LPCTSTR lpszPipeName1 =L"\\\\.\\pipe\\$cvc$";// Буфер для передачи данных через каналchar szBuf[BUFFER_SIZE];// Количество байт данных, принятых через каналDWORD cbRead;// Количество байт данных, переданных через каналDWORD cbWritten;bool flag=0,flag_exit=0;bool flag_read=false;DWORD BytesTransferred;struct Pointer{ HWND CurrWnd[50]; HWND hwnd; int Lenght; QStringList ListItem; QString ProcName[50];};QTextCodec* code = QTextCodec::codecForName("CP1251");channel::channel(){ Data_pipe=""; Flag_ext_proc=0;}channel::~channel(){ DisconnectNamedPipe(hNamedPipe); CloseHandle(hNamedPipe);}void channel::createChannel(){ DWORD Ret; DWORD Pipe; Flag_ext_proc=0; if (N_pipe==1)PipeName=lpszPipeName; if (N_pipe==2)PipeName=lpszPipeName1; // Создаем канал Pipe, имеющий имя lpszPipeName hNamedPipe = CreateNamedPipe( PipeName, // имя канала. PIPE_ACCESS_DUPLEX, PIPE_TYPE_MESSAGE |PIPE_READMODE_MESSAGE |PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, // максимальное количество экземпляров канала. BUFFER_SIZE, // размер выходного буфера по умолчанию. BUFFER_SIZE, // рахмер входного буфера по умолчанию. INFINITE, // клиент ждет связь бесконечно долго. NULL // безопасность по умолчанию. ); // Если возникла ошибка, выводим ее код и завершаем // работу приложения if(hNamedPipe == INVALID_HANDLE_VALUE) { str+="CreateNamedPipe: Error %ld\n"+GetLastError(); fprintf(stdout,"CreateNamedPipe: Error %ld\n", GetLastError()); } if(!fConnected) // Ожидаем соединения со стороны клиента fConnected = ConnectNamedPipe(hNamedPipe, NULL); // При возникновении ошибки выводим ее код if(!fConnected) { if (GetLastError() != ERROR_IO_PENDING) { printf("ConnectNamedPipe for pipe %d failed with", " error %d\n", GetLastError()); CloseHandle(hNamedPipe); return; } } else { printf("Server is now running\n"); while(1) { bool rez=0; DWORD BRead; if(Flag_ext_proc==1) { Data_pipe=""; break; } rez=ReadFile(hNamedPipe, szBuf,BUFFER_SIZE, &BRead,NULL); if ( rez ==false) { if (GetLastError() != ERROR_IO_PENDING) { printf("ReadFile failed with error %d\n", GetLastError()); } } if(strlen(szBuf)>0) { fprintf(stdout, szBuf); analize_data(szBuf); } } }}void channel::run(){ createChannel(); }void channel::disconnect_pipe(){ DisconnectNamedPipe(hNamedPipe); Data_pipe="";}
channel *chan;channel *chan1;chan= new channel();chan->N_pipe=1;chan->start();chan1= new channel();chan1->N_pipe=2;chan1->start();.....delete chan;delete chan1;
//.h#include <QString>#include <windows.h>#include <stdio.h>#include <conio.h>#include <QTimer>#include <QThread>class chanel_pipe: public QThread{ Q_OBJECT public: chanel_pipe(); ~chanel_pipe(); QTimer *Ttime; OVERLAPPED OVL; OVERLAPPED StrOverlapp; void run(); void write_chanel(char string_ch[20]); protected: private slots: };
//.cpp#include "chanel_pipe.h"#define BUFFER_SIZE 512// Идентификатор канала PipeHANDLE hNamedPipe;// Идентификатор событияHANDLE hEndWrite;// Количество байт, переданных через каналDWORD cbWritten;// Количество байт, принятых через каналDWORD cbRead;DWORD BytesTransferred;// Идентификатор событияHANDLE hEvent;// Буфер для передачи данныхchar szBuf[BUFFER_SIZE];chanel_pipe::chanel_pipe(){}chanel_pipe::~chanel_pipe(){ CloseHandle(hNamedPipe);}void chanel_pipe::write_chanel(char string_ch[20]){ for(int i=0;i<20;i++)szBuf[i]=string_ch[i]; WriteFile(hNamedPipe, szBuf, BUFFER_SIZE, &cbWritten, NULL); }void chanel_pipe::run(){ hEndWrite=CreateEvent(NULL,TRUE,TRUE,NULL); OVL.Offset=0; OVL.OffsetHigh=0; OVL.hEvent=hEndWrite; bool PRezWait=WaitNamedPipe( L"\\\\.\\pipe\\$cvc$", NMPWAIT_WAIT_FOREVER ); // Создаем канал с процессом PIPES hNamedPipe = CreateFile( L"\\\\.\\pipe\\$cvc$", GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING,0, NULL); // Если возникла ошибка, выводим ее код и // завершаем работу приложения if(hNamedPipe == INVALID_HANDLE_VALUE) { fprintf(stdout,"CreateFile: Error %ld\n", GetLastError()); }}
channel *chan;chan= new channel();chan->start();// создаем канал и ждем клиентаif(chan->Data_pipe.left(6)=="reg2")// пришла команда по каналу запустить второго клиента и закрыть первого { chan->terminate(); chan->disconnect_pipe(); parametr="rm1 "; parametr+="0 "; parametr+=Zakaz+" "; parametr+=Form_IN2+" "; parametr+=Form_OUT2+" "; parametr+=IP_BOR; k=parametr.toWCharArray(Code_par); Code_par[k]='\0'; chan->start(); ShellExecute(Handle,L"open",L"reg2.exe",Code_par,NULL,SW_RESTORE); parametr="taskkill /F /IM "; parametr+=Tek_regim; ::WinExec(parametr.toAscii(), SW_HIDE); Tek_regim="reg2.exe";
//Сервер//.h#include <QtGui/QMainWindow>#include <windows.h>#include <stdio.h>#include <conio.h>#include <QTimer>#include <QString>#include <QThread>#include <QProcess>#include <QTextCodec>#define BUFFER_SIZE 512class channel: public QThread {Q_OBJECTpublic: channel(); ~channel(); OVERLAPPED StrOverlapp; OVERLAPPED StrOverlappW; QString Data_pipe; bool Flag_ext_proc; LPCTSTR PipeName; int N_pipe; void run(); void createChannel(); void analize_data(char buff[BUFFER_SIZE]); void disconnect_pipe(); };//.cpp#include "channel.h"QString str;// Флаг успешного создания каналаBOOL fConnected;// Идентификатор событияHANDLE hEvent;// Идентификатор канала PipeHANDLE hNamedPipe;// Имя создаваемого канала PipeLPCTSTR lpszPipeName =L"\\\\.\\pipe\\$cv_r$";// Буфер для передачи данных через каналchar szBuf[BUFFER_SIZE];// Количество байт данных, принятых через каналDWORD cbRead;// Количество байт данных, переданных через каналDWORD cbWritten;bool flag=0,flag_exit=0;bool flag_read=false;DWORD BytesTransferred;struct Pointer{ HWND CurrWnd[50]; HWND hwnd; int Lenght; QStringList ListItem; QString ProcName[50];};QTextCodec* code = QTextCodec::codecForName("CP1251");channel::channel(){ Data_pipe=""; Flag_ext_proc=0;}channel::~channel(){ DisconnectNamedPipe(hNamedPipe); CloseHandle(hNamedPipe);}void channel::createChannel(){ DWORD Ret; DWORD Pipe; // Создаем канал Pipe, имеющий имя lpszPipeName hNamedPipe = CreateNamedPipe( lpszPipeName, // имя канала. PIPE_ACCESS_DUPLEX, PIPE_TYPE_MESSAGE |PIPE_READMODE_MESSAGE |PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, // максимальное количество экземпляров канала. BUFFER_SIZE, // размер выходного буфера по умолчанию. BUFFER_SIZE, // рахмер входного буфера по умолчанию. INFINITE, // клиент ждет связь бесконечно долго. NULL // безопасность по умолчанию. ); // Если возникла ошибка, выводим ее код и завершаем // работу приложения if(hNamedPipe == INVALID_HANDLE_VALUE) { str+="CreateNamedPipe: Error %ld\n"+GetLastError(); fprintf(stdout,"CreateNamedPipe: Error %ld\n", GetLastError()); } if(!fConnected) // Ожидаем соединения со стороны клиента fConnected = ConnectNamedPipe(hNamedPipe, NULL); // При возникновении ошибки выводим ее код if(!fConnected) { if (GetLastError() != ERROR_IO_PENDING) { printf("ConnectNamedPipe for pipe %d failed with", " error %d\n", GetLastError()); CloseHandle(hNamedPipe); return; } } else { printf("Server is now running\n"); while(1) { bool rez=0; DWORD BRead; rez=ReadFile(hNamedPipe, szBuf,BUFFER_SIZE, &BRead,NULL); if ( rez ==false) { if (GetLastError() != ERROR_IO_PENDING) { printf("ReadFile failed with error %d\n", GetLastError()); } } if(strlen(szBuf)>0) { fprintf(stdout, szBuf); analize_data(szBuf); if(szBuf[0]=='r') break; } } DisconnectNamedPipe(hNamedPipe); CloseHandle(hNamedPipe); }}void channel::run(){ createChannel(); }void channel::analize_data(char buff[BUFFER_SIZE]){ QString str; HWND Id_prog=0; int numW; for(int i=0;i<BUFFER_SIZE; i++) str+=buff[i]; Data_pipe=str; }void channel::disconnect_pipe(){ DisconnectNamedPipe(hNamedPipe); Data_pipe="";}// использованиеchannel *chan;chan= new channel();if(chan->Data_pipe.left(4)=="reg2"){chan->terminate();parametr="rm2 ";parametr+="0 ";parametr+=Zakaz+" ";parametr+=Form_IN_2+" ";parametr+=Form_OUT_2+" ";parametr+=IP_BOR;k=parametr.toWCharArray(Code_par);Code_par[k]='\0';chan->start();ShellExecute(Handle,L"open",L"reg2.exe",Code_par,NULL,SW_RESTORE);parametr="taskkill /F /IM ";parametr+=Tek_regim;::WinExec(parametr.toAscii(), SW_HIDE);Tek_regim="reg2.exe"; }......delete chan;
