当前页面位置: » 丰搜网 » 文档中心 » 详细内容
用c++builder建立多线程com服务器
一、线程、apartment和进程
说道com的线程模型，大家就会想到各种apartment模型。但apartment究竟是什么？如何建立一个apartment呢？
apartment就是线程的容器，线程中有关com的操作必须在apartment中进行。 apartment分为sta和mta两种，sta是只能容纳一个线程的容器，mta是能容纳多个线程的容器。com规定，一个进程中可以有多个sta，但最多只能有一个mta。线程调用coinitializeex(null,coinit_apartmentthreaded)后，这个线程就建立并且进入了一个sta，线程调用coinitializeex(null,coinit_multithreaded)后，这个线程就进入了进程公用mta。一个线程不能同时进入两个apartment。线程调用couninitialize()后，这个线程就退出了它所在的apartment。设计com对象时设定的“apartment模型”就是指这个com对象可以呆在那种apartment中。一个线程建立的com对象自动地呆在这个线程所在的apartment中。要是这个线程建立了很多个com对象，那这些对象都呆在这个线程所在的apartment中。
一个线程可以直接访问它所在的apartment中的com对象，但要访问另一个apartment中的com对象就必须经过调度。因为sta中只有一个线程，别的线程要访问这个线程建立的com对象就必须让这个线程代劳了，如此一来，对这个apartment中所有的com对象的访问都是序列化的，这些com对象就不用担心有好几个线程同时访问它的麻烦事。mta中的com对象就没这么舒服了，它们必须考虑到可能会有好几个线程同时访问它们。mta之外的一个线程访问mta中的一个com对象时，系统会从com系统线程池中取出一个线程进入mta，由它来代表客户线程访问这个com对象。（com系统线程池的机理是怎么样的？池中有几个线程？）
二、客户与服务器
com对象位于服务器中，服务器分为进程内服务器、进程外服务器、远程服务器三种。进程内服务器是一个dll文件，进程外服务器是一个exe文件，远程服务器是另一台计算机上的一个dll文件或exe文件。远程服务器如果是一个dll文件的话，由一个被称为“surrogate”的代理程序调用它。
进程内服务器中的com对象的apartment模型如果与客户线程所在的apartment相配合的话，客户线程建立com对象时会直接建立在客户线程所在的apartment中。比如apartment模型与sta、free模型与mta，both模型与sta或mta。这样客户线程就可以直接调用com对象而不用调度。否则就会专门建立一个线程，然后由这个线程建立com对象，com对象和客户线程就分处在两个apartment中。进程外服务器和远程服务器中的com对象一定不会建立在客户线程所在的apartment中。对它们的调用一定要经过调度的。
三、在c++builder下建立一个多apartment的进程外服务器
由于不必考虑并行的问题，com对象一般设成使用apartment线程模型。进程内服务器还没什么问题，如果你试着建了一个进程外服务器，并且让几个客户同时访问服务器中的对象的话，就会发现这些访问不是同时进行的。如果有一个访问特别费时间，它后面的访问就要等很久才能进行。这是因为服务器中只有一个sta，虽然每个线程都建立了自己的com对象，但这些对象都在这个sta中，当然无法并行执行。
克服这个问题的办法很简单，打开borland\cbuilder5\include\atl\atlmod.h文件，把第266行的：
typedef tatlmodule tcommodule;
改成：
#ifdef __dll__
typedef tatlmodule tcommodule;
#else
typedef tatlmodule > tcommodule;
#endif
再打开borland\cbuilder5\include\atl\atlcom.h文件，把第3214行的：
declare_classfactory()
改成：
#ifdef __dll__
declare_classfactory()
#else
declare_classfactory_auto_thread()
#endif |
就可以了。重新编译你的程序，同时开两个客户试一试，是不是并发执行了？
先别高兴得太早，如果你同时开了五个客户，并且其中四个在执行费时的访问，你就会发现第五个客户的访问要等待一段时间。这种现象与c++builder的实现代码有关。
作了前面的修改后，
服务器启动后会预先生成几个
线程，这些
线程各自进入一个sta中。当
服务器接到客户的访问要求后，会循环指定一个
线程负责这个客户的建立com对象、访问com对象的事务。
比如第一个客户要求建立一个com对象，
服务器就给一号
线程发消息，让这个
线程建立一个com对象并把这个com对象的接口传给客户，以后第一个客户对这个com对象的访问就全由一号
线程代理。而第二个客户的建立com对象、访问com对象的事务就由
服务器指定二号
线程来办，如果客户太多，
线程用完了，
服务器又会让一号
线程负责客户的要求，依次循环。如果客户很多，
线程可能会负责几个客户的访问要求，而由同一个
线程服务的客户的访问就会顺序执行。预先生成的
线程数缺省为系统的cpu个数乘以四，也就是四个（除非你的机器有好几个cpu）。
只能同时服务四个客户当然是不行的，让我们继续修改。打开主cpp文件，可以看到下面两行代码：
tcommodule projectmodule(0);
tcommodule &_module = projectmodule;
改为：
tcommodule projectmodule(myinitatlserver);
tcommodule &_module = projectmodule;
其中“myinitatlserver”是一个新加的函数，定义如下：
void __fastcall myinitatlserver()
{
if (_module.saveinitproc)
_module.saveinitproc();
_module.init(objectmap, sysinit::hinstance, null, 6);//注意这个6
_module.m_threadid = ::getcurrentthreadid();
_module.m_bautomationserver = true;
_module.dofileandobjectregistration();
addterminateproc(_module.automationterminateproc);
} |
看到那个6没有，这代表
服务器启动后会预先生成6个
线程，也就能同时服务6个客户。这个6可以改成别的数，当然不要太大了，不然机器垮了可别怪我。
改到现在你可能比较满意了，但其实这个
服务器还是有缺陷：一开始就生成所有
线程是不是太浪费了？循环分配
线程好象也不太合理，更重要的是，如果客户程序中途垮了，没有release它建立的com对象，那这个com对象将一直存在下去，占用的资源无法收回。
要解决这些问题就比较麻烦了，建议大家看一看atl源代码，编写自己的tcommodule类和ccomthreadallocator类。
四、编写多线程客户程序时要注意的问题 建立客户程序时必须包含的*_atl.h文件中有一个很好的com对象包装类。比如我建立了一个comlib
服务器，里面有一个mycomobj对象，那么在comlib_atl.h文件中有一个tcomimycomobj类，它很好的封装了mycomobj对象。写单
线程程序时可以这样建立它：
tcomimycomobj acomobj = comycomobj::createinstance();
（comycomobj是定义在在comlib_atl.h文件中的一个辅助类）然后就可以使用acomobj了，不必调用coinitializeex()和couninitialize()，也不必释放acomobj。假设mycomobj对象中定义了一个方法fun()，一个属性num，可以这样使用：
acomobj.fun();
acomobj.num = 14;
int val = acomobj.num;
注意到num的访问方法了吗？c++builder灵活运用了特有的__property关键字，不必调用get_num()和set_num()了。
如果在写多
线程客户程序时也这样就会出问题：除了第一个
线程正常外，后面的的
线程无法建立com对象了。
问题出在comycomobj里面，它保证了会调用coinitializeex()和couninitialize()并且在整个进程中只会调用一次。而在多
线程客户程序中，每个
线程都必须调用coinitializeex()和couninitialize()一次。因此，除了第一个
线程成功进入了apartment，别的
线程都失败了。
可以这样建立tcomimycomobj对象：
coinitializeex(null, coinit_apartmentthreaded);
imycomobj *pcomobj;
olecheck(cocreateinstance(clsid_mycomobj, null, clsctx_local_server
, iid_imycomobj, (void **)(&pcomobj)));
tcomicomobjinexe acomobj(pcomobj);
……使用acomobj……
couninitialize(); |
注意，这段代码必须写在tthread::execute()中，因为只有tthread::execute()里的代码才是真正运行在新
线程中的。另外决不能调用pcomobj->release()。
后记 学com的念头起于看李维写的那三本书中的第一本的时候，李维描述了建立多
线程服务器的重要性，但具体方法只是一笔带过。后来我看了
delphi带的例子，想用在c++builder中，却无从下手。在关于com的部分，
delphi和c++builder相差太大了，而又没有这方面的c++builder的书，网上的资料也很少，只好自己摸索。期间曾在网上发贴提问，总是没人回答，痛苦啊！
