铺装案例:IP多播技术及其编程

ip多播（也称多址广播或组播）技术，是一种允许一台或多台主机（多播源）发送单一数据包到多台主机（一次的，同时的）的tcp/ip网络技术。多播作为一点对多点的通信，是节省网络带宽的有效方法之一。在网络音频/视频广播的应用中，当需要将一个节点的信号传送到多个节点时，无论是采用重复点对点通信方式，还是采用广播方式，都会严重浪费网络带宽，只有多播才是最好的选择。多播能使一个或多个多播源只把数据包发送给特定的多播组，而只有加入该多播组的主机才能接收到数据包。目前，ip多播技术被广泛应用在网络音频/视频广播、aod/vod、网络视频会议、多媒体远程教育、“push”技术（如股票行情等）和虚拟现实游戏等方面。

　　一、ip多播技术简介

　　1．ip多播地址和多播组
　　ip多播通信必须依赖于ip多播地址，在ipv4中它是一个d类ip地址，范围从224.0.0.0到239.255.255.255，并被划分为局部链接多播地址、预留多播地址和管理权限多播地址三类。其中，局部链接多播地址范围在224.0.0.0~224.0.0.255，这是为路由协议和其它用途保留的地址，路由器并不转发属于此范围的ip包；预留多播地址为224.0.1.0~238.255.255.255，可用于全球范围（如internet）或网络协议；管理权限多播地址为239.0.0.0~239.255.255.255，可供组织内部使用，类似于私有ip地址，不能用于internet，可限制多播范围。

　　使用同一个ip多播地址接收多播数据包的所有主机构成了一个主机组，也称为多播组。一个多播组的成员是随时变动的，一台主机可以随时加入或离开多播组，多播组成员的数目和所在的地理位置也不受限制，一台主机也可以属于几个多播组。此外，不属于某一个多播组的主机也可以向该多播组发送数据包。

　　2．ip多播技术的硬件支持
　　要实现ip多播通信，要求介于多播源和接收者之间的路由器、集线器、交换机以及主机均需支持ip多播。目前，ip多播技术已得到硬件、软件厂商的广泛支持。

　　（1）主机
　　支持ip多播通信的平台包括windows ce 2.1、windows 95、windows 98、windows nt 4和windows 2000等，运行这些操作系统的主机都可以进行ip多播通信。此外，新生产的网卡也几乎都提供了对ip多播的支持。
　　（2）集线器和交换机
　　目前大多数集线器、交换机只是简单地把多播数据当成广播来发送接收，但一些中、高档交换机提供了对ip多播的支持。例如，在3com superstack 3 swith 3300交换机上可启用802.1p或igmp多播过滤功能，只为已侦测到igmp数据包的端口转发多播数据包。
　　（3）路由器
　　多播通信要求多播源节点和目的节点之间的所有路由器必须提供对internet组管理协议（igmp）、多播路由协议（如pim、dvmrp等）的支持。

　　当一台主机欲加入某个多播组时，会发出“主机成员报告”的igmp消息通知多播路由器。当多播路由器接收到发给那个多播组的数据时，便会将其转发给所有的多播主机。多播路由器还会周期性地发出“主机成员查询”的igmp消息，向子网查询多播主机，若发现某个多播组已没有任何成员，则停止转发该多播组的数据。此外，当支持igmp v2的主机（如windows 98/2000计算机）退出某个多播组时，还会向路由器发送一条“离开组”的igmp消息，以通知路由器停止转发该多播组的数据。但只有当子网上所有主机都退出某个多播组时，路由器才会停止向该子网转发该多播组的数据。

　　使用多播路由协议，路由器可建立起从多播源节点到所有目的节点的多播路由表，从而实现在子网间转发多播数据包。例如，pim（协议独立多播）就是一种多播路由协议，它有两种类型：稀疏模式（sparse-mode）和密集模式（dense-mode）。以cisco 2621路由器为例，启用ip多播转发功能的基本设置如下：

　　c2621(config)# ip multicast-routing 启动ip多播，使路由器成为一个多播路由器
　　c2621(config)# int f0/0 配置快速以太网端口0
　　c2621(config-if)# ip pim dense-mode（或sparse-mode）启动pim，同时激活igmp协议
　　c2621(config-if)# int f0/1 配置快速以太网端口1
　　c2621(config-if)# ip pim dense-mode（或sparse-mode）

　　二、ip多播应用的编程方法

