开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 远程控制编程 > 查看源码
RCAClient.cpp
资源名称：riptideAnyWhere.rar　[点击查看]
上传用户：hyz2004817
上传日期：2022-03-30
资源大小：226k
文件大小：19k
源码类别：

远程控制编程

开发平台：

Visual C++

RCAClient.cpp：源码内容
  1. // RCAClient.cpp : 定义控制台应用程序的入口点。
  2. //
  4. #include "stdafx.h"
  5. #include "resource.h"
  7. typedef enum _ThreadWorkState
  8. {
  9. UNINIT =0,
  10. WAIT_CONNECT,
  11. WAIT_REQUEST,
  12. CONNECTING,
  13. REQUESTING,
  15. } THREAD_WORK_STATE;
  17. typedef struct _ThreadCommun {
  19. HANDLE hExitEvent;
  20. HANDLE hBeginConnectEvent;
  21. HANDLE hBeginRequest;
  22. HWND hwnd;
  23. UINT msg;
  25. } THREAD_COMMUN, *PTHREAD_COMMUN;
  27. HWND g_hWnd;
  28. HINSTANCE g_hInstance;
  29. HIMAGELIST g_hImageList;
  31. SOCKET g_hSocket1 = NULL;
  32. SOCKET g_hSocket2 = NULL;
  33. sockaddr_in g_addr;
  34. sockaddr_in g_addr2;
  36. HANDLE g_hThread1 = NULL;
  37. HANDLE g_hThread2 = NULL;
  39. HANDLE g_hEvent1;
  40. HANDLE g_hEvent2;
  41. HBITMAP g_hRemoteBitmap = NULL;
  43. THREAD_COMMUN g_tc;
  44. THREAD_WORK_STATE g_ThreadState = UNINIT;
  45. RCAGETIMAGEDATA g_gm;
  46. BOOL g_bMustExit = FALSE;
  48. DWORD g_dwServerIP = 0;
  49. u_short g_usPort = 0;
  51. INT g_hWidth;
  52. INT g_hHeight;
  56. // 主窗口的子窗口标识符
  57. #define ID_TOOLBAR 1 // 工具栏窗口
  59. #define WM_THREADWORKSTATE (WM_USER+100)
  60. #define CANNOT_WAIT 0
  61. #define CANNOT_CREATESOCKET 1
  62. #define CANNOT_CONNECT 2
  63. #define CANNOT_REQUEST 3
  64. #define RESPONSE_ERROR 4
  65. #define WORK_SUCCEEDED 5
  66. #define CONNECTED 6
  68. INT WINAPI AddToolbarString( HWND tb, char * string )
  69. {
  70. char tmp[256];
  71. lstrcpy( tmp, string );
  72. tmp[ lstrlen(string) +1 ] = 0;
  73. return (INT)SendMessage( tb, TB_ADDSTRING, 0, (LPARAM)(LPSTR)tmp );
  74. }
  77. /////////////////////////////////////////////////////
  78. ///
  79. // 获取远程计算机图象函数, 由 创建的一个工作线程运行
  80. //
  82. DWORD WINAPI ThreadFunc1( PVOID p )
  83. {
  86. DWORD dwret;
  88. RCAREQUESTHEADER rreqh;
  89. RCAGETIMAGEDATA gm;
  90. RECT rect;
  91. PTHREAD_COMMUN ptc = (PTHREAD_COMMUN)p;
  93. HANDLE hEventArray[2] = { NULL, ptc->hExitEvent };
  94. HANDLE hWaitConnectArray[2] = { ptc->hBeginConnectEvent, ptc->hExitEvent };
  95. HANDLE  hWaitRequestArray[3] = { ptc->hBeginRequest, ptc->hExitEvent, ptc->hBeginConnectEvent };
  97. InitRCARequestHead( &rreqh, 1, 0, 0X20, sizeof(rreqh) + sizeof(gm) );
  98. rreqh.wMajorVersion = 1;
  99. rreqh.wMinorVersion = 0;
  100. gm.x = 0;
  101. gm.y = 0;
  102. gm.w = 0;
  103. gm.h = 0;
  104. gm.zh = 0;
  105. gm.zw = 0;
  106. gm.iBitCount = 8;
  107. gm.dwFlagEx1 = 50; // 图象质量
  108. gm.dwImageFormat = IMAGE_FORMAT_JPEG;
  110. g_gm.dwImageFormat = IMAGE_FORMAT_JPEG;
  111. g_gm.iBitCount = 8;
  112. g_gm.dwFlagEx1 = 50;
  115. while(1)
  116. {
  117. // 线程进入等待, 准备连接服务器
  118. g_ThreadState = WAIT_CONNECT;
  119. dwret = WaitForMultipleObjects( 2, hWaitConnectArray, FALSE, INFINITE );
  120. g_ThreadState = CONNECTING;
  122. if( dwret == (WAIT_OBJECT_0 +1))
  123. {
  124. return 0;
  125. }
  127. if( dwret == WAIT_FAILED)
  128. {
  129. PostMessage( ptc->hwnd, ptc->msg, CANNOT_WAIT, 0 );
  130. g_ThreadState = UNINIT;
  131. return 0;
  132. }
  135. ///////////////////////////////////////////////////////////
  137. if( !CreateEventSelectSocket( &g_hSocket1, &(hEventArray[0]), 
  138. FD_CONNECT | FD_WRITE | FD_READ | FD_CLOSE ) )
  139. {
  140. PostMessage( ptc->hwnd, ptc->msg, CANNOT_CREATESOCKET, 0 );
  141. continue;
  142. }
  144. g_addr.sin_addr.S_un.S_addr = g_dwServerIP;
  145. g_addr.sin_family = AF_INET;
  146. g_addr.sin_port = g_usPort;
  148. if( TRUE != RCAConnect_EventSelectIO( g_hSocket1, hEventArray, 
  149. (sockaddr*)&g_addr, sizeof(sockaddr) ) )
  150. {
  151. CloseHandle( g_hEvent1 );
  152. closesocket( g_hSocket1 );
  153. PostMessage( ptc->hwnd, ptc->msg, CANNOT_CONNECT, 0 );
  154. continue;
  155. }
  158. PostMessage( ptc->hwnd, ptc->msg, CONNECTED , 0 );
  159. ////////////////////////////
  160. // 请求开始
  161. while(1)
  162. {
  163. g_ThreadState = WAIT_REQUEST;
  164. dwret = WaitForMultipleObjects( 3,  hWaitRequestArray, FALSE, INFINITE );
  166. g_ThreadState = REQUESTING;
  167. if( dwret != (WAIT_OBJECT_0 ) )
  168. {
  169. if( dwret == (WAIT_OBJECT_0 +1) )
  170. {
  171. break;
  173. } else if( dwret == (WAIT_OBJECT_0 +2 ))
  174. { 
  175. break; 
  177. } else if( dwret == WAIT_FAILED )
  178. {
  179. PostMessage(ptc->hwnd, ptc->msg, CANNOT_WAIT, 0 );
  180. break;
  181. }
  183. // never run to here
  184. }
  185. GetClientRect( ptc->hwnd, &rect );
  186. gm.zw = rect.right;
  187. gm.zh = rect.bottom;
  189. gm.dwFlagEx1 = g_gm.dwFlagEx1;
  190. gm.dwImageFormat = g_gm.dwImageFormat;
  191. gm.iBitCount = g_gm.iBitCount;
  192. // now dwret==WAIT_OBJECT, start request server
  193. if( TRUE != RCASendRequest_0X20_EventSelectIO( g_hSocket1, hEventArray, 
  194. &gm ) )
  195. {
  196. PostMessage(ptc->hwnd, ptc->msg, CANNOT_REQUEST, 0 );
  197. break;
  198. }
  200.  
  202. HBITMAP bm = RCARecvImageData( g_hSocket1, hEventArray, gm.dwImageFormat );
  203. if( bm == NULL )
  204. {
  205. PostMessage( ptc->hwnd, ptc->msg, CANNOT_REQUEST, 0 );
  206. break;
  207. }
  210. PostMessage( ptc->hwnd, ptc->msg, WORK_SUCCEEDED, (LPARAM)bm );
  211. }
  213. if( g_bMustExit )
  214. break;
  215. else
  216. {
  217. closesocket( g_hSocket1 );
  218. CloseHandle( hEventArray[0] );
  219. }
  220. }
  222. closesocket( g_hSocket1 );
  223. CloseHandle( hEventArray[0] );
  224. return 0;
  225. }
  227. DWORD WINAPI ThreadFunc2( PVOID p )
  228. {
  229. while(1)
  230. {
  231. SuspendThread( GetCurrentThread());
  233. }
  234. return 0;
  235. }
  238. VOID WINAPI  OnPaint( HWND hwnd, HDC hdc )
  239. {
  241. if( g_hRemoteBitmap )
  242. {
  244. DIBSECTION  ds;
  245. RECT rect;
  246. GetClientRect( hwnd, &rect );
  248. GetObject( g_hRemoteBitmap, sizeof(ds), (LPVOID)&ds );
  250. HDC hdcmem = CreateCompatibleDC(hdc);
  251. SelectObject( hdcmem, g_hRemoteBitmap );
  253. StretchBlt( hdc, 0, 0, rect.right, rect.bottom, 
  254. hdcmem, 0, 0, ds.dsBm.bmWidth, ds.dsBm.bmHeight, SRCCOPY );
  256. SelectObject( hdcmem, (HBITMAP)NULL );
  257. DeleteDC( hdcmem );
  258. }
  259. }
  261. VOID WINAPI OnThreadWorkState( HWND hwnd, WPARAM w, LPARAM l )
  262. {
  263. switch( w )
  264. {
  265. case WORK_SUCCEEDED:
  267. if(g_hRemoteBitmap != NULL )
  268. DeleteObject( g_hRemoteBitmap );
  269. g_hRemoteBitmap = (HBITMAP)l;
  271. InvalidateRect( hwnd, NULL, FALSE );
  272. break;
  273. }
  274. return;
  275. }
  277. BOOL WINAPI InitWorkThread( HWND hwnd )
  278. {
  279. // 确保 WIN98 的支持
  280. DWORD tmp;
  282. g_tc.hBeginConnectEvent = CreateEvent( NULL, FALSE, FALSE, NULL );
  283. g_tc.hBeginRequest = CreateEvent( NULL, FALSE, FALSE, NULL );
  284. g_tc.hExitEvent = CreateEvent( NULL, FALSE, FALSE, NULL );
  285. g_tc.hwnd = hwnd;
  286. g_tc.msg = WM_THREADWORKSTATE;
  287. g_hRemoteBitmap = NULL;
  289. g_hThread1 = CreateThread( NULL, 0, ThreadFunc1, (LPVOID)&g_tc, 0, &tmp );
  292. if( g_hThread1 != NULL )
  293. return TRUE;
  295. return TRUE;
  296. }
  298. VOID WINAPI DestroyWorkThreadResource()
  299. {
  301. if( g_ThreadState == UNINIT )
  302. return;
  304. // 通知线程退出;
  305. SetEvent( g_tc.hExitEvent );
  307. if( g_hSocket2 != NULL )
  308. closesocket( g_hSocket2 );
  310. if( g_hThread1 )
  311. {
  313. if ( WAIT_TIMEOUT == WaitForSingleObject( g_hThread1, 3000 ) )
  314. TerminateThread( g_hThread1, 0);
  316. CloseHandle( g_hThread1 );
  317. g_hThread1 = NULL;
  318. }
  320. // 关闭用于通信的所有事件句柄
  321. CloseHandle( g_tc.hBeginConnectEvent );
  322. CloseHandle( g_tc.hBeginRequest );
  323. CloseHandle( g_tc.hExitEvent );
  325. if( g_hRemoteBitmap  )
  326. {
  327. DeleteObject( g_hRemoteBitmap );
  328. g_hRemoteBitmap = NULL;
  329. }
  331. }
  333. BOOL WINAPI OnCreate( HWND hwnd, PAINTSTRUCT * pps )
  334. {
  335. WSADATA data;
  336. if( SOCKET_ERROR == WSAStartup( MAKEWORD(2,2), &data ) )
  337. return FALSE;
  339. INITCOMMONCONTROLSEX icex;
  340. icex.dwSize = sizeof(icex);
  341. icex.dwICC = ICC_WIN95_CLASSES;
  343. if( !InitWorkThread( hwnd) )
  344. return FALSE;
  346. return TRUE;
  347. }
  350. VOID WINAPI OnDestroy()
  351. {
  352. WSACleanup();
  353. DestroyWorkThreadResource();
  354. }
  357. BOOL CALLBACK ConnectDialogProc( HWND dlg, UINT msg, WPARAM w, LPARAM l )
  358. {
  359. char str[256];
  360. int ret;
  361. switch( msg )
  362. {
  363. case WM_INITDIALOG:
  364. SetFocus( GetDlgItem( dlg, IDC_SERVERNAME ) );
  365. return TRUE;
  367. case WM_COMMAND:
  368. switch( w )
  369. {
  370. case IDOK:
  371. GetWindowText( GetDlgItem(dlg, IDC_SERVERNAME), str, 255 );
  372. g_dwServerIP = inet_addr( str );
  374. GetWindowText( GetDlgItem( dlg, IDC_PORT), str, 255 );
  375. g_usPort  = htons( atoi(str));
  377. if( g_ThreadState == WAIT_CONNECT )
  378. {
  379. g_addr2.sin_addr.S_un.S_addr = g_dwServerIP;
  380. g_addr2.sin_family = AF_INET;
  381. g_addr2.sin_port = g_usPort;
  382. g_hSocket2 = socket( AF_INET, SOCK_STREAM, 0 );
  383. if( g_hSocket2 == INVALID_SOCKET )
  384. {
  385. MessageBox( dlg, "资源不足, 无法创建套接字", "RCA Client Error" , MB_ICONERROR );
  386. g_hSocket2 = NULL;
  387. return TRUE;
  388. }
  390. if( g_ThreadState == WAIT_CONNECT )
  391. SetEvent( g_tc.hBeginConnectEvent );
  393. ret = connect( g_hSocket2, (sockaddr*)&g_addr2, sizeof(sockaddr) );
  394. if( ret == SOCKET_ERROR )
  395. {
  396. MessageBox( dlg, WSAERRORSTRING, "RCA Client Error", MB_ICONERROR );
  397. closesocket( g_hSocket2 );
  398. g_hSocket2 = NULL;
  399. return TRUE;
  400. }
  402. MSG msg;
  403. while(1)
  404. {
  405. GetMessage( &msg, NULL, NULL, NULL );
  406. if( (msg.hwnd == g_hWnd) && (msg.message==WM_THREADWORKSTATE))
  407. {
  408. if( msg.wParam != CONNECTED )
  409. {
  410. MessageBox( dlg, WSAERRORSTRING, "RCA Client Error", MB_ICONERROR );
  411. return FALSE;
  412. }
  413. {
  414. EndDialog( dlg, TRUE );
  415. return TRUE;
  416. }
  417. }
  418. else
  419. {
  420. TranslateMessage( &msg );
  421. DispatchMessage( &msg );
  422. }
  423. }
  425. if( g_ThreadState == WAIT_REQUEST )
  426. {
  427. EndDialog( dlg, TRUE );
  428. }
  429. } 
  430. return TRUE;
  431. break;
  433. case IDCANCEL:
  434. EndDialog( dlg, FALSE );
  435. return TRUE;
  437. default:
  438. break;
  439. }
  440. default:
  441. return FALSE;
  442. }
  443. return FALSE;
  444. }
  447. VOID WINAPI OnCommand( HWND hwnd, WPARAM w, LPARAM l )
  448. {
  450. // 筛选命令 ID
  451. switch( w )
  452. {
  453. case ID_EXIT:
  454. if ( g_ThreadState == CONNECTING)
  455. {
  456. if( IDOK == MessageBox( hwnd, "正在获取远程计算机屏幕信息, 是否要中断连接 ?"
  457. , "RCA Client", MB_ICONQUESTION | MB_OKCANCEL ) )
  458. DestroyWindow( hwnd );
  459. }
  460. else
  461. {
  462. g_bMustExit = TRUE;
  463. DestroyWindow( hwnd );
  464. }
  466. break;
  468. case ID_CONNECT:
  469. //if( false )
  470. if( FALSE == DialogBox( g_hInstance, MAKEINTRESOURCE(IDD_CONNECTDIALOG), 
  471. g_hWnd, ConnectDialogProc ) )
  472. {
  473. return;
  474. } else {
  476. // 设置 UI
  478. EnableMenuItem( GetMenu(hwnd), ID_DISCONNECT, MF_ENABLED);
  479. EnableMenuItem( GetMenu(hwnd), ID_CONNECT, MF_GRAYED | MF_DISABLED);
  480. EnableMenuItem( GetMenu(hwnd), ID_REFRUSH, MF_ENABLED );
  482. }
  484. break;
  486. case ID_IMAGE_FORMAT_BMP:
  487. CheckMenuItem( GetMenu(hwnd), ID_IMAGE_FORMAT_BMP , MF_CHECKED );
  488. CheckMenuItem( GetMenu(hwnd), ID_IMAGE_FORMAT_JPEG, MF_UNCHECKED );
  489. g_gm.dwImageFormat = IMAGE_FORMAT_BMP;
  490. return;
  491. case ID_IMAGE_FORMAT_JPEG:
  492. CheckMenuItem( GetMenu(hwnd), ID_IMAGE_FORMAT_JPEG , MF_CHECKED );
  493. CheckMenuItem( GetMenu(hwnd), ID_IMAGE_FORMAT_BMP, MF_UNCHECKED );
  494. g_gm.dwImageFormat = IMAGE_FORMAT_JPEG;
  495. return;
  497. case ID_BIT_8:
  498. CheckMenuItem( GetMenu(hwnd), ID_BIT_8, MF_CHECKED );
  499. CheckMenuItem( GetMenu(hwnd), ID_BIT_16, MF_UNCHECKED );
  500. CheckMenuItem( GetMenu(hwnd), ID_BIT_24, MF_UNCHECKED );
  501. g_gm.iBitCount = 8;
  502. return;
  504. case ID_BIT_16:
  505. CheckMenuItem( GetMenu(hwnd), ID_BIT_8, MF_UNCHECKED );
  506. CheckMenuItem( GetMenu(hwnd), ID_BIT_16, MF_CHECKED );
  507. CheckMenuItem( GetMenu(hwnd), ID_BIT_24, MF_UNCHECKED );
  508. g_gm.iBitCount = 16;
  509. return;
  511. case ID_BIT_24:
  512. CheckMenuItem( GetMenu(hwnd), ID_BIT_8, MF_UNCHECKED );
  513. CheckMenuItem( GetMenu(hwnd), ID_BIT_16, MF_UNCHECKED );
  514. CheckMenuItem( GetMenu(hwnd), ID_BIT_24, MF_CHECKED );
  515. g_gm.iBitCount = 24;
  516. return;
  518. case ID_JPEG_QUALITY_10:
  519. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_10, MF_CHECKED );
  520. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_30, MF_UNCHECKED );
  521. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_50, MF_UNCHECKED );
  522. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_70, MF_UNCHECKED );
  523. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_90, MF_UNCHECKED );
  524. g_gm.dwFlagEx1 = 10;
  525. return;
  527. case ID_JPEG_QUALITY_30:
  528. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_10, MF_UNCHECKED );
  529. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_30, MF_CHECKED );
  530. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_50, MF_UNCHECKED );
  531. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_70, MF_UNCHECKED );
  532. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_90, MF_UNCHECKED );
  533. g_gm.dwFlagEx1 = 30;
  534. return;
  536. case ID_JPEG_QUALITY_50:
  537. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_10, MF_UNCHECKED );
  538. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_30, MF_UNCHECKED );
  539. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_50, MF_CHECKED );
  540. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_70, MF_UNCHECKED );
  541. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_90, MF_UNCHECKED );
  542. g_gm.dwFlagEx1 = 50;
  543. return;
  545. case ID_JPEG_QUALITY_70:
  546. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_10, MF_UNCHECKED );
  547. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_30, MF_UNCHECKED );
  548. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_50, MF_UNCHECKED );
  549. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_70, MF_CHECKED );
  550. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_90, MF_UNCHECKED );
  551. g_gm.dwFlagEx1 = 70;
  552. return;
  554. case ID_JPEG_QUALITY_90:
  555. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_10, MF_UNCHECKED );
  556. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_30, MF_UNCHECKED );
  557. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_50, MF_UNCHECKED );
  558. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_70, MF_UNCHECKED );
  559. CheckMenuItem( GetMenu(hwnd), ID_JPEG_QUALITY_90, MF_CHECKED );
  560. g_gm.dwFlagEx1 = 90;
  561. return;
  564. case ID_REFRUSH:
  565. if( g_ThreadState == WAIT_REQUEST )
  566. SetEvent( g_tc.hBeginRequest );
  567. break;
  569. case ID_DISCONNECT:
  570. EnableMenuItem( GetMenu(hwnd), ID_CONNECT, MF_ENABLED );
  571. EnableMenuItem( GetMenu(hwnd), ID_DISCONNECT, MF_DISABLED | MF_GRAYED );
  572. EnableMenuItem( GetMenu(hwnd), ID_REFRUSH, MF_DISABLED | MF_GRAYED );
  574. if( g_ThreadState == WAIT_REQUEST )
  575. {
  576. SetEvent( g_tc.hBeginConnectEvent );
  577. }
  579. if( g_ThreadState == REQUESTING )
  580. {
  581. SetEvent( g_tc.hExitEvent );
  582. }
  584. closesocket( g_hSocket2 );
  585. g_hSocket2 = NULL;
  587. break;
  589. default:
  590. break;
  591. }
  593. return;
  594. }
  595. RCAMOUSEINPUT mi;
  596. RCAKEYBDINPUT ki;
  598. RCAREQUESTHEADER rreqh;
  600. LRESULT CALLBACK MainWindowProc( HWND hwnd, UINT msg, WPARAM w, LPARAM l )
  601. {
  603. PAINTSTRUCT ps;
  604. HDC hdc;
  605. RECT rect;
  606. INT ret;
  607. GetClientRect( hwnd, &rect );
  609. static UINT_PTR timer;
  611. switch( msg )
  612. {
  613. case WM_RBUTTONDOWN:
  614. if( g_hSocket2 )
  615. {
  616. mi.dwExtraInfo =0;
  617. mi.dwFlags = MOUSEEVENTF_RIGHTDOWN;
  618. //mi.dx = (lParam&0x0000ffff) * (65535 / 1024);
  619. //mi.dy = (lParam>>16) * (65535 / 768);
  620. mi.mouseData = 0;
  621. mi.time = 0;
  622. rreqh.dwRequestID = 0x40;
  623. rreqh.requestBytes = sizeof(RCAREQUESTHEADER) + sizeof(RCAMOUSEINPUT);
  624. ret = send(g_hSocket2, (char*)&rreqh, sizeof(rreqh), 0 );
  625. if( ret == SOCKET_ERROR )
  626. return FALSE;
  627. ret = send(g_hSocket2, (char*)&mi, sizeof(mi), 0 );
  628. if( ret == SOCKET_ERROR )
  629. return FALSE;
  630. }
  631. return TRUE;
  633. case WM_RBUTTONUP:
  634. if( g_hSocket2 )
  635. {
  636. mi.dwExtraInfo =0;
  637. mi.dwFlags = MOUSEEVENTF_RIGHTUP;
  638. //mi.dx = (lParam&0x0000ffff) * (65535 / 1024);
  639. //mi.dy = (lParam>>16) * (65535 / 768);
  640. mi.mouseData = 0;
  641. mi.time = 0;
  642. rreqh.dwRequestID = 0x40;
  643. rreqh.requestBytes = sizeof(RCAREQUESTHEADER) + sizeof(RCAMOUSEINPUT);
  644. ret = send(g_hSocket2, (char*)&rreqh, sizeof(rreqh), 0 );
  645. if( ret == SOCKET_ERROR )
  646. return FALSE;
  647. ret = send(g_hSocket2, (char*)&mi, sizeof(mi), 0 );
  648. if( ret == SOCKET_ERROR )
  649. return FALSE;
  650. }
  651. return TRUE;
  653. case WM_LBUTTONUP:
  654. if( g_hSocket2 )
  655. {
  656. mi.dwExtraInfo =0;
  657. mi.dwFlags = MOUSEEVENTF_LEFTUP;
  658. // mi.dx = (lParam&0x0000ffff) * (65535 / 1024);
  659. // mi.dy = (lParam>>16) * (65535 / 768);
  660. mi.mouseData = 0;
  661. mi.time = 0;
  662. rreqh.dwRequestID = 0x40;
  663. rreqh.requestBytes = sizeof(RCAREQUESTHEADER) + sizeof(RCAMOUSEINPUT);
  664. ret = send(g_hSocket2, (char*)&rreqh, sizeof(rreqh), 0 );
  665. if( ret == SOCKET_ERROR )
  666. return FALSE;
  667. ret = send(g_hSocket2, (char*)&mi, sizeof(mi), 0 );
  668. if( ret == SOCKET_ERROR )
  669. return FALSE;
  670. }
  671. return TRUE;
  672. case WM_LBUTTONDOWN:
  673. if( g_hSocket2 )
  674. {
  675. mi.dwExtraInfo =0;
  676. mi.dwFlags = MOUSEEVENTF_LEFTDOWN;
  677. // mi.dx = (lParam&0x0000ffff) * (65535 / 1024);
  678. // mi.dy = (lParam>>16) * (65535 / 768);
  679. mi.mouseData = 0;
  680. mi.time = 0;
  681. rreqh.dwRequestID = 0x40;
  682. rreqh.requestBytes = sizeof(RCAREQUESTHEADER) + sizeof(RCAMOUSEINPUT);
  683. ret = send(g_hSocket2, (char*)&rreqh, sizeof(rreqh), 0 );
  684. if( ret == SOCKET_ERROR )
  685. return FALSE;
  686. ret = send(g_hSocket2, (char*)&mi, sizeof(mi), 0 );
  687. if( ret == SOCKET_ERROR )
  688. return FALSE;
  690. }
  691. return TRUE;
  693. case WM_MOUSEMOVE:
  694. if( g_hSocket2 )
  695. {
  696. mi.dwFlags = MOUSEEVENTF_ABSOLUTE | MOUSEEVENTF_MOVE;
  697. mi.dx = (LONG)(l & 0x0000ffff) * 65535 / rect.right;
  698. mi.dy = (LONG)(l >> 16) * 65535 / rect.bottom;
  699. rreqh.dwRequestID = 0x40;
  700. rreqh.requestBytes = 64;
  701. ret = send(g_hSocket2, (char*)&rreqh, sizeof(rreqh), 0 );
  702. if( ret == SOCKET_ERROR )
  703. {
  704. MessageBox( hwnd, "网络连接出现问题或 RCA 服务器已经被关闭", "RCA Client Information", MB_ICONINFORMATION );
  705. PostMessage( hwnd, WM_COMMAND, ID_DISCONNECT, 0 );
  706. return FALSE;
  707. }
  708. ret = send(g_hSocket2, (char*)&mi, sizeof(mi), 0 );
  709. if( ret == SOCKET_ERROR )
  710. return FALSE;
  711. }
  712. break;
  714. case WM_KEYDOWN:
  715. if( (w==VK_F5) && (g_ThreadState==WAIT_REQUEST) )
  716. SetEvent( g_tc.hBeginRequest );
  718. if( (w==VK_RWIN) || (w==VK_LWIN) )
  719. break;
  721. break;
  723. case WM_THREADWORKSTATE:
  724. OnThreadWorkState( hwnd, w, l );
  725. return 0;
  727. case WM_COMMAND:
  728. OnCommand( hwnd, w, l );
  729. return 0;
  731. case WM_TIMER:
  732. if( g_ThreadState != WAIT_CONNECT )
  733. PostMessage(hwnd, WM_COMMAND, ID_DISCONNECT , NULL );
  734. DestroyWindow( hwnd );
  735. KillTimer( hwnd, timer );
  737. return TRUE;
  739. case WM_CREATE:
  740. mi.dwExtraInfo =0;
  741. mi.mouseData = 0;
  742. mi.time = 0;
  743. lstrcpy(rreqh.rcaID, "RCA" );
  744. rreqh.wMajorVersion =1;
  745. rreqh.wMinorVersion =0;
  746. timer = SetTimer(hwnd, 1, 10 * 60 * 1000, NULL );
  748. return OnCreate( hwnd, (PAINTSTRUCT*)l );
  751. g_gm.dwImageFormat = IMAGE_FORMAT_JPEG;
  752. g_gm.iBitCount = 8;
  753. g_gm.dwFlagEx1 = 50;
  755. break;
  757. case WM_SIZE:
  758. SendMessage( GetDlgItem( hwnd, ID_TOOLBAR ), TB_AUTOSIZE, 0, 0 );
  759. break;
  761. case WM_PAINT:
  762. hdc = BeginPaint( hwnd, &ps );
  763. OnPaint( hwnd, hdc );
  764. EndPaint( hwnd, &ps );
  765. break;
  767. case WM_DESTROY:
  768. g_bMustExit = TRUE;
  769. OnDestroy();
  771. PostQuitMessage(0);
  772. break;
  774. default:
  775. break;
  776. }
  778. return DefWindowProc( hwnd, msg, w, l );
  779. }
  781. INT WINAPI WinMain( HINSTANCE, HINSTANCE, PSTR, INT )
  782. //int main(int argc, char* argv[])
  783. {
  784. g_hInstance = GetModuleHandle( NULL );
  787. WNDCLASSEX wcex;
  788. wcex.cbClsExtra = 0;
  789. wcex.cbSize = sizeof(wcex);
  790. wcex.cbWndExtra = 0;
  791. wcex.hbrBackground = (HBRUSH)(COLOR_WINDOW +1);
  792. wcex.hCursor = LoadCursor( NULL, IDC_ARROW );
  793. wcex.hIcon = LoadIcon( g_hInstance, MAKEINTRESOURCE(IDI_CLIENTICON) );
  794. wcex.hIconSm = LoadIcon( g_hInstance, MAKEINTRESOURCE(IDI_CLIENTICON) );
  795. wcex.hInstance = g_hInstance;
  796. wcex.lpfnWndProc = MainWindowProc;
  797. wcex.lpszMenuName = NULL;
  798. wcex.lpszClassName = "RCAClient_Window";
  799. wcex.style = CS_VREDRAW | CS_HREDRAW;
  801. if( !RegisterClassEx( &wcex ) )
  802. return FALSE;
  804. g_hWnd = CreateWindowEx( 0, "RCAClient_Window", "RCA Client", WS_OVERLAPPEDWINDOW,
  805. CW_USEDEFAULT, CW_USEDEFAULT, CW_USEDEFAULT, CW_USEDEFAULT, 
  806. NULL, LoadMenu( g_hInstance, MAKEINTRESOURCE(IDR_MENU1) ), 
  807. g_hInstance, NULL );
  809. if( !g_hWnd )
  810. return 0;
  812. ShowWindow( g_hWnd, SW_SHOWNORMAL );
  813. UpdateWindow( g_hWnd );
  815. MSG  msg;
  816. while( GetMessage( &msg, NULL, 0, 0 ) )
  817. {
  818. TranslateMessage( &msg );
  819. DispatchMessage( &msg );
  820. }
  823. return 0;
  824. }