2， 路由器从端口接收数据
方法名称： CentralRout::ReceiveData
方法参数： 无
返回值： 无
方法的目的： 路由器从路由器端口读数据的过程。如果成功则执行路由计算。
可能的出错： 无
// 路由器从端口接收数据
void CentralRout::ReceiveData(void)
{
dataIter = dataInList.begin();
if(dataIter != dataInList.end())
{//读取一个数据包
currIPData.SetAddressFrom(dataIter->GetAddressFrom());
currIPData.SetAddressTo(dataIter->GetAddressTo());
currIPData.SetNextHop(dataIter->GetNextHop());
currIPData.SetPreHop(dataIter->GetPreHop());
currIPData.ID = dataIter->ID;
currIPData.SetIPData(dataIter->GetIPData());
//从端口删除所取数据包
dataInList.erase(dataIter);
dataListLength --;
//执行路由计算
DataRoutCompute();
}
}
3， 对当前数据包进行路由计算
方法名称： AbsRout::DataRoutCompute
方法参数： 无
返回值： 无
方法的目的： 路由器对当前数据包进行计算，以判断它要被送往哪一个路由器。然后调用路由器向端口写数据的过程。
可能的出错： 无
// 对当前数据包进行路由计算
void AbsRout::DataRoutCompute(void)
{
currIPData.SetPreHop(selfAddress);
unsigned int *addr=routTable.GetAddrNextHop(currIPData.GetAddressTo());
currIPData.SetNextHop(addr);
//------------------------------------------------
//向控制台输出提示信息
std::cout<<"\n\t计算成功...";
std::cout<<"\n\tNext Hop:";
for(int i=0;i<IP_ADDRESS_LENGTH;i++)
std::cout<<addr[i];
std::cout<<std::endl;
//------------------------------------------------
SendData();
}
4， 路由器向端口发送数据
方法名称： CentralRout::SendData
方法参数： 无
返回值： 无
方法的目的： 路由器向端口写数据的过程。
可能的出错： 无
// 路由器向端口发送数据
void CentralRout::SendData(void)
{
dataOutList.push_back(currIPData);
}
5， 网络从路由器端口接收数据
方法名称： CentralRout::NetReadData
方法参数： 无
返回值： NetData *
方法的目的： 网络从路由器端口中读取数据包的拷贝，将该数据包拷贝返回。IPData和Message作不同的处理。本方案实现较为简洁，实时模拟需要扩充代码。
可能的出错： 无
// 网络从路由器端口接收数据
NetData * CentralRout::NetReadData()
{
NetData *_netData = NULL;
dataIter = dataOutList.begin();
if(dataIter!=dataOutList.end())
{
if(!dataIter->IsMessage())
{
_netData = new NetData(false);
_netData->SetAddressFrom(dataIter->GetAddressFrom());
_netData->SetAddressTo(dataIter->GetAddressTo());
_netData->SetPreHop(dataIter->GetPreHop());
_netData->SetNextHop(dataIter->GetNextHop());
_netData->ID = dataIter->ID;
_netData->SetIPData(dataIter->GetIPData());
//从语义上讲，路由器每送出一个数据包，就应该启动一个记时器，
//以等待应答消息；或者某种机制代替记时器，来做重传的依据。
//代码待扩充。
}else if(dataIter->IsMessage())
{
_netData = new NetData(true);
_netData->SetAddressFrom(dataIter->GetAddressFrom());
_netData->SetAddressTo(dataIter->GetAddressTo());
_netData->SetPreHop(dataIter->GetPreHop());
_netData->SetNextHop(dataIter->GetNextHop());
_netData->ID = dataIter->ID;
//应答消息不重传
dataOutList.erase(dataIter);
}//end of else if
}//end of if
return _netData;
}
<未完>