　　在实际应用中，编程人员通常需要自己编制底层网络应用程序来实现网上的底层通信，如具体实现ip多播通信的功能。编制底层网络应用程序通常要借助于网络数据通信编程接口，而在不同的操作系统中所提供的网络编程接口是有所不同的，如在microsoft windows环境下的网络编程接口就是windows套接字（windows socket，简称winsock）。
winsock提供了包括tcp/ip、ipx等多种通信协议下的编程接口。不同的windows版本支持不同的winsock版本，其中windows 95等早期版本本身只支持winsock1.1（16位）下的编程（可以通过安装相关的软件包使其支持winsock2.0），而windows98、windows nt4.0、windows 2000则直接支持winsock2.0（32位）。winsock2.0是winsock1.1的扩展，除兼容winsock1.1 api外，还定义了一套可支持ip多播的与协议无关的api。

　　使用winsock 2.0实现ip多播的一般步骤如下：

　　1．初始化winsock资源
　　在使用winsock之前，必须调用wsastartup()函数初始化windows sockets dll。它允许应用程序或dll指定windows sockets api要求的版本。

2．创建套接字
　　调用wsasocket()函数可以创建一个使用udp协议的套接字，它是加入多播组的初始化套接字，并且以后数据的发送和接收都在该套接字上进行。针对ip多播通信，可将参数dwflags设置为wsa_flag_multipoint_c_leaf、wsa_flag_multipoint_d_leaf和wsa_flag_overlapped的位和，指明ip多播通信在控制层面和数据层面都是“无根的”，只存在叶节点，它们可以任意加入一个多播组，而且从一个叶节点发送的数据会传送到每一个叶节点（包括它自己）；创建的套接字具有重叠属性。

　　3．设置套接字的选项
　　调用setsockopt()函数为套接字设置so_reuseaddr选项，以允许套接字绑扎到一个已在使用的地址上。

　　4．绑定套接字
　　调用bind()函数绑定套接字，从而将创建好的套接字与本地地址和本地端口联系起来。对于多播通信来说，发送和接收数据通常采用同一个端口。

　　5．设置多播套接字的模式
　　wsaioctl()函数的命令码sio_multicast_loop用来允许或禁止多播通信时发送出去的通信流量是否也能够在同一个套接字上被接收（即多播返回）。值得注意的是，在windows 95/98/nt 4中，默认是允许多播返回，但不能设置禁止，否则会出错；只有在windows 2000以上版本中，才能设置允许/禁止多播返回。
　　wsaioctl()函数的命令码sio_multicast_scope用来设置多播传播的范围，即生存时间ttl。每当多播路由器转发多播数据包时，数据包中的ttl值都会被减1，若数据包的ttl减少到0，则路由器将抛弃该数据包。ttl的值是多少，多播数据便最多能经过多少个多播路由器。例如，ttl值为0，则多播只能在本地主机的多个套接字间传播，而不能传播到“网线”上；ttl值为1（默认值），则多播数据遇到第一个路由器，便会被它“无情”地丢弃，不允许传出本地网络之外，即只有同一个网络内的多播组成员才能收到多播数据。

　　6．加入一个多播组
　　调用wsajoinleaf()函数可加入一个多播组并指定角色（发送者/接收者）。调用时，参数dwflags可指定套接字作为发送者（jl_sender_only）、接收者（jl_receiver_only）或身兼两者（jl_both）。调用成功后会返回一个多播套接字，调用closesocket()函数关闭该套接字就离开了多播组，此时可以调用wsajoinleaf()函数再次加入多播组。注意，对多播组数据的接收和发送不能在该套接字上完成。

　　7．向多播组发送数据
　　调用sendto()函数，可在指定的udp套接字上向指定的多播组发送多播数据。调用时，参数to应指向多播组的ip地址。值得注意的是，若一个应用程序只是打算给多播组发送数据，便不必加入一个多播组。

　　8．等待事件
　　调用wsaasyncselect()函数，使套接字置于非阻塞模式，这时应用程序就可在该套接字上接收以windows消息为基础的网络事件通知。例如，若参数levent值为fd_read，则应用程序可在套接字上接收到“数据正等待被读入”的通知。
　　9．从多播组接收数据
　　调用recvfrom函数，可在指定的udp套接字上读取输入数据。多播通信中数据的发送与接收一般采用同一个端口，因此其发送套接字和接收套接字是一样的。

　　10．关闭套接字，释放winsock资源。
　　在多播通信结束后，先调用closesocket()函数关闭多播套接字和udp套接字，然后调用wsacleanup()函数结束对windows sockets dll的使用。

