Native Socket.IO and Android

Posted 2020-07-07 和平world

原文链接地址：http://socket.io/blog/native-socket-io-and-android/

在本教程中我们将学习如何创建一个聊天客户端用socket . io Node. JS做为聊天服务器 ,我们的 nativate安卓客户端 ! 如果你想直接跳转到代码,它在 GitHub 。 否则,继续读下去!

#介绍

跟随,首先克隆存储库: socket.io-android-chat 。

应用程序具有以下特点:

• 发送消息到所有用户加入到房间。
• 每个用户加入或者离开时通知。
• 一个用户开始输入信息时通知。

Socket.IO提供了一个面向事件的API,可以在所有网络、设备和浏览器。 非常健壮的(甚至作品背后的公司代理!)和高性能,这是非常适合多人游戏或实时通信。

#安装的依赖关系

第一步是安装Java Socket。 输入输出端与 Gradle 。

对于这个应用程序,我们将依赖项添加到 build.gradle :

// app/build.gradle
dependencies {
    ...
    compile ‘com.github.nkzawa:socket.io-client:0.3.0‘
}

我们必须记住添加网络许可 AndroidManifest.xml 。

<!-- app/AndroidManifest.xml -->
<manifest xmlns:android="http://schemas.android.com/apk/res/android">
    <uses-permission android:name="android.permission.INTERNET" />
    ...
</manifest>

现在我们可以在android上使用socket.IO!

#在Activity和Fragment使用Socket

首先,我们必须初始化Socket.io 的一个新实例。如下:

import com.github.nkzawa.socketio.client.IO;
import com.github.nkzawa.socketio.client.Socket;

private Socket mSocket;
{
    try {
        mSocket = IO.socket("http://chat.socket.io");
    } catch (URISyntaxException e) {}
}

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

IO.socket() 返回Socket http://chat.socket.io 使用默认选项。 注意,方法缓存结果,所以你可以得到一个相同的 Scocket从任何Activity或Fragment实例的url。

我们显式调用 connect() 在这里建立连接(与javascript客户端)。 在这个程序中,我们使用 onCreate 生命周期回调,但它实际上取决于您的应用程序。

#发射事件

发送数据看起来如下。 在这种情况下,我们发送一个字符串,但你也可以做JSON数据 org.json 包,甚至还支持二进制数据!

private EditText mInputMessageView;

private void attemptSend() {
    String message = mInputMessageView.getText().toString().trim();
    if (TextUtils.isEmpty(message)) {
        return;
    }

    mInputMessageView.setText("");
    mSocket.emit("new message", message);
}

#监听事件

就像我前面提到的,Socket.IO 是 双向的 ,这意味着我们可以向服务器发送事件,但也随时在通信服务器可以发送事件。

然后我们可以Socket监听事件 onCreate 生命周期回调。

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);

    mSocket.on("new message", onNewMessage);
    mSocket.connect();
}

我们监听 new message 事件从其他用户接收消息。

import com.github.nkzawa.emitter.Emitter;

private Emitter.Listener onNewMessage = new Emitter.Listener() {
    @Override
    public void call(final Object.. args) {
        getActivity().runOnUiThread(new Runnable() {
            @Override
            public void run() {
                JSONObject data = (JSONObject) args[0];
                String username;
                String message;
                try {
                    username = data.getString("username");
                    message = data.getString("message");
                } catch (JSONException e) {
                    return;
                }

                // add the message to view
                addMessage(username, message);
            }
        });
    }
};

这就是 onNewMessage 的样子。 一个侦听器的一个实例 Emitter.Listener ,必须实施 call 方法。 你会注意到里面的call()包装的 Activity# runOnUiThread() ,这是因为回调总是另一个线程从Android UI线程里面调用,因此我们必须确保将消息添加到UI线程的视图上。

#套接字状态管理

因为一个Android活动有自己的生命周期,我们也应该仔细管理套接字的状态,以避免内存泄漏等问题。 在这个程序中,我们将关闭套接字连接,删除所有的听众 onDestroy 回调的活动。

@Override
public void onDestroy() {
    super.onDestroy();

    mSocket.disconnect();
    mSocket.off("new message", onNewMessage);
}

调用 off() 删除new message()的侦听器事件。

#进一步的阅读

如果你想探索更多的,我建议你看看:

• 这个程序的其他特征。他们只是实现了 发出() , 在() 和 () 。
• 套接字的细节。 IO Java客户机。 它支持JS客户机的所有特性。
• 许多其他伟大的套接字。 IO实现创建的社区!