当前位置： 首页 > news >正文

初识SDN（二）

news 来源：原创 2024/9/29 2:54:40

初识SDN（二）

SDN部分实现

REST API 是什么？

REST API（Representational State Transfer Application Programming Interface，表述性状态传递应用程序接口）是一种基于HTTP协议的接口，广泛用于Web服务和应用程序之间的通信。REST API 通过标准的HTTP方法（如GET、POST、PUT、DELETE）来执行操作，具有以下特点：

特点

  1. 无状态性：

    • 每个请求都是独立的，服务器不保存客户端的上下文状态。这意味着每个请求必须包含所有必要的信息。

  2. 资源导向：

    • REST API 将系统中的所有内容视为资源（如用户、订单、产品等），每个资源都有唯一的URI（统一资源标识符）。

  3. 标准化操作：

    • 使用HTTP方法来执行操作：
      • GET：获取资源
      • POST：创建资源
      • PUT：更新资源
      • DELETE：删除资源

  4. 表现层状态转移：

    • 客户端与服务器之间的交互通过表述（representation）来进行，这些表述可以是JSON、XML、HTML等格式。

优点

  • 简单易用：基于HTTP协议，容易理解和使用。
  • 灵活性强：可以处理各种数据格式，如JSON、XML。
  • 可扩展性好：通过标准化的URI和HTTP方法，可以轻松扩展和维护API。

在 REST API 中，HTTP 方法用于定义对资源执行的操作。以下是主要的 HTTP 方法及其区别：

1. GET

  • 功能：用于从服务器获取资源。
  • 幂等性：是（多次相同请求的效果与一次请求相同）。
  • 安全性：是（不会改变服务器状态，只是获取数据）。
  • 示例：
    GET /users
GET /users/{userId}

2. POST

  • 功能：用于向服务器创建新资源。
  • 幂等性：否（多次相同请求会创建多个资源）。
  • 安全性：否（会改变服务器状态）。
  • 示例：
    POST /users
Content-Type: application/json{"name": "John Doe","email": "john.doe@example.com"
}

3. PUT

  • 功能：用于更新或替换服务器上的资源。如果资源不存在，则可以创建新资源（视实现而定）。
  • 幂等性：是（多次相同请求的效果与一次请求相同）。
  • 安全性：否（会改变服务器状态）。
  • 示例：
    PUT /users/{userId}
Content-Type: application/json{"name": "Jane Doe","email": "jane.doe@example.com"
}

4. DELETE

  • 功能：用于删除服务器上的资源。
  • 幂等性：是（多次相同请求的效果与一次请求相同，即使资源已经被删除）。
  • 安全性：否（会改变服务器状态）。
  • 示例：
    DELETE /users/{userId}

5. PATCH

  • 功能：用于部分更新服务器上的资源。
  • 幂等性：视实现而定（通常认为是，但不一定总是）。
  • 安全性：否（会改变服务器状态）。
  • 示例：
    PATCH /users/{userId}
Content-Type: application/json{"email": "new.email@example.com"
}

总结

  • GET：获取资源，不会改变服务器状态，幂等且安全。
  • POST：创建新资源，可能改变服务器状态，非幂等且不安全。
  • PUT：更新或替换资源，可能改变服务器状态，幂等但不安全。
  • DELETE：删除资源，可能改变服务器状态，幂等但不安全。
  • PATCH：部分更新资源，可能改变服务器状态，通常幂等但不安全。

示例

假设有一个管理用户的REST API，以下是一些示例请求：

  1. 获取所有用户：

    GET /users

  2. 获取特定用户：

    GET /users/{userId}

  3. 创建新用户：

    POST /users
Content-Type: application/json{"name": "John Doe","email": "john.doe@example.com"
}

  4. 更新用户信息：

    PUT /users/{userId}
Content-Type: application/json{"name": "John Doe","email": "john.doe@newdomain.com"
}

  5. 删除用户：

    DELETE /users/{userId}

gRPC 接口

gRPC（gRPC Remote Procedure Calls）是一种高性能、开源的远程过程调用（RPC）框架，由 Google 开发。它使用 HTTP/2 作为传输协议，并采用 Protocol Buffers（protobuf）作为接口描述语言。以下是 gRPC 的一些关键特点和优点：

特点

  1. 高性能：

    • 使用 HTTP/2 协议，支持多路复用、头部压缩和服务器推送，提供更高的性能和效率。

  2. 多语言支持：

    • gRPC 支持多种编程语言，包括 C++、Java、Python、Go、Ruby、C# 等，便于跨语言应用开发。

  3. 强类型接口：

    • 使用 Protocol Buffers 定义服务和消息格式，提供强类型检查和高效的序列化/反序列化。

  4. 双向流：

    • 支持客户端流、服务器流和双向流，适用于复杂的通信模式。

