By that I meant that the socket.io methods were moved from the application
extended class into an android service class but I still kept getting
multiple "hits" to the socket.io "on" methods regardless on the service
thread being executed only once.
On Wednesday, January 20, 2016 at 5:16:53 PM UTC-4, Gabriel Avila wrote:
>
> I'm trying to implement a globalized Socket.io connection method for an
> entire application (multiple activities).
>
> The requirements:
> 1. The socket.io must be enabled as long as the user is logged into the
> application
> 2. The socket has to keep connected even when switching activities.
> 3. The socket.io connection must be kept alive even when application is
> in background
>
> The Current Layout:
> 1. Socket.io methods are implemented in a class that extends the
> application class
>
> The Main Issues:
> 1. When emitting from the server to the Android the socket.io "on"
> methods are executed multiple times. The server code has been validated and
> determined it is only sending one emit to the client.
> 2. If I emit the methods from the server multiple times the "on" method
> execution increases exponentially.
>
> The Previous Solution:
> 1. Moved all the Socket.io methods into an Android Service but it did not
> work.
>
> What can I do to solve this? Am I missing something else? From what I read
> on other posts The singleton class will be elegible for termination by the
> OS once the application moves into the background, how can I avoid this?
>
> Here is my Application Extended Class
>
> public class AppSettings extends Application {
>
> private static String TAG = "AppSettings";
> private static String username;
> private boolean isdriver;
> private int time, Buffer, intents;
> public CountDownTimer Clock;
> public Context mainContext;
> GOGODBHelper mGOGODBHelper;
> SQLiteDatabase db;
> private URI uri;
> public static Socket mSocket;
> public static long transaction_id = 0;
>
> {
> try {
> uri = new URI("http://gogosocket.cloudapp.net:3000";);
> AppSettings.this.mSocket = IO.socket(uri);
>
> } catch (URISyntaxException e) {
> Log.d(TAG, e.getMessage());
> }
> }
> @Override
> public void onCreate() {
> super.onCreate();
> final Fabric fabric = new Fabric.Builder(this)
> .kits(new Crashlytics())
> .debuggable(true)
> .build();
> Fabric.with(this, new Crashlytics());
>
> mGOGODBHelper = new GOGODBHelper(this);
>
> registerReceiver(ConnectionReceiver, new
> IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION));
>
> }
>
> public void setMainContext(Context context){
> this.mainContext = context;
> }
>
> public Context getMainContext(){
> return this.mainContext;
> }
>
> //set and get username
> public void setUsername(String username) {
> this.username = username;
> }
>
> public String getUsername() {
> return this.username;
> }
>
> //set and get isDriver
> public void setIsdriver(boolean isdriver) {
> this.isdriver = isdriver;
> }
>
> public boolean getIsdriver() {
> return this.isdriver;
> }
>
> private long saveTransaction(String to, String from,String
> event,String data,String timeStamp) {
>
> long newRowID = 0;
>
> db = mGOGODBHelper.getWritableDatabase();
>
> ContentValues values = new ContentValues();
> values.put(Transactions.Transaction.COLUMN_NAME_TO,to);
> values.put(Transactions.Transaction.COLUMN_NAME_FROM, from);
> values.put(Transactions.Transaction.COLUMN_NAME_METHOD,event);
> values.put(Transactions.Transaction.COLUMN_NAME_DATA,data);
> values.put(Transactions.Transaction.COLUMN_NAME_TIMESTAMP,
> timeStamp);
>
> newRowID =
> db.insert(Transactions.Transaction.TABLE_NAME,null,values);
>
> return newRowID;
> }
>
> private boolean deleteTransaction(long transaction_id){
> db = mGOGODBHelper.getReadableDatabase();
>
> return db.delete(Transactions.Transaction.TABLE_NAME,
> Transactions.Transaction._ID + " = " +transaction_id , null) >0;
> }
>
> public void onSocket() {
> AppSettings.this.mSocket.on(Socket.EVENT_CONNECT_ERROR,
> onConnectError)
> .on(Socket.EVENT_CONNECT_TIMEOUT, onConnectError)
> .on(Socket.EVENT_RECONNECT_ERROR, onConnectError)
> .on(Socket.EVENT_RECONNECT_FAILED, onConnectError)
> .on(Socket.EVENT_DISCONNECT, onConnectError)
> .on(Socket.EVENT_ERROR, onConnectError)
> .on(Socket.EVENT_RECONNECT_ATTEMPT, onReconnect)
> .on(Socket.EVENT_RECONNECT, onReconnect)
> .on(Socket.EVENT_CONNECT, onConnect)
> .on("ping", ping)
> .on("method", method);
> // AppSettings.this.mSocket.on(Socket.EVENT_CONNECT_TIMEOUT,
> onConnectError);
> // AppSettings.this.mSocket.on(Socket.EVENT_RECONNECT_ERROR,
> onConnectError);
> // AppSettings.this.mSocket.on(Socket.EVENT_RECONNECT_FAILED,
> onConnectError);
> // AppSettings.this.mSocket.on(Socket.EVENT_DISCONNECT,
> onConnectError);
> // AppSettings.this.mSocket.on(Socket.EVENT_ERROR, onConnectError);
> // AppSettings.this.mSocket.on(Socket.EVENT_RECONNECT_ATTEMPT,
> onReconnect);
> // AppSettings.this.mSocket.on(Socket.EVENT_RECONNECT, onReconnect);
> // AppSettings.this.mSocket.on(Socket.EVENT_CONNECT, onConnect);
>
>
> // this.mSocket.on("ping", ping);
> // this.mSocket.on("method", method);
> }
>
> public void offSocket() {
> AppSettings.this.mSocket.off(Socket.EVENT_CONNECT_ERROR,
> onConnectError)
> .off(Socket.EVENT_CONNECT_TIMEOUT, onConnectError)
> .off(Socket.EVENT_RECONNECT_ERROR, onConnectError)
> .off(Socket.EVENT_RECONNECT_FAILED, onConnectError)
> .off(Socket.EVENT_ERROR, onConnectError)
> .off(Socket.EVENT_DISCONNECT, onConnectError)
> .off(Socket.EVENT_RECONNECT, onReconnect)
> .off(Socket.EVENT_RECONNECT_ATTEMPT, onReconnect)
> .off("ping", ping)
> .off("method", method);
> // AppSettings.this.mSocket.off(Socket.EVENT_CONNECT_TIMEOUT,
> onConnectError);
> // AppSettings.this.mSocket.off(Socket.EVENT_RECONNECT_ERROR,
> onConnectError);
> // AppSettings.this.mSocket.off(Socket.EVENT_RECONNECT_FAILED,
> onConnectError);
> // AppSettings.this.mSocket.off(Socket.EVENT_ERROR, onConnectError);
> // AppSettings.this.mSocket.off(Socket.EVENT_DISCONNECT,
> onConnectError);
> // AppSettings.this.mSocket.off(Socket.EVENT_RECONNECT,
> onReconnect);
> // AppSettings.this.mSocket.off(Socket.EVENT_RECONNECT_ATTEMPT,
> onReconnect);
> // AppSettings.this.mSocket.off("ping", ping);
> // AppSettings.this.mSocket.off("method", method);
> }
>
> BroadcastReceiver ConnectionReceiver = new BroadcastReceiver() {
> @Override
> public void onReceive(Context context, Intent intent) {
>
> //startActivity(new Intent(AppSettings.this,
> LoginActivity.class));
>
> }
> };
>
> public long setTimeout(int B, int T, int I, int D) {
> long result = 0;
>
> if (D > 0) {
> result = ((B + T * I) * D);
> } else {
> result = B + T * I;
> }
>
> return result;
> }
>
> public void setBuffer(int buffer) {
> this.Buffer = buffer;
> }
>
> public int getBuffer() {
> return this.Buffer;
> }
>
> public void setTime(int time) {
> this.time = time;
> }
>
> public int getTime() {
> return this.time;
> }
>
> public void startClockWaitTime(Context context,final int B, final int
> T, final int I, final int D) {
>
>
> ((Activity)context).runOnUiThread(new Runnable() {
> @Override
> public void run() {
> if (AppSettings.this.Clock == null) {
>
> AppSettings.this.Clock =
> AppSettings.this.setClockWaitTime(B, T, I, D);
> AppSettings.this.Clock.start();
> Log.d(TAG, "CountDownTimer was starting");
> }
> }
> });
> }
>
> public void stopClockWaitTime(Context context) {
>
> ((Activity)context).runOnUiThread(new Runnable() {
> @Override
> public void run() {
> if (AppSettings.this.Clock != null) {
> AppSettings.this.Clock.cancel();
> AppSettings.this.Clock = null;
>
> Log.d(TAG, "CountDownTimer was stoped");
> }
>
> }
> });
> }
>
> public CountDownTimer setClockWaitTime(int B, int T, int I, int D) {
>
>
> CountDownTimer result;
> long waitTime = setTimeout(B, T, I, D) * 1000;
> Log.d(TAG, "Waitime: " + waitTime);
>
> result = new CountDownTimer(waitTime, 1000) {
> @Override
> public void onTick(long millisUntilFinished) {
>
> Log.d(TAG, "CountDownTimer tick");
> }
>
> @Override
> public void onFinish() {
>
> Log.d(TAG, "CountDownTimer finish");
>
> AppSettings.this.reconnect();
>
> if (AppSettings.this.Clock != null) {
> AppSettings.this.Clock.cancel();
> AppSettings.this.Clock = null;
> }
> }
> }.start();
>
> Log.d(TAG, "CountDownTimer was set");
> return result;
> }
>
> public boolean isConnected() {
>
> boolean result = false;
>
> if (AppSettings.this.mSocket != null &&
> AppSettings.this.mSocket.connected() ) {
> result = true;
> }
>
> return result;
> }
>
> public void connect() {
> if (AppSettings.this.mSocket != null) {
> if(AppSettings.this.mSocket.connect() == null){
> reconnect();
> }
>
> }
> }
>
> private void ResetTravelElements() {
> Session.setSelectedLocation(null);
> Session.setSelectedDestination(null);
> Session.setEstimateDistance(0);
> Session.setEstimatePayment(null);
> Session.setPaxCount(null);
> Session.setBagCount(null);
> Session.setTypeVehicle(null);
> Session.setTotalTravelled(0);
> Session.resetWaitInstance();
> Session.setStartWaitTime(0);
> }
>
> public void reconnect(){
>
> Intent intent_expirate = new Intent("expirate");
> intent_expirate.putExtra("message", "Reconnection - Comunication
> Error");
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_expirate);
>
>
> }
>
>
> public void Emit(JSONObject jsonObject, int B, int T, int I, int D) {
>
> try {
>
> SimpleDateFormat df = new SimpleDateFormat("dd/MM/yyyy
> hh:mm:ss");
> Calendar c = Calendar.getInstance();
> this.transaction_id =
> saveTransaction(null,getUsername(),jsonObject.getString("event"),jsonObject.toString(),df.format(c.getTime()));
>
> jsonObject.put("TID",transaction_id);
>
> if(AppSettings.this.mSocket.emit("method", jsonObject) ==
> null){
> reconnect();
> return;
> }
>
> Log.d(TAG, this.getUsername() + " emit the event: " +
> jsonObject.getString("event"));
> LogFile(getApplicationContext(),String.valueOf(transaction_id),
> AppSettings.this.mSocket.id(),AppSettings.this.mSocket.id
> (),jsonObject.getString("event"),this.getUsername()
> ,Session.getDriver(),Session.getEmei());
>
> if (AppSettings.this.Clock == null) {
>
> if(getMainContext() != null){
>
> AppSettings.this.startClockWaitTime(this.getMainContext(), B, T, I, D);
> }
>
> }
>
> } catch (JSONException e) {
> e.printStackTrace();
> }
> }
>
> private Emitter.Listener onConnectError = new Emitter.Listener() {
> @Override
> public void call(final Object... args) {
> //final JSONObject data = (JSONObject) args[0];
>
> Log.i("Data", String.valueOf(args[0]));
>
> AppSettings.this.connect();
>
> if (!AppSettings.this.isConnected()){
>
> Log.d(TAG, "onConnectError Socket disconnected");
> if(AppSettings.this.Clock == null){
> if(getMainContext() != null){
>
> AppSettings.this.startClockWaitTime(AppSettings.this.getMainContext(),15,
> 15, 1, 0);
> }
> }
>
> AppSettings.this.reconnect();
> }
> }
> };
>
> private Emitter.Listener onReconnect = new Emitter.Listener() {
> @Override
> public void call(final Object... args) {
>
> Log.i("onReconect Data", String.valueOf(args[0]));
> JSONObject object = new JSONObject();
>
> if(AppSettings.this.isConnected()){
>
> try{
> object.put("event","join");
> object.put("uid", username);
> AppSettings.this.Emit(object, 15, 15, 1, 0);
> }
> catch (JSONException e){
> Log.d(TAG,e.getMessage());
> }
> }else{
> AppSettings.this.reconnect();
> }
> }
> };
>
> private Emitter.Listener onConnect = new Emitter.Listener() {
> @Override
> public void call(Object... args) {
> try {
>
> if(isConnected()){
>
> JSONObject object = new JSONObject();
> object.put("event", "join");
> object.put("uid", username);
> AppSettings.this.Emit(object, 15, 15, 1, 0);
> }
> else {
> AppSettings.this.reconnect();
> }
>
>
> } catch (JSONException e) {
> Log.d(TAG, e.getMessage());
> }
>
> }
> };
>
> private Emitter.Listener ping = new Emitter.Listener() {
> @Override
> public void call(final Object... args) {
>
> Log.i("Data", String.valueOf(args[0]));
> try {
> JSONObject object = new JSONObject();
> object.put("beat", 1);
> AppSettings.this.mSocket.emit("pong", object);
> } catch (JSONException e) {
> Log.d(TAG, e.getMessage());
> }
> }
> };
>
> public static void LogFile(Context context,String transaction,String
> socketID,String receivedID,String methodSocket,String userID,boolean
> Taxiser,String imei){
> try {
> // Creates a trace file in the primary external storage space
> of the
> // current application.
> // If the file does not exists, it is created.
>
> Calendar c = Calendar.getInstance();
> SimpleDateFormat df = new SimpleDateFormat("dd/MM/yyyy
> hh:mm:ss");
> File traceFile = new File(context.getExternalFilesDir(null),
> "GPS_Data.csv");
> if (!traceFile.exists())
> traceFile.createNewFile();
> // Adds a line to the trace file
> BufferedWriter writer = new BufferedWriter(new
> FileWriter(traceFile, true /*append*/));
> writer.write(df.format(c.getTime()) +", "+ transaction + ",
> "+socketID+", "
> +receivedID+", "+ methodSocket+", "+userID+",
> "+Taxiser+'\n');
> writer.close();
> // Refresh the data so it can seen when the device is plugged
> in a
> // computer. You may have to unplug and replug the device to
> see the
> // latest changes. This is not necessary if the user should
> not modify
> // the files.
> MediaScannerConnection.scanFile(context,
> new String[]{traceFile.toString()},
> null,
> null);
>
> } catch (IOException e) {
> //Log.d("com.cindypotvin.FileTest", "Unable to write to the
> TraceFile.txt file.");
> }
> }
>
> private Emitter.Listener method = new Emitter.Listener() {
> @Override
> public void call(Object... args) {
>
> try {
>
> long tid = 0;
>
> JSONObject received_object = (JSONObject) args[0];
> String method = received_object.getString("event");
>
> Log.d(TAG,"method: "+method+" is called...");
>
> if(!method.equals("received")) {
> JSONObject sender_object = new JSONObject();
> sender_object.put("TID",
> received_object.getString("TID"));
> sender_object.put("event","received");
> AppSettings.this.mSocket.emit("method", sender_object);
> }else{
> tid = received_object.getLong("TID");
> }
>
> switch (method){
> case "DriverConfirmed":
>
> //Log.d(TAG,"Socket on DriverConfirm");
>
> String driver = received_object.getString("UID");
> String name = received_object.getString("Name");
> String driverPhone =
> received_object.getString("Phone");
> double lat = received_object.getDouble("lat");
> double lng = received_object.getDouble("lon");
> float rating =
> Float.parseFloat(received_object.getString("Rating"));
> String tripnum =
> received_object.getString("TripNum");
> boolean answer =
> received_object.getBoolean("answer");
> String driverphoto =
> received_object.getString("driverPhoto");
> String vehiclephoto =
> received_object.getString("vehiclePhoto");
>
> Intent intent_DriverConfirmed = new
> Intent("DriverConfirmed");
> intent_DriverConfirmed.putExtra("driver",driver);
> intent_DriverConfirmed.putExtra("name",name);
>
> intent_DriverConfirmed.putExtra("driverPhone",driverPhone);
> intent_DriverConfirmed.putExtra("lat",lat);
> intent_DriverConfirmed.putExtra("lon",lng);
> intent_DriverConfirmed.putExtra("rating",rating);
> intent_DriverConfirmed.putExtra("tripnum",tripnum);
> intent_DriverConfirmed.putExtra("answer",answer);
>
> intent_DriverConfirmed.putExtra("driverphoto",driverphoto);
> intent_DriverConfirmed.putExtra("vehiclephoto",
> vehiclephoto);
>
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_DriverConfirmed);
>
> break;
> case "DriverSelected":
>
> //Log.d(TAG,"Socket on DriverSelected");
>
> String pass = received_object.getString("pass");
> int requestID =
> received_object.getInt("requestid");
> double passlat = received_object.getDouble("lat");
> double passlng = received_object.getDouble("lon");
>
> Intent intent_DriverSelected = new
> Intent("DriverSelected");
> intent_DriverSelected.putExtra("pass",pass);
>
> intent_DriverSelected.putExtra("requestID",requestID);
> intent_DriverSelected.putExtra("passlat",passlat);
> intent_DriverSelected.putExtra("passlng", passlng);
>
> if (Session.getCurrentLocationInfo() != null) {
>
>
> NotificationManagement.statiticsNotification(AppSettings.this, 1);
> Location mCurrentLocation =
> Session.getCurrentLocationInfo();
> intent_DriverSelected.putExtra("driverlat",
> mCurrentLocation.getLatitude());
> intent_DriverSelected.putExtra("driverlng",
> mCurrentLocation.getLongitude());
>
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_DriverSelected);
> }else{
> Log.d(TAG, "Current Location isn't
> available.");
> Intent intent = new Intent("LOCATION_STATUS");
> intent.putExtra("message", "Localizacion no
> disponible");
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent);
> }
>
> break;
> case "TaxiArrived":
>
> //Log.d(TAG,"Socket on TaxiArrived");
>
> //Verificar si logica sigue igual.
> Intent intent_TaxiArrived = new
> Intent("TaxiArrived");
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_TaxiArrived);
>
> break;
> case "tripcancelled":
>
> // Log.d(TAG,"Socket on tripcancelled");
>
> //Implementar logica de navegacion en activity
> waitTaxi,GetPassenger,PassengerTrip,
> ResetTravelElements();
>
> Intent intent_tripcancelled = new
> Intent("tripcancelled");
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_tripcancelled);
>
> break;
> case "currentfare":
>
> //Log.d(TAG,"Socket on currentfare");
>
> String fare = received_object.getString("fare");
>
> Intent intent_currentfare = new
> Intent("currentfare");
> intent_currentfare.putExtra("fare", fare);
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_currentfare);
>
> break;
> case "endtrip":
>
> // Log.d(TAG,"Socket on endtrip");
>
> String tripID =
> received_object.getString("tripid");
> String final_fare =
> received_object.getString("fare");
> String estimate =
> received_object.getString("estimate");
>
> Intent intent_endtrip = new Intent("endtrip");
> intent_endtrip.putExtra("tripid",tripID);
> intent_endtrip.putExtra("fare",final_fare);
> intent_endtrip.putExtra("estimate", estimate);
>
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_endtrip);
> break;
> case "location":
>
> //Log.d(TAG, "Socket on location");
>
> float bearing =
> Double.valueOf(received_object.getString("bearing")).floatValue();
> boolean billable =
> received_object.getBoolean("billable");
> double distance =
> received_object.getDouble("dist");
> double ltd = received_object.getDouble("lat");
> double lon = received_object.getDouble("lon");
> double speed = received_object.getDouble("spd");
> String tripNum =
> received_object.getString("tripnum");
>
> Intent intent_location = new Intent("location");
> intent_location.putExtra("bearing",bearing);
> intent_location.putExtra("billable",billable);
> intent_location.putExtra("dist",distance);
> intent_location.putExtra("lat",ltd);
> intent_location.putExtra("lon",lon);
> intent_location.putExtra("spd",speed);
> intent_location.putExtra("lon",lon);
> intent_location.putExtra("tripnum", tripNum);
>
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_location);
>
> break;
>
> case "received":
>
> // Log.d(TAG, "Socket on received");
>
> if(tid > 0){
> if(deleteTransaction(tid)){
> if(AppSettings.this.Clock != null){
> if(getMainContext() != null){
>
> AppSettings.this.stopClockWaitTime(AppSettings.this.getMainContext());
> }
> }
> }
> }else{
> if(AppSettings.this.Clock != null){
> if(getMainContext() != null){
>
> AppSettings.this.stopClockWaitTime(AppSettings.this.getMainContext());
> }
> }
> }
> Intent intent_received = new Intent("received");
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_received);
>
> return;
>
>
> case "PassengerReceipt":
>
> //Log.d(TAG,"Socket on PassengerReceipt");
>
> String TID = received_object.getString("TripNum");
> String passenger =
> received_object.getString("PID");
>
> Intent intent_PassengerReceipt = new
> Intent("PassengerReceipt");
> intent_PassengerReceipt.putExtra("tripnum", TID);
> intent_PassengerReceipt.putExtra("pass",
> passenger);
>
> LocalBroadcastManager.getInstance(AppSettings.this).sendBroadcast(intent_PassengerReceipt);
>
> break;
> }
>
> LogFile(getApplicationContext(),
> received_object.getString("TID"), AppSettings.this.mSocket.id(),
> AppSettings.this.mSocket.id(), received_object.getString("event"),
> AppSettings.this.getUsername()
> , Session.getDriver(), Session.getEmei());
> }
> catch (JSONException e){
> Log.d(TAG,e.getMessage());
> }
> }
> };
> }
>
>
--
You received this message because you are subscribed to the Google Groups
"Android Developers" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to android-developers+unsubscr...@googlegroups.com.
To post to this group, send email to android-developers@googlegroups.com.
Visit this group at https://groups.google.com/group/android-developers.
To view this discussion on the web visit
https://groups.google.com/d/msgid/android-developers/025f9e6d-b4f5-4f0f-a1f4-93476ae5423d%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
