一 前提
- 安裝mininet和Open vSwitch軟件捞蚂，也可以直接下載一個(gè)裝有mininet和Open vSwitch的虛擬機(jī) Virtual Machine Image (OVF format, 64-bit, Mininet 2.0)
- 下載Floodlight源碼亮蛔，并導(dǎo)入Eclipse中
我們將編寫一個(gè)簡單的Floodlight模塊伍纫，用來檢測在網(wǎng)絡(luò)中新的茎杂、未被發(fā)現(xiàn)的MAC地址隙畜，并記錄被檢測到的MAC地址和交換機(jī)凌彬。
二 創(chuàng)建監(jiān)聽器
2.1在Eclipse中添加類
a). 將“floodlight”項(xiàng)目導(dǎo)入Eclipse中挖藏，并在包管理器中展開，然后找到
“src/main/java”目錄勤讽。
b). 右鍵單擊“src/main/java”目錄蟋座，選擇“New / Class”.
c). 在“Package”框中輸入“net.floodlightcontroller.mactracker”。
d). 在“Name”框中輸入“MACTracker”。
e). 接下來找到“Interface”那一欄，點(diǎn)擊旁邊的“Add...”按鈕犯建。
f). 添加“IOFMessageListener”和“IFloodlightModule”，點(diǎn)擊“OK”按鈕飒硅。
g). 點(diǎn)擊對話框上的“Finish”按鈕。
最后你會得到一個(gè)類作谚，如下所示：
package net.floodlightcontroller.mactracker;
import java.util.Collection;
import java.util.Map;
import org.projectfloodlight.openflow.protocol.OFMessage;
import org.projectfloodlight.openflow.protocol.OFType;
import org.projectfloodlight.openflow.types.MacAddress;
import net.floodlightcontroller.core.FloodlightContext;
import net.floodlightcontroller.core.IOFMessageListener;
import net.floodlightcontroller.core.IOFSwitch;
import net.floodlightcontroller.core.module.FloodlightModuleContext;
import net.floodlightcontroller.core.module.FloodlightModuleException;
import net.floodlightcontroller.core.module.IFloodlightModule;
import net.floodlightcontroller.core.module.IFloodlightService;
public class MACTracker implements IOFMessageListener, IFloodlightModule {
@Override
public String getName() {
// TODO Auto-generated method stub
return null;
}
@Override
public boolean isCallbackOrderingPrereq(OFType type, String name) {
// TODO Auto-generated method stub
return false;
}
@Override
public boolean isCallbackOrderingPostreq(OFType type, String name) {
// TODO Auto-generated method stub
return false;
}
@Override
public Collection<Class<? extends IFloodlightService>> getModuleServices() {
// TODO Auto-generated method stub
return null;
}
@Override
public Map<Class<? extends IFloodlightService>, IFloodlightService> getServiceImpls() {
// TODO Auto-generated method stub
return null;
}
@Override
public Collection<Class<? extends IFloodlightService>> getModuleDependencies() {
// TODO Auto-generated method stub
return null;
}
@Override
public void init(FloodlightModuleContext context)
throws FloodlightModuleException {
// TODO Auto-generated method stub
}
@Override
public void startUp(FloodlightModuleContext context) {
// TODO Auto-generated method stub
}
@Override
public Command receive(IOFSwitch sw, OFMessage msg, FloodlightContext cntx) {
// TODO Auto-generated method stub
return null;
}
}
2.2 設(shè)置模塊的依賴關(guān)系和初始化
在開始前，我們需要引入一些依賴包庵芭。使用像eclipse一樣的工具可以很方便的添加妹懒，如果你沒有使用eclipse，只需要將下面的代碼添加到類的前面双吆。
import net.floodlightcontroller.core.IFloodlightProviderService;
import java.util.ArrayList;
import java.util.concurrent.ConcurrentSkipListSet;
import java.util.Set;
import net.floodlightcontroller.packet.Ethernet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
現(xiàn)在眨唬，我們有了類的框架，我們還需要實(shí)現(xiàn)相關(guān)的功能才能使得模塊能夠被加載好乐。首先匾竿，我們添加一些在類中需要的成員變量。因?yàn)橐O(jiān)聽OpenFLow的消息蔚万，我們需要用FloodlightProvider（IFloodlightProviderService類）注冊信息岭妖，我們也需要一個(gè)Set集合來存儲被檢測到的MAC地址，最后反璃，我們使用一個(gè)日志類logger打印出被檢測出的信息昵慌。
protected IFloodlightProviderService floodlightProvider;
protected Set<Long> macAddresses;
protected static Logger logger;
我們需要將其連接到模塊加載系統(tǒng)。通過修改getModuleDependencies() 方法告訴模塊加載器它與該類的依賴關(guān)系淮蜈。
@Override
public Collection<Class<? extends IFloodlightService>> getModuleDependencies() {
Collection<Class<? extends IFloodlightService>> l =
new ArrayList<Class<? extends IFloodlightService>>();
l.add(IFloodlightProviderService.class);
return l;
}
現(xiàn)在我們開始寫模塊的初始化方法init()斋攀，init()會在控制器啟動(dòng)過程的早期被調(diào)用——它主要用來加載相關(guān)依賴和初始化數(shù)據(jù)結(jié)構(gòu)。
@Override
public void init(FloodlightModuleContext context) throws FloodlightModuleException {
floodlightProvider = context.getServiceImpl(IFloodlightProviderService.class);
macAddresses = new ConcurrentSkipListSet<Long>();
logger = LoggerFactory.getLogger(MACTracker.class);
}
2.3 處理Packet-In消息
接下來實(shí)現(xiàn)基本的監(jiān)聽器梧田。我們將在startUp()方法中注冊PACKET_IN消息淳蔼。在這里侧蘸，我們確保其他被依賴的模塊已經(jīng)被初始化。
@Override
public void startUp(FloodlightModuleContext context) {
floodlightProvider.addOFMessageListener(OFType.PACKET_IN, this);
}
我們也必須在OFMessage消息監(jiān)聽器中設(shè)置一個(gè)ID鹉梨，這可以在getName()方法中實(shí)現(xiàn)闺魏。
@Override
public String getName() {
return MACTracker.class.getSimpleName();
}
現(xiàn)在我們來定義我們想要的對PACKET_IN消息的處理行為。注意俯画，為了使PACKET_IN
消息在后面可以繼續(xù)被其他相關(guān)消息處理程序處理析桥，我們需要返回Command.CONTINUE。
@Override
public net.floodlightcontroller.core.IListener.Command receive(IOFSwitch sw, OFMessage msg, FloodlightContext cntx) {
Ethernet eth = IFloodlightProviderService.bcStore.get(cntx,
IFloodlightProviderService.CONTEXT_PI_PAYLOAD)
Long sourceMACHash = eth.getSourceMACAddress().getLong();
if (!macAddresses.contains(sourceMACHash)) {
macAddresses.add(sourceMACHash);
logger.info("MAC Address: {} seen on switch: {}",
eth.getSourceMACAddress().toString(),
sw.getId().toString());
}
return Command.CONTINUE;
}
2.4 注冊模塊
我們已經(jīng)基本完成了模塊的編寫工作艰垂，現(xiàn)在我們只需要告訴Floodlight在啟動(dòng)的時(shí)候加載本模塊泡仗。首先，我們必須告訴加載器本模塊的存在猜憎，這需要在文件src/main/resources/META-INF/services/
net.floodlightcontroller.core.module.IFloodlightModule 中添加一行模塊的全名娩怎。打開該文件，然后在下面添加一行：
net.floodlightcontroller.mactracker.MACTracker
接下來需要讓模塊被加載胰柑。我們可以在Floodlight模塊配置文件中添加MACTracker模塊截亦，這個(gè)默認(rèn)的文件在src/main/resources/floodlightdefault.properties。它的key值是floodlight.modules柬讨，value是一個(gè)將模塊名用逗號分割的列表崩瓤。
floodlight.modules = <leave the default list of modules in place>, net.floodlightcontroller.mactracker.MACTracker
最后運(yùn)行控制器，右鍵Main.java文件踩官，選擇"Run As... / Java Application"却桶。
三 檢驗(yàn)?zāi)K功能
3.1 建立網(wǎng)絡(luò)拓?fù)?/h3>
打開mininet虛擬機(jī)，輸入命令
sudo mn --topo single,3 --controller=remote,ip=<你本機(jī)的ip地址>,port=6653 --switch ovsk,protocols=OpenFlow13
結(jié)果如下圖所示：
3.2 查看floodlight輸出結(jié)果
在Eclipse的控制臺輸出信息里蔗牡，查找MACTracker颖系，可以看到如下信息，可以看到網(wǎng)絡(luò)中新接入設(shè)備的MAC地址和相關(guān)交換機(jī)
