Red5项目部署到tomcat

package org.red5.server.stream; /* * RED5 Open Source Flash Server - http://code.google.com/p/red5/ * * Copyright (c) 2006-2010 by respective authors (see below). All rights reserved. * * This library is free software; you can redistribute it and/or modify it under the * terms of the GNU Lesser General Public License as published by the Free Software * Foundation; either version 2.1 of the License, or (at your option) any later * version. * * This library is distributed in the hope that it will be useful, but WITHOUT ANY * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public License along * with this library; if not, write to the Free Software Foundation, Inc., * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ import java.io.IOException; import java.util.HashMap; import java.util.LinkedList; import java.util.Map; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; import org.apache.mina.core.buffer.IoBuffer; import org.red5.io.amf.Output; import org.red5.io.object.Serializer; import org.red5.logging.Red5LoggerFactory; import org.red5.server.api.IScope; import org.red5.server.api.scheduling.IScheduledJob; import org.red5.server.api.scheduling.ISchedulingService; import org.red5.server.api.stream.IBroadcastStream; import org.red5.server.api.stream.IPlayItem; import org.red5.server.api.stream.IPlaylistSubscriberStream; import org.red5.server.api.stream.IStreamCodecInfo; import org.red5.server.api.stream.ISubscriberStream; import org.red5.server.api.stream.IVideoStreamCodec; import org.red5.server.api.stream.OperationNotSupportedException; import org.red5.server.api.stream.StreamState; import org.red5.server.messaging.AbstractMessage; import org.red5.server.messaging.IFilter; import org.red5.server.messaging.IMessage; import org.red5.server.messaging.IMessageComponent; import org.red5.server.messaging.IMessageInput; import org.red5.server.messaging.IMessageOutput; import org.red5.server.messaging.IPassive; import org.red5.server.messaging.IPipe; import org.red5.server.messaging.IPipeConnectionListener; import org.red5.server.messaging.IProvider; import org.red5.server.messaging.IPushableConsumer; import org.red5.server.messaging.OOBControlMessage; import org.red5.server.messaging.PipeConnectionEvent; import org.red5.server.net.rtmp.event.Aggregate; import org.red5.server.net.rtmp.event.AudioData; import org.red5.server.net.rtmp.event.IRTMPEvent; import org.red5.server.net.rtmp.event.Notify; import org.red5.server.net.rtmp.event.Ping; import org.red5.server.net.rtmp.event.VideoData; import org.red5.server.net.rtmp.event.VideoData.FrameType; import org.red5.server.net.rtmp.message.Constants; import org.red5.server.net.rtmp.message.Header; import org.red5.server.net.rtmp.status.Status; import org.red5.server.net.rtmp.status.StatusCodes; import org.red5.server.stream.codec.StreamCodecInfo; import org.red5.server.stream.message.RTMPMessage; import org.red5.server.stream.message.ResetMessage; import org.red5.server.stream.message.StatusMessage; import org.slf4j.Logger; /** * A play engine for playing an IPlayItem. * * @author The Red5 Project (red5@osflash.org) * @author Steven Gong * @author Paul Gregoire (mondain@gmail.com) * @author Dan Rossi * @author Tiago Daniel Jacobs (tiago@imdt.com.br) */ public final class PlayEngine implements IFilter, IPushableConsumer, IPipeConnectionListener { private static final Logger log = Red5LoggerFactory.getLogger(PlayEngine.class); private IMessageInput msgIn; private IMessageOutput msgOut; private final ISubscriberStream subscriberStream; private ISchedulingService schedulingService; private IConsumerService consumerService; private IProviderService providerService; private int streamId; /** * Receive video? */ private boolean receiveVideo = true; /** * Receive audio? */ private boolean receiveAudio = true; private boolean pullMode; private String waitLiveJob; private boolean waiting; /** * timestamp of first sent packet */ private int streamStartTS; private IPlayItem currentItem; private RTMPMessage pendingMessage; /** * Interval in ms to check for buffer underruns in VOD streams. */ private int bufferCheckInterval = 0; /** * Number of pending messages at which a <code>NetStream.Play.InsufficientBW</code> * message is generated for VOD streams. */ private int underrunTrigger = 10; /** * threshold for number of pending video frames */ private int maxPendingVideoFramesThreshold = 10; /** * if we have more than 1 pending video frames, but less than maxPendingVideoFrames, * continue sending until there are this many sequential frames with more than 1 * pending */ private int maxSequentialPendingVideoFrames = 10; /** * the number of sequential video frames with > 0 pending frames */ private int numSequentialPendingVideoFrames = 0; /** * State machine for video frame dropping in live streams */ private IFrameDropper videoFrameDropper = new VideoFrameDropper(); private int timestampOffset = 0; /** * Timestamp of the last message sent to the client. */ private int lastMessageTs = -1; /** * Number of bytes sent. */ private AtomicLong bytesSent = new AtomicLong(0); /** * Start time of stream playback. * It's not a time when the stream is being played but * the time when the stream should be played if it's played * from the very beginning. * Eg. A stream is played at timestamp 5s on 1:00:05. The * playbackStart is 1:00:00. */ private long playbackStart; /** * Scheduled future job that makes sure messages are sent to the client. */ private volatile ScheduledFuture<?> pullAndPushFuture = null; /** * Monitor to guard setup and teardown of pull/push thread. */ private Object pullAndPushMonitor = new Object(); /** * Monitor guarding completion of a given push/pull run. * Used to wait for job cancellation to finish. */ private Object doingPullMonitor = new Object(); /** * Offset in ms the stream started. */ private int streamOffset; /** * Timestamp when buffer should be checked for underruns next. */ private long nextCheckBufferUnderrun; /** * Send blank audio packet next? */ private boolean sendBlankAudio; /** * decision: 0 for Live, 1 for File, 2 for Wait, 3 for N/A */ private int playDecision = 3; /** * List of pending operations */ private LinkedList<Runnable> pendingOperations = null; /** * Constructs a new PlayEngine. */ private PlayEngine(Builder builder) { subscriberStream = builder.subscriberStream; schedulingService = builder.schedulingService; consumerService = builder.consumerService; providerService = builder.providerService; // streamId = subscriberStream.getStreamId(); pendingOperations = new LinkedList<Runnable>(); } /** * Builder pattern */ public final static class Builder { //Required for play engine private ISubscriberStream subscriberStream; //Required for play engine private ISchedulingService schedulingService; //Required for play engine private IConsumerService consumerService; //Required for play engine private IProviderService providerService; public Builder(ISubscriberStream subscriberStream, ISchedulingService schedulingService, IConsumerService consumerService, IProviderService providerService) { this.subscriberStream = subscriberStream; this.schedulingService = schedulingService; this.consumerService = consumerService; this.providerService = providerService; } public PlayEngine build() { return new PlayEngine(this); } } public void setBufferCheckInterval(int bufferCheckInterval) { this.bufferCheckInterval = bufferCheckInterval; } public void setUnderru