WEB开发网      婵犵數濮烽弫鍛婄箾閳ь剚绻涙担鍐叉搐绾剧懓鈹戦悩瀹犲闁汇倗鍋撻妵鍕箛閸洘顎嶉梺绋款儑閸犳劙濡甸崟顖氬唨闁靛ě浣插亾閹烘鈷掗柛鏇ㄥ亜椤忣參鏌″畝瀣暠閾伙絽銆掑鐓庣仭缁楁垿姊绘担绛嬪殭婵﹫绠撻、姘愁樄婵犫偓娴g硶鏀介柣妯款嚋瀹搞儱螖閻樺弶鍟炵紒鍌氱Ч瀹曟粏顦寸痪鎯с偢瀵爼宕煎☉妯侯瀳缂備焦顨嗗畝鎼佸蓟閻旈鏆嬮柣妤€鐗嗗▓妤呮⒑鐠団€虫灀闁哄懐濮撮悾鐤亹閹烘繃鏅濋梺闈涚墕濡瑩顢欒箛鏃傜瘈闁汇垽娼ф禒锕傛煕閵娿儳鍩f鐐村姍楠炴﹢顢欓懖鈺嬬幢闂備浇顫夊畷妯肩矓椤旇¥浜归柟鐑樻尭娴滃綊姊虹紒妯虹仸闁挎洍鏅涜灋闁告洦鍨遍埛鎴︽煙閼测晛浠滃┑鈥炽偢閹鈽夐幒鎾寸彇缂備緡鍠栭鍛搭敇閸忕厧绶炴俊顖滅帛濞呭洭姊绘担鐟邦嚋缂佽鍊垮缁樼節閸ャ劍娅囬梺绋挎湰缁嬫捇宕㈤悽鍛婄厽閹兼番鍨婚埊鏇㈡煥濮樿埖鐓熼煫鍥ュ劤缁嬭崵绱掔紒妯肩畺缂佺粯绻堝畷姗€濡歌缁辨繈姊绘担绛嬪殐闁搞劋鍗冲畷顖炲级閹寸姵娈鹃梺缁樻⒒閳峰牓寮崒鐐寸厱闁抽敮鍋撻柡鍛懅濡叉劕螣鐞涒剝鏂€闂佺粯鍔曞Ο濠囧吹閻斿皝鏀芥い鏃囨閸斻倝鎽堕悙鐑樼厱闁哄洢鍔屾晶顖炴煕濞嗗繒绠婚柡灞界Ч瀹曨偊宕熼鈧▍锝囩磽娴f彃浜炬繝銏f硾椤戝洨绮绘ィ鍐╃厵閻庢稒岣跨粻姗€鏌ㄥ☉妯夹fい銊e劦閹瑩顢旈崟顓濈礄闂備浇顕栭崰鏍礊婵犲倻鏆﹂柟顖炲亰濡茶鈹戦埄鍐ㄧ祷妞ゎ厾鍏樺璇测槈閵忕姈鈺呮煏婢跺牆鍔撮柛鏂款槺缁辨挻鎷呯粙搴撳亾閸濄儳鐭撶憸鐗堝笒閺嬩線鏌熼崜褏甯涢柡鍛倐閺屻劑鎮ら崒娑橆伓 ---闂傚倸鍊搁崐鐑芥倿閿旈敮鍋撶粭娑樺幘濞差亜鐓涢柛娑卞幘椤斿棝姊虹捄銊ユ珢闁瑰嚖鎷�
开发学院软件开发Delphi 开发一个基于DCOM的局域网聊天室(二) 阅读

开发一个基于DCOM的局域网聊天室(二)

 2006-02-04 13:43:55 来源:WEB开发网 闂傚倸鍊搁崐椋庢濮橆兗缂氱憸宥堢亱闂佸湱铏庨崰鏍不椤栫偞鐓ラ柣鏇炲€圭€氾拷闂傚倸鍊搁崐椋庣矆娓氣偓楠炲鏁撻悩鎻掔€梺姹囧灩閻忔艾鐣烽弻銉︾厵闁规鍠栭。濂告煕鎼达紕校闁靛洤瀚伴獮鎺楀箣濠靛啫浜鹃柣銏⑶圭壕濠氭煙閻愵剚鐏辨俊鎻掔墛缁绘盯宕卞Δ鍐冣剝绻涘畝濠佺敖缂佽鲸鎹囧畷鎺戭潩閹典焦鐎搁梻浣烘嚀閸ゆ牠骞忛敓锟�婵犵數濮烽弫鍛婃叏椤撱垹绠柛鎰靛枛瀹告繃銇勯幘瀵哥畼闁硅娲熷缁樼瑹閳ь剙岣胯鐓ら柕鍫濇偪濞差亜惟闁宠桨鑳堕崝锕€顪冮妶鍡楃瑐闁煎啿鐖奸崺濠囧即閵忥紕鍘梺鎼炲劗閺呮稒绂掕缁辨帗娼忛埡浣锋闂佽桨鐒﹂幑鍥极閹剧粯鏅搁柨鐕傛嫹闂傚倸鍊搁崐椋庢濮橆兗缂氱憸宥堢亱闂佸湱铏庨崰鏍不椤栫偞鐓ラ柣鏇炲€圭€氾拷  闂傚倸鍊搁崐鐑芥嚄閼哥數浠氱紓鍌欒兌缁垶銆冮崨鏉戠厺鐎广儱顦崡鎶芥煏韫囨洖校闁诲寒鍓熷铏圭磼濡搫顫嶅銈嗗姉閸樠囧煡婢跺á鐔兼煥鐎n兘鍋撴繝姘拺鐟滅増甯掓禍浼存煕閹惧鈽夐柍缁樻煥椤繈鎳滅喊妯诲闂備礁鎲$粙鎴︺偑閺夋垟鏋旈柡鍐e亾缂佺粯绋撴禒锕傚磼濮橆剦鐎抽梻浣哥-缁垶骞戦崶顒傚祦閻庯綆浜栭弨浠嬫煙闁箑澧い鏂垮€规穱濠囨倷椤忓嫧鍋撻弽褜娼栧┑鐘宠壘閸屻劎鎲歌箛娑樼疅闁圭虎鍠楅弲鎼佹煥閻曞倹瀚�
