用C++Builder打造网上聊天软件--MyNetMeeting

 

  

随着 Internet 和局域网的飞速发展和普及,越来越多的企事业单位和学校的都已经建成局域网并接上了Internet 。在局域网或Internet 上很需要一些软件能够很方便快捷地实现互相发送信息和传送文件等功能,我们编写的这个聊天软件――MyNetMeeting就是用来适应这个要求的。它的功能包括网上聊天或网上会议(NetMeeting),一对一的即时信息交换,以及相互传送文件。

一. 软件的分析和设计:

  现在在网上有很多聊天软件,例如现在很流行OICQ 可以很方便简单的实现两个人之间聊天但是在局域网上比较难实现多人共同通信即NetMeeting,即使有也是要通过互联网上的Web的聊天室。这样不仅不够方便快捷(尤其对于在同一个局域网内的来说),而且还有价格昂贵和安去性不好等诸多问题。比如有时候,一间公司想在网上开一个会议,如果通过互联网上的聊天室,不仅上网费用高昂,速度又慢,而且还容易泄漏商业秘密,得不偿失。针对这个情况,我们就设计出这个集NetMeeting和Oicq功能于一身的软件--MyNetMeeting。
这个软件可以在局域网上实现快速的网上通信,既省钱又省时间。而且服务端是运行在局域网里的本地PC机上,既安全又方便管理,而且速度快,方便可靠。服务端可以运行在本地局域网里的普通PC机内,不用特别的服务器,所以可以大大节省成本,而且实现简单,不对后台数据库做出要求。但如果有需要的话,也可以很方便的实现后台数据库支持。

二.软件架构:

我们做的聊天软件包括服务器端部分和客户端部分。服务器端包括了三个部分,会议内容,在线用户的昵称,在线用户的地址。使用这个聊天软件的时候,首先要登陆服务器,服务器就把登陆上来的用户的昵称和地址登记下来,这样就可以很方便的监测和管理在线用户。

 

客户端包括三部分:第一,网上会议;第二,私聊空间;第三,发送文件。还有右边有个在线用户列表列出当前在线的所有用户。下面时语句输入框,输入要发送的信息。


三.软件的功能和特点:

1.网上聊天和网上会议(NetMeeting)
  如右图所示,网上会议实现的功能是多个人同时一起在网上实时开会,所以一个人发的信息所有在线用户都可以看得到(类似于聊天室)。左上的Memo就放着会议的内容(什么时间,谁说过什么),还有是系统信息(谁在加入了会议,或是谁退出了会议等)。只需在那里的空白位置进行右击,按连接服务器,就可以连到服务器里进行聊天及会议;按字体颜色就可以根据自己的喜好改变字体的颜色;按显示/隐藏在线用户,就可以把右面的在线用户列表显示或者隐藏起来。左下那个Memo是你要发送的信息,在框里打上要说的话,按发送或者快捷键Alt+S就可以把信息发送出去。右边是一个在线用户的列表,随时都可以看到在线用户的名单。(如果想发送个人信息或者传送文件,在用户列表中击鼠标右键弹出菜单,选择发送信息或传送文件)。

2.私聊空间
  私聊空间是用来在线用户之间一对一发送信息的(其他人无法收到)。  要私聊时,先在在线用户列表中选择你私聊的对象,双击鼠标左键,这时左上的label就会显示你选择的私聊对象(右图中的私聊对象是laixh)。那你就可以单独地跟你选择的私聊对象发送信息,说悄悄话啦。具体的操作就像和网上会议操作一样。

3.传送文件
  如果要传送文件,可以先点发送文件这一页,然后在右面的列表中选择你要传送文件给那个在线用户,同样,"发送文件到:"后面的label会显示该用户,之后用浏览选择要传送的文件(也可以直接把文件以及文件的路径输进去),再按发送就可以把文件传送到你选定的用户。

 

四.软件具体实现

1. 软件平台:Windows98 + Borland C++Builder5.0

2. 在实现发送和接收文件中的流数据,我使用了Builder里面的NerMasters控件中的NMStrm和NMStrmServ两个控件。NMStrm控件是一个基于TCP/IP的流控件。它可以接收流数据,然后通过网络将其发送给服务器。此控件包括一些方法和属性,例如,设置数据的来源等。NMStrmServ控件可以接收从客户端发送来的数据流。流服务器只监听TCP/IP端口,不负责监听UDP 端口,默认的端口号是6771。要发送的文件流数据,只需要简单地调用NMStrm控件地PostIt方法。而当有流数据发送到服务端,触发NMStrmAerv控件地OnMsg事件时,可以在此事件处理函数中完成文件地显示等处理工作。

