package totalThreads;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.io.ObjectOutputStream;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import transportPacket.RouterTablePacket;

import totalThreads.TotalPacket;

import entity.Constant;

import entity.NetMap;

import entity.Router;

/*每一个路由器线程都有的发送线程*/

public class SendThread extends Thread {

/*本路由器的路由表，里面还有 RouterTable属性，即是本路由器路由表的值。*/

private Router router;

/*用于发送路由表的 socket*/

private DatagramSocket receiveSocket;

/*SendThread 的默认构造函数*/

public SendThread() {

super();

}

/*含有参数的构造函数*/

public SendThread(DatagramSocket receiveSocket,Router router) { super();

this.receiveSocket=receiveSocket;

this.router = router;

}

/*开启发送线程，每隔 1 秒钟就发送本路由表中的信息*/

public synchronized void run() {

ByteArrayOutputStream bos = null;

ObjectOutputStream oos = null;

int severReceivePort=0;

DatagramPacket datagramPacket = null;

byte[] bufferOut = new byte[1024 * 1024];

while(true) {

try {

DatagramSocket sendSocket=new DatagramSocket();

InetAddress serverInetAddress =InetAddress.getByName("localhost");

TotalPacket totalPacket=new TotalPacket("sendTable");

RouterTablePacket routerTablePacket=new RouterTablePacket();

routerTablePacket.setSourceRouterId(router.getRouterId());

routerTablePacket.setRouterTable(router.getRouterTable());

totalPacket.setRouterTablePacket(routerTablePacket);

bos = new ByteArrayOutputStream();

oos = new ObjectOutputStream(bos);

oos.writeObject(totalPacket);

bufferOut = bos.toByteArray();

for(int i=0;i<new NetMap().getInitInternetMap().length;i++){

if(1==router.getRouterTable().getDistance()[i]){

severReceivePort=Constant.getPortBasic()+i;

if(severReceivePort!=router.getPort()){

datagramPacket = new DatagramPacket(bufferOut,

bufferOut.length,serverInetAddress, severReceivePort); sendSocket.send(datagramPacket);

}

}

}

this.sleep(1000);

} catch (Exception e) { e.printStackTrace();

}finally{

try {

bos.close();

oos.close();

} catch (IOException e) { e.printStackTrace();

}

}

}

}

}