2019獨角獸企業(yè)重金招聘Python工程師標(biāo)準(zhǔn)>>>

package ZClient; import java.io.IOException; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.Date; import java.util.EventListener; import java.util.EventObject; import javax.swing.event.EventListenerList; import jpcap.JpcapCaptor; import jpcap.NetworkInterface; import jpcap.PacketReceiver; import ZClient.EAPSender.EAPNameExcetion; import ZClient.PacketProc.EAPListener;/*** Dot1X is the main class of dot1x application<p>* @author Lingle<p>* Email: mea08@126.com<p>*/ public class Dot1X{private static final Dot1X dot1x=new Dot1X();private static NetworkInterface[] devices = JpcapCaptor.getDeviceList();public static long LENOVO_KEEP_GAP=60000;private NetworkInterface selectedDevice =null;private final EAPSender eapSender=new EAPSender();private JpcapCaptor eapWatcher =null;private byte[] ip =null;private byte[] mac =null;private EventListenerList listeners =null;public class OpenDevException extends Exception{private static final long serialVersionUID = -3485654124088246345L;public OpenDevException() {super("Open Selected Device Error!");}}public class NoIPException extends Exception{private static final long serialVersionUID = -1398907348086842693L;public NoIPException() {super("Selected device has no IP!");}}public class NoDeviceException extends Exception{private static final long serialVersionUID = -6577467488384162978L;public NoDeviceException() {super("Have no device?");}}private boolean hasListerner() {if(listeners==null){return false;}else return true;}/*** event define*/public class Dot1XMsgSourceObject {public int msgType;public String message;public Dot1XMsgSourceObject (int type, String msg) {msgType = type;message = new Date().toLocaleString().substring(9, 17)+" "+msg;}}public class Dot1XMsgEvent extends EventObject{private static final long serialVersionUID = 7003505759602936517L;public Dot1XMsgEvent(int msgType, String messsage) {super(new Dot1XMsgSourceObject(msgType,messsage));}/*** @param msgType 0:EAPMessage,1:KeepOnline,2:device,3:debug stderr* @param messsage*/public Dot1XMsgSourceObject getSource() {return (Dot1XMsgSourceObject) super.getSource();}}public interface Dot1XMsgListener extends EventListener {public void msgUpdateAction(Dot1XMsgEvent dMsgEvent);}public void addDot1XMsgListener(Dot1XMsgListener listener) {if (!hasListerner()) {listeners=new EventListenerList();}listeners.add(Dot1XMsgListener.class, listener);}/*** @param msgType 0:EAPMessage,1:KeepOnline,2:device,3:debug stderr* @param messsage*/private void postDot1XMessage(int msgType, String messsage) {for (Dot1XMsgListener listener : listeners.getListeners(Dot1XMsgListener.class)) {listener.msgUpdateAction(new Dot1XMsgEvent(msgType, messsage));}}interface ThreadStopListener extends EventListener {public abstract void threadStopAction(Class<? extends Thread> t);}private void addThreadListener(ThreadStopListener listener){if (!hasListerner()) {listeners=new EventListenerList();}listeners.add(ThreadStopListener.class, listener);}private void postThreadStop(Class<? extends Thread> t) {for (ThreadStopListener listener : listeners.getListeners(ThreadStopListener.class)) {listener.threadStopAction(t);}}private void removeThreadListener(ThreadStopListener listener) {if (hasListerner()) listeners.remove(ThreadStopListener.class,listener);}private abstract class EAPSuccAdapter implements EAPListener{@Overridepublic void failureEventAction() {}@Overridepublic void pktRecivedAction(String messsage) {}}private abstract class EAPFailAdapter implements EAPListener{@Overridepublic void successEventAction() {}@Overridepublic void pktRecivedAction(String messsage) {}}private abstract class EAPMessAdapter implements EAPListener{@Overridepublic void successEventAction() {}@Overridepublic void failureEventAction() {}}/*** thread define*/private class KeepOnlineThread extends Thread implements ThreadStopListener{public KeepOnlineThread() {setName("KeepOnline..");setPriority(7);start();}@Overridepublic synchronized void run() {while (true) {try {Thread.sleep(LENOVO_KEEP_GAP);eapSender.sendEapOnline();if (hasListerner())postDot1XMessage(1, "Send EAP_KEEP_ONLINE");} catch (InterruptedException e) {if (hasListerner())postDot1XMessage(3, "Error:" + e.getMessage());}}}@Overridepublic void threadStopAction(Class<? extends Thread> t) { if (t.isInstance(this)) {removeThreadListener(this);stop();}}}private class EapWatchThread extends Thread implements ThreadStopListener{public EapWatchThread() {setName("EapWatching..");setPriority(7);start();}@Overridepublic synchronized void run() {if (hasEapWatcher()) {try {eapWatcher.setFilter("ether dst " + getMACString()+ " and ether proto 0x888e", true);} catch (IOException e) {if (hasListerner())postDot1XMessage(3, e.getMessage());}PacketReceiver pktReceiver = new PacketProc(eapSender);((PacketProc) pktReceiver).addEapListener(new EAPMessAdapter() {public void pktRecivedAction(String messsage) {if (hasListerner())postDot1XMessage(0, messsage);}});((PacketProc) pktReceiver).addEapListener(new EAPSuccAdapter() {@Overridepublic void successEventAction() {postThreadStop(KeepOnlineThread.class);addThreadListener(new KeepOnlineThread());}});((PacketProc) pktReceiver).addEapListener(new EAPFailAdapter() {@Overridepublic void failureEventAction() {postThreadStop(KeepOnlineThread.class);eapWatcher.breakLoop();}});eapWatcher.loopPacket(-1, pktReceiver);removeThreadListener(this);}}@Overridepublic void threadStopAction(Class<? extends Thread> t) { if (t.isInstance(this)) {if (hasEapWatcher()) eapWatcher.breakLoop();}}}private Dot1X(){}private boolean hasEapWatcher(){if(eapWatcher==null){return false;}else return true;}public void setDevice(int devindex) throws NoIPException, NoDeviceException {try {selectedDevice=devices[devindex];} catch (ArrayIndexOutOfBoundsException e1) {throw new NoDeviceException();}mac=selectedDevice.mac_address;try {ip=selectedDevice.addresses[0].address.getAddress();} catch (ArrayIndexOutOfBoundsException e1) {throw new NoIPException();}try {eapWatcher = JpcapCaptor.openDevice(selectedDevice, 65535, true, 20);eapSender.setSender(eapWatcher.getJpcapSenderInstance(), ip, mac); } catch (IOException e) {if (hasListerner()) postDot1XMessage(3, "Error:"+e.getMessage()); }}public void setName(String username,String password) throws OpenDevException{if(hasEapWatcher()){eapSender.setName(username, password);}else throw new OpenDevException();}public void Start() throws OpenDevException{if (hasEapWatcher()) {postThreadStop(EapWatchThread.class);postThreadStop(KeepOnlineThread.class);addThreadListener(new EapWatchThread());try {eapSender.sendEapStart();if (hasListerner()) postDot1XMessage(0, "Send EAP_START");} catch (EAPNameExcetion e) {if (hasListerner()) postDot1XMessage(0, e.getMessage());postThreadStop(EapWatchThread.class);postThreadStop(KeepOnlineThread.class);if (hasEapWatcher()) eapWatcher.breakLoop();}} else throw new OpenDevException();}public void Stop(){if (hasEapWatcher()) eapSender.sendEapLogOff();postThreadStop(EapWatchThread.class);postThreadStop(KeepOnlineThread.class);if (hasEapWatcher()) eapWatcher.breakLoop();postDot1XMessage(0, "EAP_STOP");}public static String[] getDeviceList() {String[] devs=new String[devices.length];for (int i=0; i<devices.length; i++) {devs[i]=devices[i].description;}return devs;}public String getMACString() {try {return String.format("%02X:%02X:%02X:%02X:%02X:%02X", mac[0],mac[1], mac[2], mac[3], mac[4], mac[5]);} catch (java.lang.NullPointerException e) {return "00:00:00:00";}}public String getIPString() {try {return InetAddress.getByAddress(ip).getHostAddress();} catch (UnknownHostException e) {return "0.0.0.0";}}public static Dot1X getDot1XInstance() {return dot1x;}}

轉(zhuǎn)載于:https://my.oschina.net/u/212925/blog/106854

總結(jié)

以上是生活随笔為你收集整理的联想天工 802.1x认证 主程序的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。