aioice里面candidate固定UDP端口测试
环境:
aioice0.9.0
问题描述:
aioice里面candidate固定UDP端口测试
解决方案:
/miniconda3/envs/nerfstream/lib/python3.10/site-packages/aioice
import hashlib
import ipaddress
import random
from typing import Optional
import logging# 配置日志级别,默认为 INFO,可改为 DEBUG 查看详细调试信息
logging.basicConfig(level=logging.INFO)class Candidate:"""表示一个 ICE 候选者,包括固定端口功能和多种优化。"""FIXED_PORT = 59990 # 定义固定端口def __init__(self,foundation: str,component: int,transport: str,priority: int,host: str,port: Optional[int] = None, # 端口可以是 None,将被替换为固定端口type: str = "host",related_address: Optional[str] = None,related_port: Optional[int] = None,tcptype: Optional[str] = None,generation: Optional[int] = None,) -> None:"""初始化候选者对象,并强制使用固定端口。"""self.foundation = foundationself.component = componentself.transport = transportself.priority = priorityself.host = hostself.port = self.get_fixed_port() if port is None else port # 设置为固定端口或提供的端口self.type = typeself.related_address = related_addressself.related_port = related_portself.tcptype = tcptypeself.generation = generation# 输出候选者信息到日志logging.info(f"创建候选者:host={self.host}, port={self.port}, type={self.type}")@classmethoddef get_fixed_port(cls) -> int:"""返回固定端口值,并记录日志。"""fixed_port = cls.FIXED_PORTlogging.debug(f"Returning fixed port: {fixed_port}")return fixed_port@classmethoddef from_sdp(cls, sdp: str):"""从 SDP 字符串中解析一个 ICE 候选者。示例 SDP:'6815297761 1 udp 659136 192.168.1.1 12345 typ host'"""bits = sdp.split()if len(bits) < 8:raise ValueError("SDP 描述字段不足")kwargs = {"foundation": bits[0],"component": int(bits[1]),"transport": bits[2],"priority": int(bits[3]),"host": bits[4],"port": cls.get_fixed_port(), # 使用固定端口"type": bits[7],}# 提取 SDP 中的附加信息for i in range(8, len(bits), 2):if bits[i] == "raddr":kwargs["related_address"] = bits[i + 1]elif bits[i] == "rport":kwargs["related_port"] = int(bits[i + 1])elif bits[i] == "tcptype":kwargs["tcptype"] = bits[i + 1]elif bits[i] == "generation":kwargs["generation"] = int(bits[i + 1])return cls(**kwargs)def to_sdp(self) -> str:"""返回一个适用于 SDP 的字符串表示形式。"""sdp = f"{self.foundation} {self.component} {self.transport} {self.priority} {self.host} {self.port} typ {self.type}"if self.related_address is not None:sdp += f" raddr {self.related_address}"if self.related_port is not None:sdp += f" rport {self.related_port}"if self.tcptype is not None:sdp += f" tcptype {self.tcptype}"if self.generation is not None:sdp += f" generation {self.generation}"return sdpdef can_pair_with(self, other) -> bool:"""判断本地候选者是否可以与远程候选者配对。配对条件:- 组件相同- 使用相同的传输协议- IP 地址版本相同"""a = ipaddress.ip_address(self.host)b = ipaddress.ip_address(other.host)return (self.component == other.componentand self.transport.lower() == other.transport.lower()and a.version == b.version)def __repr__(self) -> str:"""返回候选者的字符串表示形式。"""return f"Candidate({self.to_sdp()})"# 工具函数部分
def candidate_foundation(candidate_type: str, candidate_transport: str, base_address: str) -> str:"""计算候选者的 Foundation(基础标识符)。"""key = f"{candidate_type}|{candidate_transport}|{base_address}"return hashlib.md5(key.encode("ascii")).hexdigest()def candidate_priority(candidate_component: int, candidate_type: str, local_pref: int = 65535) -> int:"""计算候选者优先级。优先级从高到低的顺序为:host > srflx > relay。"""type_preferences = {"host": 126, # Host 类型优先级最高"srflx": 100, # Server reflexive 类型"relay": 0, # Relay 类型优先级最低}type_pref = type_preferences.get(candidate_type, 0)return (1 << 24) * type_pref + (1 << 8) * local_pref + (256 - candidate_component)# 测试代码部分
if __name__ == "__main__":# 测试创建候选者candidate = Candidate(foundation="1",component=1,transport="udp",priority=candidate_priority(1, "host"),host="192.168.168.77", # 使用你的本地 IP 地址type="host",)print(candidate) # 打印候选者信息print(candidate.to_sdp()) # 打印 SDP 字符串# 测试从 SDP 创建候选者sdp_example = "1 1 udp 100 192.168.1.1 12345 typ host"candidate_from_sdp = Candidate.from_sdp(sdp_example)print(candidate_from_sdp) # 打印解析后的候选者print(candidate_from_sdp.to_sdp()) # 打印 SDP 字符串# 模拟 WebRTC 应用程序创建多个候选者candidates = [Candidate(foundation=str(i),component=1,transport="udp",priority=candidate_priority(1, "host"),host=f"192.168.1.{i % 255}", # 使用不同的 IP 地址模拟不同设备type="host",)for i in range(1, 6)]for c in candidates:print(c)
运行没有成功

相关文章:
aioice里面candidate固定UDP端口测试
环境: aioice0.9.0 问题描述: aioice里面candidate固定UDP端口测试 解决方案: /miniconda3/envs/nerfstream/lib/python3.10/site-packages/aioice import hashlib import ipaddress import random from typing import Optional import…...
Git使用教程-分支使用/合并分支提交
Git使用教程-分支使用 文章目录 Git使用教程-分支使用一、分支(branch)的基本操作:二、查看分支:参考 一、分支(branch)的基本操作: git clone https://.git git status …...
单元测试使用记录
什么是单元测试 简单来说就是对一个类中的方法进行测试,对输出的结果检查判断是否符合预期结果 但是在多年的工作中,从来没有哪个项目中真正系统的用到了单元测试,因此对它还是很陌生的,也就造成更加不会在项目中区使用它。 如何…...
LabVIEW实时信号采集与频谱分析
系统通过LabVIEW与PXIe硬件结合,实现高精度模拟信号的实时采集、频谱分析与可视化显示。核心功能包括采样率配置、快速傅里叶变换(FFT)、功率谱图生成及动态缩放调整,同时支持信号平均与噪声抑制。系统设计灵活,适用于…...
OpenCV(python)从入门到精通——运算操作
加法减法操作 import cv2 as cv import numpy as npx np.uint8([250]) y np.uint8([10])x_1 np.uint8([10]) y_1 np.uint8([20])# 加法,相加最大只能为255 print(cv.add(x,y))# 减法,相互减最小值只能为0 print(cv.subtract(x_1,y_1))图像加法 import cv2 as…...
基础2:值类型与右值引用
1.函数返回 在讲解右值之前,要知道下面这个函数要进行几次拷贝以及为什么? int get_x() {int x 20;return x; }int aget_x(); 答案:两次 # 第一次 int tmpa; # 第二次 int xtmp;2.左值与右值 🍏2.1 能取地址操作的就是左值 …...
GitHub年度报告发布!Python首次超越JavaScript
全球开发者数量激增,GenAI 项目呈爆炸式增长趋势,推动编程语言的应用格局也发生了巨大变化,最新的 GitHub Octoverse 报告来了! 1、Python 首次超越 JavaScript,成为 GitHub 平台最顶级编程语言 不同于流传“AI 即将取…...
EdgeX Message Bus 消息总线
EdgeX Message Bus 消息总线 一、概述 EdgeX MessageBus 内部消息总线,用于 EdgeX 服务之间的内部通信。 EdgeX 服务是指来自 EdgeX 的任何核心/支持/应用程序/设备服务或使用 EdgeX SDK 构建的任何自定义应用程序或设备服务。 EdgeX MessageBus 用于内部 EdgeX 服务与服务之间…...
【JavaEE进阶】关于Maven
目录 🌴什么是Maven 🌲为什么要学Maven 🎍创建一个Maven项目 🎄Maven核心功能 🚩项目构建 🚩依赖管理 🎋Maven Help插件 🍀Maven 仓库 🚩本地仓库 Ὢ…...
YOLOv9-0.1部分代码阅读笔记-autoanchor.py
autoanchor.py utils\autoanchor.py 目录 autoanchor.py 1.所需的库和模块 2.def check_anchor_order(m): 3.def check_anchors(dataset, model, thr4.0, imgsz640): 4.def kmean_anchors(dataset./data/coco128.yaml, n9, img_size640, thr4.0, gen1000, verboseTrue…...
Electronjs+Vue如何开发PC桌面客户端(Windows,Mac,Linux)
electronjs官网 https://www.electronjs.org/zh/ Electron开发PC桌面客户端的技术选型非常适合已经有web前端开发人员的团队。能够很丝滑的过渡。 Electron是什么? Electron是一个使用 JavaScript、HTML 和 CSS 构建桌面应用程序的框架。 嵌入 Chromium 和 Node.…...
谷歌浏览器 安装谷歌浏览器特定版本后禁止自动更新
问题描述 我们通过离线安装谷歌浏览器后,第一次打开浏览器时会默认下载最新版本,等到我们重启浏览器后它会自动更新。在项目中为了能固定浏览器版本,所以要禁止谷歌浏览器的更新,网上找了好多方法都没用,自己摸索出来…...
Linux计算时间差
Linux计算时间差 1、Linux计算时间差2、时间差的应用 1、Linux计算时间差 在Linux中,计算时间差通常是为了统计、监控或调试。时间差可以用来衡量任务执行的时间,或者两个事件之间的间隔。例如,响应时间、执行时间、定时任务与延时处理等 以…...
Python的3D可视化库【vedo】2-5 (plotter模块) 坐标转换、场景导出、添加控件
文章目录 4 Plotter类的方法4.7 屏幕和场景中的坐标点转换4.7.1 屏幕坐标转为世界坐标4.7.2 世界坐标转为屏幕坐标4.7.3 屏幕坐标取颜色 4.8 导出4.8.1 导出2D图片4.8.2 导出3D文件 4.9 添加控件4.9.1 添加内嵌子窗口4.9.2 添加选择区4.9.3 添加比例尺4.9.4 为对象添加弹出提示…...
【VUE】13、安装nrm管理多个npm源
nrm(npm registry manager)是一个 npm 源管理器,它允许用户快速地在不同的 npm 源之间进行切换,以提高包管理的速度和效率。以下是对 nrm 使用的详细介绍: 1、安装nrm 在使用 nrm 之前,需要先确保已经安装…...
【SQL/MySQL 如何使用三种触发器】SQL语句实例演示
触发器介绍 – 触发器是与表有关的数据库对象,指在insert/update/delete之前(BEFORE)或之后(AFTER),触发并执行触发器中定义的SQL语句集合。 – 使用别名OLD和NEW来引用触发器中发生变化的记录内容,这与其他的数据库是相似的。现在触发器还只…...
Docker容器五种网络驱动模式详解
Docker 网络用于在容器之间以及容器与外部网络之间提供通信功能。它允许容器在隔离的网络环境中运行,同时也能根据需要与其他容器或外部网络进行交互。通过使用网络驱动,Docker 可以创建不同类型的网络,以满足各种应用场景的需求。 传统上&am…...
netfilter简介及流程图
Netfilter 是 Linux 内核中用于网络包过滤和操作的框架,由 Rusty Russell 于1998年创立,旨在改进旧的 ipchains 和 ipfwadm 实现。它采用模块化设计,具有良好可扩展性,并在2000年3月合并进Linux 2.3.x内核版本。 Netfilter的主要…...
Vue 前端代码规范
在 Vue 前端开发中,遵循代码规范可以提高代码的可读性、可维护性和团队协作效率。以下是一些详细的 Vue 前端代码规范,涵盖了多个方面: ### 1. **项目结构** - **目录结构**:- src/ 目录下应包含 components/、views/、store/、router/、ass…...
JAVA:组合模式(Composite Pattern)的技术指南
1、简述 组合模式(Composite Pattern)是一种结构型设计模式,旨在将对象组合成树形结构以表示“部分-整体”的层次结构。它使客户端对单个对象和组合对象的使用具有一致性。 设计模式样例:https://gitee.com/lhdxhl/design-pattern-example.git 2、什么是组合模式 组合模式…...
Flask RESTful 示例
目录 1. 环境准备2. 安装依赖3. 修改main.py4. 运行应用5. API使用示例获取所有任务获取单个任务创建新任务更新任务删除任务 中文乱码问题: 下面创建一个简单的Flask RESTful API示例。首先,我们需要创建环境,安装必要的依赖,然后…...
【HarmonyOS 5.0】DevEco Testing:鸿蒙应用质量保障的终极武器
——全方位测试解决方案与代码实战 一、工具定位与核心能力 DevEco Testing是HarmonyOS官方推出的一体化测试平台,覆盖应用全生命周期测试需求,主要提供五大核心能力: 测试类型检测目标关键指标功能体验基…...
push [特殊字符] present
push 🆚 present 前言present和dismiss特点代码演示 push和pop特点代码演示 前言 在 iOS 开发中,push 和 present 是两种不同的视图控制器切换方式,它们有着显著的区别。 present和dismiss 特点 在当前控制器上方新建视图层级需要手动调用…...
在鸿蒙HarmonyOS 5中使用DevEco Studio实现企业微信功能
1. 开发环境准备 安装DevEco Studio 3.1: 从华为开发者官网下载最新版DevEco Studio安装HarmonyOS 5.0 SDK 项目配置: // module.json5 {"module": {"requestPermissions": [{"name": "ohos.permis…...
《Docker》架构
文章目录 架构模式单机架构应用数据分离架构应用服务器集群架构读写分离/主从分离架构冷热分离架构垂直分库架构微服务架构容器编排架构什么是容器,docker,镜像,k8s 架构模式 单机架构 单机架构其实就是应用服务器和单机服务器都部署在同一…...
C++_哈希表
本篇文章是对C学习的哈希表部分的学习分享 相信一定会对你有所帮助~ 那咱们废话不多说,直接开始吧! 一、基础概念 1. 哈希核心思想: 哈希函数的作用:通过此函数建立一个Key与存储位置之间的映射关系。理想目标:实现…...
ui框架-文件列表展示
ui框架-文件列表展示 介绍 UI框架的文件列表展示组件,可以展示文件夹,支持列表展示和图标展示模式。组件提供了丰富的功能和可配置选项,适用于文件管理、文件上传等场景。 功能特性 支持列表模式和网格模式的切换展示支持文件和文件夹的层…...
Java数组Arrays操作全攻略
Arrays类的概述 Java中的Arrays类位于java.util包中,提供了一系列静态方法用于操作数组(如排序、搜索、填充、比较等)。这些方法适用于基本类型数组和对象数组。 常用成员方法及代码示例 排序(sort) 对数组进行升序…...
Canal环境搭建并实现和ES数据同步
作者:田超凡 日期:2025年6月7日 Canal安装,启动端口11111、8082: 安装canal-deployer服务端: https://github.com/alibaba/canal/releases/1.1.7/canal.deployer-1.1.7.tar.gz cd /opt/homebrew/etc mkdir canal…...
【java】【服务器】线程上下文丢失 是指什么
目录 ■前言 ■正文开始 线程上下文的核心组成部分 为什么会出现上下文丢失? 直观示例说明 为什么上下文如此重要? 解决上下文丢失的关键 总结 ■如果我想在servlet中使用线程,代码应该如何实现 推荐方案:使用 ManagedE…...
