Reading Data from comm port in Java

This code first write 0x80 to COM port () then it reads 0x32 from COM port and then sends 6 more bytes and to terminate the packet it receives  0x70 form COM port.

Play Free Online Games and Win Big Prize Money 

This code can be very helpful to communicate with embedded devices which communicate with PC through COM port.

-Watch video
https://youtu.be/sX0XAROhuiQ

// library import

import java.io.*;


import java.util.*;

import javax.comm.*;

import java.sql.Connection;

import  java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.Statement;





public class Fms implements Runnable{ 



static Enumeration portList;

static CommPortIdentifier portId;

static SerialPort serialPort;

static OutputStream outputStream;

static InputStream inputStream;

static Thread readThread,dataBase;

static int crf;

static int cwf;

static byte cxc[] = new byte[4];

static int cxm = 128;//0x80

static byte[] creadBuffer;//1byte read

static int creadBuff[]; 

write rt=new write();

static read rd;   

public void run() {

    };

    public static void main(String[] args) {

        int a=10;

        write wr = new write();

        read rd = new read(1);

         int b = 0;

        int speed=0,tcount=0,jcount=0,status=0;

      while(b!=10){      

       for(int j =0 ; j<=1;j++){

            try{

        wr.cwritemain(a); 

         rd.cmainx(a);          

         readThread.sleep(1000);

            }

            catch(Exception e){}

            if(j==0){

                status =creadBuff[1];

                jcount =creadBuff[5];

          System.out.println("results : "+status +"\t"+jcount); 

            }

            if(j==1){

                speed =creadBuff[1]*256+creadBuff[2];//to convert received data in decimal

                tcount =creadBuff[6];

          System.out.println("results : "+speed +"\t"+tcount); 

            }

             }    

    }            

       }





 static class write{        



         public void cwritemain(int m)


  {       

             cwf = m;

             cxc[0] = 0x26;

             portList = CommPortIdentifier.getPortIdentifiers();

             System.out.println(portList.hasMoreElements());

   while (portList.hasMoreElements()) {                                   

                                        portId = (CommPortIdentifier) portList.nextElement();

                                        if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {

                                    

     if (portId.getName().equals("COM1"))

     {                                  

      try {

       serialPort = (SerialPort) portId.open("SimpleWriteApp32", 2000);

                                                  } catch (PortInUseException e) {

      }

      try {

       outputStream = serialPort.getOutputStream();



      } catch (Exception e) {

      }

      try {

       serialPort.setSerialPortParams(9600,

         SerialPort.DATABITS_8,

         SerialPort.STOPBITS_1,

         SerialPort.PARITY_NONE);

      } catch (Exception e) {

      }

                                               if(cwf==10){

       try {      

        outputStream.write(cxm);// 0x80 written   

        serialPort.close();

                                                                outputStream.close();        

       } catch (Exception e) {

       }

                                               }

                                        }

                                }

                        }

         }        

    }   

   static class read implements SerialPortEventListener{

      public read(int s) {}

      public void cmainx(int cp) {

   crf = 10;

   portList = CommPortIdentifier.getPortIdentifiers();

   while (portList.hasMoreElements()) {

    portId = (CommPortIdentifier) portList.nextElement();

    if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {

     if (portId.getName().equals("COM1")) {

      try {

                                                    serialPort = (SerialPort) portId.open("readapp32",

         2000);

      } catch (PortInUseException e) {

       System.out.println(e.getMessage());

      }

      try {

       inputStream = serialPort.getInputStream();     

      } catch (Exception e) {

       System.out.println(e);

      }

      try {

       serialPort.addEventListener(this);

      } catch (Exception e) {

       System.out.println(e);

      }

      serialPort.notifyOnDataAvailable(true);

      try {

       serialPort.setSerialPortParams(9600,

         SerialPort.DATABITS_8,

         SerialPort.STOPBITS_1,

         SerialPort.PARITY_NONE);                                                

      } catch (Exception e) {

       System.out.println(e);

      }

     }

    }

   }                       

  }

        public void serialEvent(SerialPortEvent event) {            

            switch (event.getEventType()) {

   case SerialPortEvent.DATA_AVAILABLE:

    creadBuffer = new byte[8];

                                creadBuff= new int[8];

    try {

                                   int i = 0;                               

     while (inputStream.available() > 0) {       

                                          creadBuff[i]=inputStream.read();

  
                                        System.out.println("Data 
available is: "+creadBuff[i]);                                          
        

                                               i++;

     }

                                      inputStream.close();

    } catch (IOException e) {

    }

                                System.out.println("event");

    System.out.println("recieved \t"+creadBuffer[0] );

    if (creadBuffer[0] == 0x70) {

                                    System.out.println("Got 0x70"+creadBuffer[0] );

     serialPort.close();

     rd = new read(5);

     rd.cmainx(1);// ag

                                }

                                if (creadBuffer[0] == 0x32) {

                                    System.out.println("Got"+creadBuffer[0] );

     serialPort.close();                                

                                }

                                serialPort.close();

            }

        }

   }  



   }







Watch video



https://youtu.be/sX0XAROhuiQ

Datagram Client in Java

This Example is implementation of Datagram Client or UDP client purpose of this example is to provide a fare idea about the working of UDP client server this client example works with server example and link to server example is given at the end of this code example works on the concept of UDP protocol (simple transmission model without implicit handshaking)

Play Free Online Games and Win Big Prize Money 

-Watch video
https://youtu.be/sX0XAROhuiQ

import java.io.*;

import java.net.*;

public class Client {

