Я делаю обмен сообщениями между сервером и клиентом через сокет сервера с помощью javafx.
Я занимаюсь этим уже давно и подумал, что это будет достаточно просто, но я не могу понять это.Я пробовал кучу разных способов, но я не достаточно хорош.Пожалуйста, помогите мне разобраться, если можете.
Вот код для клиента
// IO streams
DataOutputStream toServer = null;
DataInputStream fromServer = null;
String serverMessage = "";
@Override // Override the start method in the Application class
public void start(Stage primaryStage) {
// Panel p to hold the label and text field
BorderPane paneForTextField = new BorderPane();
Button btnSend = new Button("|>");
paneForTextField.setPadding(new Insets(5, 5, 5, 5));
paneForTextField.setStyle("-fx-border-color: green");
paneForTextField.setRight( btnSend );
TextField tf = new TextField();
tf.setAlignment(Pos.BOTTOM_RIGHT);
paneForTextField.setCenter(tf);
BorderPane mainPane = new BorderPane();
// Text area to display contents
TextArea ta = new TextArea();
mainPane.setTop(new ScrollPane(ta));
mainPane.setCenter(paneForTextField);
// Create a scene and place it in the stage
Scene scene = new Scene(mainPane, 450, 270);
primaryStage.setTitle("Client"); // Set the stage title
primaryStage.setScene(scene); // Place the scene in the stage
primaryStage.show(); // Display the stage
tf.setOnAction(e -> {
try {
// Get the message from the text field
String message = tf.getText().trim();
// Send the message to the server
toServer.writeBytes(message);
toServer.flush();
System.out.println("message sent");
tf.setText("");
// Display to the text area
ta.appendText("client: " + message + "\n");
}
catch (IOException ex) {
System.err.println(ex);
}
});
try {
// Create a socket to connect to the server
Socket socket = new Socket("localhost", 8000);
// Socket socket = new Socket("130.254.204.36", 8000);
// Socket socket = new Socket("drake.Armstrong.edu", 8000);
// Create an input stream to receive data from the server
fromServer = new DataInputStream( socket.getInputStream() );
// Create an output stream to send data to the server
toServer = new DataOutputStream( socket.getOutputStream() );
new Thread(() -> {
try{
while(true){
serverMessage = fromServer.readUTF();
System.out.println("message received");
Platform.runLater( () -> {
tf.appendText(serverMessage);
});
}
}
catch(IOException e){
ta.appendText(e.toString() + "\n");
}
}).start();
}
catch (IOException ex) {
ta.appendText(ex.toString() + '\n');
}
}
, а вот код для сервера
private TextField tf = new TextField();
private ServerSocket serverSocket;
private Socket socket;
private DataInputStream input ;
private BufferedWriter output;
// Text area for displaying contents
TextArea ta = new TextArea();
@Override // Override the start method in the Application class
public void start(Stage primaryStage) {
// Create a server socket
BorderPane borderPaneForText = new BorderPane();
Button btnSend = new Button("|>");
btnSend.setOnAction( e-> {
Platform.runLater( () -> {
try{
output.write(tf.getText());
showMessage("server: " + tf.getText() + "\n");
}
catch(IOException ex){
ex.printStackTrace();
}
});
});
tf.setAlignment(Pos.BOTTOM_RIGHT);
borderPaneForText.setCenter(tf);
borderPaneForText.setRight(btnSend);
borderPaneForText.setPadding( new Insets( 5, 5, 5, 5) );
BorderPane mainPane = new BorderPane();
mainPane.setTop(new ScrollPane(ta));
mainPane.setCenter(borderPaneForText);
// Create a scene and place it in the stage
Scene scene = new Scene(mainPane, 450, 270);
primaryStage.setTitle("Server"); // Set the stage title
primaryStage.setScene(scene); // Place the scene in the stage
primaryStage.show(); // Display the stage
ta.setEditable(false);
new Thread( () -> {
try {
// Create a server socket
serverSocket = new ServerSocket(8000);
Platform.runLater(() ->
ta.appendText("Server started at " + new Date() + '\n'));
// Listen for a connection request
Socket socket = serverSocket.accept();
// Create data input and output streams
input = new DataInputStream( socket.getInputStream() );
output = new BufferedWriter( new OutputStreamWriter(socket.getOutputStream() ) );
while (true) {
// Receive message from the client
String message = input.readUTF();
output.write(message);
Platform.runLater(() -> {
ta.appendText("Client: " + message + "\n");
});
}
}
catch(IOException ex) {
ex.printStackTrace();
}
}).start();
}
/**
* The main method is only needed for the IDE with limited
* JavaFX support. Not needed for running from the command line.
*/
public static void main(String[] args) {
launch(args);
}
public void showMessage(String message){
Platform.runLater( () -> {
ta.appendText(message);
});
}
IНе знаю, если это проблема с datainputstream, потому что у него нет метода readline или readString.Когда я его опробовал, сработала похожая программа с double.
Я пытаюсь сделать как обычное окно чата в обоих приложениях, чтобы оба могли обмениваться сообщениями.когда я нажимаю отправить в одном из приложений, я ожидаю, что строка будет отправлена в другое приложение.Затем я хочу отобразить этот текст в текстовой области на сервере и в клиенте, например, как ведет себя настоящий чат.В настоящее время строки отображаются в соответствующих текстовых областях, но не в другом приложении.