优点

  • 高效通信：基于 HTTP/2 和 Protocol Buffers，提供低延迟、高吞吐量的通信。
  • 简洁的接口定义：通过 .proto 文件定义服务和消息，生成代码可以直接使用。
  • 自动生成代码：gRPC 工具可以自动生成客户端和服务器端代码，减少手动编写代码的工作量。
  • 跨平台：支持多种操作系统和编程语言，便于跨平台开发。

示例

假设我们有一个简单的用户管理服务，定义在一个 .proto 文件中：

syntax = "proto3";package user;service UserService {rpc GetUser (GetUserRequest) returns (GetUserResponse);rpc CreateUser (CreateUserRequest) returns (CreateUserResponse);
}message GetUserRequest {string user_id = 1;
}message GetUserResponse {string user_id = 1;string name = 2;string email = 3;
}message CreateUserRequest {string name = 1;string email = 2;
}message CreateUserResponse {string user_id = 1;
}

使用步骤

  1. 定义 .proto 文件：

    • 使用 Protocol Buffers 定义服务和消息格式，如上面的示例。

  2. 生成代码：

    • 使用 protoc 工具生成客户端和服务器端代码。例如：
      protoc --go_out=. --go-grpc_out=. user.proto

  3. 实现服务：

    • 在服务器端实现定义的服务接口。在客户端调用生成的客户端代码。

gRPC 的应用场景

  • 微服务架构：适用于需要高效、可靠通信的微服务架构。
  • 实时通信：如实时聊天、视频流等需要低延迟的应用。
  • 跨平台通信：需要在不同语言和平台之间进行通信的应用。

核心服务层的主要功能

  1. 拓扑发现：

    • 功能：动态发现和维护网络拓扑结构。
    • 作用：通过与网络设备的交互，SDN 控制器可以实时获取和更新网络拓扑信息。这包括设备之间的连接关系、链路状态等。
    • 实现方式：通常通过 LLDP（链路层发现协议）等协议实现。

  2. 路径计算：

    • 功能：根据网络状态和策略计算最优的流量路径。
    • 作用：SDN 控制器根据当前的网络拓扑和预定义的策略（如最短路径、负载均衡等），计算出数据包应通过的最佳路径。
    • 实现方式：使用各种算法（如 Dijkstra 算法）来计算路径，并动态调整以优化网络性能。

  3. 流量管理：

    • 功能：管理和控制网络流量，实施流量工程策略。
    • 作用：通过控制数据包的转发路径，SDN 控制器可以实现流量的优化和管理，如流量分流、带宽控制、优先级管理等。
    • 实现方式：使用 OpenFlow 等南向接口协议下发流表项，控制数据包的转发行为。

  4. 设备管理：

    • 功能：管理网络设备的配置和状态。
    • 作用：SDN 控制器可以集中管理网络设备的配置，监控设备状态，进行故障检测和恢复，确保网络的稳定运行。
    • 实现方式：通过 NETCONF、SNMP 等协议与设备进行交互，获取和修改设备配置。

扩展

步骤 1：安装 Protocol Buffers 编译器

首先，你需要安装 Protocol Buffers 编译器 protoc。你可以从 Protocol Buffers 的 GitHub 页面 下载适合你操作系统的版本并进行安装。

步骤 2：安装 gRPC 插件

根据你使用的编程语言，安装相应的 gRPC 插件。例如，对于 Python，你可以使用 pip 安装：

pip install grpcio grpcio-tools

对于其他语言，你可以参考 gRPC 官方文档 获取详细的安装指南。

步骤 3：定义 .proto 文件

创建一个 .proto 文件，定义你的服务和消息。例如，创建一个 user.proto 文件：

syntax = "proto3";package user;service UserService {rpc GetUser (GetUserRequest) returns (GetUserResponse);rpc CreateUser (CreateUserRequest) returns (CreateUserResponse);
}message GetUserRequest {string user_id = 1;
}message GetUserResponse {string user_id = 1;string name = 2;string email = 3;
}message CreateUserRequest {string name = 1;string email = 2;
}message CreateUserResponse {string user_id = 1;
}

步骤 4：生成代码

使用 protoc 编译器和 gRPC 插件生成客户端和服务器端代码。例如，对于 Python：

python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. user.proto

这将生成两个文件：

  • user_pb2.py：包含消息类。
  • user_pb2_grpc.py：包含服务类和客户端存根。