    public static void main(String[] args) {

      DatagramSocket clientSkt = null;

      InetAddress IPAdd = null;

      String text =null;

      DatagramPacket receivePkt= null;

      BufferedReader inFromUser =

         new BufferedReader(new InputStreamReader(System.in));

      try{

      clientSkt = new DatagramSocket();

      IPAdd = InetAddress.getByName("localhost");

      }

      catch(SocketException exp){

          System.out.println(exp);

      }

      catch(UnknownHostException exp){

          System.out.println(exp);

      }      

      byte[] sendData = new byte[1024];

      byte[] receiveData = new byte[1024];

      try{

      text = inFromUser.readLine();

      sendData = text.getBytes();

      DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAdd, 3030);

      clientSkt.send(sendPacket);

      receivePkt = new DatagramPacket(receiveData, receiveData.length);

      clientSkt.receive(receivePkt);

      }

      catch(IOException exp){

          System.out.println(exp);

      }

      String modifiedSentence = new String(receivePkt.getData());

      System.out.println("FROM SERVER:" + modifiedSentence);

      clientSkt.close();

    }

}

Watch video

https://youtu.be/sX0XAROhuiQ

Datagram Server Source

Datagram Server in Java

This example is about Datagram Server or UDP server purpose of this example is to provide a fare idea about the working of UDP client server this server example works with client example and link to the client example is given at the end of this code example works on the concept of UDP protocol (simple transmission model without implicit handshaking)

Play Free Online Games and Win Big Prize Money 

-Watch video
https://youtu.be/sX0XAROhuiQ

import java.io.*;

import java.net.*;

public class Server {

    public static void main(String[] args) {

        DatagramSocket serverSkt= null;

        try{

            serverSkt = new DatagramSocket(3030);

        }

        catch(SocketException exp)

        {

            System.out.println(exp);

        }

        byte[] receiveData = new byte[1024];

        byte[] sendData = new byte[1024];

        while(true)

          {

            DatagramPacket receivePkt = new DatagramPacket(receiveData, receiveData.length);

            try{

                serverSkt.receive(receivePkt);

            }

            catch(IOException exp)

            {

                System.out.println(exp);

            }

            String sentence = new String( receivePkt.getData());

            System.out.println("RECEIVED: " + sentence);

            InetAddress IPAddress = receivePkt.getAddress();

            int port = receivePkt.getPort();

            String capitalizedSentence = sentence.toUpperCase();

            sendData = capitalizedSentence.getBytes();

            DatagramPacket sendPkt =

            new DatagramPacket(sendData, sendData.length, IPAddress, port);

            try{

            serverSkt.send(sendPkt);

            }

            catch(IOException exp)

            {

                System.out.println(exp);

            }   

        }

      }        

  }

Watch video

https://youtu.be/sX0XAROhuiQ

Datagram Client Source

Get Your PC's IP Address in Java

This example returns IP address of your PC.

Play Free Online Games and Win Big Prize Money 

-Watch video
https://youtu.be/sX0XAROhuiQ

import java.net.*;

public class TellMyIP {

public static void main(String[] args) {

 InetAddress localHostIP= null;

   //creates instance of InetAddress

  try{

  localHostIP=InetAddress.getLocalHost();

  //initializes localHostIP

  System.out.println("IP ADDRESS OF MY PC IS = "+localHostIP.getHostAddress());

  //gets IP address and prints it

  }catch (Exception exception){

  System.out.println("Something that went wrong is :"+exception.getMessage());

  }

   }

}

Watch video

https://youtu.be/sX0XAROhuiQ

Send email in Java with attachment

Java Mail API is required to work with this code to send email in Java from your email account with attachments .

Play Free Online Games and Win Big Prize Money 

-Watch video
https://youtu.be/sX0XAROhuiQ

       
import java.util.Properties;

import javax.activation.DataHandler;

import javax.activation.DataSource;

import javax.activation.FileDataSource;

import javax.mail.*;

import javax.mail.internet.InternetAddress;

import javax.mail.internet.MimeBodyPart;

import javax.mail.internet.MimeMessage;

import javax.mail.internet.MimeMultipart;

public class MailWithAttachment

