我正在为Amazon Elastic Map Reduce开发一个Hadoop流工作流程,它涉及序列化一些二进制对象并将它们流式传输到Hadoop.Hadoop是否具有流输入的最大行长度？
我开始测试越来越大的线,但我想先问一下这里.
我试图混合几个不同的音频流,并尝试让它们同时播放,而不是一次一个.
下面的代码一次一个地播放它们,我无法找到不使用Java Mixer API的解决方案.不幸的是,我的声卡不支持使用Mixer API进行同步,我不得不想办法通过代码来实现.
请指教.
/////代码如下////
class MixerProgram {
public static AudioFormat monoFormat;
private JFileChooser fileChooser = new JFileChooser();
private static File[] files;
private int trackCount;
private FileInputStream[] fileStreams = new FileInputStream[trackCount];
public static AudioInputStream[] audioInputStream;
private Thread trackThread[] = new Thread[trackCount];
private static DataLine.Info sourceDataLineInfo = null;
private static SourceDataLine[] sourceLine;
public MixerProgram(String[] s)
{
trackCount = s.length;
sourceLine = new SourceDataLine[trackCount];
audioInputStream = new AudioInputStream[trackCount];
files = new File[s.length];
}
public static void getFiles(String[] s) …我有来自服务器的视频流,后来我想并排添加另一个.这一切都很好,我做到了.现在我的问题来了,当我想要删除视频.我设法将其从显示中删除,但我可以听到视频仍然在后台播放.那么如何停止播放该视频呢？以下是我设置视频的代码:
ns = new NetStream(connection);
ns.addEventListener(AsyncErrorEvent.ASYNC_ERROR, asyncErrorHandler);
ns.play(item[1].toString() + ".flv");
video = new Video();
video.attachNetStream( ns );
video.width = 160;
video.height = 120;
videoWrapper = new UIComponent();
videoWrapper.addChild( video );
videos.addElement( videoWrapper );
这是为了删除
videos.removeElement(myVideos[p][1]); // myVideos[p][1] is a reference of videoWrapper
我正在研究可以实时工作的项目：我必须编写一个视频流客户端服务器应用程序，该服务器将AVI / MPEG等发送到Web应用程序。我有一些问题：
建议使用什么协议来执行此操作，http？rtp？或其他？
在Web应用程序中，如何显示给用户？使用Flash Player，Java Applet（我不确定是否可以使用它）或HTML5，目前最好的方法是什么？
我希望这对您来说很干净。非常感谢您的帮助。提前致谢。:)
我有一个Django应用程序,它生成视频块到服务器的文件系统中的文件夹.我需要在生成这些块时流式传输这些块,以便用户可以在浏览器中将应用程序的输出视为单个视频.
我无法找到正确方向的解决方案来实现这一目标.有任何想法吗？？
我不仅是python的新手,而是完全编程所以我非常感谢你的帮助!
我试图使用Tweepy过滤来自twitter流API的所有推文.
我已按用户ID进行过滤,并确认正在实时收集推文.
然而,似乎只有第二张最后一条推文是实时收集而不是最新的推文.
你们能帮忙吗？
import tweepy
import webbrowser
import time
import sys
consumer_key = 'xyz'
consumer_secret = 'zyx'
## Getting access key and secret
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth_url = auth.get_authorization_url()
print 'From your browser, please click AUTHORIZE APP and then copy the unique PIN: '
webbrowser.open(auth_url)
verifier = raw_input('PIN: ').strip()
auth.get_access_token(verifier)
access_key = auth.access_token.key
access_secret = auth.access_token.secret
## Authorizing account privileges
auth.set_access_token(access_key, access_secret)
## Get the local time
localtime = time.asctime( time.localtime(time.time()) )
## Status …我希望能够将AR Drone 2的视频源从Debian Server重新映射到Flash.
我知道AR Drone使用编解码器p264.在视频编解码器方面,我完全是绿色的,所以我不知道什么适合我想实现的目标？
与使用ffplay直接连接到AR Drone相比,我能够从AR Drone流式传输视频,但延迟非常高且质量极低.
我目前在标准的ffserver.conf中使用.swf示例:
<Stream test.swf>
Feed feed1.ffm
Format swf
VideoFrameRate 30
VideoIntraOnly
NoAudio
</Stream>
并且.ffm Feed的设置如下:
<Feed feed1.ffm>
File /tmp/feed1.ffm
FileMaxSize 17K
ACL allow 127.0.0.1
NoAudio
</Feed>
我用来为ffserver feed提供输入的命令:
ffmpeg -i http://192.168.1.1:5555 http://localhost:8090/feed1.ffm
我如何才能实现更低的延迟和更高的质量,因为流目前无法获取？
我指的是这个链接上给出的媒体源api演示
它对于给定的测试webm文件工作正常,但是当我尝试将文件名更改为自定义webm文件时,代码停止工作.
它产生以下错误:Uncaught Error: INVALID_STATE_ERR: DOM Exception 11在以下代码中: sourceBuffer.append(new Uint8Array(e.target.result));
为了检查自定义webm文件是否正常工作,我创建了一个测试页面,其中我定义了一个包含该自定义webm文件源的视频标签.当我运行代码时,它工作正常.
我无法理解这种奇怪行为的原因.
我需要以相同的布局播放youtube视频和录制视频.
为了执行此操作,我搜索youtube api,发现android版本需要高于2.2,这没关系,但是,我想使用VideoView.
我在这里看到一些关于这个问题的帖子,并决定最终使用此代码在VideoView中观看视频.
videoView = (VideoView) findViewById(R.id.your_video_view);
Log.d(TAG,getUrlVideoRTSP(current_url) + " id yotube1 " );
//here type the url...
videoView.setVideoURI(Uri.parse(getUrlVideoRTSP(current_url)));
videoView.setMediaController(new MediaController(this)); //sets MediaController in the video view
videoView.requestFocus();//give focus to a specific view
videoView.start();//starts the video
这段代码有效,但只需使用rtsp链接:
String exemple = "rtsp://v4.cache3.c.youtube.com/CjYLENy73wIaLQlW_ji2apr6AxMYDSANFEIJbXYtZ29vZ2xlSARSBXdhdGNoYOr_86Xm06e5UAw=/0/0/0/video.3gp";
我在url中有多个链接因此我需要代码将url转换为RTSP,我不能手动执行此操作,我检查一些代码并且所有代码都不起作用...
我试试这个:从这里 如何获得RTSP URL？
public static String getUrlVideoRTSP(String urlYoutube)
{
try
{
String gdy = "http://gdata.youtube.com/feeds/api/videos/";
DocumentBuilder documentBuilder = DocumentBuilderFactory.newInstance().newDocumentBuilder();
String id = extractYoutubeId(urlYoutube);
URL url = new URL(gdy + id);
HttpURLConnection connection = (HttpURLConnection) url.openConnection(); …我正在尝试从flask/gunicorn服务器传输数据:
while (True):
result = json.dumps(tweetQueue.get())
yield result
然而,在流中30秒后,gunicorn超时我的连接并停止流.如何进行超时,以便从服务器向流中发布新数据将重新启动超时,以便流不会被终止？
谢谢!