What should I write in Listener method? And what does it do? import java.io.Buff

ID: 3599389 • Letter: W

Question

What should I write in Listener method? And what does it do?

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

import java.rmi.server.UnicastRemoteObject;

import java.rmi.RemoteException;

import java.rmi.Naming;

public class RMI_BioAPI_Demo {

   private String socket_listener_ip = "localhost";
// socket_listener_ip of socket server at DSP machine
////   private String socket_listener_ip = "<whatever IP it should be>";

   //*** This section is for multi-threading initialization
private final class RequestThread extends Thread {
private String option;
private String AsteriskJava_IP;
private String Service_UID;
private String remote_AsteriskSrcFilename;
private String socket_listener_ip;
private int socket_port;
private String local_fileName;

RequestThread(final String option, final String AsteriskJava_IP, final String Service_UID, final String remote_AsteriskSrcFilename, final String socket_listener_ip, final int socket_port, final String local_fileName
) {
this.option = option;
this.AsteriskJava_IP = AsteriskJava_IP;
this.Service_UID = Service_UID;
this.remote_AsteriskSrcFilename = remote_AsteriskSrcFilename;
this.socket_listener_ip = socket_listener_ip;
this.socket_port = socket_port;
this.local_fileName = local_fileName;
this.start();
}

}

   public void initialize_socket(int port) {
       // TODO Auto-generated method stub
       try {
serverSocket = new ServerSocket(port);
String addr=serverSocket.getInetAddress().toString();
String addrr=serverSocket.getLocalSocketAddress().toString();
System.out.println("IP address: "+addr);
System.out.println("socket address(IP address: port): "+addrr);

initialize_socket_stream_buffer();
socket_listener();
serverSocket.close();
       } catch (IOException e) {
System.err.println("Could not listen on port: "+port);
System.exit(-1);
}
   }

   public RMI_BioAPI_Demo(String local_fileName, int socket_port,
           String AsteriskJava_IP, String Service_UID,
           String remote_AsteriskSrcFilename) throws RemoteException {
new RequestThread("socket", "N/A", "N/A", "N/A", socket_listener_ip, socket_port, "N/A");
new RequestThread("AsteriskJava", AsteriskJava_IP, Service_UID, remote_AsteriskSrcFilename, socket_listener_ip, socket_port, local_fileName);
   }

   public static void main(String[] args) throws Exception {
   if (args.length != 5)
   {
   System.out.println
   ("Syntax - java RMI_BioAPI_Demo <local_Filename> <host_port> <Remote_AsteriskJava_IP> <service_UID> <remote_source_Filename>");
   System.exit(1);
   }


// Create an instance of our service server ...

   RMI_BioAPI_Demo demo_instance = new RMI_BioAPI_Demo(args[0], Integer.parseInt(args[1]), args[2], args[3], args[4]);

}

Explanation / Answer

Solution============================

import java.rmi.server.UnicastRemoteObject;

import java.rmi.RemoteException;

import java.rmi.Naming;

public class RMI_BioAPI_Demo {

    private String socket_listener_ip = "localhost";
// socket_listener_ip of socket server at DSP machine
////    private String socket_listener_ip = "<whatever IP it should be>";

    //*** This section is for multi-threading initialization
    private final class RequestThread extends Thread {
        private String option;
        private String AsteriskJava_IP;
        private String Service_UID;
        private String remote_AsteriskSrcFilename;
        private String socket_listener_ip;
        private int socket_port;
        private String local_fileName;

        RequestThread(final String option, final String AsteriskJava_IP, final String Service_UID, final String remote_AsteriskSrcFilename, final String socket_listener_ip, final int socket_port, final String local_fileName
) {
            this.option = option;
            this.AsteriskJava_IP = AsteriskJava_IP;
            this.Service_UID = Service_UID;
            this.remote_AsteriskSrcFilename = remote_AsteriskSrcFilename;
            this.socket_listener_ip = socket_listener_ip;
            this.socket_port = socket_port;
            this.local_fileName = local_fileName;
            this.start();
        }

