Tôi gặp rất nhiều khó khăn trong việc tìm hiểu sự khác biệt về cách Java xử lý Ổ cắm trên Windows và Linux - Đặc biệt khi một trong các bên (Máy khách hoặc Máy chủ) đóng kết nối đột ngột.Sự khác biệt về Ổ cắm Java giữa Windows và Linux - Cách xử lý chúng?
Tôi đã viết như sau rất đơn giản Server và Client lớp để giữ quan điểm của tôi cũng đơn giản, khách quan và dễ dàng để bạn có thể hiểu càng tốt:
SimpleClient.java:
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class SimpleClient {
public static void main(String args[]) {
try {
Socket client_socket = new Socket("127.0.0.1", 9009);
// Used to read from a terminal input:
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
// Used for client/server communication:
BufferedReader in = new BufferedReader(new InputStreamReader(client_socket.getInputStream()));
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(client_socket.getOutputStream()));
while(true) {
System.out.print("Command: ");
String msg = br.readLine();
// Send:
out.write(msg);
out.newLine();
out.flush();
// Receive:
int ifirst_char;
char first_char;
if((ifirst_char = in.read()) == -1) { // Server Closed
System.out.println("Server was closed on the other side.");
break;
}
first_char = (char) ifirst_char;
msg = String.valueOf(first_char);
msg += in.readLine();
// Shows the message received from the server on the screen:
System.out.println(msg);
}
}
catch(Exception e) {
e.printStackTrace();
}
}
}
SimpleServer.java:
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class SimpleServer {
public static void main(String args[]) {
try {
ServerSocket server_socket = new ServerSocket(9009);
Socket client_socket = server_socket.accept();
while(true) {
BufferedReader in = new BufferedReader(new InputStreamReader(client_socket.getInputStream()));
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(client_socket.getOutputStream()));
// Receive:
int ifirst_char;
char first_char;
if((ifirst_char = in.read()) == -1) { // Client Closed
System.out.println("Client was closed on the other side.");
break;
}
first_char = (char) ifirst_char;
String msg = msg = String.valueOf(first_char);
msg += in.readLine();
msg = "Server Received: " + msg;
// Send:
out.write(msg);
out.newLine();
out.flush();
}
}
catch(Exception e) {
e.printStackTrace();
}
}
}
Dĩ nhiên tôi có thể thực hiện một mã cho đúng cách tắt máy khách hoặc máy chủ, nhưng khách quan, như tôi đã nói, là để mô phỏng một shutdown đột ngột ở hai bên, nơi không có "mã ngắt kết nối "có thể được gửi hoặc nhận. Đó là lý do tại sao tôi tạo ra 2 lớp học rất đơn giản này.
Trên Linux, nó chạy khá tốt:
$ java SimpleClient
Command: echo
Server Received: echo
Command: test
Server Received: test
Command: (server now was closed on the other side)
Server was closed on the other side.
$
Trên Windows, tuy nhiên:
C:\simplesocket>java SimpleClient
Command: echo
Server Received: echo
Command: test
Server Received: test
Command: (server now was closed on the other side)
java.net.SocketException: Connection reset by peer: socket write error
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(Unknown Source)
at java.net.SocketOutputStream.write(Unknown Source)
at sun.nio.cs.StreamEncoder.writeBytes(Unknown Source)
at sun.nio.cs.StreamEncoder.implFlushBuffer(Unknown Source)
at sun.nio.cs.StreamEncoder.implFlush(Unknown Source)
at sun.nio.cs.StreamEncoder.flush(Unknown Source)
at java.io.OutputStreamWriter.flush(Unknown Source)
at java.io.BufferedWriter.flush(Unknown Source)
at SimpleClient.main(SimpleClient.java:32)
Hãy nói rằng tôi cố gắng bỏ qua ngoại lệ này bằng cách sửa đổi những dòng sau vào SimpleClient của tôi .java:
// Send:
try {
out.write(msg);
out.newLine();
out.flush();
}
catch(Exception e) {}
ngoại lệ khác là ném:
C:\simplesocket>java SimpleClient
Command: echo
Server Received: echo
Command: test
Server Received: test
Command: (server now was closed on the other side)
java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(Unknown Source)
at java.net.SocketInputStream.read(Unknown Source)
at sun.nio.cs.StreamDecoder.readBytes(Unknown Source)
at sun.nio.cs.StreamDecoder.implRead(Unknown Source)
at sun.nio.cs.StreamDecoder.read(Unknown Source)
at java.io.InputStreamReader.read(Unknown Source)
at java.io.BufferedReader.fill(Unknown Source)
at java.io.BufferedReader.read(Unknown Source)
at SimpleClient.main(SimpleClient.java:42)
Tôi không biết nếu các dòng tương ứng trên mã sẽ là những người chỉ ra bằng các trường hợp ngoại lệ, nhưng một trong những đầu tiên được ném vào out.flush () và ô thứ hai trên in.read(). Vì vậy, về cơ bản, như bạn có thể thấy trên Linux, ngay cả sau khi đột ngột đóng máy chủ:
1. Nó không ném một ngoại lệ khi tôi cố gắng gửi dữ liệu.
2. Và quan trọng hơn, khi tôi cố gắng nhận nó, char đầu tiên là "-1" và nhận được chính xác.
Trên Windows, nó ném ngoại lệ cả khi gửi và quan trọng hơn khi nhận - khi gọi phương thức read() - Tôi không thể lấy mã "cuối dòng" (-1).
Dẫn đến một số câu hỏi:
1. Tại sao có sự khác biệt lớn trên Windows x Linux? Tại sao trên Linux những ngoại lệ này không được ném trong khi trên Windows chúng?
2. Không nên Java, với tất cả các phẩm chất đa nền tảng của nó, cố gắng giảm thiểu sự khác biệt khi chạy trong cả hai Hệ thống? (bằng cách tôi đang sử dụng JDK 7 trên cả hai)
3. Có cách nào thay đổi mã để tắt đột ngột và làm cho nó hoạt động tốt hơn "giống như Linux" trên Windows hay không Ngoại lệ và nhận được -1 trên in.read của tôi() ??
4. Nếu không, bất kỳ API bên ngoài nào được đề xuất?
Tôi đã cố gắng tìm kiếm trên web hàng giờ về chủ đề cụ thể này nhưng không thành công.
Tôi cũng đã thử nhiều giải pháp như phương pháp gọi như isConnected(), isBound(), isClosed(), vv trong client_socket về phía khách hàng nhưng không thành công. Họ luôn nói rằng có một kết nối hoạt động và không có vấn đề với nó, ngay cả sau khi tắt máy chủ.
Hy vọng rằng ai đó sẽ dành thời gian để trả lời ít nhất một trong những câu hỏi này.
Bạn có lời cảm ơn chân thành nhất trước mọi câu trả lời.
Phương thức isXXX() cho bạn biết trạng thái của socket, không phải về trạng thái kết nối. Sự khác biệt chính giữa ổ cắm Linux và ổ cắm Windows là kích thước của bộ đệm, và điều đó một mình là đủ để giải thích mọi thứ bạn thấy ở đây. Và nó không phải là một cái gì đó Java cố gắng để mịn hơn. – EJP