对于其他语言，如 Java、Go 或 C#，生成代码的命令会有所不同。你可以参考 gRPC 官方文档 获取详细的命令。

步骤 5：实现服务器和客户端

生成代码后，你需要实现服务器和客户端逻辑。以下是一个简单的 Python 示例：

服务器实现（server.py）：
from concurrent import futures
import grpc
import user_pb2
import user_pb2_grpcclass UserService(user_pb2_grpc.UserServiceServicer):def GetUser(self, request, context):return user_pb2.GetUserResponse(user_id=request.user_id, name="John Doe", email="john.doe@example.com")def CreateUser(self, request, context):return user_pb2.CreateUserResponse(user_id="12345")def serve():server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))user_pb2_grpc.add_UserServiceServicer_to_server(UserService(), server)server.add_insecure_port('[::]:50051')server.start()server.wait_for_termination()if __name__ == '__main__':serve()
客户端实现（client.py）：
import grpc
import user_pb2
import user_pb2_grpcdef run():with grpc.insecure_channel('localhost:50051') as channel:stub = user_pb2_grpc.UserServiceStub(channel)response = stub.GetUser(user_pb2.GetUserRequest(user_id="12345"))print("GetUser response: ", response)response = stub.CreateUser(user_pb2.CreateUserRequest(name="Jane Doe", email="jane.doe@example.com"))print("CreateUser response: ", response)if __name__ == '__main__':run()

PROTO文件编辑

通过一个更详细的实际项目示例来说明如何定义 .proto 文件。

假设我们要开发一个简单的博客系统，包含以下功能：

  1. 获取博客文章
  2. 创建博客文章
  3. 更新博客文章
  4. 删除博客文章

步骤 1：明确服务和方法

我们需要一个 BlogService 服务，包含以下方法：

  • GetBlog：获取博客文章
  • CreateBlog：创建博客文章
  • UpdateBlog：更新博客文章
  • DeleteBlog：删除博客文章

步骤 2：定义消息类型

每个方法需要请求和响应消息。例如：

  • GetBlog 方法需要一个包含博客ID的请求消息，并返回包含博客详细信息的响应消息。
  • CreateBlog 方法需要一个包含博客标题和内容的请求消息，并返回新创建的博客ID。

步骤 3：编写 .proto 文件

根据上述需求，编写你的 .proto 文件。以下是一个示例：

syntax = "proto3";  // 使用 Protocol Buffers 的版本package blog;  // 定义包名// 定义 BlogService 服务
service BlogService {// 定义 GetBlog 方法rpc GetBlog (GetBlogRequest) returns (GetBlogResponse);// 定义 CreateBlog 方法rpc CreateBlog (CreateBlogRequest) returns (CreateBlogResponse);// 定义 UpdateBlog 方法rpc UpdateBlog (UpdateBlogRequest) returns (UpdateBlogResponse);// 定义 DeleteBlog 方法rpc DeleteBlog (DeleteBlogRequest) returns (DeleteBlogResponse);
}// 定义 GetBlog 请求消息
message GetBlogRequest {string blog_id = 1;  // 博客ID
}// 定义 GetBlog 响应消息
message GetBlogResponse {string blog_id = 1;  // 博客IDstring title = 2;    // 博客标题string content = 3;  // 博客内容
}// 定义 CreateBlog 请求消息
message CreateBlogRequest {string title = 1;    // 博客标题string content = 2;  // 博客内容
}// 定义 CreateBlog 响应消息
message CreateBlogResponse {string blog_id = 1;  // 新创建的博客ID
}// 定义 UpdateBlog 请求消息
message UpdateBlogRequest {string blog_id = 1;  // 博客IDstring title = 2;    // 博客标题string content = 3;  // 博客内容
}// 定义 UpdateBlog 响应消息
message UpdateBlogResponse {bool success = 1;    // 更新是否成功
}// 定义 DeleteBlog 请求消息
message DeleteBlogRequest {string blog_id = 1;  // 博客ID
}// 定义 DeleteBlog 响应消息
message DeleteBlogResponse {bool success = 1;    // 删除是否成功
}

步骤 4：生成代码

使用 protoc 编译器生成客户端和服务器端代码。例如，对于 Python：

python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. blog.proto

这将生成两个文件：

  • blog_pb2.py：包含消息类。
  • blog_pb2_grpc.py：包含服务类和客户端存根。

实际项目中的使用

在实际项目中，你可以使用生成的代码来实现服务端逻辑和客户端调用。例如，在 Python 中：

