首页 > 其他分享 >实验7:基于REST API的SDN北向应用实践

实验7:基于REST API的SDN北向应用实践

时间:2022-11-11 23:56:19浏览次数:41  
标签:url REST port headers json API SDN type requests

实验7:基于REST API的SDN北向应用实践

一、实验目的

  1. 能够编写程序调用OpenDaylight REST API实现特定网络功能;
  2. 能够编写程序调用Ryu REST API实现特定网络功能。

二、实验环境

  1. 下载虚拟机软件Oracle VisualBox或VMware;
  2. 在虚拟机中安装Ubuntu 20.04 Desktop amd64,并完整安装Mininet、OpenDaylight(Carbon版本)、Postman和Ryu;

三、实验要求

(一)基本要求

  1. 编写Python程序,调用OpenDaylight的北向接口实现以下功能
    (1) 利用Mininet平台搭建下图所示网络拓扑,并连接OpenDaylight;

  2. 使用命令./distribution-karaf-0.6.4-Carbon/bin/karaf打开ODL控制器
  3. 使用命令sudo mn --topo=single,3 --controller=remote,ip=127.0.0.1,port=6633 --switch ovsk,protocols=OpenFlow13创建拓扑并连接控制
  4. (2) 下发指令删除s1上的流表数据。

    复制代码
    #!/usr/bin/python
    import requests
    from requests.auth import HTTPBasicAuth
    if __name__ == "__main__":
        url = 'http://127.0.0.1:8181/restconf/config/opendaylight-inventory:nodes/node/openflow:1/'
        headers = {'Content-Type': 'application/json'}
        res = requests.delete(url, headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
        print (res.content)
    复制代码

    (3) 下发硬超时流表,实现拓扑内主机h1和h3网络中断20s。

    复制代码
    #!/usr/bin/python
    import requests
    from requests.auth import HTTPBasicAuth
    if __name__ == "__main__":
        url = 'http://127.0.0.1:8181/restconf/config/opendaylight-inventory:nodes/node/openflow:1/flow-node-inventory:table/0/flow/1'
        with open("./flowtimeout.json") as file:
            str = file.read()
        headers = {'Content-Type': 'application/json'}
        res = requests.put(url, str, headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
        print (res.content)
    复制代码

    json文件:

    复制代码
    {
      "flow": [
        {
          "id": "1",
          "match": {
            "in-port": "1",
            "ethernet-match": {
              "ethernet-type": {
                "type": "0x0800"
              }
            },
            "ipv4-destination": "10.0.0.3/32"
          },
          "instructions": {
            "instruction": [
              {
                "order": "0",
                "apply-actions": {
                  "action": [
                    {
                      "order": "0",
                      "drop-action": {}
                    }
                  ]
                }
              }
            ]
          },
          "flow-name": "flow",
          "priority": "65535",
          "hard-timeout": "20",
          "cookie": "2",
          "table_id": "0"
        }
      ]
    }
    复制代码

     

     (4) 获取s1上活动的流表数。

    复制代码
    #!/usr/bin/python
    import requests
    from requests.auth import HTTPBasicAuth
    if __name__ == "__main__":
        url = 'http://127.0.0.1:8181/restconf/operational/opendaylight-inventory:nodes/node/openflow:1/flow-node-inventory:table/0/opendaylight-flow-table-statistics:flow-table-statistics'
        headers = {'Content-Type': 'application/json'}
        res = requests.get(url,headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
        print (res.content)
    复制代码

    编写Python程序,调用Ryu的北向接口实现以下功能
    (1) 实现上述OpenDaylight实验拓扑上相同的硬超时流表下发。

      • 关闭ODL控制器,关闭上次的拓扑并清除拓扑后

      • 使用命令ryu-manager ryu.app.simple_switch_13 ryu.app.ofctl_rest打开Ryu控制器

      • 使用命令sudo mn --topo=single,3 --mac --controller=remote,ip=127.0.0.1,port=6633 --switch ovsk,protocols=OpenFlow13创建拓扑

      • 复制代码
        #!/usr/bin/python
        import requests
        if __name__ == "__main__":
            url = 'http://127.0.0.1:8080/stats/flowentry/add'
            with open("./hardtimeout.json") as file:
                str = file.read()
            headers = {'Content-Type': 'application/json'}
            res = requests.post(url, str, headers=headers)
            print (res.content)
        复制代码

        json文件:

      • 复制代码
        {
            "dpid": 1,
            "cookie": 1,
            "cookie_mask": 1,
            "table_id": 0,
            "hard_timeout": 20,
            "priority": 65535,
            "flags": 1,
            "match":{
                "in_port":1
            },
            "actions":[
        
        ]
        

        }

        复制代码

         

         (2) 参考Ryu REST API的文档,基于VLAN实验的网络拓扑,编程实现相同的VLAN配置。
        提示:拓扑生成后需连接Ryu,且Ryu应能够提供REST API服务

      • 复制代码
        #topo.py
        from mininet.topo import Topo
        

        class MyTopo(Topo):
        def init(self):
        # initilaize topology
        Topo.init(self)

            self.addSwitch(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addSwitch(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
        
            self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h3</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h4</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
        
            self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h3</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h4</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
            self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
        

        topos = {'mytopo': (lambda: MyTopo())}

        复制代码
        • 关闭控制器,关闭上一次实验的拓扑并清除拓扑

        • 使用命令ryu-manager ryu.app.simple_switch_13 ryu.app.ofctl_rest打开Ryu控制器

        • 使用命令sudo mn --custom topo.py --topo mytopo --mac --controller=remote,ip=127.0.0.1,port=6633 --switch ovsk,protocols=OpenFlow13创建拓扑

        •  

           

          VLAN_IDHosts
          0 h1 h3
          1 h2 h4
          • 使用命令

          • curl -X DELETE http://127.0.0.1:8080/stats/flowentry/clear/1

          • curl -X DELETE http://127.0.0.1:8080/stats/flowentry/clear/2

          • 删除流表

          • 使用命令python运行下列程序

          • 复制代码
            #!/usr/bin/python
            import json
            

            import requests

            if name == "main":
            url = 'http://127.0.0.1:8080/stats/flowentry/add'
            headers = {'Content-Type': 'application/json'}
            flow1 = {
            "dpid": 1,
            "priority": 1,
            "match":{
            "in_port": 1
            },
            "actions":[
            {
            "type": "PUSH_VLAN",
            "ethertype": 33024
            },
            {
            "type": "SET_FIELD",
            "field": "vlan_vid",
            "value": 4096
            },
            {
            "type": "OUTPUT",
            "port": 3
            }
            ]
            }
            flow2 = {
            "dpid": 1,
            "priority": 1,
            "match":{
            "in_port": 2
            },
            "actions":[
            {
            "type": "PUSH_VLAN",
            "ethertype": 33024
            },
            {
            "type": "SET_FIELD",
            "field": "vlan_vid",
            "value": 4097
            },
            {
            "type": "OUTPUT",
            "port": 3
            }
            ]
            }
            flow3 = {
            "dpid": 1,
            "priority": 1,
            "match":{
            "vlan_vid": 0
            },
            "actions":[
            {
            "type": "POP_VLAN",
            "ethertype": 33024
            },
            {
            "type": "OUTPUT",
            "port": 1
            }
            ]
            }
            flow4 = {
            "dpid": 1,
            "priority": 1,
            "match": {
            "vlan_vid": 1
            },
            "actions": [
            {
            "type": "POP_VLAN",
            "ethertype": 33024
            },
            {
            "type": "OUTPUT",
            "port": 2
            }
            ]
            }
            flow5 = {
            "dpid": 2,
            "priority": 1,
            "match": {
            "in_port": 1
            },
            "actions": [
            {
            "type": "PUSH_VLAN",
            "ethertype": 33024
            },
            {
            "type": "SET_FIELD",
            "field": "vlan_vid",
            "value": 4096
            },
            {
            "type": "OUTPUT",
            "port": 3
            }
            ]
            }
            flow6 = {
            "dpid": 2,
            "priority": 1,
            "match": {
            "in_port": 2
            },
            "actions": [
            {
            "type": "PUSH_VLAN",
            "ethertype": 33024
            },
            {
            "type": "SET_FIELD",
            "field": "vlan_vid",
            "value": 4097
            },
            {
            "type": "OUTPUT",
            "port": 3
            }
            ]
            }
            flow7 = {
            "dpid": 2,
            "priority": 1,
            "match": {
            "vlan_vid": 0
            },
            "actions": [
            {
            "type": "POP_VLAN",
            "ethertype": 33024
            },
            {
            "type": "OUTPUT",
            "port": 1
            }
            ]
            }
            flow8 = {
            "dpid": 2,
            "priority": 1,
            "match": {
            "vlan_vid": 1
            },
            "actions": [
            {
            "type": "POP_VLAN",
            "ethertype": 33024
            },
            {
            "type": "OUTPUT",
            "port": 2
            }
            ]
            }
            res1 = requests.post(url, json.dumps(flow1), headers=headers)
            res2 = requests.post(url, json.dumps(flow2), headers=headers)
            res3 = requests.post(url, json.dumps(flow3), headers=headers)
            res4 = requests.post(url, json.dumps(flow4), headers=headers)
            res5 = requests.post(url, json.dumps(flow5), headers=headers)
            res6 = requests.post(url, json.dumps(flow6), headers=headers)
            res7 = requests.post(url, json.dumps(flow7), headers=headers)
            res8 = requests.post(url, json.dumps(flow8), headers=headers)

            复制代码

          • 四、个人总结

            这次实验有较大的难度也比较综合,用到了之前OpenDaylight和Ryu的相关知识,但是叶通过这次实验进一步学习了用OpenDaylight和Ryu的rest API来实现特定的网络功能,除此之外还进一步学习了python的request库,也为以后打下可基础

(2) 下发指令删除s1上的流表数据。

复制代码
#!/usr/bin/python
import requests
from requests.auth import HTTPBasicAuth
if __name__ == "__main__":
    url = 'http://127.0.0.1:8181/restconf/config/opendaylight-inventory:nodes/node/openflow:1/'
    headers = {'Content-Type': 'application/json'}
    res = requests.delete(url, headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
    print (res.content)
复制代码

(3) 下发硬超时流表,实现拓扑内主机h1和h3网络中断20s。

复制代码
#!/usr/bin/python
import requests
from requests.auth import HTTPBasicAuth
if __name__ == "__main__":
    url = 'http://127.0.0.1:8181/restconf/config/opendaylight-inventory:nodes/node/openflow:1/flow-node-inventory:table/0/flow/1'
    with open("./flowtimeout.json") as file:
        str = file.read()
    headers = {'Content-Type': 'application/json'}
    res = requests.put(url, str, headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
    print (res.content)
复制代码

json文件:

复制代码
{
  "flow": [
    {
      "id": "1",
      "match": {
        "in-port": "1",
        "ethernet-match": {
          "ethernet-type": {
            "type": "0x0800"
          }
        },
        "ipv4-destination": "10.0.0.3/32"
      },
      "instructions": {
        "instruction": [
          {
            "order": "0",
            "apply-actions": {
              "action": [
                {
                  "order": "0",
                  "drop-action": {}
                }
              ]
            }
          }
        ]
      },
      "flow-name": "flow",
      "priority": "65535",
      "hard-timeout": "20",
      "cookie": "2",
      "table_id": "0"
    }
  ]
}
复制代码

 

 (4) 获取s1上活动的流表数。

复制代码
#!/usr/bin/python
import requests
from requests.auth import HTTPBasicAuth
if __name__ == "__main__":
    url = 'http://127.0.0.1:8181/restconf/operational/opendaylight-inventory:nodes/node/openflow:1/flow-node-inventory:table/0/opendaylight-flow-table-statistics:flow-table-statistics'
    headers = {'Content-Type': 'application/json'}
    res = requests.get(url,headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
    print (res.content)
复制代码

编写Python程序,调用Ryu的北向接口实现以下功能
(1) 实现上述OpenDaylight实验拓扑上相同的硬超时流表下发。

    • 关闭ODL控制器,关闭上次的拓扑并清除拓扑后

    • 使用命令ryu-manager ryu.app.simple_switch_13 ryu.app.ofctl_rest打开Ryu控制器

    • 使用命令sudo mn --topo=single,3 --mac --controller=remote,ip=127.0.0.1,port=6633 --switch ovsk,protocols=OpenFlow13创建拓扑

    • 复制代码
      #!/usr/bin/python
      import requests
      if __name__ == "__main__":
          url = 'http://127.0.0.1:8080/stats/flowentry/add'
          with open("./hardtimeout.json") as file:
              str = file.read()
          headers = {'Content-Type': 'application/json'}
          res = requests.post(url, str, headers=headers)
          print (res.content)
      复制代码

      json文件:

    • 复制代码
      {
          "dpid": 1,
          "cookie": 1,
          "cookie_mask": 1,
          "table_id": 0,
          "hard_timeout": 20,
          "priority": 65535,
          "flags": 1,
          "match":{
              "in_port":1
          },
          "actions":[
      
      ]
      

      }

      复制代码

       

       (2) 参考Ryu REST API的文档,基于VLAN实验的网络拓扑,编程实现相同的VLAN配置。
      提示:拓扑生成后需连接Ryu,且Ryu应能够提供REST API服务

    • 复制代码
      #topo.py
      from mininet.topo import Topo
      

      class MyTopo(Topo):
      def init(self):
      # initilaize topology
      Topo.init(self)

          self.addSwitch(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addSwitch(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
      
          self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h3</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addHost(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h4</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
      
          self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h3</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">h4</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
          self.addLink(</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s1</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span>, <span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">s2</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5; color: #800000;">"</span><span style="font-family: 'Courier New', serif; font-size: inherit; line-height: 1.5;">)
      

      topos = {'mytopo': (lambda: MyTopo())}

      复制代码
      • 关闭控制器,关闭上一次实验的拓扑并清除拓扑

      • 使用命令ryu-manager ryu.app.simple_switch_13 ryu.app.ofctl_rest打开Ryu控制器

      • 使用命令sudo mn --custom topo.py --topo mytopo --mac --controller=remote,ip=127.0.0.1,port=6633 --switch ovsk,protocols=OpenFlow13创建拓扑

      •  

         

        VLAN_IDHosts
        0 h1 h3
        1 h2 h4
        • 使用命令

        • curl -X DELETE http://127.0.0.1:8080/stats/flowentry/clear/1

        • curl -X DELETE http://127.0.0.1:8080/stats/flowentry/clear/2

        • 删除流表

        • 使用命令python运行下列程序

        • 复制代码
          #!/usr/bin/python
          import json
          

          import requests

          if name == "main":
          url = 'http://127.0.0.1:8080/stats/flowentry/add'
          headers = {'Content-Type': 'application/json'}
          flow1 = {
          "dpid": 1,
          "priority": 1,
          "match":{
          "in_port": 1
          },
          "actions":[
          {
          "type": "PUSH_VLAN",
          "ethertype": 33024
          },
          {
          "type": "SET_FIELD",
          "field": "vlan_vid",
          "value": 4096
          },
          {
          "type": "OUTPUT",
          "port": 3
          }
          ]
          }
          flow2 = {
          "dpid": 1,
          "priority": 1,
          "match":{
          "in_port": 2
          },
          "actions":[
          {
          "type": "PUSH_VLAN",
          "ethertype": 33024
          },
          {
          "type": "SET_FIELD",
          "field": "vlan_vid",
          "value": 4097
          },
          {
          "type": "OUTPUT",
          "port": 3
          }
          ]
          }
          flow3 = {
          "dpid": 1,
          "priority": 1,
          "match":{
          "vlan_vid": 0
          },
          "actions":[
          {
          "type": "POP_VLAN",
          "ethertype": 33024
          },
          {
          "type": "OUTPUT",
          "port": 1
          }
          ]
          }
          flow4 = {
          "dpid": 1,
          "priority": 1,
          "match": {
          "vlan_vid": 1
          },
          "actions": [
          {
          "type": "POP_VLAN",
          "ethertype": 33024
          },
          {
          "type": "OUTPUT",
          "port": 2
          }
          ]
          }
          flow5 = {
          "dpid": 2,
          "priority": 1,
          "match": {
          "in_port": 1
          },
          "actions": [
          {
          "type": "PUSH_VLAN",
          "ethertype": 33024
          },
          {
          "type": "SET_FIELD",
          "field": "vlan_vid",
          "value": 4096
          },
          {
          "type": "OUTPUT",
          "port": 3
          }
          ]
          }
          flow6 = {
          "dpid": 2,
          "priority": 1,
          "match": {
          "in_port": 2
          },
          "actions": [
          {
          "type": "PUSH_VLAN",
          "ethertype": 33024
          },
          {
          "type": "SET_FIELD",
          "field": "vlan_vid",
          "value": 4097
          },
          {
          "type": "OUTPUT",
          "port": 3
          }
          ]
          }
          flow7 = {
          "dpid": 2,
          "priority": 1,
          "match": {
          "vlan_vid": 0
          },
          "actions": [
          {
          "type": "POP_VLAN",
          "ethertype": 33024
          },
          {
          "type": "OUTPUT",
          "port": 1
          }
          ]
          }
          flow8 = {
          "dpid": 2,
          "priority": 1,
          "match": {
          "vlan_vid": 1
          },
          "actions": [
          {
          "type": "POP_VLAN",
          "ethertype": 33024
          },
          {
          "type": "OUTPUT",
          "port": 2
          }
          ]
          }
          res1 = requests.post(url, json.dumps(flow1), headers=headers)
          res2 = requests.post(url, json.dumps(flow2), headers=headers)
          res3 = requests.post(url, json.dumps(flow3), headers=headers)
          res4 = requests.post(url, json.dumps(flow4), headers=headers)
          res5 = requests.post(url, json.dumps(flow5), headers=headers)
          res6 = requests.post(url, json.dumps(flow6), headers=headers)
          res7 = requests.post(url, json.dumps(flow7), headers=headers)
          res8 = requests.post(url, json.dumps(flow8), headers=headers)

          复制代码

标签:url,REST,port,headers,json,API,SDN,type,requests
From: https://www.cnblogs.com/dongganchaoren/p/16882464.html

相关文章

  • 免费手机号码归属地API查询接口
    免费手机号码归属地API查询接口 一、淘宝网API   API地址: ​​http://tcc.taobao.com/cc/json/mobile_tel_segment.htm?tel=15850781443......
  • 【Azure API 管理】Azure APIM服务集成在内部虚拟网络后,在内部环境中打开APIM门户使用
    问题描述使用微软API管理服务(AzureAPIManagement),简称APIM。因为公司策略要求只能内部网络访问,所以启用了VNET集成。集成方式见:(在内部模式下使用AzureAPI管理连......
  • P5443 [APIO2019] 桥梁 题解
    容易得出一种暴力算法:将询问按\(w\)排序,将没有修改的边按\(d\)排序。对于每个询问\((t_i,s_i,w_i)\),做两部分操作(这里\(t\)是时间的意思):将没有修改的边中满足\(d......
  • 实验7基于rest-api的sdn北向应用实践
    实验7:基于RESTAPI的SDN北向应用实践一、实验目的能够编写程序调用OpenDaylightRESTAPI实现特定网络功能;能够编写程序调用RyuRESTAPI实现特定网络功能。二、实验......
  • 实验7:基于REST API的SDN北向应用实践
    实验7:基于RESTAPI的SDN北向应用实践一、实验目的能够编写程序调用OpenDaylightRESTAPI实现特定网络功能;能够编写程序调用RyuRESTAPI实现特定网络功能。二、实验......
  • [FastAPI-03]Form表单
    1.安装依赖pipinstall-ihttp://pypi.douban.com/simple/--trusted-hostpypi.douban.compython-multipart2.表单程序.├──post_test_1.py└──templates......
  • 3. 用过Konva吗,用过他的api吗
    基础:使用konva,首先需要创建舞台也就是stage,然后创建一个Layer图层,将图层放到舞台上,将图形等内容放到图层上;第一步:创建一个Stage舞台 ,就是创建一个stage实例;......
  • [FastAPI-02]模板渲染
    1.插件库pipinstall-ihttp://pypi.douban.com/simple/--trusted-hostpypi.douban.comjinja2aiofiles2.模板渲染程序2.1Python程序#_*_coding:UTF-8_*_......
  • [FastAPI-01]HelloWorld
    1.环境搭建/root/.pyenv/versions/3.9.14/bin/python3.9-mpipinstall-ihttp://pypi.douban.com/simple/--trusted-hostpypi.douban.com--upgradepippipinstal......
  • JDBC_2_相关api说明
                                      ......