公网tcp转流

之前做过几次公网推流的尝试, 今天试了UDP推到公网, 再用TCP从公网拉下来, 发现不行, 就直接改用TCP转TCP了.
中间中转使用的python脚本, 感谢GPT提供技术支持:

import socket
import threadingdef tcp_receiver(port, forward_queue):"""接收TCP数据并将其放入队列"""receiver_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)receiver_socket.bind(('', port))receiver_socket.listen(1)print(f"TCP receiver ready on port {port}")while True:client_socket, addr = receiver_socket.accept()print(f"Connected by {addr} for receiving data on port {port}")try:while True:data = client_socket.recv(1024)if not data:breakforward_queue.put(data)finally:client_socket.close()print(f"Receiver connection closed by {addr}")def tcp_forwarder(port, forward_queue):"""从队列中获取数据并转发到另一个TCP连接"""forwarder_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)forwarder_socket.bind(('', port))forwarder_socket.listen(1)print(f"TCP forwarder ready on port {port}")while True:client_socket, addr = forwarder_socket.accept()print(f"Connected by {addr} for forwarding data on port {port}")try:while True:data = forward_queue.get()  # This blocks until data is availabletry:client_socket.sendall(data)except socket.error:print("Failed to send data, discarding packet")break  # End connection if sending failsfinally:client_socket.close()print(f"Forwarder connection closed by {addr}")if __name__ == '__main__':from queue import Queuedata_queue = Queue()receiver_thread = threading.Thread(target=tcp_receiver, args=(9998, data_queue))forwarder_thread = threading.Thread(target=tcp_forwarder, args=(9997, data_queue))receiver_thread.start()forwarder_thread.start()

就是从9998端口转发数据到9997端口, 下一步就用nginx做这个好了. 不用脚本了.

rtsp的部分, 源码在下面:

https://github.com/MontaukLaw/1126_rtsp

基于官方的vi_venc_rtsp sample code, 将rtsp的部分改成直接往公网推.

播放流依然是老办法:

ffplay -i tcp://wan_ip:9997

因为我不需要缓存, 所以之前用ZLMedia转的方法, 一直会导致延迟慢慢变大, 可能是缓存的关系.
目前, 1126使用的WiFi连接的Internet, 延迟大约在1秒左右

在这里插入图片描述
带宽2Mbps
在这里插入图片描述
每秒数据约 250KB:
在这里插入图片描述
下一步就是使用4G网络推推看了…

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/7150.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

linux之NAMP

