将实时视频数据从客户端流传输到服务器,并在另一个客户端上显示

如何解决将实时视频数据从客户端流传输到服务器,并在另一个客户端上显示

我们正在尝试通过连接了树莓派cam2的raspberry pi 3创建实时视频流。到目前为止,我们已经设法将原始m264缓冲区从摄像机通过Axios传输到Express。但是我们不知道如何处理传入的数据以将其显示为实时视频流。

目标是在快递服务器上为另一个客户端创建树莓派cam的实时视频供稿。

欢迎任何帮助!

这就是我们在树莓派上拥有的东西:

const fs = require("fs")
const axios = require("axios")
const { StreamCamera,Codec,SensorMode } = require("pi-camera-connect");
 
var i = 0

const stream = async () => {
    const streamCamera = new StreamCamera({
        codec: Codec.H264,SensorMode: SensorMode.Mode7,fps: 30,width: 300,height: 200
    });

    const videoStream = streamCamera.createStream();
 
    await streamCamera.startCapture();
 
    // We can also listen to data events as they arrive
    videoStream.on("data",data => send(data));
};



function send(data) {

    console.log(i)

    i++;

    axios.post("http://192.168.60.100/video",{
        stream: data,index: i
    })
    .then (function(response) {
        console.log(response.data)
        console.log("sending now")
    }).catch(function(error) {
        console.log("error")
    })
}

stream();

这是我们的服务器:

const fs = require("fs")
var ffmpeg = require('fluent-ffmpeg');


//console clear
process.stdout.write('\033c');
console.log("Server started")

//server
const express = require("express")
const bodyParser = require('body-parser');
const { start } = require("repl");

const app = express()
app.use(bodyParser.urlencoded({ extended: true }));

app.listen(80,() => console.log("Listening"))
app.use(express.json({ limit: "1mb"}))


app.post('/video',(req,res) => {
    //res.setHeader('Content-Type','application/json');
    console.log("---------")
    stream = Buffer.from(req.body.stream)
    counter = req.body.index


    console.log(counter)
    caputure(stream)

    res.end("recieved")
})

function caputure(stream) {
    console.log(stream)
    
    var writeStream = fs.createWriteStream('./output.h264');

    stream.pipe(writeStream)

    writeStream.on('error',function (err) {
        console.log(err);
    });
}

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com(将#修改为@)

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?