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]()));
}