Как моделировать пошагово программно в Anylogic

На данный момент я пытаюсь найти способ программно сообщить Anylogic о запуске или остановке моделирования.

Я попытался применить код с веб-сайта справки Anylogic здесь:

https://help.anylogic.com/index.jsp?topic=%2Fcom.anylogic.help%2Fhtml%2Fjavadoc%2Fcom%2Fanylogic%2Fengine%2FEngine.html

К сожалению, у меня не получилось, так как движок не реагирует на мой код. В общем, я пытаюсь создать сокет, используя Anylogic в качестве моего клиента и Eclipse в качестве моего сервера, который должен давать Anylogic команды для запуска или остановки моделирования.

В целом соединение через сокет нормальное — вы общаетесь между программами, и симуляция в Anylogic автоматически останавливается, как только они подключаются друг к другу. Но если вы наберете «старт», ничего не произойдет.

Я уже получил ответ о том, как подключить Anylogic к Eclipse здесь: Как исправить: Anylogic не подключается к Eclipse через сокет

public class Client implements Serializable {


    Engine engine;  
    public Client(Engine e) {
        System.out.println("Engine Name: "+e);
        engine=e; 


    }

    public void activate() {
        try {


Socket sock = new Socket("127.0.0.1", 3000); // reading from keyboard 
BufferedReader keyRead = new BufferedReader(new InputStreamReader(System.in));// sending to client (pwrite object)
OutputStream ostream = sock.getOutputStream(); 
PrintWriter pwrite = new PrintWriter(ostream, true); 
// receiving from server ( receiveRead  object)
InputStream istream = sock.getInputStream();
BufferedReader receiveRead = new BufferedReader(new InputStreamReader(istream));

System.out.println("Start the chat, type and press Enter key");

String receiveMessage, sendMessage;               
while(true)
{
sendMessage = keyRead.readLine();  // keyboard reading
pwrite.println(sendMessage);       // sending to server
pwrite.flush();                    // flush the data

if((receiveMessage = receiveRead.readLine()) == "start") 
//receive from server
{
engine.run();
System.out.println("Start activated");
}   
if((receiveMessage = receiveRead.readLine()) == "pause") 
//receive from server
{
engine.pause();
System.out.println("Pause activated");
}  
if ((receiveMessage = receiveRead.readLine()) != null) //receive from server
{
System.out.println(receiveMessage); // displaying at DOS prompt

}

}               
        }
        catch(IOException ex) {
            System.out.println(ex);
        }
    }

    /**
     * This number is here for model snapshot storing purpose<br>
     * It needs to be changed when this class gets changed
     */
    private static final long serialVersionUID = 1L;

}

// Instead of the if clause i have also tried:

if (receiveMessage.contains("start")){
    System.out.println("receiveMessage "+ engine);
    engine.run();}


// The code for the server


import java.io.*;
import java.net.*;
public class Server3
{
  public static void main(String[] args) throws Exception
  {
      ServerSocket sersock = new ServerSocket(3000);
      System.out.println("Server  ready for chatting");
      Socket sock = sersock.accept( );                          
                              // reading from keyboard (keyRead object)
      BufferedReader keyRead = new BufferedReader(new InputStreamReader(System.in));
                          // sending to client (pwrite object)
      OutputStream ostream = sock.getOutputStream(); 
      PrintWriter pwrite = new PrintWriter(ostream, true);

                              // receiving from server ( receiveRead  object)
      InputStream istream = sock.getInputStream();
      BufferedReader receiveRead = new BufferedReader(new InputStreamReader(istream));

      String receiveMessage, sendMessage;               
      while(true)
      {
        if((receiveMessage = receiveRead.readLine()) != null)  
        {
           System.out.println(receiveMessage);         
        }         
        sendMessage = keyRead.readLine(); 
        pwrite.println(sendMessage);             
        pwrite.flush();
      }               
    }                    
}                        


person Razil    schedule 20.06.2019    source источник
comment
Можете ли вы также поделиться кодом, который вы используете на стороне сервера?   -  person Florian    schedule 21.06.2019
comment
А где именно у вас проблема? Можете ли вы получить отправленную строку? Работает ли вообще getEngine().pause() в модели AnyLogic?   -  person Florian    schedule 21.06.2019
comment
Привет, Флориан, извини за задержку с ответом. Я добавил код для сервера в посте выше. Розетка работает нормально. Я могу отправлять строки с сервера клиенту и наоборот. Моя проблема в том, что как только я набираю start или pause, которые должны быть триггерными словами для запуска или остановки двигателя, Anylogic не выполняет этого. Я предполагаю, что реализовал engine.run(); неправильный   -  person Razil    schedule 22.06.2019