The following HTTP provider can be used with the Wowza Streaming Engine™ Java API to quickly retrieve server data.
package com.wowza.wms.http;
import java.io.*;
import java.util.*;
import org.apache.mina.common.IoSession;
import com.wowza.wms.vhost.*;
import com.wowza.wms.logging.WMSLoggerFactory;
import com.wowza.wms.server.*;
import com.wowza.wms.application.*;
import com.wowza.wms.http.*;
import com.wowza.wms.client.*;
import com.wowza.wms.httpstreamer.model.*;
import com.wowza.wms.httpstreamer.util.*;
import com.wowza.util.*;
import com.wowza.wms.rtp.model.*;
public class HTTPServerInfoXML extends HTTPProvider2Base
{
private void outputConnectionInfo(StringBuffer ret, ConnectionCounter counter)
{
ret.append("<ConnectionsCurrent>"+counter.getCurrent()+"</ConnectionsCurrent>");
ret.append("<ConnectionsTotal>"+counter.getTotal()+"</ConnectionsTotal>");
ret.append("<ConnectionsTotalAccepted>"+counter.getTotalAccepted()+"</ConnectionsTotalAccepted>");
ret.append("<ConnectionsTotalRejected>"+counter.getTotalRejected()+"</ConnectionsTotalRejected>");
}
public String fixNull(String value)
{
if (value == null)
return "";
return value;
}
public void onHTTPRequest(IVHost inVhost, IHTTPRequest req, IHTTPResponse resp)
{
if (!doHTTPAuthentication(inVhost, req, resp))
return;
StringBuffer ret = new StringBuffer();
long currTime = System.currentTimeMillis();
try
{
List vhostNames = VHostSingleton.getVHostNames();
ret.append("<?xml version="1.0"?>
<WowzaStreamingEngine>");
Iterator<String> iter = vhostNames.iterator();
while (iter.hasNext())
{
String vhostName = iter.next();
IVHost vhost = (IVHost)VHostSingleton.getInstance(vhostName);
if (vhost != null)
{
ret.append("<VHost>");
ret.append("<Name>"+vhostName+"</Name>");
ret.append("<TimeRunning>"+vhost.getTimeRunningSeconds()+"</TimeRunning>");
ret.append("<ConnectionsLimit>"+vhost.getConnectionLimit()+"</ConnectionsLimit>");
outputConnectionInfo(ret, vhost.getConnectionCounter());
List appNames = vhost.getApplicationNames();
List<String> appFolders = vhost.getApplicationFolderNames();
Iterator<String> appNameIterator = appFolders.iterator();
while (appNameIterator.hasNext())
{
String applicationName = appNameIterator.next();
ret.append("<Application>");
ret.append("<Name><![CDATA["+applicationName+"]]></Name>");
boolean appExists = appNames.contains(applicationName);
ret.append("<Status>"+(appExists?"loaded":"unloaded")+"</Status>");
if (appExists)
{
IApplication application = vhost.getApplication(applicationName);
if (application == null)
continue;
ret.append("<TimeRunning>"+application.getTimeRunningSeconds()+"</TimeRunning>");
outputConnectionInfo(ret, application.getConnectionCounter());
List appInstances = application.getAppInstanceNames();
Iterator<String> iterAppInstances = appInstances.iterator();
while (iterAppInstances.hasNext())
{
String appInstanceName = iterAppInstances.next();
IApplicationInstance appInstance = application.getAppInstance(appInstanceName);
if (appInstance == null)
continue;
ret.append("<ApplicationInstance>");
ret.append("<Name><![CDATA["+appInstance.getName()+"]]></Name>");
ret.append("<TimeRunning>"+appInstance.getTimeRunningSeconds()+"</TimeRunning>");
outputConnectionInfo(ret, appInstance.getConnectionCounter());
List<IClient> clients = appInstance.getClients();
List<IHTTPStreamerSession> httpSessions = appInstance.getHTTPStreamerSessions();
List<RTPSession> rtpSessions = appInstance.getRTPSessions();
ret.append("<RTMPConnectionCount>"+appInstance.getConnectionCounter(IVHost.COUNTER_RTMP).getCurrent()+"</RTMPConnectionCount>");
ret.append("<RTPConnectionCount>"+appInstance.getConnectionCounter(IVHost.COUNTER_RTP).getCurrent()+"</RTPConnectionCount>");
ret.append("<CupertinoConnectionCount>"+appInstance.getConnectionCounter(IVHost.COUNTER_HTTPCUPERTINO).getCurrent()+"</CupertinoConnectionCount>");
ret.append("<SmoothConnectionCount>"+appInstance.getConnectionCounter(IVHost.COUNTER_HTTPSMOOTH).getCurrent()+"</SmoothConnectionCount>");
ret.append("<SanJoseConnectionCount>"+appInstance.getConnectionCounter(IVHost.COUNTER_HTTPSANJOSE).getCurrent()+"</SanJoseConnectionCount>");
//ret.append("<WebMConnectionCount>"+appInstance.getConnectionCounter(IVHost.COUNTER_HTTPWEBM).getCurrent()+"</WebMConnectionCount>");
//ret.append("<DVRChunksConnectionCount>"+appInstance.getConnectionCounter(IVHost.COUNTER_HTTPDVRCHUNKS).getCurrent()+"</v>");
ret.append("<RTMPSessionCount>"+clients.size()+"</RTMPSessionCount>");
ret.append("<HTTPSessionCount>"+httpSessions.size()+"</HTTPSessionCount>");
ret.append("<RTPSessionCount>"+rtpSessions.size()+"</RTPSessionCount>");
Iterator<IClient> iterClient = clients.iterator();
while(iterClient.hasNext())
{
IClient client = iterClient.next(); //appInstance.getClient(c);
if (client == null)
continue;
ret.append("<Client>");
ret.append("<ClientId>"+client.getClientId()+"</ClientId>");
ret.append("<FlashVersion>"+client.getFlashVer()+"</FlashVersion>");
ret.append("<IpAddress>"+client.getIp()+"</IpAddress>");
ret.append("<Referrer><![CDATA["+fixNull(client.getReferrer())+"]]></Referrer>");
ret.append("<QueryString><![CDATA["+fixNull(client.getQueryStr())+"]]></QueryString>");
ret.append("<TimeRunning>"+client.getTimeRunningSeconds()+"</TimeRunning>");
//ret.append("<Duration>"+((double)(System.currentTimeMillis()-client.getConnectTime())/1000.0)+"</Duration>");
ret.append("<DateStarted>"+client.getDateStarted()+"</DateStarted>");
ret.append("<URI><![CDATA["+client.getUri()+"]]></URI>");
String protocolStr = "unknown";
switch(client.getProtocol())
{
case RtmpSessionInfo.PROTOCOL_RTMP:
protocolStr = client.isEncrypted()?"RTMPE":"RTMP";
break;
case RtmpSessionInfo.PROTOCOL_RTMPT:
protocolStr = client.isSSL()?"RTMPS":(client.isEncrypted()?"RTMPTE":"RTMPT");
break;
}
ret.append("<Protocol>"+protocolStr+"</Protocol>");
ret.append("<IsSSL>"+client.isSSL()+"</IsSSL>");
ret.append("<IsEncrypted>"+client.isEncrypted()+"</IsEncrypted>");
ret.append("<Port>"+client.getServerHostPort().getPort()+"</Port>");
long lastValidate = client.getLastValidateTime();
if (lastValidate <= 0)
ret.append("<LastValidateTime>-1</LastValidateTime>");
else
{
long incTime = currTime - lastValidate;
if (incTime < 0)
incTime = 0;
ret.append("<LastValidateTime>"+incTime+"</LastValidateTime>");
}
IoSession ioSession = ((Client)client).getIoSession();
if (ioSession != null)
{
ret.append("<IoSessionBytesSent>"+ioSession.getWrittenBytes()+"</IoSessionBytesSent>");
ret.append("<IoSessionBytesReceived>"+ioSession.getReadBytes()+"</IoSessionBytesReceived>");
long lastIo = currTime - ioSession.getLastIoTime();
if (lastIo < 0)
lastIo = 0;
ret.append("<IoSessionLastIo>"+lastIo+"</IoSessionLastIo>");
}
IOPerformanceCounter ioPerformance = client.getMediaIOPerformanceCounter();
if (ioPerformance != null)
{
ret.append("<IoBytesSent>"+ioPerformance.getMessagesOutBytes()+"</IoBytesSent>");
ret.append("<IoBytesReceived>"+ioPerformance.getMessagesInBytes()+"</IoBytesReceived>");
}
ret.append("</Client>");
}
Iterator<IHTTPStreamerSession> iterHttp = httpSessions.iterator();
while(iterHttp.hasNext())
{
IHTTPStreamerSession httpSession = iterHttp.next();
if (httpSession == null)
continue;
ret.append("<HTTPSession>");
ret.append("<SessionId>"+httpSession.getSessionId()+"</SessionId>");
ret.append("<IpAddress>"+httpSession.getIpAddress()+"</IpAddress>");
ret.append("<Referrer><![CDATA["+fixNull(httpSession.getReferrer())+"]]></Referrer>");
ret.append("<QueryString><![CDATA["+fixNull(httpSession.getQueryStr())+"]]></QueryString>");
ret.append("<TimeRunning>"+httpSession.getTimeRunningSeconds()+"</TimeRunning>");
ret.append("<DateStarted>"+httpSession.getElapsedTime().getDateString()+"</DateStarted>");
ret.append("<URI><![CDATA["+httpSession.getUri()+"]]></URI>");
ret.append("<Protocol>"+HTTPStreamerUtils.httpSessionProtocolToName(httpSession.getSessionProtocol())+"</Protocol>");
ret.append("<SessionType>"+HTTPStreamerUtils.httpSessionTypeToName(httpSession.getSessionType())+"</SessionType>");
ret.append("<Port>"+httpSession.getServerPort()+"</Port>");
IOPerformanceCounter ioPerformance = httpSession.getIOPerformanceCounter();
if (ioPerformance != null)
{
ret.append("<IoBytesSent>"+ioPerformance.getMessagesOutBytes()+"</IoBytesSent>");
ret.append("<IoBytesReceived>"+ioPerformance.getMessagesInBytes()+"</IoBytesReceived>");
}
long lastIo = currTime - httpSession.getLastRequest();
if (lastIo < 0)
lastIo = 0;
ret.append("<IoLastRequest>"+lastIo+"</IoLastRequest>");
ret.append("</HTTPSession>");
}
Iterator<RTPSession> iterRTP = rtpSessions.iterator();
while(iterRTP.hasNext())
{
RTPSession rtpSession = iterRTP.next();
if (rtpSession == null)
continue;
ret.append("<RTPSession>");
ret.append("<SessionId>"+rtpSession.getSessionId()+"</SessionId>");
ret.append("<IpAddress>"+rtpSession.getIp()+"</IpAddress>");
ret.append("<Referrer><![CDATA["+fixNull(rtpSession.getReferrer())+"]]></Referrer>");
ret.append("<QueryString><![CDATA["+fixNull(rtpSession.getQueryStr())+"]]></QueryString>");
ret.append("<TimeRunning>"+rtpSession.getTimeRunningSeconds()+"</TimeRunning>");
ret.append("<DateStarted>"+rtpSession.getElapsedTime().getDateString()+"</DateStarted>");
ret.append("<URI><![CDATA["+rtpSession.getUri()+"]]></URI>");
ret.append("<Port>"+rtpSession.getServerPort()+"</Port>");
IOPerformanceCounter ioPerformance = rtpSession.getIOPerformanceCounter();
if (ioPerformance != null)
{
ret.append("<IoBytesSent>"+ioPerformance.getMessagesOutBytes()+"</IoBytesSent>");
ret.append("<IoBytesReceived>"+ioPerformance.getMessagesInBytes()+"</IoBytesReceived>");
}
ret.append("</RTPSession>");
}
ret.append("</ApplicationInstance>");
}
}
ret.append("</Application>");
}
ret.append("</VHost>");
}
}
ret.append("</WowzaStreamingEngine>");
}
catch (Exception e)
{
WMSLoggerFactory.getLogger(HTTPServerVersion.class).error("HTTPServerInfoXML.onHTTPRequest: "+e.toString());
e.printStackTrace();
}
try
{
resp.setHeader("Content-Type", "text/xml");
OutputStream out = resp.getOutputStream();
byte[] outBytes = ret.toString().getBytes();
out.write(outBytes);
}
catch (Exception e)
{
WMSLoggerFactory.getLogger(HTTPServerVersion.class).error("HTTPServerInfoXML.onHTTPRequest: "+e.toString());
e.printStackTrace();
}
}
}
Use the Wowza IDE to compile this class into a JAR file and copy it to the [install-dir]/lib folder. See Extend Wowza Streaming Engine using the Wowza IDE.
To use the provider, edit [install-dir]/conf/VHost.xml and change the HostPort/HTTPProvider/BaseClass to the full path to this class com.mycompany.wms.http.HTTPServerInfoXML.
