L'envoi d'un fichier texte à partir du serveur vers le client à l'aide de sockets java

Votre MyStreamSocket classe n'a pas besoin de s'étendre Socket. Le mystérieux message d'erreur est parce que le Socket représenté par MyStreamSocket est jamais connecté à rien. La Prise référencé par son socket membre est celui qui est connecté. C'est pourquoi, lorsque vous obtenez le flux d'entrée de MyStreamSocket il vraiment n'est pas connecté. Cela provoque une erreur, ce qui signifie que le client s'arrête. Qui provoque la prise de fermer, que le serveur dûment rapports

L'utilisation de BufferedReader va vous causer des problèmes. Il lit toujours autant qu'il le peut dans sa mémoire tampon, donc, au début d'un transfert de fichier, il lit la "200" message et puis les premiers Ko du fichier envoyé des qui sera analysée comme données de caractère. Le résultat sera tout un tas de bugs.

Je vous suggère de se débarrasser de BufferedReader dès maintenant et utilisez DataInputStream et DataOutputStream à la place. Vous pouvez utiliser le writeUTF et readUTF méthodes pour envoyer vos commandes textuelles. Pour envoyer le fichier, je dirais même un simple morceau de codage.

Il est probablement plus facile si je vous donne le code.

Le premier de votre classe client.

import java.io.*;
import java.net.InetAddress;
public class EchoClient2 {
public static void main(String[] args) {
InputStreamReader is = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(is);
File file = new File("C:\\MyFile.txt");
try {
System.out.println("Welcome to the Echo client.\n"
+ "What is the name of the server host?");
String hostName = br.readLine();
if( hostName.length() == 0 ) //if user did not enter a name
hostName = "localhost"; //use the default host name
System.out.println("What is the port number of the server host?");
String portNum = br.readLine();
if( portNum.length() == 0 ) portNum = "7"; //default port number
MyStreamSocket socket = new MyStreamSocket(
InetAddress.getByName(hostName), Integer.parseInt(portNum));
boolean done = false;
String echo;
while( !done ) {
System.out.println("Enter Code: 100 = Login, 200 = Upload, 400 = Logout: ");
String message = br.readLine();
boolean messageOK = false;
if( message.equals("100") ) {
messageOK = true;
System.out.println("Enter T-Number: (Use Uppercase 'T')");
String login = br.readLine();
if( login.charAt(0) == 'T' ) {
System.out.println("Login Worked fantastically");
} else {
System.out.println("Login Failed");
}
socket.sendMessage("100");
}
if( message.equals("200") ) {
messageOK = true;
socket.sendMessage("200");
socket.sendFile(file);
}
if( (message.trim()).equals("400") ) {
messageOK = true;
System.out.println("Logged Out");
done = true;
socket.sendMessage("400");
socket.close();
break;
}
if( ! messageOK ) {
System.out.println("Invalid input");
continue;
}
//get reply from server
echo = socket.receiveMessage();
System.out.println(echo);
} //end while
} //end try
catch (Exception ex) {
ex.printStackTrace();
} //end catch
} //end main
} //end class

Alors votre serveur de classe:

import java.io.*;
import java.net.*;
public class EchoServer2 {
static final String loginMessage = "Logged In";
static final String logoutMessage = "Logged Out";
public static void main(String[] args) {
int serverPort = 7; //default port
String message;
if( args.length == 1 ) serverPort = Integer.parseInt(args[0]);
try {
//instantiates a stream socket for accepting
//connections
ServerSocket myConnectionSocket = new ServerSocket(serverPort);
/**/System.out.println("Daytime server ready.");
while( true ) { //forever loop
//wait to accept a connection
/**/System.out.println("Waiting for a connection.");
MyStreamSocket myDataSocket = new MyStreamSocket(
myConnectionSocket.accept());
/**/System.out.println("connection accepted");
boolean done = false;
while( !done ) {
message = myDataSocket.receiveMessage();
/**/System.out.println("message received: " + message);
if( (message.trim()).equals("400") ) {
//Session over; close the data socket.
myDataSocket.sendMessage(logoutMessage);
myDataSocket.close();
done = true;
} //end if
if( (message.trim()).equals("100") ) {
//Login
/**/myDataSocket.sendMessage(loginMessage);
} //end if
if( (message.trim()).equals("200") ) {
File outFile = new File("C:\\OutFileServer.txt");
myDataSocket.receiveFile(outFile);
myDataSocket.sendMessage("File received "+outFile.length()+" bytes");
}
} //end while !done
} //end while forever
} //end try
catch (Exception ex) {
ex.printStackTrace();
}
} //end main
} //end class

Puis le StreamSocket classe:

public class MyStreamSocket {
private Socket socket;
private DataInputStream input;
private DataOutputStream output;
MyStreamSocket(InetAddress acceptorHost, int acceptorPort)
throws SocketException, IOException {
socket = new Socket(acceptorHost, acceptorPort);
setStreams();
}
MyStreamSocket(Socket socket) throws IOException {
this.socket = socket;
setStreams();
}
private void setStreams() throws IOException {
//get an input stream for reading from the data socket
input = new DataInputStream(socket.getInputStream());
output = new DataOutputStream(socket.getOutputStream());
}
public void sendMessage(String message) throws IOException {
output.writeUTF(message);
output.flush();
} //end sendMessage
public String receiveMessage() throws IOException {
String message = input.readUTF();
return message;
} //end receiveMessage
public void close() throws IOException {
socket.close();
}
public void sendFile(File file) throws IOException {
FileInputStream fileIn = new FileInputStream(file);
byte[] buf = new byte[Short.MAX_VALUE];
int bytesRead;        
while( (bytesRead = fileIn.read(buf)) != -1 ) {
output.writeShort(bytesRead);
output.write(buf,0,bytesRead);
}
output.writeShort(-1);
fileIn.close();
}
public void receiveFile(File file) throws IOException {
FileOutputStream fileOut = new FileOutputStream(file);
byte[] buf = new byte[Short.MAX_VALUE];
int bytesSent;        
while( (bytesSent = input.readShort()) != -1 ) {
input.readFully(buf,0,bytesSent);
fileOut.write(buf,0,bytesSent);
}
fileOut.close();
}    
} //end class

Fossé de l ' "aide" de la classe. Il n'est pas de vous aider.