0
我一直在使用一个简单的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要容易些。