This tutorial will teach you Networking Application using TCP/IP in Java step by step. the example to create a server is create a serversocket object that listens at a paticulat port for client requests.when the server gets a vaild request.the server socket obtains the Socket object created by the client.the communication between the server and the client occurs using the socket.
Functional requirements
The server shall be able to capture of receiving message from a client.
The server shall be able to connect to the database and retrieve the student information.
The server shall run on port 4000.
The client shall be a JFrame.
The client shall be capable of receiving information from the server application.
Creating the StudentInfo Class
1 2 3 4 5 | class studentinfo implements Serializable { public String sname; public String mno; } |
The preceding code is saved as StudentInfo.java
Creating the Server Class
The Server class performs the following functions:
Create a server socket using the ServerSocket object.
Listens for the client request
The following code is used to create the Server class that receives requests from the clients.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 | import java.net.*; import java.io.*; import java.sql.*; public class server { ServerSocket socket1; public server( ) { try{ socket1=new ServerSocket( 4000); System.out.println("server is now ready...."); while(true) { Socket clientconnection=socket1.accept(); /*waiting for clients to connect*/ Handler handler1= new Handler( clientconnection); handler1.start(); } } catch(Exception ioe) { System.out.println("error"); } }/*end of constructor*/ class Handler extends Thread { ObjectInputStream in=null; ObjectOutputStream out=null; public Handler( Socket request) { try{ in=new ObjectInputStream (request.getInputStream( )); out=new ObjectOutputStream( request.getOutputStream()); }catch(IOException io) { System.out.println("can't take i/o stream"); } } public void run( ) { try{ while(true) { studentinfo p1=(studentinfo)in.readObject( ); Class.forName("com.mysql.jdbc.Driver"); Connection con1 = DriverManager.getConnection("jdbc:mysql://localhost/network", "root",""); PreparedStatement stat1=con1.prepareStatement("insert into student(stname,mobile) values(?,?)"); stat1.setString(1,p1.sname); stat1.setString(2,p1.mno); int k=stat1.executeUpdate(); if(k==1)out.writeObject("success"); else out.writeObject("failed"); }/*end of while*/ }catch(Exception ee) { try{ out.writeObject("failed"); }catch(Exception eee){ } System.out.println("errrrrrrror"); } } }/*end of Handler*/ public static void main(String[ ] arg) { server server1=new server( ); } } |
Creating the Client Application using jFrame
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 | import java.io.Serializable; import java.awt.*; import java.awt.event.*; import javax.swing.*; import java.net.*; import java.io.*; public class client extends javax.swing.JFrame { Socket socket1=null; ObjectInputStream in=null; ObjectOutputStream out=null; public client() { initComponents(); } private void btn1ActionPerformed(java.awt.event.ActionEvent evt) { try{ socket1=new Socket("localhost", 4000); /*making connection*/ out= new ObjectOutputStream( socket1.getOutputStream()); in= new ObjectInputStream (socket1.getInputStream( )); btn1.setEnabled(false); btn2.setEnabled(true); labelmesg.setText("connected.."); }catch(IOException ioe) { System.out.println("can't connect"); } } private void btn2ActionPerformed(java.awt.event.ActionEvent evt) { studentinfo p1=new studentinfo( ); p1.sname=txtname.getText().trim( ); p1.mno=txtmobile.getText().trim( ); try { out.writeObject(p1); String mesg=(String)in.readObject(); labelmesg.setText(mesg); txtname.setText(""); txtmobile.setText(""); txtname.requestFocus( ); } catch(Exception ee) { System.out.println("can't send data" + ee); } } |
I have attached the video tutorial below it will help you to do this step by step.
