Как установить соединение WebSocket в андроиде службы?

Обновить

November 2018

Просмотры

6.4k раз

3

Я пытался создать андроид сервис, который позволит мне поддерживать связь WebSocket и отправить некоторое время данных времени. Я создаю обработчик в службу, чтобы соединиться с WebSocketClient. Но это не соединяется. URL работает, и я испытал это слишком. Я очень признателен, если кто-то может помочь.

Главная Activity.java

import android.app.Activity;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.os.Bundle;
import android.view.View;
import android.widget.TextView;


public class MainActivity extends Activity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        BroadcastReceiver receiver=new BroadcastReceiver() {

    @Override
        public void onReceive(Context context, Intent intent) {
            TextView text=(TextView) findViewById(R.id.textView);
            text.setText(intent.getStringExtra("msg"));

        }
    };

    registerReceiver(receiver, new IntentFilter(SocketService.BROADCAST_ACTION));

    }


    // Method to start the service
    public void startService(View view) {
        startService(new Intent(getBaseContext(), SocketService.class));
    }

    // Method to stop the service
    public void stopService(View view) {
        stopService(new Intent(getBaseContext(), SocketService.class));
    }



}

Внедрение Service

import android.app.Service;
import android.content.BroadcastReceiver;
import android.content.Intent;
import android.os.Handler;
import android.os.IBinder;
import android.util.Log;
import android.widget.Toast;

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;

import java.util.logging.LogRecord;

public class SocketService extends Service {

    boolean status=false;
    public static final String BROADCAST_ACTION = "com.supun.broadcasttest";
    BroadcastReceiver broadcaster;
    BroadcastReceiver broadreciever;
    Intent intent;
    Handler handler;
    WebSocketClient client;

    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    @Override
    public void onCreate() {
        super.onCreate();
        intent=new Intent(BROADCAST_ACTION);
        handler=new Handler();

    }

    @Override
    public int onStartCommand(final Intent intent, int flags, int startId) {
         Toast.makeText(this, "Service Started",Toast.LENGTH_LONG).show();// Let it continue running until it is stopped.
         ////////////////////////////////////////////////////////////////////////////////


        try {
            client = new WebSocketClient(new URI(
                    "ws://xxxxxxx-xxxx.rhcloud.com:8000/browser")) {

                @Override
                 public void onOpen(ServerHandshake handshakedata) {
                    Log.d("1", "open");
                    status = true;

                }

                @Override
                public void onMessage(String message) {


                    Log.d("reply", message);
                    intent.putExtra("msg", message);
                    sendBroadcast(intent);

                }

                @Override
                public void onError(Exception ex) {
                     // TODO Auto-generated method stub

                }

                @Override
                public void onClose(int code, String reason, boolean remote{
                    status = false;

                }
            };




        }catch(Exception e){


        }
            ///////////////////////////////////////////////////////////////////////////////

//
        handler.removeCallbacks(runnable);
        handler.postDelayed(runnable, 1000);
        return START_STICKY;
    }




    private Runnable runnable=new Runnable() {
        @Override
        public void run() {
            client.connect();

            for(int i=0; i<5;i++){
                if(status){
                    intent.putExtra("msg","open");
                    sendBroadcast(intent);
                    break;
                }else{
                    try {
                        intent.putExtra("msg",client.getReadyState().toString());
                        sendBroadcast(intent);
                        Thread.sleep(1000);

                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }

            if (!status) {
                intent.putExtra("msg","Time Out");
                sendBroadcast(intent);

            }



        }
    };





    @Override
    public void onDestroy() {
        super.onDestroy();
        Toast.makeText(this, "Service Destroyed", Toast.LENGTH_LONG).show();
    }
}

Я вызываю метод запуска службы в Главном деятельности от события нажатия кнопки. Выход всегда быстро повернулся к закрытию и, наконец, показывает, как истекло время ожидания. Интересно, что может быть причиной?

1 ответы

0

Клиент WebSocket ур использования не то, что надежная попытка с помощью двигателя IO - клиента , который я использовал для моего проекта, большая производительность https://github.com/nkzawa/engine.io-client.java Не все клиенты совместимы с чеком сервера , что используются на сервере , и что соединение должно быть воспроизведено с использованием различной библиотеки на сервере и на клиенте приводит к нарушению связей