Как программно моделировать шаги в Anylogic - PullRequest
Новая
       29

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

0 голосов
/ 20 июня 2019

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

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

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

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

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

Я уже получил ответ о том, как подключить 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();
      }               
    }                    
}
...