linux之NAMP Nmap(Network Mapper)是一个开源的网络扫描和安全审计工具。它被设计用来快速地扫描大型网络,尽管它也可以对单个主机进行有效的扫描。Nmap利用原始IP数据包以多种方式探测目标网络上的主机、服务(应用程序名称和版本…

LLM应用:工作流workflow创建自定义模版使用

参考: https://www.coze.cn/ 本案例是在coze平台上操作的,也有其他工具支持工作流的创建例如dify;也例如图像生成的comfyui工作流工具 创建自定义模版 可以根据自己需求创建自己的工作流工具;本文案例是创建一个联网搜索的LLM应用: 创建工作流页面: https://www.coze.c…

X 推出 Stories 功能,由 Grok AI 生成新闻摘要

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗?订阅我们的简报,深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同,从行业内部的深度分析和实用指南中受益。不要错过这个机会,成为AI领…

工厂模式+策略模式

输入实体 基类 import lombok.Data;Data public class PersonInputDto {private Integer id;private String name; }子类 Data AllArgsConstructor NoArgsConstructor public class ManPerson extends PersonInputDto {private String sex; }Data AllArgsConstructor NoArgs…

嵌入式学习day11

每日面试题 全局变量可不可以定义在可被多个.c文件包含的头文件中,为啥? 可以,在不同的C文件中各自用static声明的全局变量,变量名可能相同,但是各自C文件中的全局变量的作用域为该文件,所以互不干扰。 …

渗透 如何防御ARP欺骗,LLMNR-MDNS-NBNS等协议的作用

一. 如何防御ARP欺骗? 1.使用双向IP/MAC绑定; 2.使用静态ARP缓存表; 3.使用ARP服务器,通过服务器来查找ARP转换表来响应其他机器的广播; 4.使用ARP欺骗防护软件; 5.在网关设备上部署防ARP欺骗攻击功能…

Python自动化测试【selenium面试题】

一、selenium中如何判断元素是否存在? expected_conditions模块提供了16种判断方法,以下方法是判断元素存在DOM中: presence_of_element_located """ An expectation for checking that an element is present on the DOM of…

分布式与一致性协议之ZAB协议(三)

ZAB协议 主节点崩溃了,怎么办? 众所周知,系统在运行中不可避免会出现各种各样的问题,比如进程崩溃了、服务器死机了,这些问题会导致很严重的后果,让系统没办法继续运行。在ZAB协议中,写请求是…

深度学习论文: DMAD: Dual Memory Bank for Real-World Anomaly Detection

深度学习论文: DMAD: Dual Memory Bank for Real-World Anomaly Detection DMAD: Dual Memory Bank for Real-World Anomaly Detection PDF: https://arxiv.org/pdf/2403.12362 PyTorch代码: https://github.com/shanglianlm0525/CvPytorch PyTorch代码: https://github.com/sh…

如何快速找到并处理jar依赖冲突问题

处理jar文件的依赖冲突一般有以下几种方法: 1、使用Maven的dependency:tree命令 Maven的dependency:tree命令可以帮助你快速找到项目的所有依赖的树状图。你可以在命令行运行以下命令: mvn dependency:tree你也可以使用-Dincludes参数来过滤某些特定的…

数智先锋 | 多场景数据治理案例,释放数据要素生产力

数据作为第五大生产要素,成为释放新质生产力的关键基础。 当前各个行业数字化建设如火如荼,全力挖掘数据价值以驱动行业高质量应用发展。数据治理成为数据要素价值发挥的重要基础和前提。 数据治理不单是技术问题,不是依赖工具就能解决的&a…

JVM之内存分配的详细解析

内存分配 两种方式 不分配内存的对象无法进行其他操作,JVM 为对象分配内存的过程:首先计算对象占用空间大小,接着在堆中划分一块内存给新对象 如果内存规整,使用指针碰撞(Bump The Pointer)。所有用过的内…

首屏优化-图片懒加载的代码实践(可直接运行)

实现图片懒加载时&#xff0c;可以使用 JavaScript 监听滚动事件&#xff0c;并根据图片是否进入可视区域来延迟加载图片。 方案一 <!DOCTYPE html> <html><head><style>.placeholder {width: 300px;height: 200px;background-color: #ccc;}.image {…

一文搞定文件的读写操作

文件的操作 C C语言中&#xff0c;文件的读取操作流程如下&#xff1a; 定义一个文件的指针将指针指向需要打开的文件&#xff0c;并且赋予该指针权限&#xff08;读&#xff0c;写&#xff0c;追加&#xff09;然后开始向文件写/读数据 打开文件 定义文件指针&#xff1a;F…

Android面试必考题1-15

目录 Service 和 主进程区别 一、性能优化 2.什么情况下会导致内存泄露 3.如何避免 OOM 异常

链式队列基本操作

链式队列的基本概念 链式队列是一种常见的数据结构&#xff0c;它使用链表作为其底层数据存储结构。链式队列的特点是动态的内存分配&#xff0c;可以有效地处理队列的入队和出队操作。下面&#xff0c;我将介绍链式队列的实现方法&#xff0c;并提供相应的C语言代码示例。 链…

C语言-设置控制台信息

Win_API Win_API是Windows应用程序接口&#xff08;Windows Application Programming Interface&#xff09;的缩写&#xff0c;它是一组函数、系统服务和程序接口&#xff0c;允许开发者在微软Windows操作系统上创建应用程序。Win32 API 是Windows API的一个主要部分&#xff…

Linux PXE高效批量网络装机

系统初始化 systemctl disable --now firewalld.service setenforce 0 vim /etc/selinux/config 安装软件 yum install -y tftp-server xinetd dhcp vsftpd syslinux 复制 vmlinuz initrd.img pxelinux.0 到 /var/lib/tftpboot/ 目录 [rootlocalhost ~]# cd /mnt/…

设计模式之业务代表模式

在编程江湖的风雨中漂泊多年&#xff0c;每当我遇到那些错综复杂的业务逻辑和系统交互&#xff0c;总有一个模式像一位忠诚的骑士&#xff0c;默默守护着我的代码城堡&#xff0c;那就是——业务代表模式&#xff08;Business Delegate Pattern&#xff09;。它不是最耀眼的明星…

C++ 如何进阶?

一、C基础&#xff08;3个月&#xff09; 1、面向对象的三大特性&#xff1a;封装、继承、多态 2、类的访问权限&#xff1a;private、protected、public 3、类的构造函数、析构函数、赋值函数、拷贝函数 4、移动构造函数与接贝构造函数对比 5、深接贝与浅贝的区别 6、空…