　　三、应用实例

　　为了说明ip多播技术的应用方法，本人在visual c++.net环境下设计了一个简单的基于windows socket 2的ip多播应用程序，通过该例子读者可以掌握ip多播应用程序设计的一般方法。该程序的具体设计方法如下：

　　1．在visual studio.net中建立一个基于对话框的mfc项目cmulticastsocket。注意在“高级功能”设置中不要选择“windows套接字”，这是因为mfc只支持windows socket 1而不支持windows socket 2。为了能使用winsock 2 api编程，在程序中应包含“winsock2.h”头文件，并在项目中加入ws2_32.lib的静态库，该静态库应设置在项目属性的“链接器”\“输入”\“附加依赖项”中。

　　2．在对话框（类名ccmulticastsocketdlg）资源中，设置它的caption为“winsock 2多播应用程序”，并添加以下控件：

　　静态文本：caption为“接收到的信息：”；
　　编辑框：id为idc_receive_edit，read only、auto vscroll、vertical scroll和multiline属性值都为true
　　静态文本：caption为“发送的信息：”
　　编辑框：id为idc_send_edit
　　第一个按钮：caption为“加入多播组(&j)”，id为idc_join_button
　　第二个按钮：caption为“多播发送(&s)”，id为idc_send_button
　　第三个按钮：caption为“离开多播组(&l)”，id为idc_leave_button
　　第四个按钮：caption为“退出(&q)”，id为idc_quit_button

　　为两个编辑框分别添加相关联的cstring类型的变量m_sendmessage和m_receivemessage；为四个按钮添加相应的消息处理函数；为对话框添加定时器消息（用于定时显示接收到的消息）及其消息处理函数。

　　3．添加一个新的对话框资源，设置它的caption为“加入多播组”，保留默认的两个按钮控件，同时添加添加以下控件：

静态文本：caption为“ip多播组地址：”
　　编辑框：id为idc_ipaddress_edit
　　静态文本：caption为“ip多播端口：”
　　编辑框：id为idc_port_edit
　　静态文本：caption为“生存时间：”
　　编辑框：id为idc_ttl_edit
　　复选框：caption为“多播返回：”，id为idc_loopback_check，left text属性值为true。

　　为该对话框添加新的类cjoingroupdlg，它的基类为cdialog，然后为该对话框中的三个编辑框分别添加相
关联的变量，即csting m_ipaddress、uint m_nport、uint m_nttl；为复选框添加相关联的bool类型的变量m_loopback。

　　4．在cmulticastsocketdlg.h文件的前面添加cjoingroupdlg的头文件：#include “joingroupdlg.h”，并在ccmulticastsocketdlg类中添加了一个cjoingroupdlg类实例对象m_joindlg。

　　5．为了能在对话框中接收网络事件通知，应增加一个用户自定义的消息及消息处理函数，具体实现方法如下：在cmulticastsocketdlg.h文件的前面自定义消息：#define wm_sock_msg(wm_user+166)，并在afx_msg块中说明消息处理函数：afx_msg lresult onsocketmsg (wparam wparam,lparam lparam)；在cmulticastsocketdlg.cpp文件中的消息映射块中，使用on_message (wm_sock_msg,onsocketmsg)宏指令将消息映射到消息处理函数中，并具体实现消息处理函数：lresult ccmulticastsocketdlg:: onsocketmsg(wparam wparam,lparam lparam){…}。

该程序的主要代码可参见程序清单，相关函数的详细说明可参看microsoft msdn帮助系统。为了节省篇幅，程序中省略了部分自动生成的和用于错误处理的代码。

程序清单：

// cmulticastsocketdlg.cpp : 实现文件
#include "stdafx.h"
#include "winsock2.h"
#include "cmulticastsocket.h"
#include "cmulticastsocketdlg.h"
……
dword cbret;
socket sock,sockm; file://udp套接字，多播套接字
bool bflag,bjoin;
sockaddr_in local,remote,from; file://分别指向本地、多播组和数据来源的ip地址与端口
int fromlen;
char receivebuf[32000]; file://接收缓冲区
bool bdatareceived;
……
begin_message_map(ccmulticastsocketdlg, cdialog)
……
on_bn_clicked(idc_join_button, onbnclickedjoinbutton)
on_bn_clicked(idc_leave_button, onbnclickedleavebutton)
on_bn_clicked(idc_quit_button, onbnclickedquitbutton)
on_bn_clicked(idc_send_button, onbnclickedsendbutton)
on_wm_timer()
on_message(wm_sock_msg,onsocketmsg)
end_message_map()

