Package org.red5.server

Class BaseConnection

java.lang.Object
org.red5.server.AttributeStore
org.red5.server.BaseConnection
All Implemented Interfaces:
IEventDispatcher, IEventHandler, IEventListener, IAttributeStore, ICastingAttributeStore, IConnection, ICoreObject, AttributeStoreMXBean
Direct Known Subclasses:
RTMPConnection
public abstract class BaseConnection extends AttributeStore implements IConnection
Base abstract class for connections. Adds connection specific functionality like work with clients to AttributeStore.

  • Field Details

    • log

      private static final org.slf4j.Logger log

    • type

      protected final String type
      Connection type

    • host

      protected volatile String host
      Connection host

    • remoteAddress

      protected volatile String remoteAddress
      Connection remote address

    • remoteAddresses

      protected volatile List<String> remoteAddresses
      Connection remote addresses

    • remotePort

      protected volatile int remotePort
      Remote port

    • path

      protected volatile String path
      Path of scope client connected to

    • sessionId

      protected final String sessionId
      Connection session identifier

    • readMessages

      protected AtomicLong readMessages
      Number of read messages

    • writtenMessages

      protected AtomicLong writtenMessages
      Number of written messages

    • droppedMessages

      protected AtomicLong droppedMessages
      Number of dropped messages

    • params

      protected volatile Map<String,Object> params
      Connection params passed from client with NetConnection.connect call

    • client

      protected volatile IClient client
      Client bound to connection

    • scope

      protected transient volatile Scope scope
      Scope to which this connection belongs

    • basicScopes

      protected transient CopyOnWriteArraySet<IBasicScope> basicScopes
      Set of basic scopes. The scopes may be of shared object or broadcast stream type.

    • closed

      private volatile boolean closed
      Is the connection closed?

    • connectionListeners

      protected transient CopyOnWriteArrayList<IConnectionListener> connectionListeners
      Listeners

    • writeLock

      private final transient Semaphore writeLock
      Used to protect mulit-threaded operations on write

    • streamLocal

      private transient ThreadLocal<Number> streamLocal

  • Constructor Details

    • BaseConnection

      @ConstructorProperties("persistent") public BaseConnection()
      Creates a new persistent base connection

    • BaseConnection

      @ConstructorProperties("type") public BaseConnection(String type)
      Creates a new base connection with the given type.
      Parameters:
      type - Connection type

    • BaseConnection

      @ConstructorProperties({"type","host","remoteAddress","remotePort","path","sessionId"}) public BaseConnection(String type, String host, String remoteAddress, int remotePort, String path, String sessionId, Map<String,Object> params)
      Creates a new base connection with the given parameters.
      Parameters:
      type - Connection type
      host - Host
      remoteAddress - Remote address
      remotePort - Remote port
      path - Scope path on server
      sessionId - Session id
      params - Params passed from client

  • Method Details

    • getStreamId

      public Number getStreamId()
      Returns the current stream id.
      Specified by:
      getStreamId in interface IConnection
      Returns:
      stream id

    • setStreamId

      public void setStreamId(Number id)
      Sets the current stream id.
      Specified by:
      setStreamId in interface IConnection
      Parameters:
      id - stream id

    • addListener

      public void addListener(IConnectionListener listener)
      Adds a listener to this object
      Specified by:
      addListener in interface IConnection
      Parameters:
      listener - connection listener

    • removeListener

      public void removeListener(IConnectionListener listener)
      Removes the listener from this object
      Specified by:
      removeListener in interface IConnection
      Parameters:
      listener - connection listener

    • getLock

      public Semaphore getLock()
      Returns:
      lock for changing state operations

    • initialize

      public void initialize(IClient client)
      Initializes client
      Specified by:
      initialize in interface IConnection
      Parameters:
      client - Client bound to connection

    • getType

      public String getType()
      Description copied from interface: IConnection
      Get the connection type.
      Specified by:
      getType in interface IConnection
      Returns:
      type

    • getHost

      public String getHost()
      Description copied from interface: IConnection
      Get the hostname that the client is connected to. If they are connected to an IP, the IP address will be returned as a String.
      Specified by:
      getHost in interface IConnection
      Returns:
      host

    • getRemoteAddress

      public String getRemoteAddress()
      Description copied from interface: IConnection
      Get the IP address the client is connected from.
      Specified by:
      getRemoteAddress in interface IConnection
      Returns:
      remote address

    • getRemoteAddresses

      public List<String> getRemoteAddresses()
      Description copied from interface: IConnection
      Get the IP addresses the client is connected from. If a client is connected through RTMPT and uses a proxy to connect, this will contain all hosts the client used to connect to the server.
      Specified by:
      getRemoteAddresses in interface IConnection
      Returns:
      remote address

    • getRemotePort

      public int getRemotePort()
      Description copied from interface: IConnection
      Get the port the client is connected from.
      Specified by:
      getRemotePort in interface IConnection
      Returns:
      remote port

    • getPath

      public String getPath()
      Description copied from interface: IConnection
      Get the path for this connection. This is not updated if you switch scope.
      Specified by:
      getPath in interface IConnection
      Returns:
      path

    • getSessionId

      public String getSessionId()
      Description copied from interface: IConnection
      Get the session id, this may be null.
      Specified by:
      getSessionId in interface IConnection
      Returns:
      session id

    • getConnectParams

      public Map<String,Object> getConnectParams()
      Return connection parameters
      Specified by:
      getConnectParams in interface IConnection
      Returns:
      connection parameters

    • setClient

      public void setClient(IClient client)
      Sets the Client.
      Specified by:
      setClient in interface IConnection
      Parameters:
      client - client

    • getClient

      public IClient getClient()
      Get the client object associated with this connection.
      Specified by:
      getClient in interface IConnection
      Returns:
      Client object

    • isConnected

      public boolean isConnected()
      Check whether connection is alive
      Specified by:
      isConnected in interface IConnection
      Returns:
      true if connection is bound to scope, false otherwise

    • connect

      public boolean connect(IScope newScope)
      Connect to another scope on server
      Specified by:
      connect in interface IConnection
      Parameters:
      newScope - New scope
      Returns:
      true on success, false otherwise

    • connect

      public boolean connect(IScope newScope, Object[] params)
      Connect to another scope on server with given parameters
      Specified by:
      connect in interface IConnection
      Parameters:
      newScope - New scope
      params - Parameters to connect with
      Returns:
      true on success, false otherwise

    • getScope

      public IScope getScope()
      Return the current scope.
      Specified by:
      getScope in interface IConnection
      Returns:
      scope

    • close

      public void close()
      Closes connection
      Specified by:
      close in interface IConnection

    • notifyEvent

      public void notifyEvent(IEvent event)
      Notified on event
      Specified by:
      notifyEvent in interface IEventListener
      Parameters:
      event - Event

    • dispatchEvent

      public void dispatchEvent(IEvent event)
      Dispatches event
      Specified by:
      dispatchEvent in interface IEventDispatcher
      Parameters:
      event - Event

    • handleEvent

      public boolean handleEvent(IEvent event)
      Handles event
      Specified by:
      handleEvent in interface IEventHandler
      Parameters:
      event - Event
      Returns:
      true if associated scope was able to handle event, false otherwise

    • getBasicScopes

      public Iterator<IBasicScope> getBasicScopes()
      Description copied from interface: IConnection
      Get the basic scopes this connection has subscribed. This list will contain the shared objects and broadcast streams the connection connected to.
      Specified by:
      getBasicScopes in interface IConnection
      Returns:
      basic scopes

    • registerBasicScope

      public void registerBasicScope(IBroadcastScope basicScope)
      Registers basic scope
      Parameters:
      basicScope - Basic scope to register

    • unregisterBasicScope

      public void unregisterBasicScope(IBasicScope basicScope)
      Unregister basic scope
      Parameters:
      basicScope - Unregister basic scope

    • getReadBytes

      public abstract long getReadBytes()
      Description copied from interface: IConnection
      Total number of bytes read from the connection.
      Specified by:
      getReadBytes in interface IConnection
      Returns:
      bytes read

    • getWrittenBytes

      public abstract long getWrittenBytes()
      Description copied from interface: IConnection
      Total number of bytes written to the connection.
      Specified by:
      getWrittenBytes in interface IConnection
      Returns:
      bytes written

    • getReadMessages

      public long getReadMessages()
      Description copied from interface: IConnection
      Total number of messages read from the connection.
      Specified by:
      getReadMessages in interface IConnection
      Returns:
      messages read

    • getWrittenMessages

      public long getWrittenMessages()
      Description copied from interface: IConnection
      Total number of messages written to the connection.
      Specified by:
      getWrittenMessages in interface IConnection
      Returns:
      messages written

    • getDroppedMessages

      public long getDroppedMessages()
      Description copied from interface: IConnection
      Total number of messages that have been dropped.
      Specified by:
      getDroppedMessages in interface IConnection
      Returns:
      dropped messages

    • isReaderIdle

      public boolean isReaderIdle()
      Returns whether or not the reader is idle.
      Returns:
      queued messages

    • isWriterIdle

      public boolean isWriterIdle()
      Returns whether or not the writer is idle.
      Returns:
      queued messages

    • isClosed

      public boolean isClosed()
      Returns whether or not a connection is closed.
      Returns:
      true if closed

    • getPendingMessages

      public long getPendingMessages()
      Count of outgoing messages not yet written.
      Specified by:
      getPendingMessages in interface IConnection
      Returns:
      pending messages

    • getPendingVideoMessages

      public long getPendingVideoMessages(Number streamId)
      Count of outgoing video messages not yet written.
      Parameters:
      streamId - the id you want to know about
      Returns:
      pending messages for this streamId

    • getClientBytesRead

      public long getClientBytesRead()
      Return number of written bytes the client reports to have received. This is the last value of the BytesRead message received from a client.
      Specified by:
      getClientBytesRead in interface IConnection
      Returns:
      number of written bytes received by the client
      See Also:

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object