All about agustinus lumbantoruan

How to Change the File Name for Each Uploaded Files to the Socket Server?

Wouter Oet wrote:Well scrap that. I'm not sure any more. But you do try to close dis twice. On line 93 and 98.

hahahaha i didn't notice that. Thanks man, i appreciate it

So here is the little update of the server and client code. The update was just to make it look cleaner

Server.java

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package com.transfer;
import java.net.*;
import java.io.*;
/**
*
* @author Bio
*/
public class Server implements Runnable{
private ServerSocket incoming;
private String filename;
private FileOutputStream out;
private String outputLocation;
private int port;
private Thread t;
private DataInputStream dis;
private InputStream in;
private Socket sock;
public Server(int port, String outputLocation) throws IOException{
setOutputLocation(outputLocation);
setPort(port);
}
public void setOutputLocation(String outputLocation){
this.outputLocation=outputLocation;
}
public void setPort(int port){
this.port=port;
}
public Thread getThread(){
return t;
}
/*
* Turns on the server which keeps on listening for the incoming request
*/
public void turnOnServer() throws IOException{
incoming = new ServerSocket(port);
while (true) {
System.out.println("Waiting...");
sock = incoming.accept();
//Initialize InputStream and DataInputStream
in = sock.getInputStream();
dis = new DataInputStream(in);
filename = dis.readUTF();
//View the filename
System.out.println(filename);
//Initialize the FileOutPutStream
out=new FileOutputStream(new File(outputLocation+filename));
System.out.println("Accepted connection : " + sock);
if(sock.isConnected()){
System.out.println("Hmmm i am connected to some one");
}
// 1MB Buffer
byte[] mb = new byte[1048576];
// sendfile
for(int c = dis.read(mb); c > -1; c= dis.read(mb)){
out.write(mb, 0, c);
}
}
}
/*
* Close all connection
*/
public void closeAll() throws IOException{
/*
* Flush and close the FileOutputStream
*/
this.out.flush();
this.out.close();
/*
* Close dis
*/
dis.close();
/*
* close the InputStreamReader
*/
this.sock.close();
}
/*
* Basically it starts the thread process
*/
public void runServer(){
t=new Thread(this);
t.start();
}
public void run() {
try {
turnOnServer();
} catch (IOException ex) {
System.out.println(ex.toString());
}
}
public static void main(String []args) throws IOException{
String outputFile="c:/xampp/htdocs/videos/";
Server newServer= new Server(4444, outputFile);
/*
* run the server thread
*/
newServer.runServer();
}
}

Client.java

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package com.transfer;
import java.net.*;
import java.io.*;
/**
*
* @author Bio
*/
public class Client implements Runnable{
private Socket sock;
private String filename;
private String fileLocation;
private PrintWriter pw;
private FileInputStream in;
private String ip;
private int port;
private Thread t;
private DataOutputStream dos;
public Client(String ip, int port, String fileLocation, String filename) throws UnknownHostException, IOException{
setIpAddress(ip);
setPort(port);
setFileLocation(fileLocation);
setFileName(filename);
}
/*
* Get the runnin thread
*/
public Thread getThread(){
return t;
}
/*
* Set the input file location
*/
public void setFileLocation(String fileLocation){
this.fileLocation=fileLocation;
}
/*
* Set the filename
*/
public void setFileName(String filename){
this.filename=filename;
}
/*
* Set the server ipAddress
*/
public void setIpAddress(String ip){
this.ip=ip;
}
/*
* Set the server port number
*/
public void setPort(int port){
this.port=port;
}
/*
* Open a connection to the server
*/
private void openConnection(String Ip, int port) throws UnknownHostException, IOException{
// localhost for testing
sock = new Socket(Ip,port);
System.out.println("Connecting...");
}
/*
* Uploading your file to the server
*/
public void upload() throws UnknownHostException, IOException{
//Open Connection to the Server
openConnection(this.ip, this.port);
/*
* Initialize the File and FileInputStream
*/
File myFile = new File(fileLocation+filename);
in = new FileInputStream(myFile);
dos = new DataOutputStream(sock.getOutputStream());
dos.writeUTF(filename);
///////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////////////////////
// Uploading file started
byte[] mb = new byte[1048576];
for(int c = in.read(mb, 0, 1048576); c > 0; c = in.read(mb, 0, 1048576)){
dos.write(mb, 0, c);
}
// Uploading file done
///////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////////////////////
//Close the connection
closeConnection();
}
/*
* Closing the
* DataOutputStream
* FileInputStream
* Socket
*/
public void closeConnection() throws IOException{
/*
* Flush and Close the DataOutputStream
*/
dos.flush();
dos.close();
/*
* Close the FileInputStream
*/
in.close();
sock.close();
}
/*
* Basically it starts the thread process
*/
public void startUploading(){
/*
* Run the thread
*/
t = new Thread(this,filename);
t.start();
}
public void run() {
try {
upload();
} catch (UnknownHostException ex) {
System.out.println(ex.toString());
} catch (IOException ex) {
System.out.println(ex.toString());
}
}
public static void main(String[]args) throws UnknownHostException, IOException{
Client newClient = new Client("localhost", 4444, "c:/", "outfile.mp4");
/*
* run the client upload's thread
*/
newClient.startUploading();
/*
* Make the Thread waits for the newClient's thread finish it's job before turning it off
*/
try {
newClient.getThread().join();
} catch (InterruptedException ex) {
System.out.println(ex.toString());
}
}
}

agustinus lumbantoruan

Recent posts by agustinus lumbantoruan