核心提示: TchatRoom的实现:{ TChatRoom }constructor TChatRoom.Create(RoomName:string;RoomID:integer);begin FBufferLength:=0; FConnectCount:=0; FClearBufferTag:=1; FLocked:=f
 

TchatRoom的实现:

{ TChatRoom }

constructor TChatRoom.Create(RoomName:string;RoomID:integer);

begin

 FBufferLength:=0;

 FConnectCount:=0;

 FClearBufferTag:=1;

 FLocked:=false;

 FRoomName:=RoomName;

 FRoomID:=RoomID;

end;

 

PRocedure TChatRoom.ClearBuffer;

var

 i:integer;

begin

 ///在这里可以检测一个标志,判断是否需要服务器记录每一次聊天内容

 for i:=1 to 20 do

  FBuffer[i]:='';

 FBufferLength:=0;

 FClearBufferTag:=0-FClearBufferTag;

end;

 

procedure TChatRoom.OneSpeak(content:string);

begin

 FLocked:=true;

 inc(FBufferLength);

 if FBufferLength>20 then

 begin

  ClearBuffer;

  inc(FBufferLength);

 end;

 FBuffer[FBufferLength]:=content;

 FLocked:=false;

end;

 

function TChatRoom.OneRead:TStrings;

var

 FStrings:TStrings;

 i:integer;

begin

 FLocked:=true;

 FStrings:=TStringList.Create;

 for i:=1 to FBufferLength do

  FStrings.Add(FBuffer[i]);

 result:=FStrings;

 FLocked:=false;

end;

 

function TChatRoom.GetCanRead: boolean;

begin

 result:=false;

 if FBufferLength>0 then result:=true;

end;

 

procedure TChatRoom.LoginRoom(UserName:string);

//用户登陆聊天室事件,这里没有完全实现

begin

 inc(FConnectCount);

end;

 

procedure TChatRoom.LeaveRoom(UserName: string);

//用户离开聊天室事件,这里没有完全实现

begin

 Dec(FConnectCount);

end;

服务器端的最后一个比较重要的部分TchatRoomManager:

type

 TChatRoomManager=class

 private

  ChatRoom:array of TChatRoom;

 public

  constructor Create;

  function FindRoomByID(id:integer):TChatRoom;

 end;

实现部分:

{ TChatRoomManager }

 

constructor TChatRoomManager.Create;

var

 i,RoomCount:integer;

 RoomNames:TStrings;//RoomName是配置文件中的聊天室名称

begin

 RoomCount:=1;

 //这里将从配置文件中读出有几个聊天室

 RoomNames:=TStringList.Create;

 RoomNames.Add('TestRoom');//这句将被最终的从配置文件读取替换掉

 setlength(ChatRoom,RoomCount);

 for i:=1 to RoomCount do

  ChatRoom[i]:=TChatRoom.Create(RoomNames[i-1],i);

end;

 

function TChatRoomManager.FindRoomByID(id:integer): TChatRoom;

//该函数由IChatManager接口调用,由于最终版本的接口将会提供给客户

//端得到房间列表的功能,所以客户端知道自己房间的id

begin

 result:=ChatRoom[id];

end;

 

initialization

 ChatRoomManager:=TChatRoomManager.Create;

end.

在服务器端的主要核心部分完成以后,我们配置好服务器端的DCOM配置,就可以开发一个简单的客户端进行测试了:(虽然客户端尽可能的简单,我们不用配置DCOM但我们仍需要拷贝服务器端的类型库文件.tlb到客户端并注册后才能开发和使用客户端,当然,这些都可以通过安装程序来完成)

在客户端我们只列出两个相对重要的函数,其余的都省略,请想我来信获得全部的程序:

procedure TForm1.Button1Click(Sender: TObject);

//点击button1后将edit的内容“说”出去

begin

 Server.SpeakTo(edit1.Text,1);

end;

 

procedure TForm1.Timer1Timer(Sender: TObject);

//每隔一段时间向服务器请求谈话内容,我设置了为1.5秒

var

 TempStrings:TStrings;

 i:integer;

begin

 if Server.ReadReady(1)=1 then

 begin

  TempStrings:=TStringList.Create;

  SetOleStrings(TempStrings,Server.ReadFrom(1));

  if FReadStartPos>19 then

  if (FClearBufferTag=0-Server.TestClearBufferTag(1)) then

  begin

   FReadStartPos:=0;

   FClearBufferTag:=Server.TestClearBufferTag(1);

  end;

  for i:=FReadStartPos to TempStrings.Count-1 do

  Memo1.Lines.Add(TempStrings[i]);

  FReadStartPos:=TempStrings.Count;

 end;

end;

一个基于DCOM的局域网聊天室的核心部分就基本完成了,并且所有的测试都比较顺利,这里需要补充说明一下聊天室服务器的一个难点:就是需要开发者非常谨慎的处理同步,虽然我也进行了一定的同步处理,但在客户端人数众多的情况下仍然可能发生死锁或其它活锁的情况,这个程序还需要更进一步的测试、甚至进行一定的重构。尽请关注后文。

Tags:开发 一个 基于

编辑录入:爽爽 [复制链接] [打 印]
赞助商链接