3. WinSock是一组用C语言写的API,用于通过Internet进行数据传输。通过WinSock编程可以获得更大的灵活性。编写WinSock应用程序本来是很麻烦的,不过,在C++ Builder 5.0中,您并不需要直接与WinSock中的API打交道,因为C++ Builder 5.0新增加了TClientSocket控件和TserverSocket控件,这两个控件封装了Windows的有关API,使得对WinSock的访问大大简化。用Socket 建立的连接是建立在TCP/IP协议基础上的,同时也支持其它相关的协议,如XNS、DECnet以及 IPX/SPX等。Socket的连接必须要建立有一个服务器端(Server)和一个客户端(Client)。在C++ Builder 5.0中分别用TClientSocket控件和TServerSocket控件来操纵客户端Socket与服务器端Socket的 连接和通信。这两个控件用于管理服务器和客户的连接,它们本身并不是Socket对象,操纵 Socket对象的是TCustomWinSocket及其派生类,如TClientWinSocket、TserverWinSocket . TServerClientWinSocket等。

  Socket之间的连接可以分为三种类型:客户端连接、监听连接以及 服务器端连接,所谓客户端连接,是指由客户端的Socket提出连接请求,要连接的目标是服务 器端的Socket。为此,客户端的Socket必须首先描述它要连接的服务器端Socket(主要是指服务器 端Socket的地址和端口号),然后再定位所要连接的服务器端Socket,找到以后,就向服务器端 Socket请求连接。当然,服务器端的Socket此时未必正好处于准备好状态,不过,服务器端的 Socket会自动维护客户请求连接的队列,然后在它认为合适的时候向客户端Socket发出"允许连接" (Accept)的信号,这时客户端Socket与服务器端Socket的连接就建立了。所谓监听连接,服务器端 Socket并不定位具体的客户端Socket,而是处于等待连接的状态。当服务器端Socket监听到或者说 接收到客户端Socket的连接请求,它就响应客户端Socket的请求建立一个新的Socket句柄并与客户 端连接,而服务器端Socket继续处于监听状态,还可以接收其它客户端Socket的连接请求。所谓服 务器端连接,是指当服务器端Socket接收到客户端Socket的连接请求后,就把服务器端Socket的描述 发给客户端,一旦客户端确认了此描述,连接就建立了。在本文中的聊天程序用的就是监听连接, 即服务器设置连接个数后进行监听,客户端进行对服务器端的连接,这样就可以进行相互通信了。

1.服务器端  

  ServerSocket:用于与多个客户端连接,当有 用户登陆时就把他的昵称和他的主机地址用两 个列 表对应地登记下来,并把当前的所有用户的信息( 包括昵称和主机地址)发送给刚刚登陆的该用户, 那么刚登陆的用户就有了所有在线用户的信息。同 时,服务器会把新登陆的用户的信息发送给所有已在线的用户,那么已在线用户就都得到新登陆用户的信息。当NetMeeting的时候,用户的信息首先发送到服务器端上,服务器端根据在线用户列表的记录再把该信息转发到所有在线用户,这样所有用户都会收到信息,从而实现了多人的NetMeeting。

属性 描述
Name ServerSocket1 名称
Active Ture或False 是否激活
Port 4000 端口
ServerType stNonBlocking 服务类型(当取stNonBlocking值时为每一个连接上的ClientSocket分配一个独立线程)
ThreadCacheSize 30 最大连接ClientSocket数目
方法 描述
OnAccept 建立和 ClientSocket连接
OnClientConnect 有ClientSocket连接
OnClientDisconnect ClientSocket断开连接
OnClientError ClientSocket出错
OnClientRead ClientSocket发送信息到ServerSocket
OnListen 正在监听

主要代码:
void __fastcall TForm1::Button1Click(TObject *Sender) //关闭服务器
{
AnsiString SysInfo;
SysInfo="["+TimeToStr(Now())+"]"+" 与服务器失去连接!请重新连接!";
for(int i=0;i<m;i++)
{ServerSocket1->Socket->Connections[i]->SendText(SysInfo);}
ServerSocket1->Close();
Form1->Close();
}

