4

我有服务。我在此服务的单独线程上创建了一个Thread用于使用库的库。socket.io-java-client

我用以下方式保持线程：

@Override
public void run() {
    while (canLiveThread) {
    //  keep thread
    }
}

这种方式完全错误是吗？要解决此解决方案，我需要找到以下问题的答案：

1.是否需要我单独创建线程才能在 Service 中使用 socket.io-java-client 库？或者我可以在没有线程的情况下使用这个库，只需在 Service 中实现 socket.io-java-client 库？

2.如果需要创建线程来使用这个库，那么如何在后台服务中以正确的方式管理线程而不耗尽电池？

如果有人有任何解决方案，请回答这个问题...

提前致谢！

4

1 回答 1

1

实际上，我不知道我的使用方式是否socket-io-client正确，但我尽量做到完全清楚。据我所知socket-io-client，已经在使用后台线程来连接、发送、接收事件。

第一种方式

我认为这不是你想要的，但我尽可能展示了这个变体。所以，首先，我创建了一个SocketClient，像这样：

public class SocketClient implements IOCallback {

    private SocketIO socket;
    private Context context; // for some cases (i.e. broadcasting via LocalBroadcastManager).

    public SocketClient(Context context) {
       this.context = context;
    }

    public synchronized void connect() {
        if (socket == null || !socket.isConnected()) {
            Properties properties = new Properties();
            // setting your properties...
            try {
                socket = new SocketIO("http://your.address", properties);
                socket.connect(this);
            } catch (MalformedURLException e) {
                Log.e("SocketClientException", e.getMessage());
            }
        }
    }

    @Override
    public void onDisconnect() {

    }

    @Override
    public void onConnect() {

    }

    @Override
    public void onMessage(String data, IOAcknowledge ack) {

    }

    @Override
    public void onMessage(JsonElement json, IOAcknowledge ack) {

    }

    @Override
    public void on(String event, IOAcknowledge ack, JsonElement... args) {
        LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent("action_on"));
    }

    @Override
    public void onError(SocketIOException socketIOException) {

    }

}

然后我创建了一个包含我们的单例SocketClient：

public class API {

    private static API instance;
    private SocketClient client;

    private API() {
    }

    public static API getInstance() {
        if (instance == null) {
            instance = new API();
        }
        return instance;
    }

    public void init(Context context) {
        client = new SocketClient(context);
    }

    public SocketClient getSocketIO() {
        return client;
    }
}

然后在Service类onCreate()方法中，我只是调用我的单例：

@Override
public void onCreate() {
    super.onCreate();
    Log.i("SocketService", "onCreate");
    API.getInstance().init(getApplicationContext());
    API.getSocketIO().connect();
}

之后，socket 将一直存活Service，因此我们将能够通过我们的单例从应用程序的任何位置在后台接收和发送 socket 命令。我们可以通过LocalBroadcastManagerfromon中的onMessage方法发送接收到的数据SocketClient。

第二种方式

让我们尝试实现一个SocketService：

public class SocketService extends Service implements IOCallback {
    private SocketIO socket;

    private synchronized void connect() {
        if (socket == null || !socket.isConnected()) {
            Properties properties = new Properties();
            // setting your properties...
            try {
                socket = new SocketIO("http://your.address", properties);
                socket.connect(this);
            } catch (MalformedURLException e) {
                Log.e("SocketClientException", e.getMessage());
            }
        }
    }

    @Override
    public void onCreate() {
        super.onCreate();
        connect();
    }

    @Override
    public void onDisconnect() {

    }

    @Override
    public void onConnect() {

    }

    @Override
    public void onMessage(String data, IOAcknowledge ack) {

    }

    @Override
    public void onMessage(JsonElement json, IOAcknowledge ack) {

    }

    @Override
    public void on(String event, IOAcknowledge ack, JsonElement... args) {
         LocalBroadcastManager.getInstance(this).sendBroadcast(new Intent("action_on"));
    }

    @Override
    public void onError(SocketIOException socketIOException) {

    }
}

就这样。您可以从您的活动中启动服务并通过广播或消息处理程序进行通信。我从未尝试过第二种方式，但我认为它应该像一个魅力。

结论

这些方法中没有一个使用单独的后台线程，它对我有用，我有三个基于第一种方式的应用程序，它们都在后台工作，没有任何支持的东西。希望答案对所有有趣的SocketIO使用都有帮助:)

于 2014-11-30T15:05:53.490 回答