{

public static void main(String args[]) throws Exception

{

    String host = "smtp.gmail.com";//host name

    String from = "abc@gmail.com";//sender id

    String to = "xyz@yahoo.com";//reciever id

    String pass = "***";//sender's password 

    String fileAttachment = "test.txt";//file name for attachment 

    //system properties

    Properties prop = System.getProperties();

    // Setup mail server properties

    prop.put("mail.smtp.gmail", host);

    prop.put("mail.smtp.starttls.enable", "true");

    prop.put("mail.smtp.host", host);

    prop.put("mail.smtp.user", from);

    prop.put("mail.smtp.password", pass);

    prop.put("mail.smtp.port", "587");

    prop.put("mail.smtp.auth", "true");

    //session 

    Session session = Session.getInstance(prop, null);

    // Define message

    MimeMessage message = new MimeMessage(session);

    message.setFrom(new InternetAddress(from));

    message.addRecipient(Message.RecipientType.TO,new InternetAddress(to));

    message.setSubject("Hello Java Mail Attachment");

    // create the message part 

    MimeBodyPart messageBodyPart = new MimeBodyPart();

    //message body

    messageBodyPart.setText("Hi");

    Multipart multipart = new MimeMultipart();

    multipart.addBodyPart(messageBodyPart);

    //attachment

    messageBodyPart = new MimeBodyPart();

    DataSource source = new FileDataSource(fileAttachment);

    messageBodyPart.setDataHandler(new DataHandler(source));

    messageBodyPart.setFileName(fileAttachment);

    multipart.addBodyPart(messageBodyPart);

    message.setContent(multipart);

    //send message to reciever

    Transport transport = session.getTransport("smtp");

    transport.connect(host, from, pass);

    transport.sendMessage(message, message.getAllRecipients());

    transport.close();

}

}

Watch video

https://youtu.be/sX0XAROhuiQ

Database Connctions in Java

This example Works with MS Access to explain DB concepts and can be changed accordingly to any other database for that you will need to configure their respective JAR libraries to your project i.e. for MY-SQL you will need MySQL-Connector JAR.

Play Free Online Games and Win Big Prize Money 

-Watch video
https://youtu.be/sX0XAROhuiQ

       
import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class dbConnections

{

public static void main(String args[])

{

     try{  

      Class.forName("sun.jdbc.odbc.JdbcOdbc");  //load DB drivers

      Connection con=DriverManager.getConnection("jdbc:odbc:DBName",username,pwd);

      //create db connections

      Statement stmt = con.createStatement(); // creates statement for db access

      String query = "SELECT * FROM Job"; // sql query

      ResultSet rs = stmt.executeQuery(query);

      //execute sql query and stores the result in the result set rs

      while( rs.next() ) {

       System.out.println("Job  "+rs.getString("Job_Id"));

      }

      rs.close(); //close resultset

      stmt.close(); // close statement 

      con.close();  // close connection   

     }

    catch(SQLException e)

    {

     System.out.println(e);

    }

    catch(ClassNotFoundException e)

    {

     System.out.println(e);

   }

}

}

Watch video

https://youtu.be/sX0XAROhuiQ

Read emails from Gmail Account

This code reads emails from a Gmail account to work with this code you will need javax.mail API
-Watch video

Play Free Online Games and Win Big Prize Money 

https://youtu.be/sX0XAROhuiQ

import java.io.BufferedInputStream;

import java.io.IOException;

import java.io.FileWriter;

import java.io.InputStream;

import java.security.*;

import java.util.Properties;

import javax.mail.*;

public class ReadMail {

  public static void main(String args[]) throws IOException {

         Properties properties = System.getProperties();

         properties.setProperty("mail.store.protocol", "imaps");

             try {

                 Session session = Session.getDefaultInstance(properties, null);

                 //create session instance

                 Store store = session.getStore("imaps");//create store instance

                 store.connect("pop.gmail.com", "abc@gmail.com", "****");

                 //set your user_name and password

                 System.out.println(store); 

                 Folder inbox = store.getFolder("inbox");

                 //set folder from where u wants to read mails

                 inbox.open(Folder.READ_ONLY);//set access type of Inbox

                 Message messages[] = inbox.getMessages();// gets inbox messages

                 for (int i = 0; i < messages.length; i++) {

                System.out.println("------------ Message " + (i + 1) + " ------------");

                System.out.println("SentDate : " + messages[i].getSentDate()); //print sent date

                System.out.println("From : " + messages[i].getFrom()[0]); //print email id of sender

                System.out.println("Sub : " + messages[i].getSubject()); //print subject of email

                try

                {

                      Multipart mulpart = (Multipart) messages[i].getContent();

                      int count = mulpart.getCount();

                      for (int j = 0; j+1 < count; j++)

                     {

                          storePart(mulpart.getBodyPart(j));

                     }

                }

                catch (Exception ex)

                {

                     System.out.println("Exception arise at get Content");

                     ex.printStackTrace();

                }

           }

           store.close();

      }

catch (Exception e) {

System.out.println(e);  

}  

}

  public static void storePart(Part part) throws Exception

     {    

          InputStream input = part.getInputStream();

          if (!(input instanceof BufferedInputStream))

         {

              input = new BufferedInputStream(input);

          }

          int i;

         System.out.println("msg : ");

          while ((i = input.read()) != -1)

         {

         System.out.write(i);

         }

     }

}

Watch video

https://youtu.be/sX0XAROhuiQ

Send email using javax.mail source