Как сохранить привязку службы к нужному экземпляру активности?

Я не могу заставить свое приложение работать правильно по разным причинам.

Обзор дизайна: то, к чему я стремлюсь, - это действие, которое имеет две кнопки (подключение, отключение) и текстовое представление, которое отображает данные, полученные от соединения. Я написал службу «MySocket», которая обрабатывает соединение WebSocket (реализация Gottox на Java), и эта служба отправляет сообщение активности всякий раз, когда она получает что-то с сервера, затем активность добавляет эти данные в текстовое представление. Служба должна получать запросы на подключение/отключение от активности и иметь возможность передавать сообщения активности. MySocket также должен работать в качестве службы переднего плана, чтобы он оставался подключенным на неопределенный срок, а пользователю предоставлялось липкое уведомление.

У меня серьезные проблемы с этим в разных местах. Во-первых, я заметил, что могу запустить другой экземпляр активности, в то время как оригинал все еще обновляется. Я исправил это, указав android:launchMode="singleInstance"> в манифесте. Проблема, с которой я столкнулся, заключалась в том, что когда активность была уничтожена и создана новая, служба продолжала публиковать обновления, но сфокусированная активность их не получала. Если бы исходная активность была уничтожена, а обработчик служб не был обновлен, то, безусловно, после уничтожения активности было бы выдано исключение нулевого указателя, но приложение продолжало работать. Затем я попытался запустить unbindService(mConnection) в своем методе onDestroy, но это выдало java.lang.IllegalArgumentException: Service not registered: Служба отправляет сообщение что-то, что должно быть сфокусировано, но, похоже, не получает его. Я подозреваю, что виновата моя плохая реализация службы переднего плана, но я действительно понятия не имею.

Два рассматриваемых класса являются ДЛИННЫМИ, поэтому я удалил строки Logcat, глобальные переменные и некоторые некоторые методы, которые, я уверен, не имеют значения. Я понимаю, что архитектура ужасна, но это настолько близко, насколько мне удалось заставить ее работать. Если код слишком ужасен для чтения, я буду рад, если кто-нибудь предложит альтернативную структуру, при условии, что она приведет к желаемому результату.

Класс активности:

@Override
public void onCreate(Bundle savedInstanceState)
{
      ...
      mMessenger = new Messenger(mHandler);
      connect.setOnClickListener(new View.OnClickListener()
    {
        @Override
        public void onClick(View v)
        {
            messageSocket("ACTION", "CONNECT");
        }
    });

     @Override
    protected void onDestroy()
    {
      super.onDestroy();
      doUnbindService();
    }

    private ServiceConnection conn = new ServiceConnection() 
    {
    public void onServiceConnected(ComponentName className, IBinder binder) 
    {
        Log.d(debug, "Service Connected");
        messenger = new Messenger(binder);
        boundToService = true;
    }

    public void onServiceDisconnected(ComponentName className) 
    {
        Log.d(debug, "Service Disconnected");
        messenger = null;
        boundToService = false;
    }
    };

    void doBindService() 
    {
    final Intent intent = new Intent(this, MySocket.class);
    intent.putExtra("MESSENGER", messenger);
    Thread t = new Thread()
    {
        public void run()
        {
        boundToService =
                getApplicationContext().bindService(
                intent,
                conn,
                Context.BIND_AUTO_CREATE
            );
        }
    };
    t.start();
}

И класс MySocket:

class IncomingHandler extends Handler 
{
    @Override
    public void onCreate() 
{...}

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        startForeground( id, showNotification() );
    connect();
        return START_STICKY;
}

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        startForeground( id, showNotification() );
        connect();
        return START_STICKY;
}


private Notification showNotification()
{
    nm = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
    CharSequence text = "WebSocket currently active";
    Notification notification = new Notification(R.drawable.ic_launcher,
            text, System.currentTimeMillis());
    PendingIntent contentIntent = PendingIntent.getActivity(this, 0,
            new Intent(this, SocketTester.class), 0);
    notification.setLatestEventInfo(this, "WebSocket Test", text,
            contentIntent);
    notification.flags = Notification.FLAG_FOREGROUND_SERVICE;
    return notification;
}
        @Override
    public IBinder onBind(Intent intent)
    {
        Bundle extras = intent.getExtras();
        Log.d(debug, "onBind called");
        if (intent.getExtras() != null)
        {   
            Log.d(debug, "Setting messenger");
            outMessenger = (Messenger) extras.get("MESSENGER");
        }
        return inMessenger.getBinder();
        }   

    @Override
    public void handleMessage(Message msg) 
            {           
        Bundle data = msg.getData();            
        Message backMsg = Message.obtain();
        Bundle bundle = new Bundle();
        backMsg.setData(bundle);

        if ("CONNECT".equals(data.getString(ACTION)))
        {   
            Log.d(debug, "Connecting");
            startService(new Intent(MySocket.this, MySocket.class));
            /*startService now calls connect();*/
        }
        else if ("DISCONNECT".equals(data.getString(ACTION)))
        {
            if (socket != null)
            {   
                socket.disconnect();
            }
            stopForeground( true );
            stopSelf();
        }
    }
}