标签: streaming

遵循这个主题. 流式传输java servlet中的大型文件.

是否有可能通过java找到当前机器中可用的总互联网带宽？

我想要做的是在通过servlet流式传输大型文件时,根据并行请求的数量和总带宽我试图减少每个请求的流的BUFFER_SIZE.合理？

有没有纯粹的java方式？(没有JNI)

我希望使用提供流式API的网络服务.这个api通常可以由java方法java.net.URL.openStream();

问题是我正在尝试用C++设计我的程序,并且不知道使用什么库(我听说cUrl库非常擅长这种东西),或者如何使用它们来做我想要的.

我们的想法是,在将文件作为流打开后,我可以实时访问不断更新的数据.

任何帮助将非常感激.

在使用元信息实现Stream连接时,我遇到了这个错误

Error #2044: Unhandled AsyncErrorEvent:. text=Error #2095: flash.net.NetConnection was unable to invoke callback onBWDone. error=ReferenceError: Error #1069: Property onBWDone not found on flash.net.NetConnection and there is no default value. at SS4uOpenplayer_fla::MainTimeline/frame2()

我实现了onBWDone函数

meta.onBWDone=function(meta:Object){

}

meta.onMetaData = function(meta:Object)
{
}

但是我得到了同样的错误

是否有用于P2P视频流的RTMFP教程？

我需要创建WCF应用程序,它将处理图片.它允许您将图片作为流获取,并将图片发送到服务器(作为流).它将在流传输模式下工作.目前我对这个选择犹豫不决.BasicHttpBinding还是NetTcpBinding？它们之间有什么区别？的优点和缺点.哪个更适合这个问题？

我正在通过在Apache Tomcat/6.0.18上运行的Spring MVC控制器传输大型文档

因为它很大,并且(最终)会动态生成,所以我决定使用分块传输编码.

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;

import javax.inject.Inject;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.httpclient.ChunkedOutputStream;
import org.apache.commons.net.io.CopyStreamException;
import org.apache.commons.net.io.Util;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

@Controller
public class QueryController {  

    @Inject
    QueryService queryService;

    @RequestMapping(value = "/stream")
    public void hellostreamer(HttpServletResponse response) throws CopyStreamException, IOException  {

        response.setHeader("Transfer-Encoding", "chunked");     
        response.setHeader("Content-type", "text/xml");
        InputStream filestream = new FileInputStream("/lotsrecs.xml");      
        ChunkedOutputStream chunkStream = new ChunkedOutputStream(response.getOutputStream());      
        Util.copyStream(filestream,chunkStream);
        chunkStream.close();
        chunkStream.finish();
    }
}

但是,当我在firefox中打开它时,我得到了这个:

XML Parsing Error: syntax error
Location: http://localhost:8082/streaming-mockup-1.0-SNAPSHOT/stream
Line Number 1, Column 1:

800
^

而不是将块大小作为关于流的元数据读取,而是将它们作为流的一部分读取!

使用Live HTTP标头,我可以看到正在接收Transfer-Encoding标头: …

我必须编写一个ASP.NET Web API来从服务器目录中检索视频或音频文件,并将其流式传输到客户端应用程序.我完全是流媒体领域的新手,我想知道服务器是否需要任何基础设施？如果没有,那么任何人都可以指导我一些样品或者可以提供一些代码来开始吗？我根本找不到任何关于它的信息.

谢谢

到目前为止,我已经能够从Twitter下载流式实时数据.我该如何使用这些数据？我试图将其插入集合,但我收到此错误:

错误:流星代码必须始终在光纤内运行.尝试使用Meteor.bindEnvironment包装传递给非Meteor库的回调.

我尝试用光纤包装我的代码,但它不起作用/或者我没有包装正确的代码部分.此外,我不确定这是否是在Meteor中使用流数据的正确方法.

Posts = new Meteor.Collection('posts');

if (Meteor.isClient) {
  Meteor.call("tweets", function(error, results) {
    console.log(results); //results.data should be a JSON object
  });
}

if (Meteor.isServer) {    
  Meteor.methods({
    tweets: function(){

      Twit = new TwitMaker({
        consumer_key: '...',
        consumer_secret: '...',
        access_token: '...',
        access_token_secret: '...'
      });

      sanFrancisco = [ '-122.75', '36.8', '-121.75', '37.8' ];

      stream = Twit.stream('statuses/filter', { locations: sanFrancisco });


      stream.on('tweet', function (tweet) {
        userName = tweet.user.screen_name;
        userTweet = tweet.text;
        console.log(userName + " says: " + userTweet);
        Posts.insert({post: tweet})

      })  
    }    
  })  
}

我有这种情况:

点击一个HTML提交按钮,我把views.stream_response它"激活" views.stream_response_generator其"激活" stream.py并返回StreamingHttpResponse,我看到一个渐进的数每秒达m在/stream_response/:

1
2
3
4
5
6
7
8  //e.g. my default max value for m

stream.py

from django.template import Context, Template
import time         


def streamx(m):
    lista = []
    x=0
    while len(lista) < m:      
        x = x + 1
        time.sleep(1)
        lista.append(x)
        yield "<div>%s</div>\n" % x  #prints on browser
        print(lista)     #print on eclipse
    return (x)

views.py

def stream_response(request):   // unified the three functions as suggested

if request.method == …

我们已经使用BigQuery超过一年了,没有任何问题.我们每隔几个小时就将数据作为批处理作业加载,通常可以立即使用.

我们刚开始尝试使用模板表进行流式插入.通过我们的第一次测试,我们看到没有错误,数据立即出现.该测试创建了大约120个表.表上的一个简单的选择计数(使用web ui)提供了大约8000行的正确总数.经过几个小时的流媒体播放后,总数降至约1400行.

不确定发生了什么,我们删除了数据集,重新创建了模板表并重新运行了流.这一次,表格立即显示,但数据没有.在我们的第三次尝试中,表格本身并没有显示超过几个小时.我们正在进行第四次尝试,这次我们只流式传输属于一个表的数据.该表立即显示,但已超过一个小时,数据不会显示.

流服务使用最新的Java库,一次只插入一条记录并记录响应.没有例外的响应总是{"kind":"bigquery#tableDataInsertAllResponse"}并且没有错误.

任何试图了解正在发生的事情的帮助都会很棒.谢谢.