可不可不要这么样徘徊在目光内 / 你会察觉到我根本寂寞难耐 / 即使千多百个深夜曾在梦境内 / 我有吻过你这毕竟并没存在 / 人声车声开始消和逝 / 无声挣扎有个情感奴隶 / 是我多么的想她 / 但我偏偏只得无尽叹谓 / 其实每次见你我也着迷 / 无奈你我各有角色范围 / 就算在寂寞梦内超出好友关系 / 唯在暗里爱你暗里着迷 / 无谓要你惹上各种问题 / 共我道别吧别让空虚使我越轨 /

发布新日志

  • 用VC++和Winsock实现与HTTP服务器通话

    2007-08-25 01:19:39

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 9次

    作者:Ji Hong  
      
    一、引 言  
    ---- Windows Socket API是一套开放的、支持多种协议的Windows下的网络编程接口,它包 括一个标准的 Berkeley  
    Socket功能调用的集合,以及为Windows所作的重要扩充。 Windows Socket经过不断完善并在众  
    多公司的全力支持下,已成为Windows网络编程 的事实上的标准。  
      
    ---- 本 文 将 在VC++ 5.0 环 境 下 介 绍 一个基于 Winsock 的 HTTP 客户应用程序。 读者可以基于本例  
    同样的原理实现其他Internet常用协议(time, SMTP, POP3, Telnet, FTP 等)的客户应用程序。  
      
    二、一个简单的浏览器  
    ---- 我将创建一个简单的浏览器,以说明如何通过Winsock基于HTTP协议实现HTTP 客户应 用程序。  
      
    ---- 首先我将创建一个帮助函数 LogFile(),该函数把传递给它的字符串写到磁盘文件 中。然后再创建 本示例的核心函数 --  
    HttpClient() 。在这个核心函数中,我将通 过 Winsock 连接到 HTTP 服务器上 (本例中我将使用计算机世界日报  
    168.160.224.185)。当连接成功后,发送 Get 命令到 HTTP 服务器 去下载指定路径  
    上(/99/tips/)的文件。通过帮助函数 LogFile() 把下载的数据记录到本地磁盘文 件中。  
      
    char fname[MAXPATH];  
    void LogFile(char *p)  
    {  
    FILE *fp=fopen(fname,"a+");  
    fprintf(fp,"%s\n",p);  
    fclose(fp);  
    }  
      
    BOOL HttpClient(void)  
    {  
    WSADATA ws;  
    SOCKET s;  
    struct sockaddr_in addr;  
      
    int iResult;  
    long lResult;  
    char strSubAddr[100], strBuffer[100];  
      
    lResult = WSAStartup(0x0101,&ws);  
    s = socket(AF_INET,SOCK_STREAM,0);  
      
    addr.sin_family = AF_INET;  
    addr.sin_port = htons(80);  
    addr.sin_addr.s_addr = inet_addr  
    ("168.160.224.185"); // 计算机世界日报  
    iResult=connect(s,(struct sockaddr *)  
    &addr, sizeof(addr));  
    if(SOCKET_ERROR == iResult)  
    {  
    // 连接失败  
    WSACleanup();  
    return FALSE;  
    }  
    else {  
    // 连接成功  
    strcpy(strSubAddr, "GET /99/tips/ \r\n");  
    strcpy(fname, "index.htm");  
    iResult = send(s, strSubAddr,strlen(strSubAddr),0);  
      
    // 下载文件  
    do {  
    strset(strBuffer,' ');  
    iResult = recv(s,strBuffer,sizeof(strBuffer),0);  
    LogFile(strBuffer);  
    } while( iResult !=0 );  
    }  
      
    WSACleanup();  
    return TRUE;  
    }  
      
    三、测试  
    ---- 打开Visual C++ 5.0, 用MFC创建基于对话框的工程Test, 并在对话框上放 置"Test" 按 钮,  
    然后添加测试代码。  
      
    Void CTestDlg::OnTest()  
    {  
    HttpClient();  
    }  
      
    ---- 编译并运行该测试程序,在测试对话框中,单击 "Test" 按钮,  
      
    ---- "http://www.computerworld.com.cn/99/tips/"的index.htm文件将被下载到本地。  
      
    四. 结 论  
    ---- 这应该就是Netscape Navigator,Internet Explorer以及其他浏览器实现Internet访  
    问的基本代码了. 在这些浏览器中,其他百分之九十以上的代码主要用于HTML显示等 本地处理上。  
      
    ---- 读者如果有兴趣,基于这些代码,再加入一些解释HTML命令的代码,就可以正确显示 所下载的HTML文件,  
    那也就是说将拥有自己版本的一个百分之百的浏览器了。何不一试 ?

  • 用VC++5.0实现多线程的调度和处理

    2007-08-25 01:16:43

    用VC++5.0实现多线程的调度和处理

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 3次

    ---- Windows95 和WindowsNT 操作系统支持多任务调度和处理,基于该功能所提供的多任务空间,程序员可以完全控制应用程序中每一个片段的运行,从而编写高效率的应用程序。
    ---- 所谓多任务通常包括这样两大类:多进程和多线程。进程是指在系统中正在运行的一个应用程序;线程是系统分配处理器时间资源的基本单元,或者说进程之内独立执行的一个单元。对于操作系统而言,其调度单元是线程。一个进程至少包括一个线程,通常将该线程称为主线程。一个进程从主线程的执行开始进而创建一个或多个附加线程,就是所谓基于多线程的多任务。

    ---- 开发多线程应用程序可以利用32 位Windows 环境提供的Win32 API 接口函数,也可以利用VC++ 中提供的MFC 类库进行开发。多线程编程在这两种方式下原理是一样的,用户可以根据需要选择相应的工具。本文重点讲述用VC++5.0 提供的MFC 类库实现多线程调度与处理的方法以及由线程多任务所引发的同步多任务特征,最后详细解释一个实现多线程的例程。

    二基于MFC 的多线程编程
    ---- 1 MFC 对多线程的支持
    ---- MFC 类库提供了多线程编程支持,对于用户编程实现来说更加方便。非常重要的一点就是,在多窗口线程情况下,MFC 直接提供了用户接口线程的设计。

    ---- MFC 区分两种类型的线程:辅助线程(Worker Thread)和用户界面线程(UserInterface Thread)。辅助线程没有消息机制,通常用来执行后台计算和维护任务。MFC 为用户界面线程提供消息机制,用来处理用户的输入,响应用户产生的事件和消息。但对于Win32 的API 来说,这两种线程并没有区别,它只需要线程的启动地址以便启动线程执行任务。用户界面线程的一个典型应用就是类CWinApp,大家对类CwinApp 都比较熟悉,它是CWinThread 类的派生类,应用程序的主线程是由它提供,并由它负责处理用户产生的事件和消息。类CwinThread 是用户接口线程的基本类。CWinThread 的对象用以维护特定线程的局部数据。因为处理线程局部数据依赖于类CWinThread,所以所有使用MFC 的线程都必须由MFC 来创建。例如,由run-time 函数_beginthreadex 创建的线程就不能使用任何MFC API。

    ---- 2 辅助线程和用户界面线程的创建和终止

    ---- 要创建一个线程,需要调用函数AfxBeginThread。该函数通过参数重载具有两种版本,分别对应辅助线程和用户界面线程。无论是辅助线程还是用户界面线程,都需要指定额外的参数以修改优先级,堆栈大小,创建标志和安全特性等。函数AfxBeginThread 返回指向CWinThread 类对象的指针。

    ---- 创建助手线程相对简单。只需要两步:实现控制函数和启动线程。它并不必须从CWinThread 派生一个类。简要说明如下:

    ---- 1. 实现控制函数。控制函数定义该线程。当进入该函数,线程启动;退出时,线程终止。该控制函数声明如下:

    UINT MyControllingFunction( LPVOID pParam );
    ---- 该参数是一个单精度32 位值。该参数接收的值将在线程对象创建时传递给构造函数。控制函数将用某种方式解释该值。可以是数量值,或是指向包括多个参数的结构的指针,甚至可以被忽略。如果该参数是指结构,则不仅可以将数据从调用函数传给线程,也可以从线程回传给调用函数。如果使用这样的结构回传数据,当结果准备好的时候,线程要通知调用函数。当函数结束时,应返回一个UINT 类型的值值,指明结束的原因。通常,返回0 表明成功,其它值分别代表不同的错误。
    ---- 2. 启动线程。由函数AfxBeginThread 创建并初始化一个CWinThread 类的对象,启动并返回该线程的地址。则线程进入运行状态。

    ---- 3. 举例说明。下面用简单的代码说明怎样定义一个控制函数以及如何在程序的其它部分使用。

    UINT MyThreadProc( LPVOID pParam )
    {
    CMyObject* pObject = (CMyObject*)pParam;
    if (pObject == NULL ||
    !pObject- >IsKindOf(RUNTIME_CLASS(CMyObject)))
    return -1; //非法参数
    ……//具体实现内容
    return 0; //线程成功结束
    }

    //在程序中调用线程的函数
    ……
    pNewObject = new CMyObject;
    AfxBeginThread(MyThreadProc, pNewObject);
    ……
    创建用户界面线程有两种方法。
    ---- 第一种方法,首先从CWinTread 类派生一个类(注意必须要用宏DECLARE_DYNCREATE 和IMPLEMENT_DYNCREATE 对该类进行声明和实现);然后调用函数AfxBeginThread 创建CWinThread 派生类的对象进行初始化启动线程运行。除了调用函数AfxBeginThread 之外, 也可以采用第二种方法,即先通过构造函数创建类CWinThread 的一个对象,然后由程序员调用函数::CreateThread 来启动线程。通常类CWinThread 的对象在该线程的生存期结束时将自动终止,如果程序员希望自己来控制,则需要将m_bAutoDelete 设为FALSE。这样在线程终止之后类CWinThread 对象仍然存在,只是在这种情况下需要手动删除CWinThread 对象。
    ---- 通常线程函数结束之后,线程将自行终止。类CwinThread 将为我们完成结束线程的工作。如果在线程的执行过程中程序员希望强行终止线程的话,则需要在线程内部调用AfxEndThread(nExitCode)。其参数为线程结束码。这样将终止线程的运行,并释放线程所占用的资源。如果从另一个线程来终止该线程,则必须在两个线程之间设置通信方法。如果从线程外部来终止线程的话,还可以使用Win32 函数(CWinThread 类不提供该成员函数):BOOL TerminateThread(HANDLE hThread,DWORD dwExitcode)。但在实际程序设计中对该函数的使用一定要谨慎,因为一旦该命令发出,将立即终止该线程,并不释放线程所占用的资源,这样可能会引起系统不稳定。

    ---- 如果所终止的线程是进程内的最后一个线程,则在该线程终止之后进程也相应终止。

    ---- 3 进程和线程的优先级问题

    ---- 在Windows95 和WindowsNT 操作系统当中,任务是有优先级的,共有32 级,从0 到31,系统按照不同的优先级调度线程的运行。

    ---- 1) 0-15 级是普通优先级,线程的优先级可以动态变化。高优先级线程优先运行,只有高优先级线程不运行时,才调度低优先级线程运行。优先级相同的线程按照时间片轮流运行。2) 16-30 级是实时优先级,实时优先级与普通优先级的最大区别在于相同优先级进程的运行不按照时间片轮转,而是先运行的线程就先控制CPU,如果它不主动放弃控制,同级或低优先级的线程就无法运行。

    ---- 一个线程的优先级首先属于一个类,然后是其在该类中的相对位置。线程优先级的计算可以如下式表示:

    ---- 线程优先级= 进程类基本优先级+ 线程相对优先级

    ---- 进程类的基本优先级:

    IDLE_PROCESS_CLASS
    NORMAL_PROCESS_CLASS
    HIGH_PROCESS_CLASS
    REAL_TIME_PROCESS_CLASS
    线程的相对优先级:
    THREAD_PRIORITY_IDLE
    (最低优先级,仅在系统空闲时执行)
    THREAD_PRIORITY_LOWEST
    THREAD_PRIORITY_BELOW_NORMAL
    THREAD_PRIORITY_NORMAL (缺省)
    THREAD_PRIORITY_ABOVE_NORMAL
    THREAD_PRIORITY_HIGHEST
    THREAD_PRIORITY_CRITICAL
    (非常高的优先级)
    ---- 4 线程同步问题

    ---- 编写多线程应用程序的最重要的问题就是线程之间的资源同步访问。因为多个线程在共享资源时如果发生访问冲突通常会产生不正确的结果。例如,一个线程正在更新一个结构的内容的同时另一个线程正试图读取同一个结构。结果,我们将无法得知所读取的数据是什么状态:旧数据,新数据,还是二者的混合?

    ---- MFC 提供了一组同步和同步访问类来解决这个问题,包括:

    ---- 同步对象:CSyncObject, CSemaphore, CMutex, CcriticalSection 和CEvent ;同步访问对象:CMultiLock 和CSingleLock 。

    ---- 同步类用于当访问资源时保证资源的整体性。其中CsyncObject 是其它四个同步类的基类,不直接使用。信号同步类CSemaphore 通常用于当一个应用程序中同时有多个线程访问一个资源(例如,应用程序允许对同一个Document 有多个View)的情况;事件同步类CEvent 通常用于在应用程序访问资源之前应用程序必须等待(比如,在数据写进一个文件之前数据必须从通信端口得到)的情况;而对于互斥同步类CMutex 和临界区同步类CcriticalSection 都是用于保证一个资源一次只能有一个线程访问,二者的不同之处在于前者允许有多个应用程序使用该资源(例如,该资源在一个DLL 当中)而后者则不允许对同一个资源的访问超出进程的范畴,而且使用临界区的方式效率比较高。

    ---- 同步访问类用于获得对这些控制资源的访问。CMultiLock 和CSingleLock 的区别仅在于是需要控制访问多个还是单个资源对象。

    ---- 5 同步类的使用方法

    ---- 解决同步问题的一个简单的方法就是将同步类融入共享类当中,通常我们把这样的共享类称为线程安全类。下面举例来说明这些同步类的使用方法。比如,一个用以维护一个帐户的连接列表的应用程序。该应用程序允许3 个帐户在不同的窗口中检测,但一次只能更新一个帐户。当一个帐户更新之后,需要将更新的数据通过网络传给一个数据文档。

    ---- 该例中将使用3 种同步类。由于允许一次检测3 个帐户,使用CSemaphore 来限制对3 个视窗对象的访问。当更新一个帐目时,应用程序使用CCriticalSection 来保证一次只有一个帐目更新。在更新成功之后,发CEvent 信号,该信号释放一个等待接收信号事件的线程。该线程将新数据传给数据文档。

    ---- 要设计一个线程安全类,首先根据具体情况在类中加入同步类做为数据成员。在例子当中,可以将一个CSemaphore 类的数据成员加入视窗类中,一个CCriticalSection 类数据成员加入连接列表类,而一个CEvent 数据成员加入数据存储类中。

    ---- 然后,在使用共享资源的函数当中,将同步类与同步访问类的一个锁对象联系起来。即,在访问控制资源的成员函数中应该创建一个CSingleLock 或CMultiLock 的对象并调用该对象的Lock 函数。当访问结束之后,调用UnLock 函数,释放资源。

    ---- 用这种方式来设计线程安全类比较容易。在保证线程安全的同时,省去了维护同步代码的麻烦,这也正是OOP 的思想。但是使用线程安全类方法编程比不考虑线程安全要复杂,尤其体现在程序调试过程中。而且线程安全编程还会损失一部分效率,比如在单CPU 计算机中多个线程之间的切换会占用一部分资源。

    三编程实例
    ---- 下面以VC++5.0 中一个简单的基于对话框的MFC 例程来说明实现多线程任务调度与处理的方法,下面加以详细解释。
    ---- 在该例程当中定义两个用户界面线程,一个显示线程(CDisplayThread) 和一个计数线程(CCounterThread)。这两个线程同时操作一个字符串变量m_strNumber,其中显示线程将该字符串在一个列表框中显示,而计数线程则将该字符串中的整数加1。在例程中,可以分别调整进程、计数线程和显示线程的优先级。例程中的同步机制使用CMutex 和CSingleLock 来保证两个线程不能同时访问该字符串。同步机制执行与否将明显影响程序的执行结果。在该例程中允许将将把两个线程暂时挂起,以查看运行结果。例程中还允许查看计数线程的运行。该例程中所处理的问题也是多线程编程中非常具有典型意义的问题。

    ---- 在该程序执行时主要有三个用于调整优先级的组合框,三个分别用于选择同步机制、显示计数线程运行和挂起线程的复选框以及一个用于显示运行结果的列表框。

    ---- 在本程序中使用了两个线程类CCounterThread 和CDisplayThread,这两个线程类共同操作定义在CMutexesDlg 中的字符串对象m_strNumber。本程序对同步类CMutex 的使用方法就是按照本文所讲述的融入的方法来实现的。同步访问类CSingleLock 的锁对象则在各线程的具体实现中定义。

    ---- 下面介绍该例程的具体实现:

    利用AppWizard 生成一个名为Mutexes 基于对话框的应用程序框架。

    利用对话框编辑器在对话框中填加以下内容:三个组合框,三个复选框和一个列表框。三个组合框分别允许改变进程优先级和两个线程优先级,其ID 分别设置为:IDC_PRIORITYCLASS、IDC_DSPYTHRDPRIORITY 和IDC_CNTRTHRDPRIORITY。三个复选框分别对应着同步机制选项、显示计数线程执行选项和暂停选项,其ID 分别设置为IDC_SYNCHRONIZE、IDC_SHOWCNTRTHRD 和IDC_PAUSE。列表框用于显示线程显示程序中两个线程的共同操作对象m_strNumber,其ID 设置为IDC_DATABOX。

    创建类CWinThread 的派生类CExampleThread。该类将作为本程序中使用的两个线程类:CCounterThread 和CDisplayThread 的父类。这样做的目的仅是为了共享两个线程类的共用变量和函数。
    ---- 在CExampleThread 的头文件中填加如下变量:
    CMutexesDlg * m_pOwner;//指向类CMutexesDlg指针
    BOOL m_bDone;//用以控制线程执行
    及函数:
    void SetOwner(CMutexesDlg* pOwner)
    { m_pOwner=pOwner; };//取类CMutexesDlg的指针
    然后在构造函数当中对成员变量进行初始化:
    m_bDone=FALSE;//初始化允许线程运行
    m_pOwner=NULL;//将该指针置为空
    m_bAutoDelete=FALSE;//要求手动删除线程对象
    创建两个线程类CCounterThread 和CdisplayThread。这两个线程类是CExampleThread 的派生类。分别重载两个线程函数中的::Run() 函数,实现各线程的任务。在这两个类当中分别加入同步访问类的锁对象sLock,这里将根据同步机制的复选与否来确定是否控制对共享资源的访问。不要忘记需要加入头文件#include "afxmt.h"。
    ---- 计数线程::Run() 函数的重载代码为:
    int CCounterThread::Run()
    {
    BOOL fSyncChecked;//同步机制复选检测
    unsigned int nNumber;//存储字符串中整数

    if (m_pOwner == NULL)
    return -1;
    //将同步对象同锁对象联系起来
    CSingleLock sLock(&(m_pOwner- >m_mutex));
    while (!m_bDone)//控制线程运行,为终止线程服务
    {
    //取同步机制复选状态
    fSyncChecked = m_pOwner- >
    IsDlgButtonChecked(IDC_SYNCHRONIZE);
    //确定是否使用同步机制
    if (fSyncChecked)
    sLock.Lock();
    //读取整数
    _stscanf((LPCTSTR) m_pOwner- >m_strNumber,
    _T("%d"), &nNumber);
    nNumber++;//加1
    m_pOwner- >m_strNumber.Empty();//字符串置空
    while (nNumber != 0) //更新字符串
    {
    m_pOwner- >m_strNumber +=
    (TCHAR) ('0'+nNumber%10);
    nNumber /= 10;
    }
    //调整字符串顺序
    m_pOwner- >m_strNumber.MakeReverse();
    //如果复选同步机制,释放资源
    if (fSyncChecked)
    sLock.Unlock();
    //确定复选显示计数线程
    if (m_pOwner- >IsDlgButtonChecked(IDC_SHOWCNTRTHRD))
    m_pOwner- >AddToListBox(_T("Counter: Add 1"));
    }//结束while

    m_pOwner- >PostMessage(WM_CLOSE, 0, 0L);
    return 0;
    }
    显示线程的::Run()函数重载代码为:
    int CDisplayThread::Run()
    {
    BOOL fSyncChecked;
    CString strBuffer;

    ASSERT(m_pOwner != NULL);
    if (m_pOwner == NULL)
    return -1;
    CSingleLock sLock(&(m_pOwner- >m_mutex));
    while (!m_bDone)
    {
    fSyncChecked = m_pOwner- >
    IsDlgButtonChecked(IDC_SYNCHRONIZE);
    if (fSyncChecked)
    sLock.Lock();
    //构建要显示的字符串
    strBuffer = _T("Display: ");
    strBuffer += m_pOwner- >m_strNumber;
    if (fSyncChecked)
    sLock.Unlock();
    //将字符串加入到列表框中
    m_pOwner- >AddToListBox(strBuffer);
    }//结束while
    m_pOwner- >PostMessage(WM_CLOSE, 0, 0L);
    return 0;
    }

    3在CMutexesDlg的头文件中加入如下成员变量:
    CString m_strNumber;//线程所要操作的资源对象
    CMutex m_mutex;//用于同步机制的互斥量
    CCounterThread* m_pCounterThread;//指向计数线程的指针
    CDisplayThread* m_pDisplayThread;//指向显示线程的指针
    首先在对话框的初始化函数中加入如下代码对对话框进行初始化:
    BOOL CMutexesDlg::OnInitDialog()
    {
    ……
    //初始化进程优先级组合框并置缺省为NORMAL
    CComboBox* pBox;
    pBox = (CComboBox*) GetDlgItem(IDC_PRIORITYCLASS);
    ASSERT(pBox != NULL);
    if (pBox != NULL){
    pBox- >AddString(_T("Idle"));
    pBox- >AddString(_T("Normal"));
    pBox- >AddString(_T("High"));
    pBox- >AddString(_T("Realtime"));
    pBox- >SetCurSel(1);
    }
    //初始化显示线程优先级组合框并置缺省为NORMAL
    pBox = (CComboBox*) GetDlgItem(IDC_DSPYTHRDPRIORITY);
    ASSERT(pBox != NULL);
    if (pBox != NULL){
    pBox- >AddString(_T("Idle"));
    pBox- >AddString(_T("Lowest"));
    pBox- >AddString(_T("Below normal"));
    pBox- >AddString(_T("Normal"));
    pBox- >AddString(_T("Above normal"));
    pBox- >AddString(_T("Highest"));
    pBox- >AddString(_T("Timecritical"));
    pBox- >SetCurSel(3);
    }
    //初始化计数线程优先级组合框并置缺省为NORMAL
    pBox = (CComboBox*) GetDlgItem(IDC_CNTRTHRDPRIORITY);
    ASSERT(pBox != NULL);
    if (pBox != NULL){
    pBox- >AddString(_T("Idle"));
    pBox- >AddString(_T("Lowest"));
    pBox- >AddString(_T("Below normal"));
    pBox- >AddString(_T("Normal"));
    pBox- >AddString(_T("Above normal"));
    pBox- >AddString(_T("Highest"));
    pBox- >AddString(_T("Timecritical"));
    pBox- >SetCurSel(3);
    }
    //初始化线程挂起复选框为挂起状态
    CButton* pCheck = (CButton*) GetDlgItem(IDC_PAUSE);
    pCheck- >SetCheck(1);
    //初始化线程
    m_pDisplayThread = (CDisplayThread*)
    AfxBeginThread(RUNTIME_CLASS(CDisplayThread),
    THREAD_PRIORITY_NORMAL,
    0,
    CREATE_SUSPENDED);
    m_pDisplayThread- >SetOwner(this);

    m_pCounterThread = (CCounterThread*)
    AfxBeginThread(RUNTIME_CLASS(CCounterThread),
    THREAD_PRIORITY_NORMAL,
    0,
    CREATE_SUSPENDED);
    m_pCounterThread- >SetOwner(this);
    ……
    }
    然后填加成员函数:
    void AddToListBox(LPCTSTR szBuffer);//用于填加列表框显示
    该函数的实现代码为:
    void CMutexesDlg::AddToListBox(LPCTSTR szBuffer)
    {
    CListBox* pBox = (CListBox*) GetDlgItem(IDC_DATABOX);
    ASSERT(pBox != NULL);
    if (pBox != NULL){
    int x = pBox- >AddString(szBuffer);
    pBox- >SetCurSel(x);
    if (pBox- >GetCount() > 100)
    pBox- >DeleteString(0);
    }
    }
    ---- 然后利用ClassWizard 填加用于调整进程优先级、两个线程优先级以及用于复选线程挂起的函数。
    ---- 调整进程优先级的代码为:

    void CMutexesDlg::OnSelchangePriorityclass()
    {
    DWORD dw;
    //取焦点选项
    CComboBox* pBox = (CComboBox*)
    GetDlgItem(IDC_PRIORITYCLASS);
    int nCurSel = pBox- >GetCurSel();
    switch (nCurSel)
    {
    case 0:
    dw = IDLE_PRIORITY_CLASS;break;
    case 1:
    default:
    dw = NORMAL_PRIORITY_CLASS;break;
    case 2:
    dw = HIGH_PRIORITY_CLASS;break;
    case 3:
    dw = REALTIME_PRIORITY_CLASS;break;
    }
    SetPriorityClass(GetCurrentProcess(), dw);//调整优先级
    }
    ---- 由于调整两个线程优先级的代码基本相似,单独设置一个函数根据不同的ID 来调整线程优先级。该函数代码为:
    void CMutexesDlg::OnPriorityChange(UINT nID)
    {
    ASSERT(nID == IDC_CNTRTHRDPRIORITY ||
    nID == IDC_DSPYTHRDPRIORITY);
    DWORD dw;
    //取对应该ID的焦点选项
    CComboBox* pBox = (CComboBox*) GetDlgItem(nID);
    int nCurSel = pBox- >GetCurSel();
    switch (nCurSel)
    {
    case 0:
    dw = (DWORD)THREAD_PRIORITY_IDLE;break;
    case 1:
    dw = (DWORD)THREAD_PRIORITY_LOWEST;break;
    case 2:
    dw = (DWORD)THREAD_PRIORITY_BELOW_NORMAL;break;
    case 3:
    default:
    dw = (DWORD)THREAD_PRIORITY_NORMAL;break;
    case 4:
    dw = (DWORD)THREAD_PRIORITY_ABOVE_NORMAL;break;
    case 5:
    dw = (DWORD)THREAD_PRIORITY_HIGHEST;break;
    case 6:
    dw = (DWORD)THREAD_PRIORITY_TIME_CRITICAL;break;
    }
    if (nID == IDC_CNTRTHRDPRIORITY)
    m_pCounterThread- >SetThreadPriority(dw);
    //调整计数线程优先级
    else
    m_pDisplayThread- >SetThreadPriority(dw);
    //调整显示线程优先级
    }
    这样线程优先级的调整只需要根据不同的ID来调用该函数:
    void CMutexesDlg::OnSelchangeDspythrdpriority()
    { OnPriorityChange(IDC_DSPYTHRDPRIORITY);}
    void CMutexesDlg::OnSelchangeCntrthrdpriority()
    { OnPriorityChange(IDC_CNTRTHRDPRIORITY);}
    复选线程挂起的实现代码如下:
    void CMutexesDlg::OnPause()
    {
    //取挂起复选框状态
    CButton* pCheck = (CButton*)GetDlgItem(IDC_PAUSE);
    BOOL bPaused = ((pCheck- >GetState() & 0x003) != 0);
    if (bPaused) {
    m_pCounterThread- >SuspendThread();
    m_pDisplayThread- >SuspendThread();
    }//挂起线程
    else {
    m_pCounterThread- >ResumeThread();
    m_pDisplayThread- >ResumeThread();
    }//恢复线程运行
    }
    ---- 程序在::OnClose() 中实现了线程的终止。在本例程当中对线程的终止稍微复杂些。需要注意的是成员变量m_bDone 的作用,在线程的运行当中循环检测该变量的状态,最终引起线程的退出。这样线程的终止是因为函数的退出而自然终止,而非采用强行终止的方法,这样有利于系统的安全。该程序中使用了PostMessage 函数,该函数发送消息后立即返回,这样可以避免阻塞。其实现的代码为:
    void CMutexesDlg::OnClose()
    {
    int nCount = 0;
    DWORD dwStatus;
    //取挂起复选框状态
    CButton* pCheck = (CButton*) GetDlgItem(IDC_PAUSE);
    BOOL bPaused = ((pCheck- >GetState() & 0x003) != 0);

    if (bPaused == TRUE){
    pCheck- >SetCheck(0);//复选取消
    m_pCounterThread- >ResumeThread();
    //恢复线程运行
    m_pDisplayThread- >ResumeThread();
    }

    if (m_pCounterThread != NULL){
    VERIFY(::GetExitCodeThread(m_pCounterThread- >
    m_hThread, &dwStatus));//取计数线程结束码
    if (dwStatus == STILL_ACTIVE){
    nCount++;
    m_pCounterThread- >m_bDone = TRUE;
    }//如果仍为运行状态,则终止
    else{
    delete m_pCounterThread;
    m_pCounterThread = NULL;
    }//如果已经终止,则删除该线程对象
    }

    if (m_pDisplayThread != NULL){
    VERIFY(::GetExitCodeThread(m_pDisplayThread- >
    m_hThread, &dwStatus));//取显示线程结束码
    if (dwStatus == STILL_ACTIVE){
    nCount++;
    m_pDisplayThread- >m_bDone = TRUE;
    }//如果仍为运行状态,则终止
    else{
    delete m_pDisplayThread;
    m_pDisplayThread = NULL;
    }//如果已经终止,则删除该线程对象
    }
    if (nCount == 0)//两个线程均终止,则关闭程序
    CDialog::OnClose();
    else //否则发送WM_CLOSE消息
    PostMessage(WM_CLOSE, 0, 0);
    }
    ---- 在例程具体实现中用到了许多函数,在这里不一一赘述,关于函数的具体意义和用法,可以查阅联机帮助。

  • 如何用VC++60编写查看二进制文件程序

    2007-08-25 01:09:29

     

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 14次

    雷霆工作室 韩燕

    ---- 在计算机应用中,经常需要查看二进制文件的内容。目前,在各种VC++书籍中介绍查看文本文件的文章很多,但鲜有介绍查看二进制文件的文章。本文从功能设计、方案设计、编程实现以及技术要点等方面来简单介绍。

    ---- 1 功能设计

    ---- 显示界面见图1(略),将窗口客户区划分为三部分,左边列用于以16进制方式显示文件内容的相应位置,中间列用于以16进制方式显示文件内容,右边列用于显示文件内容对应的ASCII码的内容。为简化程序设计,没有打印功能。

    ---- 2 方案设计

    ---- 采用MFC的SDI(单文档界面)。由于在一屏内一般不可能显示整个文件的内容,所以选择视类的基类为CScrollView。二进制文件的读出与处理在文档类中完成,文件的显示与滚动由视类来实现。

    ---- 3 编程实现

    ---- 3.1 使用MFC AppWizard向导产生一应用框架在VC++的“File”菜单中,单击“New”,弹出一New对话框。在“Projects”页中选择“MFC AppWizard [exe]”,在“Project name”编辑框中填入“HexShow”(见图2(略)),按“OK”按钮,退出New对话框。在“MFC AppWizard Step 1”对话框中选择单选钮“Single document”,按“Next>”按钮,进入“MFC AppWizard Step 2 of 6”对话框,保持缺省选择,按“Next>”按钮,进入“MFC AppWizard Step 3 of 6”对话框,保持缺省选择,按“Next>”按钮,进入“MFC AppWizard Step 4 of 6”对话框,取消“Printing and print preview”选项(见图3(略)),按“Next>”按钮,进入“MFC AppWizard Step 5 of 6”对话框,保持缺省设置,继续按“Next>”按钮,进入“MFC AppWizard Step 6 of 6”对话框,在“Base class”组合框中选择CscrollView(见图4(略)), 按“Finish”按钮即可完成应用框架的定制。

    ---- 3.2 在文档类CHexShowDoc中增加文件的读出及处理工作

    ---- 3.2.1 定义文档的成员变量,做好初始化及清理工作

    ---- 打开HexShowDoc.h文件,增加2个公共变量:

    CFile* m_pHexFile;
    LONG m_lFileLength;
    int  m_nBytesPerLine;   
    //每行显示多少个Byte然后,打开HexShowDoc.cpp文件,

    ---- 在类的构造函数中增加下列初始化代码:

    m_pHexFile = NULL;
    m_lFileLength = 0L;
    m_nBytesPerLine=16;   
    //每行显示16个Byte在类的析构函数中增加下列清理代码:
    if (m_pHexFile != NULL)
    {
    m_pHexFile- >Close();
    delete m_pHexFile;
    m_pHexFile = NULL;
    }

    ---- 3.2.2 在OnOpenDocument()中打开文档

    ---- 首先利用ClassWizard重载消息成员函数OnOpenDocument()。

    ---- 在该成员函数的代码添加处增加下列代码:

         if (m_pHexFile != NULL)
    {
    m_pHexFile- >Close();
    delete m_pHexFile;
    }
    m_pHexFile = new CFile(lpszPathName,
    CFile::modeRead | CFile::typeBinary);
    if (!m_pHexFile)
    {
    AfxMessageBox("该文件打开错");
    return FALSE;
    }
    m_lFileLength = m_pHexFile- >GetLength();

    ---- 3.2.3 增加用于读文件及进行输出格式化处理的成员函数为CHexShowDoc类增加成员函数如下:

    BOOL CHexShowDoc::ReadFileAndProcess
    (CString &strLine, LONG lOffset)
    {
        LONG lPos;
    if (lOffset != -1L)
    lPos = m_pHexFile- >Seek(lOffset, CFile::begin);
    else
    lPos = m_pHexFile- >GetPosition();
    unsigned char szBuf[16];
    int nRet = m_pHexFile- >Read(szBuf, m_nBytesPerLine);
    if (nRet < = 0)
    return FALSE;
    CString sTemp;
    CString sChars;
    sTemp.Format(_T("%8.8lX : "), lPos);
    strLine = sTemp;
    for (int i = 0; i < nRet; i++)
    {
    if (i == 0)
    sTemp.Format(_T("%2.2X"), szBuf[i]);
    else if (i % 16 == 0)
    sTemp.Format(_T("=%2.2X"), szBuf[i]);
    else if (i % 8 == 0)
    sTemp.Format(_T(" - %2.2X"), szBuf[i]);
    else
    sTemp.Format(_T(" %2.2X"), szBuf[i]);
    if (_istprint(szBuf[i]))
    sChars += szBuf[i];
    else
    sChars += _T('.');
    strLine += sTemp;
    }
    if (nRet < m_nBytesPerLine)
    {
    CString sPad(_T(' '),
    2+3*(m_nBytesPerLine-nRet));
    strLine += sPad;
    }
    strLine += _T("  ");
    strLine += sChars;
    return TRUE;
    }

    ---- 3.3 在视中添加显示文件内容以及处理滚动操作

    ---- 3.3.1 变量定义以及初始化

    ---- a) 打开HexShowView.h文件,增加成员变量如下:

    CFont* m_pFont;     //用于为显示文件内容选择字体

    ---- b) 在视的构造函数中为文件内容显示选择合适的字体

    //选择一种名为“Fixedsys”的字体,该字体使得字符的排列整齐
    LOGFONT m_logfont;
    memset(&m_logfont, 0, sizeof(m_logfont));
      _tcscpy(m_logfont.lfFaceName, _T("Fixedsys"));
    CClientDC dc(NULL);
    m_logfont.lfHeight = ::MulDiv
       (120, dc.GetDeviceCaps(LOGPIXELSY), 720);
    m_logfont.lfPitchAndFamily = FIXED_PITCH;
    m_pFont = new CFont;
    m_pFont- >CreateFontIndirect(&m_logfont);
        c)  将ChexShowView::OnInitialUpdate()中的代码修改为:
    CScrollView::OnInitialUpdate();
    CHexShowDoc* pDoc = GetDocument();
    ASSERT_VALID(pDoc);
    CSize sizeTotal(0, pDoc- >m_lFileLength);
    SetScrollSizes(MM_TEXT, sizeTotal);

    ---- c) 在视的析构函数中完成对字体对象的删除,增加代码如下:

    if (m_pFont != NULL)
    delete m_pFont;

    ---- 3.3.2 在视中的OnDraw()中添加如下代码

    CHexShowDoc* pDoc = GetDocument();
    ASSERT_VALID(pDoc);
    CFont* pOldFont;
    CString sLine;//用于显示的文本行
    CSize ScrolledSize;//窗口的客户区的范围
    int iStartLine;//当前屏第一行显示的行的索引号
    int nHeight;//输出文本行的高度
    CRect ScrollRect;
    //获得该屏滚动条的位置
    CPoint ScrolledPos = GetScrollPosition();
      CRect rectClient;
    GetClientRect(&rectClient);
    // 求出每行的高度(单位:象素数)
    TEXTMETRIC tm; //tm用于存储库存字体的参数;
    pDC- >GetTextMetrics(&tm);
    nHeight = tm.tmHeight;
    pOldFont = pDC- >SelectObject(m_pFont);
    // 根据滚动,求出开始行
    ScrolledSize = CSize(rectClient.Width(),
    rectClient.Height());
    ScrollRect = CRect(rectClient.left, ScrolledPos.y,
    rectClient.right, ScrolledSize.cy +
     ScrolledPos.y);
    iStartLine = ScrolledPos.y/16;
    // make sure we are drawing where we should
    ScrollRect.top = iStartLine*nHeight;
    if (pDoc- >m_pHexFile != NULL)
    {
    int nLine;
    for (nLine = iStartLine; ScrollRect.top
     < ScrollRect.bottom; nLine++)
    {
    if (!pDoc- >ReadFileAndProcess
    (sLine, nLine*16))
    break;
    nHeight = pDC- >DrawText(sLine, -1,
    &ScrollRect, DT_TOP |
     DT_NOPREFIX | DT_SINGLELINE);
    ScrollRect.top += nHeight;
    }
    }
    pDC- >SelectObject(pOldFont);

    ---- 3.4 对该工程进行编译、连接,形成运行文件HexShow.exe经过运行、实际测试,使用效果良好。

    ---- 4 技术关键

    ---- 通过上面介绍,可知该程序并不复杂。其设计到的技术关键有4条。

    ---- a) 利用文档/视架构能有效地降低软件的复杂度,使文档专注于处理数据,而视由于继承自CScrollView,则便于文本的显示和滚动;

    ---- b) 选择一种合适的字体非常重要,否则,可能出现显示混乱的情况;

    ---- c) 选择一个正确的成员函数往往能起到事半功倍的效果,比如,进行文本输出时,使用CDC::DrawText(…),就比使用常规的CDC::TextOut(…)有很大的优点;

    ---- d) 不管滚动条处于什么位置,视只显示所涉及到的文本行。

  • VC++程序中用对话框的形式显示HTML文件

    2007-08-25 00:55:11


     

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 7次

    ---- 在 安 装 了IE 4 后, 可 以 在 程 序 中 用 对 话 框 的 形 式 显 示HTML 文 件, 如 弹 出 用HTML 写 的 帮 助 文 件 等 等, 如 同 直 接 用 浏 览 器, 但 又 与 浏 览 器 风 格 不 同。

    ---- 其 实 现 如 下:

    //在头文件或.cpp文件的开头
    包含文件urlmon.h,定义函数
    /////
    #include "urlmon.h"
    typedef HRESULT STDAPICALLTYPE SHOWHTMLDIALOGFN
    (HWND hwndParent, IMoniker
    *pmk, VARIANT *pvarArgIn, TCHAR* pchOptions,
       VARIANT *pvArgOut);
    //////

    //函数显示对话框,成功返回TRUE,失败返回FALSE
    BOOL ShowHtml()
    {
    HINSTANCE  hinstMSHTML = LoadLibrary
       (TEXT("MSHTML.DLL")); //装载动态连
    接库
    WCHAR url[]=L"HTTP://www.ccw.com.cn";
    //此地址名称可直接用html文件名代替

      if(hinstMSHTML)//装载动态连接库成功
      {
         SHOWHTMLDIALOGFN *pfnShowHTMLDialog;

         pfnShowHTMLDialog = (SHOWHTMLDIALOGFN*)
       GetProcAddress(hinstMSHTML,
    TEXT  ("ShowHTMLDialog"));

         if(pfnShowHTMLDialog)
         {
         IMoniker *moniker=NULL;

            //
         if( FAILED(CreateURLMoniker(NULL,
         (LPWSTR)url,&moniker ) ))
         {
            FreeLibrary(hinstMSHTML);
           return FALSE;
          }

            //调用ShowHTMLDialog函数显示URL上的HTML文件
          pfnShowHTMLDialog(m_hWnd,moniker,NULL,NULL,NULL);

          if(moniker!=NULL)
              moniker->Release();

          //显示成功,返回TRUE
           return TRUE;

         }
         else //GetProcessAddress失败
          return FALSE;

       FreeLibrary(hinstMSHTML);
      }
      else //装载动态连接库失败
       return FALSE;
    }

  • 如何防止Edit框中的Password不被非法获取

    2007-08-25 00:51:29

     

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 8次

    文/郝峰

        Windows虽然是一个功能强大的操作系统,但其存在的一些先天性不足,给黑客留下了许多可乘之机,著名的BO程序就是利用Windows的这些漏洞来危害计算机的安全。笔者最近发现了一个很流行的专门获取Edit框Password的工具,甚至其源代码已在某报纸发表,这无疑是对Edit的Password功能的完全否定。本文将首先分析非法获取Password的原理,然后给出用Visual C++来实现保护Edit框中的Password不被非法获取的对策。

      (一) 非法获取Password的原理

      Edit是Windows的一个标准控件,当把其Password属性设为True时,就会将输入的内容屏蔽为星号(*),从而达到保护的目的。而Edit框中的内容可通过发WM_GETTEXT,EM_GETLINE消息来获取。黑客程序就是利用Edit的这个特性,首先枚举当前程序的所有子窗口,当发现枚举的窗口是EDIT并且具有ES_PASSWORD属性时,则通过SendMessage向此窗口发送WM_GETTEXT或EM_GETLINE消息,这样Edit框中的内容就一目了然了。

      (二) 对Password进行保护

      由上述分析可看出,Edit的漏洞在于没有检查发送WM_GETTEXT或EM_GETLINE消息者的身份,只要找到Edit窗口句柄,任何进程都可获取其内容。这里给出一种简单的方法来验证发送消息者的身份是否合法。

      1) 创建新CEdit类

      从CEdit继承一个子类CPasswordEdit, 申明全局变量g_bAuthorIdentity表明消息发送者的身份:

        BOOL g_bAuthorIdentity;
        
      然后响应CWnd的虚函数DefWindowProc,在这个回调函数中进行身份验证:

    LRESULT CPasswordEdit::DefWindowProc(UINT message,
    WPARAM wParam, LPARAM lParam)
        {
            // 对Edit的内容获取必须通过以下两个消息之一
            if(( message == WM_GETTEXT) ||
            ( message == EM_GETLINE))
            {
                // 检查是否为合法
                if( !g_bAuthorIdentity)
                {
                    // 非法获取,显示信息
                    AfxMessageBox(_T("我的密码,可不能让你看哦!"));
                    //
                    return 0;
                }
                // 合法获取
                g_bAuthorIdentity = FALSE;
            }
            return CEdit::DefWindowProc(message, wParam, lParam);
        }
      2) 在数据输入对话框中做处理

      在对话框中申明一个类成员m_edtPassword:

        CPasswordEdit m_edtPassword;
      然后在对话框的OnInitDialog()中加入下列代码:

        m_edtPassword.SubclassDlgItem(IDC_EDIT_PASSWORD, this);
      其目的是将控制与新类做关联。

      之后在对话框的数据交换中将身份设为合法:

        void CDlgInput::DoDataExchange(CDataExchange* pDX)
        {
            // 如果获取数据
    // 注意:对于CPropertyPage类这里不需要
            if( pDX- >m_bSaveAndValidate) 条件
            if( pDX- >m_bSaveAndValidate)
            {
                g_bAuthorIdentity = TRUE;
            }
            CDialog::DoDataExchange(pDX);
            //{{AFX_DATA_MAP(CDlgInput)
            DDX_Text(pDX, IDC_EDIT_PASSWORD, m_sPassword);
            //}}AFX_DATA_MAP
    }
      这样,Password输入框就会受到保护。

      (三) 需要注意的问题

      以上的方法仅针对VC程序,对于VB程序,需要借助VC做一个Password的ActiveX 控件,实现方法与上类似。同时以上程序在Visual C++6.0上通过,并且用黑客程序 PWBTool测试通过。

  • VC命名管道通信的实现

    2007-08-25 00:38:56

     

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 12次

    无论是SQL Server的用户,还是PB的用户,作为C/S结构开发环境,他们在网络通信的实现上,都有一种共同的方法——命名管道。由于当前操作系统的不惟一性,各个系统都有其独自的通信协议,导致了不同系统间通信的困难。尽管TCP/IP协议目前已发展成为Internet的标准,但仍不能保证C/S应用程序的顺利进行。命名管道作为一种通信方法,有其独特的优越性,这主要表现在它不完全依赖于某一种协议,而是适用于任何协议——只要能够实现通信。

      命名管道具有很好的使用灵活性,表现在:

      1) 既可用于本地,又可用于网络。

      2) 可以通过它的名称而被引用。

      3) 支持多客户机连接。

      4) 支持双向通信。

      5) 支持异步重叠I/O操作。

      不过,当前只有Windows NT支持服务端的命名管道技术。



      一、命名管道程序设计的实现

      1.命名管道Server和Client间通信的实现流程

      (1)建立连接:服务端通过函数CreateNamedPipe创建一个命名管道的实例并返回用于今后操作的句柄,或为已存在的管道创建新的实例。如果在已定义超时值变为零以前,有一个实例管道可以使用,则创建成功并返回管道句柄,并用以侦听来自客户端的连接请求,该功能通过ConnectNamedPipe函数实现。

      另一方面,客户端通过函数WaitNamedPipe使服务进程等待来自客户的实例连接,如果在超时值变为零以前,有一个管道可以为连接使用,则WaitNamedPipe将返回True,并通过调用CreateFile或CallNamedPipe来呼叫对服务端的连接。此时服务端将接受客户端的连接请求,成功建立连接,服务端ConnectNamedPipe返回True,客户端CreateFile将返回一指向管道文件的句柄。

      从时序上讲,首先是客户端通过WaitNamedPipe使服务端的CreateFile在限时时间内创建实例成功,然后双方通过ConnectNamedPipe和CreateFile成功连接,并返回用以通信的文件句柄,此时双方即可进行通信。

      (2)通信实现:建立连接之后,客户端与服务器端即可通过ReadFile和WriteFile,利用得到的管道文件句柄,彼此间进行信息交换。

      (3)连接终止:当客户端与服务端的通信结束,或由于某种原因一方需要断开时,客户端应调用CloseFile,而服务端应接着调用DisconnectNamedPipe。当然服务端亦可通过单方面调用DisconnectNamedPipe终止连接。最后应调用函数CloseHandle来关闭该管道。

      2.命名管道服务器端和客户端代码实现

      (1)客户端:

      HANDLE CltHandle;

      char pipenamestr[30];

      sprintf(pipenamestr,″\\\\servername\\pipe\\pipename″)

      if (WaitNamedPipe( pipenamestr, NMPWAIT—WAIT—FOREVER)==FALSE

      // 管道名要遵循UNC,格式为\ \.\pipe\pipname,名字不分大小写。

       AfxMessageBox(″操作失败,请确定服务端正确建立管道实例!″);

      Else

       CltHandle=CreateFile(pipenamestr, GENERIC—READ|GENERIC—WRITE, FILE—SHARE—READ| FILE—SHARE—WRITE,NULL, OPEN—EXISTING,

      //为了与命名管道连接,此参数应一直为OPEN—EXISTING

      FILE—ATTRIBUTE—ARCHIVE|FILE—FLAG—WRITE—THROUGH,

      // FILE—FLAG—WRITE—THROUGH会使管道WriteFile调用处于阻塞状态,直到数据传送成功。

      NULL);

      If (CltHandle== INVALID—HANDLE—VALUE)

       AfxMessageBox(″管道连接失败″);

      Else

       DoUsertTransactInfo();

      //执行用户自定义信息交换函数——从管道读、写信息。

      ……

      (2)服务端:

      HANDLE SvrHandle;

      char pipenamestr[30];

      sprintf(pipenamestr,″\\\\.\\pipe\\pipename″)

      SvrHandle=CreateNamedPipe(pipenamestr,

      PIPE—ACCESS—DUPLEX|FILE—FLAG—WRITE—THROUGH,

      //阻塞模式,这种模式仅对″字节传输管道″操作有效。

      FILE—WAIT|PIPE—TYPE—BYTE,

      //字节模式

      PIPE—UNLIMITED—INSTANCES,

      128,128,

      NULL,NULL);

      // SECURITY—ATTRIBUTES结构指针,描述一个新管道,确定子进程的继承权,如果为NULL则该命名管道不能被继承。

      If (SvrHandle==INVALID—HANDLE—VALUE)

       AfxMessageBox(″管道创建失败,请确定客户端提供连接可能!″);

      Else

       If (ConnectNamedPipe(SvrHandle,NULL)==FALSE)

         AfxMessageBox(″建立连接失败!″);

       Else

       DoUsertTransactInfo();

      //用户自定义信息交换函数

      ……



      二、程序设计的注意事项

      1.如果命名管道客户端已打开,函数将会强迫关闭管道,用DisconnectNamedPipe关闭的管道,其客户端还必须用CloseHandle来关闭最后的管道。

      2. ReadFile和WriteFile的hFile句柄是由CreateFile及ConnectNamedPipe返回得到。

      3.一个已被某客户端连接的管道句柄在被另一客户通过ConnectNamedPipe建立连接之前,服务端必须用DisconnectNamedPipe函数对已存在的连接进行强行拆离。服务端拆离管道会造成管道中数据的丢失,用FlushFileBuffers函数可以保证数据不被丢失。

      4.命名管道服务端可以通过新创建的管道句柄或已被连接过其他客户的管道句柄来使用ConnectNamedPipe函数,但在连接新的客户端之前,服务端必须用函数DisconnectNamedPipe切断之前的客户句柄,否则ConnectNamedPipe 将会返回False。

      5.阻塞模式,这种模式仅对“字节传输管道"操作有效,并且要求客户端与服务端不在同一机器上。如果用这种模式,则只有当函数通过网络向远端计算机管道缓冲器写数据成功时,才能有效返回。如果不用这种模式,系统会运行缺省方式以提高网络的工作效率。

      6.用户必须用FILE—CREATE—PIPE—INSTANCE 来访问命名管道对象。新的命名管道建立后,来自安全参数的访问控制列表定义了访问该命名管道的权限。所有命名管道实例必须使用统一的管道传输方式、管道模式等参数。客户端未启动,管道服务端不能执行阻塞读操作,否则会发生空等的阻塞状态。当最后的命名管道实例的最后一个句柄被关闭时,就应该删除该命名管道。

      摘自《赛迪网》 冷山述/文

  • 用Visual C++建立SOAP客户端应用

    2007-08-25 00:33:34

     

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 46次

    Soap是一个在信息交换中使用得非常广泛的协议,使用方便,并直接可与HTTP, SMTP等其它协议一起工作。本文讨论如何使用Microsoft SOAP Tookit的C++来建立一个简单的SOAP客户端应用。
    =========================================================
    一、先决条件:
    必须熟悉使用COM,特别要熟悉COM中的Smart Pointers。我通过导入方法将COM接口转换成Smart Pointers。系统必须安装了Microsoft SOAP Toolkit和Microsoft XML Parser。文末参考一节介绍如何下载工具箱。文末附件可下载本文源程序。



    二、SOAP编程基础:
    下面开始介绍一个简单SOAP应用中所包含的类。在此之前,必需先导入所需的类型库,然后程序才能够使用SOAP的类。



    导入类型库:
    SOAP中使用的对象和接口都在mssoap1.dll文件中。这个文件在安装Microsoft SOAP Toolkit 2.0时生成,存在路径:"C:\Program Files\Common Files\MSSoap\Binaries\MSSOAP1.dll"。用#import将该文件导入到程序中。类型库的内容在导入时被转换成COM smart pointers来描述COM接口。因为SOAP完全依赖于XML,因此必需用Microsoft XML Parser来处理XML。Microsoft XML parser在msxml3.dll文件里。这个文件要在导入mssoap1.dll之前导入。



    #import "msxml3.dll"



    using namespace MSXML2;



    #import "C:\Program Files\Common Files\MSSoap\Binaries\MSSOAP1.dll" \



    exclude("IStream", "ISequentialStream", "_LARGE_INTEGER", \



    "_ULARGE_INTEGER", "tagSTATSTG", "_FILETIME")



    using namespace MSSOAPLib;



    上面这些代码是编写SOAP程序必需包含的。



    建立SOAP客户端应用有以下三步骤:
    1- 指定和连接Web服务器。
    2- 准备和发送消息。
    3- 读取服务端返回的信息。



    下面是在基本SOAP客户端要使用到的类:



    1- SoapConnector:
    在客户/服务模式下,首先要做的事就是连接服务器。SoapConnector类执行客户端与服务端之间的消息传送协议。 SoapConnector是一个抽象类,定义了协议执行的接口。事实上, SoapConnector类不定义执行某种特定的传送协议,例如:MSMQ, MQ Series, SMTP 和 TCP/IP等。 为简便起见,本文只说明使用HTTP传送协议,它是由Microsoft SOAP Toolkit 2.0中的HttpConnector 类来执行的。



    SoapConnector类使用步骤如下:
    a) 创建SoapConnector类对象:
     ISoapConnectorPtr connector;
     Connector.CreateInstance(__uuidof(HttpConnector));



    b) 指定Web服务器地址:
    指定服务器,要做二件事:选择HttpConnector的属性和相应的属性值。本文示例选用EndPointURL属性:
     Connector->Property ["EndPointURL"] = "some url pointing to web service";



    以下是属性选项说明(属性名是大小写敏感的):
    AuthPassword:客户口令
    AuthUser:客户名
    EndPointURL :客户URL
    ProxyPassword:  代理(proxy)口令
    ProxyPort :代理断口
    ProxyServer :代理服务器的IP地址或主机名
    ProxyUser :代理用户名
    SoapAction:HTTP的抬头值。这个属性只使用于低级API。它将忽略SoapClient接口(高级API)中的ConnectorProperty属性 。
    SSLClientCertificateName:指定使用Secure Sockets Layer (SSL)加密协议。语法如下:
     [CURRENT_USER | LOCAL_MACHINE\[store-name\]]cert-name with the defaults being CURRENT_USER\MY (与Microsoft Internet Explorer用法相同)。
    Timeout:HttpConnector的超时限制,以毫秒为单位。
    UseProxy:定义是否使用代理(proxy)。缺省值为False。如果将这个属性为真(True),又没有设置上面的ProxyServer值,代理服务器将使用IE里的代理服务器。此时HttpConnector将不理会IE的"Bypass Proxy"(绕道)设置。
    UseSSL:定义是否使用SSL(True 或 False)。此值设置为真时,HttpConnector对象不管WSDL设置是HTTP或HTTPS都用SSL连接方式。若此值设置为非真,HttpConnector对象只在WSDL设置为HTTPS时才用SSL方式连接。

    c) 与Web服务器连接:
     Connector->Connect();



    d) 指定动作:
    Connector->Property ["SoapAction"] = "some uri";



    e) 启动消息句柄:
    必需在SoapSerializer(消息准备函数)之前先启动消息处理机制
    Connector->BeginMessage();



    在消息处理完毕之后,用EndMessage()函数将消息送往服务器。
    .
    .
    [ 消息准备代码 ]
    .
    .
    Connector->EndMessage();



    以上就是与服务器连接的过程。下面介绍如何创建和准备消息。



    SoapSerializer:
    用于建立送往服务器的SOAP消息。在与服务器通讯之前,SoapSerializer对象必需先与SoapConnector对象连接。SoapSerializer的初始化函数将建立这个内部连接。初始化代入的参数是InputStream (数据流):
    // 创建SoapSerializer对象,并用InputSTream进行初始化。
     ISoapSerializerPtr Serializer;
     Serializer.CreateInstance(_uuidof(SoapSerializer));
     Serializer->Init(_variant_t((IUnknown*)Connector->InputStream));



    下面是SOAP请求代码:



    <SOAP: Envelope xmlns:SOAP="soap namespace">
    <SOAP:Body>
    <m:someMethodName xmlns:m="some namespace">
    <someParameter> someParameterValue </someParameter>
    <m:someMethodName>
    </SOAP:Body>
    </SOAP: Envelope>



    SOAP请求被安放在标记之中。<Envelope>是SOAP文件的主标记。SOAP信息通常都安放在”信封“(Envelope)里。信封里的<Body>标记中安放信息体,其中包含具体请求。在C++里,用相应的方法来解释这些标记并定义有关的值。
    下面的代码说明如何使用这些方法:




    Serializer->startEnvelope("SOAP","","");
    // 开始处理SOAP消息。第一个参数是命名空间,缺省为SOAP-ENV。
    // 第二个参数定义URI。第三个参数定义Serialzier->startBody("")函数的编码方式。
    // 开始处理<Body>元素,第一个参数是URI的编码类型,缺省为NONE。



    Serializer->startElement("someMethodName","","","m");
    // 开始处理Body里的子元素。
    // 第一个参数是元素名。第二个参数是URI。
    // 第三个参数编码类型。第四个参数是元素的命名空间。



    Serializer->WriteString("someParameterValue")
    // 写入元素值



    在上面的每个startXXX函数后都要又相应的endXXX函数来结尾。消息做完之后,连接器就调用endMessage()方法将消息发送到服务器。



    至此,我们已经连接了服务器,制作了相应的消息。最后一个步骤就是接收服务器回应。



    SoapReader:
    读取服务器返回的信息,将信息解析之后装入DOM,为进一步处理所用。下面是服务器返回的SOAP回应信息:



    <SOAP: Envelope xmlns:SOAP="soap namespace">
    <SOAP:Body>
    <m:someMethodNameResponse xmlns:m="some namespace">
    <return> someResult </return>
    <m:someMethodNameResponse>
    </SOAP:Body>
    </SOAP: Envelope>



    使用OutputStream来读取SoapReader对象中的信息。(OutputStream接收服务器返回的信息)。



    // 创建SOAPReader对象,并连接到outputstream
     ISoapReaderPtr Reader;
     Reader.CreateInstance(_uuidof(SoapReader));
     Reader->Load(_variant_t((IUnknown*)Connector->OutputStream));
    // load方法还可以用于加载XML文件或字符串



    将回应信息加载到SoapReader对象之后,就可以用它的RPCResult属性来获取结果。不过,But RPCResult并不直接返回结果,它返回<Body>的第一个实体元素,然后用text属性读取该元素属性值:
    Reader->RPCResult->text



    三、举例说明一个简单的SOAP客户端应用:
    本文示例用www.xmethods.net做服务器。这个服务器指向Yahoo在线信息。
    可以在http://www.xmethods.net/ve2/ViewListing.po?serviceid=156找到有关细节。
    下面的代码中要输入一个参数,即Yahoo的用户ID。返回结果为0表示离线,1表示在线。
    其他细节可参阅:http://www.allesta.net:51110/webservices/wsdl/YahooUserPingService.xml



    四、参考:
    The SOAP specification Simple Object Access Protocol (SOAP) 1.1 - W3C Note :
    http://www.w3.org/TR/SOAP
    Microsoft SOAP Toolkit Download :
    http://download.microsoft.com/download/xml/soap/2.0/w98nt42kme/EN-US/SoapToolkit20.exe



    五:本文示例的SOAP代码:
    #include <stdio.h>



    #import "msxml3.dll"
    using namespace MSXML2;



    #import "C:\Program Files\Common Files\MSSoap\Binaries\MSSOAP1.dll" \
    exclude("IStream", "ISequentialStream", "_LARGE_INTEGER", \
    "_ULARGE_INTEGER", "tagSTATSTG", "_FILETIME")
    using namespace MSSOAPLib;



    void main()
    {
       CoInitialize(NULL);



       ISoapSerializerPtr Serializer;
       ISoapReaderPtr Reader;
       ISoapConnectorPtr Connector;



       // 连接服务器
       Connector.CreateInstance(__uuidof(HttpConnector));
       Connector->Property["EndPointURL"] = "http://www.allesta.net:51110/webservices/soapx4/isuseronline.php";
       Connector->Connect();



       // 启动消息机制
       Connector->Property["SoapAction"] = "uri:allesta-YahooUserPing";
       Connector->BeginMessage();



       // 创建SoapSerializer对象
       Serializer.CreateInstance(__uuidof(SoapSerializer));



       // 与输入流连接
       Serializer->Init(_variant_t((IUnknown*)Connector->InputStream));



       // 制作SOAP信息
       Serializer->startEnvelope("","","");
       Serializer->startBody("");
       Serializer->startElement("isuseronline","uri:allesta-YahooUserPing","","m");
       Serializer->startElement("username","","","");
       Serializer->writeString("laghari78");
       Serializer->endElement();
       Serializer->endElement();
       Serializer->endBody();
       Serializer->endEnvelope();



       // 向服务器发送信息
       Connector->EndMessage();



       // 读取回应
       Reader.CreateInstance(__uuidof(SoapReader));



       // 连接输出流
       Reader->Load(_variant_t((IUnknown*)Connector->OutputStream), "");



       // 显示结果
       printf("Answer: %s\n", (const char *)Reader->RPCResult->text);
         CoUninitialize();
    }




    本文附件



    http://www.topxml.com/snippetcentral/snippetfiles/v20020425121357.zip

  • 直接通过ODBC读写Excel表格文件

    2007-08-25 00:31:18

     

    发布: 2007-7-14 21:11 | 作者: 佚名    | 来源: 网络转载     | 查看: 10次

    译者:徐景周(原作:Alexander Mikula)

    想要通过ODBC直接读、写Excel表格文件,首先,应确保ODBC中已安装有Excel表格文件的驱动"MICROSOFT EXCEL DRIVER (*.XLS)"。然后,可根据下面步骤进行:

    1. 在StdAfx.h文件中加入:

    #include <afxdb.h>
    #include <odbcinst.h>

    2. 通过ODBC直接创建Excel文件并在表中插入数据(暂定文件名:Demo.xls) //创建并写入Excel文件
    void CRWExcel::WriteToExcel()
    {
      CDatabase database;
      CString sDriver = "MICROSOFT EXCEL DRIVER (*.XLS)"; // Excel安装驱动
      CString sExcelFile = "c:\\demo.xls";                // 要建立的Excel文件
      CString sSql;
        
      TRY
      {
        // 创建进行存取的字符串
        sSql.Format("DRIVER={%s};DSN='''';FIRSTROWHASNAMES=1;READONLY=FALSE;CREATE_DB=\"%s\";DBQ=%s",
                    sDriver, sExcelFile, sExcelFile);

        // 创建数据库 (既Excel表格文件)
        if( database.OpenEx(sSql,CDatabase::noOdbcDialog) )
        {
          // 创建表结构(姓名、年龄)
          sSql = "CREATE TABLE demo (Name TEXT,Age NUMBER)";
          database.ExecuteSQL(sSql);

          // 插入数值
          sSql = "INSERT INTO demo (Name,Age) VALUES (''徐景周'',26)";
          database.ExecuteSQL(sSql);

          sSql = "INSERT INTO demo (Name,Age) VALUES (''徐志慧'',22)";
          database.ExecuteSQL(sSql);

          sSql = "INSERT INTO demo (Name,Age) VALUES (''郭徽'',27)";
          database.ExecuteSQL(sSql);
        }      

        // 关闭数据库
        database.Close();
      }
      CATCH_ALL(e)
      {
        TRACE1("Excel驱动没有安装: %s",sDriver);
      }
      END_CATCH_ALL;
    }

    3. 通过ODBC直接读取Excel文件(暂定文件名:Demo.xls) // 读取Excel文件
    void CRWExcel::ReadFromExcel()
    {
        CDatabase database;
        CString sSql;
        CString sItem1, sItem2;
        CString sDriver;
        CString sDsn;
        CString sFile = "Demo.xls";  // 将被读取的Excel文件名
                                         
        // 检索是否安装有Excel驱动 "Microsoft Excel Driver (*.xls)"
        sDriver = GetExcelDriver();
        if (sDriver.IsEmpty())
        {
            // 没有发现Excel驱动
            AfxMessageBox("没有安装Excel驱动!");
            return;
        }
        
        // 创建进行存取的字符串
        sDsn.Format("ODBC;DRIVER={%s};DSN='''';DBQ=%s", sDriver, sFile);

        TRY
        {
            // 打开数据库(既Excel文件)
            database.Open(NULL, false, false, sDsn);
            
            CRecordset recset(&database);

            // 设置读取的查询语句.
            sSql = "SELECT Name, Age "       
                   "FROM demo "                 
                   "ORDER BY Name ";
        
            // 执行查询语句
            recset.Open(CRecordset::forwardOnly, sSql, CRecordset::readOnly);

            // 获取查询结果
            while (!recset.IsEOF())
            {
                //读取Excel内部数值
                recset.GetFieldValue("Name ", sItem1);
                recset.GetFieldValue("Age", sItem2);

                // 移到下一行
                recset.MoveNext();
            }

            // 关闭数据库
            database.Close();
                                 
        }
        CATCH(CDBException, e)
        {
            // 数据库操作产生异常时...
            AfxMessageBox("数据库错误: " + e->m_strError);
        }
        END_CATCH;
    }

    4. 获取ODBC中Excel驱动的函数 CString CRWExcel::GetExcelDriver()
    {
        char szBuf[2001];
        WORD cbBufMax = 2000;
        WORD cbBufOut;
        char *pszBuf = szBuf;
        CString sDriver;

        // 获取已安装驱动的名称(涵数在odbcinst.h里)
        if (!SQLGetInstalledDrivers(szBuf, cbBufMax, &cbBufOut))
            return "";
        
        // 检索已安装的驱动是否有Excel...
        do
        {
            if (strstr(pszBuf, "Excel") != 0)
            {
                //发现 !
                sDriver = CString(pszBuf);
                break;
            }
            pszBuf = strchr(pszBuf, ''\0'') + 1;
        }
        while (pszBuf[1] != ''\0'');

        return sDriver;
    }

    作者信息:
    姓名:徐景周(未来工作室 Future Studio)
    EMAIL:jingzhou_xu@163.net

Open Toolbar