// Prac client

import java.net.*;
import java.awt.*;

publicclass Prac41Client extends Frame implements Runnable
{
    Label lblNewsHeadline;
    String NewsMsg;
    Thread t=null;
    int ClinetPortNumber;

    Prac41Client()
    {
        super("News Client");
    }
    publicvoid Setup(int ClientPort)
    {
        ClinetPortNumber=ClientPort;
        setSize(500,50);
        lblNewsHeadline=new Label("Retrieving News From News.Com");
        add(lblNewsHeadline);        
        show();
        t=new Thread(this);
        t.start();
    }
    publicstaticvoid main(String args[]) throws Exception
    {
        Prac41Client ob=new Prac41Client();    
        ob.Setup(Integer.parseInt(args[0]));
    }
    publicvoid run()
    {
        while(true)
        {
            try
            {
                DatagramSocket ClientSoc=new DatagramSocket(ClinetPortNumber);
                String Command="GET";
                
                byte Sendbuff[]=newbyte[1024];
                Sendbuff=Command.getBytes();
    
                InetAddress ServerHost=InetAddress.getLocalHost();
                ClientSoc.send(new DatagramPacket(Sendbuff,Sendbuff.length,ServerHost,5217));

                byte Receivebuff[]=newbyte[1024];
                DatagramPacket dp=new DatagramPacket(Receivebuff,Receivebuff.length);
                ClientSoc.receive(dp);
                
                
                NewsMsg=new String(dp.getData(),0,dp.getLength());
                System.out.println(NewsMsg);
                lblNewsHeadline.setText(NewsMsg);
                
                Thread.sleep(5000);            
                ClientSoc.close();
            }
            catch(Exception ex)
            {
                ex.printStackTrace();
            }
        }
    }    
}


// Prac Server

import java.net.*;
import java.util.*;
import java.io.*;

class Prac41Server
{
    publicstaticvoid main(String args[]) throws Exception    
    {
        DatagramSocket ServerSoc=new DatagramSocket(5217);        
        while(true)
        {        
            AcceptClientRequest ob=new AcceptClientRequest(ServerSoc);
        }
    }
}

class AcceptClientRequest extends Thread
{
    
    DatagramSocket ServerSoc;
    byte Receivebuff[]=newbyte[1024];
    byte Sendbuff[]=newbyte[1024];
    DatagramPacket dp;

    AcceptClientRequest(DatagramSocket Soc)
    {
        ServerSoc=Soc;
        dp=new DatagramPacket(Receivebuff,Receivebuff.length);
        try
        {
            ServerSoc.receive(dp);
        }
        catch(Exception ex)
        {
        }
        start();    
    }
    
    publicvoid run()
    {
        try
        {    
            InetAddress ClientHost=dp.getAddress();
            int ClientPort=dp.getPort();            
            System.out.println(ClientHost);
            
            FileReader fin=new FileReader("NewsDataFile.txt");
            BufferedReader br=new BufferedReader(fin);

            StringBuffer News=new StringBuffer();
            String NewsHeadLine;
        
            while((NewsHeadLine=br.readLine())!=null)
            {
                News.append("|" + NewsHeadLine + " |");
            }
        

            Sendbuff=News.toString().getBytes();
            System.out.println(News.toString());
            DatagramPacket sendPacket=new DatagramPacket(Sendbuff,Sendbuff.length,ClientHost,ClientPort);
             ServerSoc.send(sendPacket);
            System.out.println("Packet Sent ...");
            
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }

    }        
}