bool ccmulticastsocketdlg::oninitdialog()
{
cdialog::oninitdialog();
……
settimer(1,100,null); file://设置定时器
fromlen=sizeof(from);
bdatareceived=true;
bjoin=false;
return true; // 除非设置了控件的焦点，否则返回 true
}
……
void ccmulticastsocketdlg::onbnclickedjoinbutton() file://加入多播组
{
if(m_joindlg.domodal()==idok)
{
word wversionrequested;
wsadata wsadata;
int 北京中庆;
wversionrequested = makeword(2,2);
北京中庆 = wsastartup(wversionrequested, &wsadata); file://初始化winsock2资源
if(北京中庆!= 0){
afxmessagebox("不能加载windows套接字动态链接库,mb_ok");
return;
}
if (lobyte(wsadata.wversion) !=2 || hibyte(wsadata.wversion) !=2){
afxmessagebox("winsock dll不支持2.0版本,mb_ok");
wsacleanup( );
return;
}
file://创建一个套接字
sock=wsasocket(af_inet,sock_dgram,ipproto_udp,
(lpwsaprotocol_info)null,0,wsa_flag_overlapped
| wsa_flag_multipoint_c_leaf|wsa_flag_multipoint_d_leaf);

bflag=true; file://设置套接字选项，使套接字为可重用端口地址
setsockopt(sock,sol_socket,so_reuseaddr,(char*)&bflag,sizeof(bflag));

file://将套接字绑定到用户指定端口及默认的接口
memset(&local,0,sizeof(local));
local.sin_family=af_inet;
local.sin_port=htons((ushort)m_joindlg.m_nport);
local.sin_addr.s_addr=htonl(inaddr_any);
bind(sock,(struct sockaddr far *)&local,sizeof(local));

file://设置多播数据报传播范围（生存时间ttl）
wsaioctl(sock,sio_multicast_scope,&m_joindlg.m_nttl,sizeof(int),
null,0,&cbret,null,null);
file://设置多播返回（lookback）
bool nloopback=m_joindlg.m_loopback;
wsaioctl(sock,sio_multipoint_loopback,&nloopback,sizeof(nloopback),
null,0,&cbret,null,null);

memset(&remote,0,sizeof(remote));
remote.sin_family=af_inet;
remote.sin_addr.s_addr=inet_addr(m_joindlg.m_ipaddress);
remote.sin_port=htons(m_joindlg.m_nport);
file://加入到指定的多播组，并指定为既作为发送者又作为接收者（jl_both）
sockm=wsajoinleaf(sock,(sockaddr*)&remote,sizeof(remote),
null,null,null,null,jl_both);
wsaasyncselect(sock,m_hwnd,wm_sock_msg,fd_read); file://注册网络消息及其网络事件
bjoin=true;
}
}

void ccmulticastsocketdlg::onbnclickedsendbutton() file://多播发送
{
if(bjoin){
updatedata(true);
const char* strmessage=lpctstr(m_sendmessage);
int nsize=m_sendmessage.getlength()+1;
sendto(sock,strmessage,nsize,0,(sockaddr*)&remote,sizeof(remote));
}
else
afxmessagebox("请先加入多播组！");
m_sendmessage="";
updatedata(false);
}

void ccmulticastsocketdlg::onbnclickedleavebutton()
{ file://离开多播组
closesocket(sockm);
closesocket(sock);
wsacleanup();
m_sendmessage="";
m_receivemessage="";
bdatareceived=true;
bjoin=false;
updatedata(false);
}

void ccmulticastsocketdlg::onbnclickedquitbutton()
{ file://退出
destroywindow();
}

void ccmulticastsocketdlg::ontimer(uint nidevent) file://定时器处理函数，实现接收信息的定时更新
{
if(bdatareceived)
{
m_receivemessage+=receivebuf;
m_receivemessage+="\r\n";
bdatareceived=false;
updatedata(false);
}
cdialog::ontimer(nidevent);
}

lresult ccmulticastsocketdlg::onsocketmsg(wparam wparam,lparam lparam)
{
file://检索网络事件
switch(wsagetselectevent(lparam)){
case fd_read:
recvfrom(sock,receivebuf,32000,0,(sockaddr *)&from,&fromlen);
bdatareceived=true; file://设置已接收到一条信息标志
break;
}
return true;
}