WebSocket and Socket.IO client for Android

Credits

The hybi parser was ported from JavaScript to Java by Eric Butler eric@codebutler.com.

The WebSocket client was written by Eric Butler eric@codebutler.com.

The Socket.IO client was written by Koushik Dutta.

The Socket.IO client component was ported from Koushik Dutta's AndroidAsync(https://github.com/koush/AndroidAsync) by Vinay S Shenoy

WebSocket Usage

List<BasicNameValuePair> extraHeaders = Arrays.asList(
    new BasicNameValuePair("Cookie", "session=abcd")
);

WebSocketClient client = new WebSocketClient(URI.create("wss://irccloud.com"), new WebSocketClient.Listener() {
    @Override
    public void onConnect() {
        Log.d(TAG, "Connected!");
    }

    @Override
    public void onMessage(String message) {
        Log.d(TAG, String.format("Got string message! %s", message));
    }

    @Override
    public void onMessage(byte[] data) {
        Log.d(TAG, String.format("Got binary message! %s", toHexString(data)));
    }

    @Override
    public void onDisconnect(int code, String reason) {
        Log.d(TAG, String.format("Disconnected! Code: %d Reason: %s", code, reason));
    }

    @Override
    public void onError(Exception error) {
        Log.e(TAG, "Error!", error);
    }

}, extraHeaders);

client.connect();

// Later… 
client.send("hello!");
client.send(new byte[] { 0xDE, 0xAD, 0xBE, 0xEF });
client.disconnect();

Socket.IO Usage

SocketIOClient.connect("http://localhost:80", new ConnectCallback() {

    @Override
    public void onConnectCompleted(Exception ex, SocketIOClient client) {
        
        if (ex != null) {
            return;
        }

        //Save the returned SocketIOClient instance into a variable so you can disconnect it later
        client.setDisconnectCallback(MainActivity.this);
        client.setErrorCallback(MainActivity.this);
        client.setJSONCallback(MainActivity.this);
        client.setStringCallback(MainActivity.this);
        
        //You need to explicitly specify which events you are interested in receiving
        client.addListener("news", MainActivity.this);

        client.of("/chat", new ConnectCallback() {
        
            @Override
            public void onConnectCompleted(Exception ex, SocketIOClient client) {
                
                if (ex != null) {
                    ex.printStackTrace();
                    return;
                }

                //This client instance will be using the same websocket as the original client, 
                //but will point to the indicated endpoint
                client.setDisconnectCallback(MainActivity.this);
                client.setErrorCallback(MainActivity.this);
                client.setJSONCallback(MainActivity.this);
                client.setStringCallback(MainActivity.this);
                client.addListener("a message", MainActivity.this);

            }
        });

    }
}, new Handler());

        
@Override
public void onEvent(String event, JSONArray argument, Acknowledge acknowledge) {
    try {
        Log.d("MainActivity", "Event:" + event + "Arguments:"
                + argument.toString(2));
    } catch (JSONException e) {
        e.printStackTrace();
    }

}

@Override
public void onString(String string, Acknowledge acknowledge) {
    Log.d("MainActivity", string);

}

@Override
public void onJSON(JSONObject json, Acknowledge acknowledge) {
    try {
        Log.d("MainActivity", "json:" + json.toString(2));
    } catch (JSONException e) {
        e.printStackTrace();
    }

}

@Override
public void onError(String error) {
    Log.d("MainActivity", error);

}

@Override
public void onDisconnect(Exception e) {
    Log.d(mComponentTag, "Disconnected:" + e.getMessage());

}

TODO

Run autobahn tests
Investigate using naga instead of threads.

License

(The MIT License)