Я использую простой плагин eclipse для создания визуальных состояний машин под названием statecharts, который также использует Java-код для работы. Моя общая цель состоит в том, чтобы заставить две государственные машины взаимодействовать друг с другом через сокеты и обмениваться данными и делать на них переходы, такие как связь клиент-сервер. В начале я использовал простой синхронный клиент-серверный код, но, по-видимому, использование синхронного подхода не может помочь; правильным способом является непрерывный опрос данных из очереди. Теперь я пытаюсь использовать Java NIO, который кажется многообещающим, но, к сожалению, не имел успеха с первой попытки. Кажется, что есть занятый цикл где-то, что не позволяет полученному значению инициировать изменение.Связь между двумя государственными машинами в Java
Код довольно прост: сначала я пытаюсь подключиться к серверу (он работает), отправлять данные (он работает) и пытаться читать из входного буфера каждый цикл как способ получения данных, как вы можете видеть в изображение. Логика до сих пор имеет смысл. Я устанавливаю полученные данные в переменную, которая также находится в выражении перехода. Поэтому в принципе, когда это задано, я должен перейти в следующее состояние. Но это не сработает.
Может ли кто-нибудь помочь мне решить эту проблему? Я видел, что есть асинхронные API, такие как Netty и Naga, которые могут облегчить ситуацию, если это средство.
Вот визуальная схема государственной машины: 
Вот код для клиента:
package test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class EchoClient2 {
String serverHostname = new String("127.0.0.1");
BufferedReader stdIn;
Socket echoSocket = null;
PrintWriter out = null;
BufferedReader in = null;
public void open(){
System.out.println("Attemping to connect to host " + serverHostname
+ " on port 5555.");
try {
echoSocket = new Socket(serverHostname, 5555);
out = new PrintWriter(echoSocket.getOutputStream(), true);
in = new BufferedReader(new InputStreamReader(
echoSocket.getInputStream()));
} catch (UnknownHostException e) {
System.err.println("Don't know about host: " + serverHostname);
} catch (IOException e) {
System.err.println("Couldn't get I/O for " + "the connection to: "
+ serverHostname);
}
}
public void send(){
String userInput = "1";
out.println(userInput);
}
public String receive(){
String result = "";
try {
result = in.readLine();
if(result==null)
return "0";
} catch (IOException e) {
}
return result;
}
}
и вот код для сервера:
package test;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class EchoServer extends Thread {
protected Socket clientSocket;
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = null;
try {
serverSocket = new ServerSocket(5555);
System.out.println("Connection Socket Created");
try {
while (true) {
System.out.println("Waiting for Connection");
new EchoServer(serverSocket.accept());
}
} catch (IOException e) {
System.err.println("Accept failed.");
System.exit(1);
}
} catch (IOException e) {
System.err.println("Could not listen on port: 5555.");
System.exit(1);
} finally {
try {
serverSocket.close();
} catch (IOException e) {
System.err.println("Could not close port: 5555.");
System.exit(1);
}
}
}
private EchoServer(Socket clientSoc) {
clientSocket = clientSoc;
start();
}
public void run() {
System.out.println("New Communication Thread Started");
try {
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(),
true);
BufferedReader in = new BufferedReader(new InputStreamReader(
clientSocket.getInputStream()));
String inputLine;
while ((inputLine = in.readLine()) != null) {
System.out.println("Server: " + inputLine);
out.println(inputLine);
if (inputLine.equals("Bye."))
break;
}
out.close();
in.close();
clientSocket.close();
} catch (IOException e) {
System.err.println("Problem with Communication Server");
System.exit(1);
}
}
}
И here - это папка проекта Eclipse, которую вы можете просто импортировать, если это mi ght быть проще.