0% found this document useful (0 votes)
13 views14 pages

Java Server-Client File Management System

This document contains code for a server and client application for a multicast messaging system. The Server.java code defines a server class that accepts client connections, stores client details in a database, and allows sending messages to clients in a cluster. The Node.java code defines a client GUI class that can receive and display messages from the server, and allows the user to open, save, and send messages. The Database.java code defines a class to connect to an Access database for storing client details.

Uploaded by

balavignesh1313
Copyright
© Attribution Non-Commercial (BY-NC)
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as DOC, PDF, TXT or read online on Scribd
0% found this document useful (0 votes)
13 views14 pages

Java Server-Client File Management System

This document contains code for a server and client application for a multicast messaging system. The Server.java code defines a server class that accepts client connections, stores client details in a database, and allows sending messages to clients in a cluster. The Node.java code defines a client GUI class that can receive and display messages from the server, and allows the user to open, save, and send messages. The Database.java code defines a class to connect to an Access database for storing client details.

Uploaded by

balavignesh1313
Copyright
© Attribution Non-Commercial (BY-NC)
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as DOC, PDF, TXT or read online on Scribd

CODING

[Link]

package server;
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link].*;
import [Link].*;
import [Link];
import [Link].*;
import [Link];

public class Server extends [Link] implements Runnable {

public Server() {
initComponents();

private void jButton1ActionPerformed([Link] evt)


{//GEN-FIRST:event_jButton1ActionPerformed

db = new Database();
con = [Link]();
try {
st = [Link]();
[Link]("delete from node");
} catch (SQLException e) {
[Link]();
}
[Link](0);
}//GEN-LAST:event_jButton1ActionPerformed

private void btnSaveActionPerformed([Link] evt)


{//GEN-FIRST:event_btnSaveActionPerformed
db = new Database();
con = [Link]();
try {
ps = [Link]("insert into node values(?,?,?,?);");
for (int j = 0; j < i; j++) {
String name = (String) [Link]().getValueAt(j, 0);
String address = (String) [Link]().getValueAt(j, 1);
String strport = [Link]().getValueAt(j, 2) + "";
int port = [Link]([Link]());
String cluster = (String) [Link]().getValueAt(j, 3);
[Link](1, name);
[Link](2, address);
[Link](3, port);
[Link](4, cluster);
[Link]();
[Link]("Node details will be inserted");
}
[Link](this, "All the Node details are stored
in the database....!");
} catch (SQLException e) {
[Link]();
}
}//GEN-LAST:event_btnSaveActionPerformed

private void jMenu1ActionPerformed([Link] evt)


{//GEN-FIRST:event_jMenu1ActionPerformed
}//GEN-LAST:event_jMenu1ActionPerformed

private void mnuSendActionPerformed([Link] evt)


{//GEN-FIRST:event_mnuSendActionPerformed

ArrayList name = new ArrayList();


ArrayList data = new ArrayList();

String clusterName = [Link]("Please Enter Cluster


Name...!");

db = new Database();
con = [Link]();
try {
st = [Link]();
rs = [Link]("select * from node where cluster='" +
clusterName + "';");
while ([Link]()) {
[Link]([Link](1));
}
[Link]();
ArrayList message = Robber([Link](), [Link]());
[Link](message);

if (!([Link]())) {
}
} catch (SQLException e) {
[Link]();
}

}//GEN-LAST:event_mnuSendActionPerformed

private void mnuExitActionPerformed([Link] evt)


{//GEN-FIRST:event_mnuExitActionPerformed
}//GEN-LAST:event_mnuExitActionPerformed

private void btnBrowseActionPerformed([Link] evt)


{//GEN-FIRST:event_btnBrowseActionPerformed
FileDialog fd = new FileDialog(this, "Open");
[Link](true);
String dir = [Link]();
String file = [Link]();
[Link](dir + file);
}//GEN-LAST:event_btnBrowseActionPerformed

public void run() {


while (true) {
try {
socket = [Link]();
String name = [Link]().getHostName();
String address = [Link]().getHostAddress();
ObjectInputStream ois = new
ObjectInputStream([Link]());
[Link] l = ([Link]) [Link]();
int port = [Link]((String) [Link](0));
[Link]([Link]().getHostName() + " was
Accepted by Server");

[Link]().setValueAt(name, i, 0);
[Link]().setValueAt(address, i, 1);
[Link]().setValueAt(port, i, 2);
i++;

} catch (IOException e) {
[Link]();
} catch (ClassNotFoundException e) {
[Link]();
}
}
}

public static void main(String args[]) {


[Link](new Runnable() {

public void run() {


Server ser = new Server();
[Link](true);
[Link]();
}
});
}
// Variables declaration - do not modify//GEN-BEGIN:variables
private [Link] btnBrowse;
private [Link] btnSave;
private [Link] jButton1;
private [Link] jLabel1;
private [Link] jLabel3;
private [Link] jMenu1;
private [Link] jMenuBar1;
private [Link] jPanel1;
private [Link] jPanel2;
private [Link] jPanel4;
private [Link] jScrollPane1;
private [Link] mnuExit;
private [Link] mnuSend;
private [Link] tbl;
private [Link] txtFile;
// End of variables declaration//GEN-END:variables
ServerSocket server;
Socket socket;
Thread t;
int i = 0;
Connection con;
PreparedStatement ps;
Statement st;
ResultSet rs;
Database db;

void connection() {
try {
[Link]("\t\t***************");
[Link]("\t\tServer Details");
[Link]("\t\t***************");
server = new ServerSocket(100);

[Link]("*** Server is running on the port 100 ****");

t = new Thread(this);
[Link]();
} catch (IOException e) {
[Link]();
}
}

public ArrayList Robber(String path, int count) {


ArrayList message = new ArrayList();
int temp = 0;
try {
FileInputStream fis = new FileInputStream([Link]());
int length = [Link]();
byte buffer[] = new byte[length];
[Link](buffer);
int block = length / count;
while (temp < length) {
String str = new String(buffer, temp, block);
[Link](str);
temp = temp + block;

}
} catch (IOException e) {
[Link]();
}
[Link](message);
return message;
}
}

[Link]

package server;
import [Link].*;

public class Database {

Connection con;

Connection connect(){
try{

[Link]("[Link]");

con=[Link]("jdbc:odbc:multicast");
[Link]("Database Connection success");

}
catch(Exception e){
[Link]("*** Connection Error ***");
}
return con;
}
}

[Link]

package client;
import [Link].*;
import [Link];
import [Link].*;
import [Link].*;
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link].*;
import [Link];

public class Node extends [Link] implements Runnable {

public Node() {
initComponents();

/** This method is called from within the constructor to


* initialize the form.
* WARNING: Do NOT modify this code. The content of this method is
* always regenerated by the Form Editor.
*/

private void formWindowActivated([Link] evt)


{//GEN-FIRST:event_formWindowActivated
[Link](new [Link]("[Link]"));

}//GEN-LAST:event_formWindowActivated
private void jMenuItem6ActionPerformed([Link] evt)
{//GEN-FIRST:event_jMenuItem6ActionPerformed
[Link](null);
}//GEN-LAST:event_jMenuItem6ActionPerformed

private void mnuExitActionPerformed([Link] evt) {//GEN-


FIRST:event_mnuExitActionPerformed
[Link](0);
}//GEN-LAST:event_mnuExitActionPerformed

private void mnuOpenActionPerformed([Link] evt)


{//GEN-FIRST:event_mnuOpenActionPerformed
FileDialog fd = new FileDialog(this, "Open");
[Link]();
File f = new File([Link]() + [Link]());
try {
FileInputStream fis = new FileInputStream(f);
int avail = [Link]();
byte b[] = new byte[avail];
[Link](b);
String str = new String(b).trim();
[Link](str);
} catch (Exception e) {
[Link](e);
}
}//GEN-LAST:event_mnuOpenActionPerformed

private void mnuSaveActionPerformed([Link] evt)


{//GEN-FIRST:event_mnuSaveActionPerformed

String str = [Link]();


byte buffer[] = [Link]();
FileDialog fd = new FileDialog(this, "Save", 1);
[Link]();
File f = new File([Link]() + [Link]());
try {
FileOutputStream fos = new FileOutputStream(f);
[Link](buffer);
[Link]("File created");
} catch (Exception e) {
}
}//GEN-LAST:event_mnuSaveActionPerformed

private void jMenuItem1ActionPerformed([Link] evt)


{//GEN-FIRST:event_jMenuItem1ActionPerformed
Color c = [Link]();
c = [Link](this, "Color Chooser", c);
if (c == null) {
} else {
[Link](c);
[Link]();
}
}//GEN-LAST:event_jMenuItem1ActionPerformed

private void jMenuItem2ActionPerformed([Link] evt)


{//GEN-FIRST:event_jMenuItem2ActionPerformed
Color c = [Link]();
c = [Link](this, "Color Chooser", c);
if (c == null) {
} else {
[Link](c);
[Link]();
}
}//GEN-LAST:event_jMenuItem2ActionPerformed

private void jComboBox2ItemStateChanged([Link] evt)


{//GEN-FIRST:event_jComboBox2ItemStateChanged
}//GEN-LAST:event_jComboBox2ItemStateChanged

private void btnSendActionPerformed([Link] evt) {//GEN-


FIRST:event_btnSendActionPerformed
}//GEN-LAST:event_btnSendActionPerformed

private void jMenuItem3ActionPerformed([Link] evt)


{//GEN-FIRST:event_jMenuItem3ActionPerformed
}//GEN-LAST:event_jMenuItem3ActionPerformed

private void jMenuItem5ActionPerformed([Link] evt)


{//GEN-FIRST:event_jMenuItem5ActionPerformed
[Link](0);
}//GEN-LAST:event_jMenuItem5ActionPerformed

/**
* @param args the command line arguments
*/
public static void main(String args[]) {
[Link](new Runnable() {

public void run() {


Node n = new Node();
n.show1();
[Link](100, 30, 913, 655);
[Link](true);
TimeThread t = new TimeThread();
[Link]();
}
});
}
// Variables declaration - do not modify//GEN-BEGIN:variables
private [Link] btnSend;
static [Link] jComboBox1;
static [Link] jComboBox2;
private [Link] jLabel1;
public static [Link] jLabel2;
private [Link] jLabel3;
private [Link] jLabel4;
private [Link] jMenu1;
private [Link] jMenu2;
private [Link] jMenu3;
private [Link] jMenuBar1;
private [Link] jMenuItem1;
private [Link] jMenuItem2;
private [Link] jMenuItem3;
private [Link] jMenuItem4;
private [Link] jMenuItem5;
private [Link] jMenuItem6;
private [Link] jPanel1;
private [Link] jPanel3;
private [Link] jPanel4;
private [Link] jPanel5;
private [Link] jPanel6;
private [Link] jScrollPane1;
private [Link] jScrollPane2;
private [Link] jScrollPane3;
private [Link] jSeparator1;
private [Link] jTabbedPane1;
private [Link] jTextArea1;
private [Link] mnuOpen;
private [Link] mnuSave;
[Link] txtMessage;
private [Link] txtReceive;
// End of variables declaration//GEN-END:variables
ServerSocket server;
Socket socket;
Thread t;
int port;
String host;

void connection() {
try {
[Link]("\t\t***************");
[Link]("\t\tNode Details");
[Link]("\t\t***************");
socket = new Socket(host, 100);
ObjectOutputStream oos = new
ObjectOutputStream([Link]());
ArrayList l = new ArrayList();
[Link]([Link](port));
[Link](l);
server = new ServerSocket();

[Link]("*** Node is running on the port "+port+"*****");

t = new Thread(this);
[Link]();
} catch (IOException e) {
[Link]();
}
}
public void run() {
try {
server = new ServerSocket(port);
while (true) {
Socket soc = [Link]();
ObjectInputStream ois = new ObjectInputStream([Link]());
ArrayList al = (ArrayList) [Link]();
String s = (String) [Link](0);
if ([Link]("server")) {
}
}
} catch (IOException e) {
[Link]();
} catch (ClassNotFoundException e) {
[Link]();
}
}

public void show1() {


host = [Link]("Enter serevr host here....");
port = [Link]([Link]("Enter Port number"));
}
}

class TimeThread implements Runnable {

Thread t;

public TimeThread() {
t = new Thread(this);
[Link]();

public void run() {


while (true) {
DateFormat dateFormat = new SimpleDateFormat("dd/MM/yyyy
HH:mm:ss");
Date date = new Date();
Calendar cal = [Link]();
[Link]([Link]([Link]()));
}

You might also like