Tag: 多播

NodeJS – 如何pipe相同的videostream到多个客户端？: 我们有一种情况试图为videostream服务。由于HTML5video标签不支持udp组播，因此我们试图重新使用已经转换的ffmpegstream并将其发送给多个响应。但是这不起作用。第一个响应得到了正确的stream，但第二个响应没有。似乎这个stream不能通过另一个响应pipe道，也不能被克隆。有没有人做过？有任何想法吗？提前致谢！代码如下： var request = require('request'); var http = require('http'); var child_process = require("child_process"); var n = 1; var stdouts = {}; http.createServer(function (req, resp) { console.log("***** url ["+req.url+"], call "+n); if (req.url != "/favicon.ico" && req.url != "/") { var params = req.url.substring(1).split("/"); switch (params[0]) { case […]

zeromq epgm pub / sub不工作: 我正在使用node.js示例。我已经在我的ubuntu 12.10机器上安装了openpgm和zeromq 3.2。代码如下： var zmq = require('zmq') , port = 'epgm://eth0;239.192.1.1:5555'; var socket = zmq.socket('pub'); socket.identity = 'publisher' + process.pid; var stocks = ['AAPL', 'GOOG', 'YHOO', 'MSFT', 'INTC']; socket.bind(port, function(err) { if (err) throw err; console.log('bound!'); setInterval(function() { var symbol = stocks[Math.floor(Math.random()*stocks.length)] , value = Math.random()*1000; console.log(socket.identity + ': sent ' + symbol […]

采用Node.js的IPv6组播: 我正在通过VPN试验IPv6 UDP多播。我已经尝试了下面的代码： const dgram = require('dgram'); let sock = dgram.createSocket('udp6', { reuseAddr: true }); sock.on('message', (data, source) => { console.log('on message', arguments); }); sock.bind('36912', '2620:9b::1944:e598', () => { sock.addMembership('ff02::1:3', '2620:9b::1944:e598'); }); setInterval(() => { let buf = Buffer.from((new Date()).toString()); sock.send(buf, 0, buf.length, 36912, 'ff02::1:3'); }, 500); 脚本运行，我看到数据包是用Wireshark发送/接收的，但是两端都没有显示在控制台中。我究竟做错了什么？使用IPv6发送和接收基本组播的方式是什么？

NodeJS UDP多播如何: 我试图发送一个UDP组播包到：230.185.192.108，所以每个人订阅将收到。有点卡住了。我相信它的播放是正确的，但似乎无法与任何客户端进行比较。服务器： var news = [ "Borussia Dortmund wins German championship", "Tornado warning for the Bay Area", "More rain for the weekend", "Android tablets take over the world", "iPad2 sold out", "Nation's rappers down to last two samples" ]; var dgram = require('dgram'); var server = dgram.createSocket("udp4"); server.bind(); server.setBroadcast(true) server.setMulticastTTL(128); server.addMembership('230.185.192.108'); setInterval(broadcastNew, 3000); […]