void __fastcall TForm1::ServerSocket1ClientRead(TObject *Sender,
TCustomWinSocket *Socket)
{
AnsiString Data=Socket->ReceiveText(); //接收用户发送的信息
AnsiString SubData1=Data.SubString(Data.Length()-7,Data.Length()); //分析信息
if(SubData1=="@login@@") //如果是用户登陆的信息
{
int AddLen=StrToInt(Data.SubString(1,2));
AnsiString Address=Data.SubString(3,AddLen);
AnsiString SubData2=Data.SubString(3+AddLen,Data.Length()-8-2-AddLen);
ListBox1->Items->Add(SubData2); //用户信息加入到用户列表
ListBox2->Items->Add(Address);
AnsiString SysInfo="["+TimeToStr(Now())+"]"+SubData2+" 加入了会议!";//显示系统信息
Memo1->Lines->Add(SysInfo);
}
else if(SubData1=="@logout@") //如果是用户退出会议
{
int AddLen=StrToInt(Data.SubString(1,2));
AnsiString Address=Data.SubString(3,AddLen);
AnsiString SubData2=Data.SubString(3+AddLen,Data.Length()-8-2-AddLen);
int Index1;
Index1=ListBox1->Items->IndexOf(SubData2); //从用户列表中删除该用户信息
ListBox1->Items->Delete(Index1);
int Index2;
Index2=ListBox2->Items->IndexOf(Address);
ListBox2->Items->Delete(Index2);
Memo1->Lines->Add("["+TimeToStr(Now())+"]"+SubData2+" 退出了会议!"); //显示系统信息
}
else
{
Data="["+TimeToStr(Now())+"]"+Data; //加入系统时间
Memo1->Lines->Add(Data);
}
if(m!=0)
{
for(int i=0;i<m;i++)
{ServerSocket1->Socket->Connections[i]->SendText(Data);} //向所有用户转发信息
}}

void __fastcall TForm1::ServerSocket1Accept(TObject *Sender, //与客户端建立连接
TCustomWinSocket *Socket)
{
for(int i=0;i<m;i++)
{AnsiString SysInfo1=IntToStr(ListBox2->Items->Strings[i].Length())+ListBox2->
Items->Strings[i]+ListBox1->Items->Strings[i]+"@login@@"; //把所有在线用户信息发给用户
ServerSocket1->Socket->Connections[m]->SendText(SysInfo1);
}
m=m+1;
}

void __fastcall TForm1::ServerSocket1ClientDisconnect(TObject *Sender,//有用户退出会议
TCustomWinSocket *Socket)
{
m=m-1;
}

2.客户端

ClientSocket1:用于NetMeeting中从服务器上收取信息,或者发信息到服务器上;

属性 取值 描述
Active True或False 是否激活
Address 202.116.191.168 ServerSocket地址
ClientType 连接类型 当取stNonBlocking值时为每一个连接上的ClientSocket分配一个独立线程
Host Minghao ServerSocket地址
Name ClientSocket 名称
Port 4000 端口
方法 描述
OnConnect 连接到ServerSocket
OnDisconnect 断开到ServerSocket的连接
OnConnecting 正在连接
OnRead 收到信息

  ClientSocket2和Serversocket:与某一用户私聊时收发信息;因为用户一登陆到服务器端就立刻收到所有用户的信息,在客户端用两个列表保存着这些用户信息。当要私聊的时候,可以根据这些用户信息,找到该用户的地址,再直接把信息发送到想要私聊的对象的主机上(当然这一切都是通过鼠标在用户列表中点击选择私聊对象实现,简单快捷)。那么用户就可以收到该信息,而其他人根本无法得到这些信息(即使是服务器端也无能为力,所以这里私聊是有一定安全保密性的)。而且,这样还有一个好处就是当客户端和服务器端断开连接后,私聊还可以继续,毫无影响,因为在线用户信息一早保存到客户端拉。当然,这样在线用户的信息无法更新,即有用户登陆或退出都无法知道,因为你保存的是断线之前的用户信息。

NMStrm和NMStrmServ:用户之间传送文件的控件;
NMStrm:

属性 取值 描述
Host (动态) 主机地址
Name NMStrm1 名称
Port 6711 端口
ReportLevel 报告等级 细节报告等级
方法 描述
OnConnect 连接到主机
OnHostResovled 解析主机地址
OnMessageSect 发送完数据

NmStrmServ:

属性 取值 描述
Host (动态) 客户端地址
Name 名称 NMStrmServ1  
Port 6711 端口
ReportLevel 报告等级 细节报告等级
方法 描述
OnConnect 连接到客户端
OnHostResovled 解析主机地址
OnMsg 接收NMStrm发送的数据

OpenDialog:用于用户间传送文件时选择要传送的文件;
SaveDialog:当有用户向你传送文件时用来保存文件;
Timer:控制发送信息时间,超时管理;

客户端主要代码:

void __fastcall TForm1::ClientSocket1Connect(TObject *Sender,
TCustomWinSocket *Socket) //连接服务器
{
AnsiString Data="成功连接到服务器"+ClientSocket1->Host;
StatusBar1->SimpleText="成功连接到服务器...";
}

void __fastcall TForm1::N1Click(TObject *Sender) //登陆到服务器
{
ListBox1->Items->Clear();
ListBox2->Items->Clear();
if(IsLand)
{if(InputQuery("登陆到服务器","请输入你的昵称:",NickName)) //输入昵称
{
ClientSocket1->Open();
Timer1->Enabled=true;
BitBtn1->Enabled=true;
BitBtn3->Enabled=true;
IsLand=false; }
else ShowMessage("请输入你的昵称.");}
else
{
ClientSocket1->Open();
Timer1->Enabled=true;
}
}