        public void run() {
            if (option.equals("socket")) {
                    try {
                            initialize_socket(socket_port);
                    } catch (Exception e) {
                            System.out.println("Error on initializing socket server");
                    }
            }
            if (option.equals("AsteriskJava")) {
                new RMI_BioAPI_AsteriskJava_Client(AsteriskJava_IP, Service_UID, remote_AsteriskSrcFilename, socket_listener_ip, socket_port, local_fileName);
            }
            // Runs the above operations simultaneously as multi-threads
        }

}

    private PrintWriter pw, pwt;
    private BufferedReader br;
    private Socket socket;
    private ServerSocket serverSocket = null;
    // private int port = 1688;

    public void initialize_socket_stream_buffer() {
        try{
            socket=serverSocket.accept();
            System.out.println("connected");
            br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
            pw = new PrintWriter(socket.getOutputStream(), true);
        }catch(IOException e) {e.printStackTrace();}
    }

    public void socket_stream_buffer_close () {
        pw.close();
        try {
            br.close();
        } catch(IOException e) {e.printStackTrace();}
    }

    public void socket_listener () {
        // Finish this!!!!
       String data;
       try {
           //Reading data from buffer reader until the end of stream
           while((data=br.readLine())!=null){
               System.out.println(data);
               //Writing it back
               pw.println(data);
           }

           //Closing both streams
           socket_stream_buffer_close();

       } catch (IOException e) {
           // TODO Auto-generated catch block
           e.printStackTrace();
       }
    }

    public void initialize_socket(int port) {
        // TODO Auto-generated method stub
        try {
            serverSocket = new ServerSocket(port);
            String addr=serverSocket.getInetAddress().toString();
            String addrr=serverSocket.getLocalSocketAddress().toString();
            System.out.println("IP address: "+addr);
            System.out.println("socket address(IP address: port): "+addrr);

            initialize_socket_stream_buffer();
            socket_listener();
            serverSocket.close();
        } catch (IOException e) {
            System.err.println("Could not listen on port: "+port);
            System.exit(-1);
        }
    }

    public RMI_BioAPI_Demo(String local_fileName, int socket_port,
            String AsteriskJava_IP, String Service_UID,
            String remote_AsteriskSrcFilename) throws RemoteException {
        new RequestThread("socket", "N/A", "N/A", "N/A", socket_listener_ip, socket_port, "N/A");
        new RequestThread("AsteriskJava", AsteriskJava_IP, Service_UID, remote_AsteriskSrcFilename, socket_listener_ip, socket_port, local_fileName);
    }

    public static void main(String[] args) throws Exception {
        if (args.length != 5)
        {
                System.out.println
                    ("Syntax - java RMI_BioAPI_Demo <local_Filename> <host_port> <Remote_AsteriskJava_IP> <service_UID> <remote_source_Filename>");
                System.exit(1);
        }


        // Create an instance of our service server ...

        RMI_BioAPI_Demo demo_instance = new RMI_BioAPI_Demo(args[0], Integer.parseInt(args[1]), args[2], args[3], args[4]);

}

Purpose:

Notice the use of this method

           initialize_socket_stream_buffer();
            socket_listener();
            serverSocket.close();

This method gets called after a connection has been made . And after that server socket connection is closed. Thus method socket_listener() is expected to read data from Network Buffer, and process it in some way (depending on problem statement) . Here, I have just read all the data from buffer, and sent it wrote it back to socket's printstream as it is. You can change it's behaviour if the question demands otherwise..

Let me know if any doubts..

Navigate

What should I say in a follow-up phone call or letter? Lo 30-1 Reinforce positiv

What should a firm do in the short run if profit is negative at the quantity whe

Integrity-first tutoring: explanations and feedback only — we do not complete graded work. Learn more.

What should I write in Listener method? And what does it do? import java.io.Buff

Question

Explanation / Answer

Related Questions

Navigate