服务端实现（server.py）
import grpc
from concurrent import futures
import blog_pb2_grpc as pb2_grpc
import blog_pb2 as pb2class BlogService(pb2_grpc.BlogServiceServicer):def GetBlog(self, request, context):# 实现获取博客文章的逻辑return pb2.GetBlogResponse(blog_id=request.blog_id, title="Sample Title", content="Sample Content")def CreateBlog(self, request, context):# 实现创建博客文章的逻辑return pb2.CreateBlogResponse(blog_id="new_blog_id")def UpdateBlog(self, request, context):# 实现更新博客文章的逻辑return pb2.UpdateBlogResponse(success=True)def DeleteBlog(self, request, context):# 实现删除博客文章的逻辑return pb2.DeleteBlogResponse(success=True)def serve():server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))pb2_grpc.add_BlogServiceServicer_to_server(BlogService(), server)server.add_insecure_port('[::]:50051')server.start()server.wait_for_termination()if __name__ == '__main__':serve()
客户端调用（client.py）
import grpc
import blog_pb2_grpc as pb2_grpc
import blog_pb2 as pb2def run():with grpc.insecure_channel('localhost:50051') as channel:stub = pb2_grpc.BlogServiceStub(channel)response = stub.GetBlog(pb2.GetBlogRequest(blog_id="sample_blog_id"))print("GetBlog Response:", response)if __name__ == '__main__':run()

相关文章：

  • 弘君资本：存储芯片概念强势，西测测试三连板，佰维存储涨超10%
  • 【C++】6-6 你好，输出的格式控制（对齐）
  • H6911 DC2.6-40V升压IC 升24V36V48V60V80V100V10A数转模无频闪LED芯片
  • 过滤器、监听器、拦截器的区别
  • 格式化数据恢复指南：从备份到实战，3个技巧一网打尽
  • pycharm 上一次编辑位置不见了
  • AI时代下的智能商品计划管理
  • Love-Yi情侣网站3.0存在SQL注入漏洞
  • 如何在路由器上安装代理服务：详细教程
  • redis笔记1
  • 在 Qt Creator 上创建 ROS 项目并新建/导入 ROS 包
  • 探究MySQL中的“树”结构
  • 【TensorFlow深度学习】卷积层变种与深度残差网络原理
  • Java——二进制原码、反码和补码
  • xmake+xrepo自建仓库添加交叉编译工具链
  • 【css3】浏览器内核及其兼容性
  • dva中组件的懒加载
  • express如何解决request entity too large问题
  • linux安装openssl、swoole等扩展的具体步骤
  • Netty 4.1 源代码学习：线程模型
  • Selenium实战教程系列（二）---元素定位
  • Spring核心 Bean的高级装配
  • ubuntu 下nginx安装 并支持https协议
  • vue-router 实现分析
  • 从零开始的无人驾驶 1
  • 工作中总结前端开发流程--vue项目
  • 回流、重绘及其优化
  • 基于Mobx的多页面小程序的全局共享状态管理实践
  • 前端相关框架总和
  • 如何选择开源的机器学习框架？
  • 通过来模仿稀土掘金个人页面的布局来学习使用CoordinatorLayout
  • 限制Java线程池运行线程以及等待线程数量的策略
  • 交换综合实验一
  • ​Python 3 新特性：类型注解
  • ‌分布式计算技术与复杂算法优化：‌现代数据处理的基石
  • # 日期待t_最值得等的SUV奥迪Q9：空间比MPV还大，或搭4.0T，香
  • #微信小程序（布局、渲染层基础知识）
  • #我与Java虚拟机的故事#连载05：Java虚拟机的修炼之道
  • （11）MSP430F5529 定时器B
  • (70min)字节暑假实习二面（已挂）
  • (javascript)再说document.body.scrollTop的使用问题
  • (Mirage系列之二)VMware Horizon Mirage的经典用户用例及真实案例分析
  • (php伪随机数生成)[GWCTF 2019]枯燥的抽奖
  • （rabbitmq的高级特性）消息可靠性
  • （补充）：java各种进制、原码、反码、补码和文本、图像、音频在计算机中的存储方式
  • (差分)胡桃爱原石
  • （二刷）代码随想录第16天|104.二叉树的最大深度 559.n叉树的最大深度● 111.二叉树的最小深度● 222.完全二叉树的节点个数
  • （附源码）springboot“微印象”在线打印预约系统 毕业设计 061642
  • （十三）Flask之特殊装饰器详解
  • （一）SpringBoot3---尚硅谷总结
  • （总结）Linux下的暴力密码在线破解工具Hydra详解
  • ***测试-HTTP方法
  • . NET自动找可写目录
  • .config、Kconfig、***_defconfig之间的关系和工作原理
  • .net 8 发布了，试下微软最近强推的MAUI