void __fastcall TForm1::BitBtn1Click(TObject *Sender) //发送信息
{
if(Memo2->Lines->Text=="")
{
ShowMessage("错误, 不能发空信息!");
}
else
{
AnsiString Data;
Data=NickName+":"+Memo2->Lines->Text;
ClientSocket1->Socket->SendText(Data);
Memo2->Lines->Clear();
}
}

void __fastcall TForm1::ClientSocket1Read(TObject *Sender,
TCustomWinSocket *Socket) //接收服务器发送过来的信息
{
Form1->SetFocus(); //获得焦点
AnsiString Data=Socket->ReceiveText(); //接收信息
AnsiString SubData1=Data.SubString(Data.Length()-7,Data.Length());
if(SubData1=="@login@@") //判断标志位
{
int AddLen=StrToInt(Data.SubString(1,2));
AnsiString Address=Data.SubString(3,AddLen);
AnsiString SubData2=Data.SubString(3+AddLen,Data.Length()-8-2-AddLen);
ListBox1->Items->Add(SubData2); //加入在线用户
ListBox2->Items->Add(Address);
AnsiString SysInfo=SubData2+" 加入了会议!";
Memo1->Lines->Add(SysInfo);
}
else if(SubData1=="@logout@")
{
int AddLen=StrToInt(Data.SubString(1,2));
AnsiString Address=Data.SubString(3,AddLen);
AnsiString SubData2=Data.SubString(3+AddLen,Data.Length()-8-2-AddLen);
int Index1;
Index1=ListBox1->Items->IndexOf(SubData2);
ListBox1->Items->Delete(Index1); //删除在线用户
int Index2;
Index2=ListBox2->Items->IndexOf(Address);
ListBox2->Items->Delete(Index2);
Memo1->Lines->Add(SubData2+" 退出了会议!");
}
else
{
Memo1->Lines->Add(Data);
}
}

void __fastcall TForm1::ListBox1Click(TObject *Sender) //私聊空间或传送文件选定对象
{
if(ClientSocket2->Active)
{ClientSocket2->Close();}
int Index=ListBox1->ItemIndex;
HostName=ListBox2->Items->Strings[Index];
Label11->Caption=ListBox1->Items->Strings[Index];
Label2->Caption=ListBox1->Items->Strings[Index];
ClientSocket2->Host=HostName;
ClientSocket2->Open();
BitBtn3->Enabled=true;
}

void __fastcall TForm1::BitBtn3Click(TObject *Sender) //在私聊空间发送信息给选定用户
{
if(Memo4->Lines->Text=="")
{
ShowMessage("错误, 不能发空信息!");
}
else
{
AnsiString Data;
Data=NickName+"对"+Label11->Caption+"说:"+Memo4->Lines->Text;
ClientSocket2->Socket->SendText(Data);
Memo3->Lines->Add(Data);
Memo4->Lines->Clear();
}
}

void __fastcall TForm1::BitBtn5Click(TObject *Sender) //选择要传送的文件
{
if(OpenDialog1->Execute())
{Edit1->Text=OpenDialog1->FileName;
FileName=OpenDialog1->FileName;
for(int n=FileName.Length()-1;n>=1;n--)
{
if(FileName.SubString(n,1)==".")
{
FileName=FileName.SubString(n+1,FileName.Length()-n) ;
BitBtn6->Enabled=true;
break;
}
}
}
}

void __fastcall TForm1::NMStrmServ1MSG(TComponent *Sender,
const AnsiString sFrom, TStream *strm) //接收并保存发送过来的文件
{
Form1->SetFocus();
char *Buffer=new char[strm->Size+1]; //在内存中定义一个字符数组
strm->ReadBuffer(Buffer,strm->Size); //接收传送过来的字符
Buffer[strm->Size+1]='\0';
SaveDialog1->FileName="";
SaveDialog1->DefaultExt=sFrom;
SaveDialog1->Filter="."+sFro;
if(SaveDialog1->Execute()) //把接收的字符保存成文件
{
AnsiString FN=SaveDialog1->FileName;
for(int n=FN.Length()-1;n>=1;n--)
{
if(FN.SubString(n,1)=="\\")
{
FN=FN.SubString(n+1,FN.Length()-n) ;
break;
}
}
char *file=FN.c_str();
FILE *stream =fopen(file,"w+");
for(int i=0;i<=strm->Size;i++)
{
fwrite(&Buffer[i],sizeof(char), 1, stream);
}
fclose(stream);
delete stream;
delete