Large File Transfer using Java
This video shows how to code a application to transfer large data from one device to another using JAVA. You can use it to code for Computers or Android Mobile Devices
Enjoy!!!
don’t forget to subscribe on YouTube as more code coming.
Watch YouTube video and configure your project properties and use below code
Client Code: TCPDataClient.java
/*
* Code By Rahul(CodeVlog)
*/
package tcpdataclient;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.io.UnsupportedEncodingException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JFileChooser;
/**
*
* @author rahul
*/
public class TCPDataClient {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
try {
TCPDataClient obj = new TCPDataClient();
Socket obj_client = new Socket(InetAddress.getByName("127.0.0.1"), 6578);
DataInputStream din = new DataInputStream(obj_client.getInputStream());
DataOutputStream dout = new DataOutputStream(obj_client.getOutputStream());
JFileChooser jfc = new JFileChooser();
int dialog_value = jfc.showOpenDialog(null);
if (dialog_value == JFileChooser.APPROVE_OPTION) {
File target_file = jfc.getSelectedFile();
dout.write(obj.CreateDataPacket("124".getBytes("UTF8"), target_file.getName().getBytes("UTF8")));
dout.flush();
RandomAccessFile rw = new RandomAccessFile(target_file, "r");
long current_file_pointer = 0;
boolean loop_break = false;
while (true) {
if (din.read() == 2) {
byte[] cmd_buff = new byte[3];
din.read(cmd_buff, 0, cmd_buff.length);
byte[] recv_buff = obj.ReadStream(din);
switch (Integer.parseInt(new String(cmd_buff))) {
case 125:
current_file_pointer = Long.valueOf(new String(recv_buff));
int buff_len = (int) (rw.length() - current_file_pointer < 20000 ? rw.length() - current_file_pointer : 20000);
byte[] temp_buff = new byte[buff_len];
if (current_file_pointer != rw.length()) {
rw.seek(current_file_pointer);
rw.read(temp_buff, 0, temp_buff.length);
dout.write(obj.CreateDataPacket("126".getBytes("UTF8"), temp_buff));
dout.flush();
System.out.println("Upload percentage: " + ((float)current_file_pointer/rw.length())*100+"%");
} else {
loop_break = true;
}
break;
}
}
if (loop_break == true) {
System.out.println("Stop Server informed");
dout.write(obj.CreateDataPacket("127".getBytes("UTF8"), "Close".getBytes("UTF8")));
dout.flush();
obj_client.close();
System.out.println("Client Socket Closed");
break;
}
}
}
} catch (UnknownHostException ex) {
Logger.getLogger(TCPDataClient.class.getName()).log(Level.SEVERE, null, ex);
} catch (IOException ex) {
Logger.getLogger(TCPDataClient.class.getName()).log(Level.SEVERE, null, ex);
}
}
private byte[] CreateDataPacket(byte[] cmd, byte[] data) {
byte[] packet = null;
try {
byte[] initialize = new byte[1];
initialize[0] = 2;
byte[] separator = new byte[1];
separator[0] = 4;
byte[] data_length = String.valueOf(data.length).getBytes("UTF8");
packet = new byte[initialize.length + cmd.length + separator.length + data_length.length + data.length];
System.arraycopy(initialize, 0, packet, 0, initialize.length);
System.arraycopy(cmd, 0, packet, initialize.length, cmd.length);
System.arraycopy(data_length, 0, packet, initialize.length + cmd.length, data_length.length);
System.arraycopy(separator, 0, packet, initialize.length + cmd.length + data_length.length, separator.length);
System.arraycopy(data, 0, packet, initialize.length + cmd.length + data_length.length + separator.length, data.length);
} catch (UnsupportedEncodingException ex) {
Logger.getLogger(TCPDataClient.class.getName()).log(Level.SEVERE, null, ex);
}
return packet;
}
private byte[] ReadStream(DataInputStream din) {
byte[] data_buff = null;
try {
int b = 0;
String buff_length = "";
while ((b = din.read()) != 4) {
buff_length += (char) b;
}
int data_length = Integer.parseInt(buff_length);
data_buff = new byte[Integer.parseInt(buff_length)];
int byte_read = 0;
int byte_offset = 0;
while (byte_offset < data_length) {
byte_read = din.read(data_buff, byte_offset, data_length - byte_offset);
byte_offset += byte_read;
}
} catch (IOException ex) {
Logger.getLogger(TCPDataClient.class.getName()).log(Level.SEVERE, null, ex);
}
return data_buff;
}
}
Server code: TCPDataServer.java
/*
* Code By Rahul(CodeVlog)
*/
package tcpdataserver;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.io.UnsupportedEncodingException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
*
* @author rahul
*/
public class TCPDataServer {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
try {
ServerSocket server_socket = new ServerSocket(6578);
while (true) {
new Thread(new ClientWorker(server_socket.accept())).start();
}
} catch (IOException ex) {
Logger.getLogger(TCPDataServer.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
class ClientWorker implements Runnable {
private Socket target_socket;
private DataInputStream din;
private DataOutputStream dout;
public ClientWorker(Socket recv_socket) {
try {
target_socket = recv_socket;
din = new DataInputStream(target_socket.getInputStream());
dout = new DataOutputStream(target_socket.getOutputStream());
} catch (IOException ex) {
Logger.getLogger(ClientWorker.class.getName()).log(Level.SEVERE, null, ex);
}
}
@Override
public void run() {
RandomAccessFile rw = null;
long current_file_pointer = 0;
boolean loop_break = false;
while (true) {
byte[] initilize = new byte[1];
try {
din.read(initilize, 0, initilize.length);
if (initilize[0] == 2) {
byte[] cmd_buff = new byte[3];
din.read(cmd_buff, 0, cmd_buff.length);
byte[] recv_data = ReadStream();
switch (Integer.parseInt(new String(cmd_buff))) {
case 124:
rw = new RandomAccessFile("/home/rahul/Downloads/" + new String(recv_data), "rw");
dout.write(CreateDataPacket("125".getBytes("UTF8"), String.valueOf(current_file_pointer).getBytes("UTF8")));
dout.flush();
break;
case 126:
rw.seek(current_file_pointer);
rw.write(recv_data);
current_file_pointer = rw.getFilePointer();
System.out.println("Download percentage: " + ((float)current_file_pointer/rw.length())*100+"%");
dout.write(CreateDataPacket("125".getBytes("UTF8"), String.valueOf(current_file_pointer).getBytes("UTF8")));
dout.flush();
break;
case 127:
if ("Close".equals(new String(recv_data))) {
loop_break = true;
}
break;
}
}
if (loop_break == true) {
target_socket.close();
}
} catch (IOException ex) {
Logger.getLogger(ClientWorker.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
private byte[] ReadStream() {
byte[] data_buff = null;
try {
int b = 0;
String buff_length = "";
while ((b = din.read()) != 4) {
buff_length += (char) b;
}
int data_length = Integer.parseInt(buff_length);
data_buff = new byte[Integer.parseInt(buff_length)];
int byte_read = 0;
int byte_offset = 0;
while (byte_offset < data_length) {
byte_read = din.read(data_buff, byte_offset, data_length - byte_offset);
byte_offset += byte_read;
}
} catch (IOException ex) {
Logger.getLogger(ClientWorker.class.getName()).log(Level.SEVERE, null, ex);
}
return data_buff;
}
private byte[] CreateDataPacket(byte[] cmd, byte[] data) {
byte[] packet = null;
try {
byte[] initialize = new byte[1];
initialize[0] = 2;
byte[] separator = new byte[1];
separator[0] = 4;
byte[] data_length = String.valueOf(data.length).getBytes("UTF8");
packet = new byte[initialize.length + cmd.length + separator.length + data_length.length + data.length];
System.arraycopy(initialize, 0, packet, 0, initialize.length);
System.arraycopy(cmd, 0, packet, initialize.length, cmd.length);
System.arraycopy(data_length, 0, packet, initialize.length + cmd.length, data_length.length);
System.arraycopy(separator, 0, packet, initialize.length + cmd.length + data_length.length, separator.length);
System.arraycopy(data, 0, packet, initialize.length + cmd.length + data_length.length + separator.length, data.length);
} catch (UnsupportedEncodingException ex) {
Logger.getLogger(ClientWorker.class.getName()).log(Level.SEVERE, null, ex);
}
return packet;
}
}
