* Copyright (c) 2002-2014 Delft University of Technology, Jaffalaan 5, 2628 BX Delft, the Netherlands. All rights reserved. *
* See for project information www.simulation.tudelft.nl. *
* The DSOL project is distributed under a BSD-style license.
* @version Aug 15, 2014
* @author Alexander Verbraeck
*/
public class SuperDemoWebApplication implements Checkable
{
/** */
private OTSSimulatorInterface simulator;
/** */
private OTSModelInterface model;
/** the socket. */
private ZMQ.Socket fsSocket;
/** the context. */
private ZContext fsContext;
/** federation run id. */
private Object federationRunId;
/** modelId unique Id of the model that is used as the sender/receiver when communicating. */
private String modelId;
/** runtime. */
private Duration runDuration;
/** warmup. */
private Duration warmupDuration;
/** message count. */
private long messageCount = 0;
/** home page for the web server. */
@SuppressWarnings("checkstyle:visibilitymodifier")
@Option(names = {"-m", "--modelId"}, description = "Id of the model to run", required = true)
String homePage;
/** internet port for the web server. */
@SuppressWarnings("checkstyle:visibilitymodifier")
@Option(names = {"-p", "--port"}, description = "Internet port to use", defaultValue = "8081")
int port;
/** {@inheritDoc} */
@Override
public void check() throws Exception
{
if (this.port < 1 || this.port > 65535)
{
throw new Exception("Port number should be between 1 and 65535");
}
}
/**
* Construct a console application.
* @throws SimRuntimeException on error
* @throws NamingException on error
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
* @throws IOException when TRAFCOD file cannot be found
*/
protected void init() throws SimRuntimeException, NamingException, Sim0MQException, SerializationException, IOException
{
this.simulator = new OTSAnimator("SuperDemoWebApplication");
this.modelId = this.modelId.trim();
if (this.modelId.toLowerCase().contains("circularroad"))
{
this.model = new CircularRoadModel(this.simulator);
}
else if (this.modelId.toLowerCase().contains("straight"))
{
this.model = new StraightModel(this.simulator);
}
else if (this.modelId.toLowerCase().contains("shortmerge"))
{
this.model = new ShortMerge.ShortMergeModel(this.simulator);
}
else if (this.modelId.toLowerCase().contains("networksdemo"))
{
this.model = new NetworksModel(this.simulator);
}
else if (this.modelId.toLowerCase().contains("crossingtrafficlights"))
{
this.model = new CrossingTrafficLightsModel(this.simulator);
}
else if (this.modelId.toLowerCase().contains("trafcoddemosimple"))
{
URL url = URLResource.getResource("/TrafCODDemo1/TrafCODDemo1.xml");
String xml = TrafCODDemo2.readStringFromURL(url);
this.model = new TrafCODDemo1.TrafCODModel(this.simulator, "TrafCODDemo1", "TrafCODDemo1", xml);
}
else if (this.modelId.toLowerCase().contains("trafcoddemocomplex"))
{
URL url = URLResource.getResource("/TrafCODDemo2/TrafCODDemo2.xml");
String xml = TrafCODDemo2.readStringFromURL(url);
this.model = new TrafCODDemo2.TrafCODModel(this.simulator, "TrafCODDemo2", "TrafCODDemo2", xml);
}
else if (this.modelId.toLowerCase().contains("tjunction"))
{
this.model = new TJunctionDemo.TJunctionModel(this.simulator);
}
else if (this.modelId.toLowerCase().contains("busstreet"))
{
this.model = new BusStreetDemo.BusStreetModel(this.simulator);
}
else if (this.modelId.toLowerCase().contains("turboroundabout"))
{
this.model = new TurboRoundaboutDemo.TurboRoundaboutModel(this.simulator);
}
if (this.model == null)
{
System.err.println("Could not find model " + this.modelId);
}
else
{
startListener();
}
}
/**
* Start listening on a port.
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
protected void startListener() throws Sim0MQException, SerializationException
{
this.fsContext = new ZContext(1);
this.fsSocket = this.fsContext.createSocket(SocketType.ROUTER);
this.fsSocket.bind("tcp://*:" + this.port);
System.out.println("Model started. Listening at port: " + this.port);
System.out.flush();
while (!Thread.currentThread().isInterrupted())
{
// Wait for next request from the client -- first the identity (String) and the delimiter (#0)
String identity = this.fsSocket.recvStr();
this.fsSocket.recvStr();
byte[] request = this.fsSocket.recv(0);
System.out.println(MessageUtil.printBytes(request));
Object[] fields = Sim0MQMessage.decodeToArray(request);
Object receiverId = fields[4];
Object messageTypeId = fields[5];
System.out.println("Received " + Sim0MQMessage.print(fields));
System.out.flush();
if (receiverId.equals(this.modelId))
{
switch (messageTypeId.toString())
{
case "FS.1":
processRequestStatus(identity, new FS1RequestStatusMessage(fields));
break;
case "FM.5":
processRequestStatus(identity, new FM5RequestStatus(fields));
break;
case "FM.2":
processSimRunControl(identity, new FM2SimRunControlMessage(fields));
break;
case "FM.3":
processSetParameter(identity, new FM3SetParameterMessage(fields));
break;
case "FM.4":
processSimStart(identity, new FM4SimStartMessage(fields));
break;
case "FM.6":
processRequestStatistics(identity, new FM6RequestStatisticsMessage(fields));
break;
case "FS.3":
processKillFederate();
break;
default:
// wrong message
System.err.println("Received unknown message -- not processed: " + messageTypeId);
}
}
else
{
// wrong receiver
System.err.println(
"Received message not intended for " + this.modelId + " but for " + receiverId + " -- not processed: ");
}
}
}
/**
* Process FS.1 or FM.5 message and send MC.1 message back.
* @param identity reply id for REQ-ROUTER pattern
* @param message the message (0 payload fields)
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
private void processRequestStatus(final String identity, final Sim0MQMessage message)
throws Sim0MQException, SerializationException
{
if (this.federationRunId == null)
{
this.federationRunId = message.getFederationId();
}
String status = "started";
if (this.simulator.isStartingOrRunning())
{
status = "running";
}
else if (this.simulator.getSimulatorTime() != null && this.simulator.getReplication() != null
&& this.simulator.getReplication().getTreatment() != null)
{
if (this.simulator.getSimulatorTime().ge(this.simulator.getReplication().getTreatment().getEndTime()))
{
status = "ended";
}
else
{
status = "error";
}
}
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
byte[] mc1Message = new MC1StatusMessage(this.federationRunId, this.modelId, message.getSenderId(), ++this.messageCount,
message.getMessageId(), status, "").createByteArray();
this.fsSocket.send(mc1Message, 0);
System.out.println("Sent MC.1");
System.out.flush();
}
/**
* Process FM.2 message and send MC.2 message back.
* @param identity reply id for REQ-ROUTER pattern
* @param message the FM.2 message
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
private void processSimRunControl(final String identity, final FM2SimRunControlMessage message)
throws Sim0MQException, SerializationException
{
boolean status = true;
String error = "";
try
{
Object runDurationField = message.getRunDuration();
if (runDurationField instanceof Number)
{
this.runDuration = new Duration(((Number) runDurationField).doubleValue(), DurationUnit.SI);
}
else if (runDurationField instanceof Duration)
{
this.runDuration = (Duration) runDurationField;
}
else
{
throw new Sim0MQException("runTimeField " + runDurationField + " neither Number nor Duration");
}
Object warmupDurationField = message.getWarmupDuration();
if (warmupDurationField instanceof Number)
{
this.warmupDuration = new Duration(((Number) warmupDurationField).doubleValue(), DurationUnit.SI);
}
else if (warmupDurationField instanceof Duration)
{
this.warmupDuration = (Duration) warmupDurationField;
}
else
{
throw new Sim0MQException("warmupField " + warmupDurationField + " neither Number nor Duration");
}
}
catch (Exception e)
{
status = false;
error = e.getMessage();
}
byte[] mc2Message = new MC2AckNakMessage(this.federationRunId, this.modelId, message.getSenderId(), ++this.messageCount,
message.getMessageId(), status, error).createByteArray();
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
this.fsSocket.send(mc2Message, 0);
System.out.println("Sent MC.2");
System.out.flush();
}
/**
* Process FM.3 message and send MC.2 message back.
* @param identity reply id for REQ-ROUTER pattern
* @param message the FM3 message
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
private void processSetParameter(final String identity, final FM3SetParameterMessage message)
throws Sim0MQException, SerializationException
{
boolean status = true;
String error = "";
try
{
// TODO: change for InputParameter
/*-
String parameterName = message.getParameterName();
Object parameterValueField = message.getParameterValue();
switch (parameterName)
{
case "seed":
this.model.seed = ((Number) parameterValueField).longValue();
break;
case "iat":
this.model.iat = ((Number) parameterValueField).doubleValue();
break;
case "servicetime":
this.model.serviceTime = ((Number) parameterValueField).doubleValue();
break;
default:
status = false;
error = "Parameter " + parameterName + " unknown";
break;
}
*/
}
catch (Exception e)
{
status = false;
error = e.getMessage();
}
byte[] mc2Message = new MC2AckNakMessage(this.federationRunId, this.modelId, message.getSenderId(), ++this.messageCount,
message.getMessageId(), status, error).createByteArray();
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
this.fsSocket.send(mc2Message, 0);
System.out.println("Sent MC.2");
System.out.flush();
}
/**
* Process FM.4 message and send MC.2 message back.
* @param identity reply id for REQ-ROUTER pattern
* @param message the FM.4 message
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
private void processSimStart(final String identity, final FM4SimStartMessage message)
throws Sim0MQException, SerializationException
{
boolean status = true;
String error = "";
try
{
OTSReplication replication =
OTSReplication.create("rep1", Time.ZERO, this.warmupDuration, this.runDuration, this.model);
this.simulator.initialize(replication, ReplicationMode.TERMINATING);
// TODO: different... this.simulator.scheduleEventAbs(100.0, this, this, "terminate", null);
this.simulator.start();
}
catch (Exception e)
{
status = false;
error = e.getMessage();
}
byte[] mc2Message = new MC2AckNakMessage(this.federationRunId, this.modelId, message.getSenderId(), ++this.messageCount,
message.getMessageId(), status, error).createByteArray();
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
this.fsSocket.send(mc2Message, 0);
System.out.println("Sent MC.2");
System.out.flush();
}
/**
* Process FM.6 message and send MC.3 or MC.4 message back.
* @param identity reply id for REQ-ROUTER pattern
* @param message the FM.6 message
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
*/
private void processRequestStatistics(final String identity, final FM6RequestStatisticsMessage message)
throws Sim0MQException, SerializationException
{
boolean ok = true;
String error = "";
String variableName = message.getVariableName();
double variableValue = Double.NaN;
try
{
// TODO: change for real outputs of the model.
/*-
switch (variableName)
{
case "dN.average":
variableValue = this.model.dN.getSampleMean();
break;
case "uN.average":
variableValue = this.model.uN.getSampleMean();
break;
case "qN.max":
variableValue = this.model.qN.getMax();
break;
default:
ok = false;
error = "Parameter " + variableName + " unknown";
break;
}
*/
}
catch (Exception e)
{
ok = false;
error = e.getMessage();
}
if (Double.isNaN(variableValue))
{
ok = false;
error = "Parameter " + variableName + " not set to a value";
}
if (ok)
{
byte[] mc3Message = new MC3StatisticsMessage(this.federationRunId, this.modelId, message.getSenderId(),
++this.messageCount, variableName, variableValue).createByteArray();
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
this.fsSocket.send(mc3Message, 0);
System.out.println("Sent MC.3");
System.out.flush();
}
else
{
byte[] mc4Message = new MC4StatisticsErrorMessage(this.federationRunId, this.modelId, message.getSenderId(),
++this.messageCount, variableName, error).createByteArray();
this.fsSocket.sendMore(identity);
this.fsSocket.sendMore("");
this.fsSocket.send(mc4Message, 0);
System.out.println("Sent MC.4");
System.out.flush();
}
}
/**
* Process FS.3 message.
*/
private void processKillFederate()
{
this.fsSocket.close();
this.fsContext.destroy();
this.fsContext.close();
System.exit(0);
}
/** stop the simulation. */
protected final void terminate()
{
// TODO: This probably goes away or is replaced by metadata
/*-
System.out.println("average queue length = " + this.model.qN.getSampleMean());
System.out.println("average queue wait = " + this.model.dN.getSampleMean());
System.out.println("average utilization = " + this.model.uN.getSampleMean());
*/
}
/**
* @param args contain e.g., port number, and a model to run: SuperDemoWebpplication --port=8080 -m TJunctionDemo.
* @throws SimRuntimeException on error
* @throws NamingException on error
* @throws Sim0MQException on error
* @throws SerializationException on serialization problem
* @throws IOException when TRAFCODDEMO file cannot be found
*/
public static void main(final String[] args)
throws SimRuntimeException, NamingException, Sim0MQException, SerializationException, IOException
{
SuperDemoWebApplication webApp = new SuperDemoWebApplication();
CliUtil.execute(webApp, args);
webApp.init();
}
}