【正文】 p。amp。nextHopsNew[i]!=()){ nextHopsOld[i]=sourceRouterId。 if(dissNew[i]16){ dissOld[i]=dissNew[i]+1。 }else{ dissOld[i]=dissNew[i]。 } }else{ if(i!=()()amp。amp。i!=()amp。amp。nextHopsNew[i]!=0){ if(nextHopsOld[i]==0amp。amp。nextHopsNew[i]!=()){ nextHopsOld[i]=sourceRouterId。 if(dissNew[i]16){ dissOld[i]=dissNew[i]+1。 }else{ dissOld[i]=dissNew[i]。 } }else if(nextHopsOld[i]!=0amp。amp。nextHopsOld[i]==nextHopsNew[i]amp。amp。nextHopsNew[i]!=()){ nextHopsOld[i]=sourceRouterId。 if(dissNew[i]16){ dissOld[i]=dissNew[i]+1。 }else{ dissOld[i]=dissNew[i]。 } }else if(nextHopsOld[i]!=0amp。amp。nextHopsOld[i]!=nextHopsNew[i]amp。amp。nextHopsNew[i]!=()){ if((dissNew[i]+1)dissOld[i]){ nextHopsOld[i]=sourceRouterId。 if(dissNew[i]16){ dissOld[i]=dissNew[i]+1。 }else{ dissOld[i]=dissNew[i]。 } } } } } } } updateShow(routerAreaLeft)。 } } catch (Exception e) { ()。 }finally{ try { ()。 ()。 } catch (IOException e) { ()。 } } } } /** * 當(dāng)收到新的路由表時(shí)，更新顯示新的路由表。 * @param routerAreaLeft 在左邊區(qū)域顯示新路由表的信息 */ public synchronized void updateShow(JTextArea routerAreaLeft){ RouterTable routerTable=()。 String distances=(())。 String nextHops=(())。 ()。 (目的路由：\n[2001, 2002, 2003, 2004, 2005, 2006]\n)。 (下一跳是：\n+nextHops+\n)。 (距離是：\n+distances+\n)。 }}package totalThreads。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。import 。/** * 每一個(gè)路由器線程都有的轉(zhuǎn)發(fā)線程 * @author 郭金磊 *@since 20131220 */public class ForwardThread extends Thread { /** * 注入的可以修改左邊區(qū)域顯示的routerArea */ private JTextArea routerAreaLeft。 /** * 注入的可以修改右上邊區(qū)域顯示的routerArea */ private JTextArea routerAreaRightNorth。 /** * 注入的可以修改右下邊區(qū)域顯示的routerArea */ private JTextArea routerAreaRightSouth。 /** * 注入的可以更新的本路由器的路由表 */ private Router router。 /** * 接收路由表的socket */ private DatagramSocket receiveDataSocket。 /** * 默認(rèn)的構(gòu)造方法 */ public ForwardThread() { super()。 } /** * 含有參數(shù)初始化的構(gòu)造函數(shù) * @param routerAreaLeft 注入的可以修改左邊區(qū)域顯示的routerArea * @param routerAreaRightNorth 注入的可以修改右上邊區(qū)域顯示的routerArea * @param routerAreaRightSouth 注入的可以修改右下邊區(qū)域顯示的routerArea * @param receiveDataSocket 接收路由表的socket * @param router 注入的可以更新的本路由器的路由表 */ public ForwardThread(JTextArea routerAreaLeft,JTextArea routerAreaRightNorth,JTextArea routerAreaRightSouth,DatagramSocket receiveDataSocket,Router router) { super()。 = routerAreaLeft。 = routerAreaRightNorth。 = routerAreaRightSouth。 = receiveDataSocket。 = router。 } /** * 轉(zhuǎn)發(fā)進(jìn)程的開啟，始終監(jiān)聽收到的數(shù)據(jù) */ @Override public synchronized void run() { DatagramPacket dataPacket =null。 ByteArrayInputStream bis =null。 ObjectInputStream ois =null。 byte[] bufferIn = new byte[1024 * 1024]。 while(true){ try { dataPacket = new DatagramPacket(bufferIn, )。 (dataPacket)。 bis = new ByteArrayInputStream(())。 ois = new ObjectInputStream(bis)。 TotalPacket totalPacket = (TotalPacket) ()。 ()。 if(sendData.equals(())){ SendDataPacket sendDataPacket=()。 int destRouterId=()。 int sourceRouterId=()。 byte [] data=()。 int remainHops=()1。 String datas=new String(data)。 (收到了+sourceRouterId+傳向+destRouterId+的數(shù)據(jù)\n)。 (數(shù)據(jù)是:+datas+\n)。 if(destRouterId == ()){ (我就是目的地。\n)。 }else{ if(()==1){ (無法到達(dá)跳數(shù)已經(jīng)16了，\n我要拋棄該包了。\n)。 }else{ ().setHops(remainHops)。 ().setSourceRouterId(())。 //轉(zhuǎn)發(fā) for(int i=0。inew NetMap().getInitInternetMap().length。i++){ if(i==(())){ if((().getDistance()[i]!=16)amp。amp。(().getNextHop()[i]!=0)){ int forwardNextHopRouterId=().getNextHop()[i]。 (我要轉(zhuǎn)發(fā)這個(gè)數(shù)據(jù)包給+forwardNextHopRouterId+\n)。 forward(forwardNextHopRouterId,totalPacket)。 (轉(zhuǎn)發(fā)完畢。\n)。 }else if(().getNextHop()[i]==0){ (這個(gè)路由我不可達(dá)，\n我要丟棄該包。\n)。 break。 } } } } } } } catch (Exception e) { ()。 }finally{ try { ()。 ()。 } catch (IOException e) { ()。 } } } } /** * 此方法用于當(dāng)收到的數(shù)據(jù)的目的地址不是我自己是，我就將數(shù)據(jù)轉(zhuǎn)發(fā)給我的下一跳。 * @param forwardNextHopRouterId 要轉(zhuǎn)發(fā)的下一跳路由 * @param totalPacketForward 要轉(zhuǎn)發(fā)的數(shù)據(jù)打成的包 */ public synchronized void forward(int forwardNextHopRouterId,TotalPacket totalPacketForward){ DatagramSocket sendSocket=null。 ByteArrayOutputStream bos = null。 ObjectOutputStream oos = null。 DatagramPacket datagramPacket = null。 byte[] bufferOut = new byte[1024 * 1024]。 try { sendSocket=new DatagramSocket()。 InetAddress serverInetAddress =(localhost)。 bos = new ByteArrayOutputStream()。 oos = new ObjectOutputStream(bos)。 (totalPacketForward)。 bufferOut = ()。 int severReceivePort=()+()+10。 datagramPacket = new DatagramPacket(bufferOut, ,serverInetAddress, severReceivePort)。 (datagramPacket)。 } catch (SocketException e) { ()。 } catch (UnknownHostException e) { ()。 } catch (IOException e) { ()。 }finally{ ()。 } }}package transportPacket。import 。/** * 最后的包裝包實(shí)體類，不但可以傳輸數(shù)據(jù)包，還可以傳送路由表 * @author 郭金磊 *@since 20131220 */public class TotalPacket implements Serializable{ /** * 產(chǎn)生全局唯一的序列化的實(shí)體ID */ private static final long serialVersionUID = 7430514869915215965L。 /** * 要發(fā)送的是路由表還是發(fā)送的是數(shù)據(jù)的標(biāo)記 */ private String type。 /** * 如果發(fā)送的是路由表，