AsyncSocket

Asynchronous socket (client+server) continues communications

A java library which used SocketChannels to communicate with server in non-blocking way I/O endpoints and totally based on NIO, used Buffer to send and retrieve data from server. Open multiple connections at once.

Features

• Based on NIO. One thread, driven by callbacks. Highly efficient.
• All operations return a Future that can be cancelled
• Socket client + socket server
• HTTP client + server
• Used java Socket and SocketChannel (non-blocking way)
• Fast and continues emit data from server when available
• Thread optimized, easy to use, Byte Buffer optimized
• ~65KB

USAGE

Import

dependencies {
  implementation 'com.samigehi:socket:1.0'
}

Java

connect using helper class (easy and recommended)

 private final SocketHelper helper = new SocketHelper("127.0.0.1", 1236);
  
  
// later...
// check if connected or wifi-on
helper.connect(new SocketListener() {

           @Override
           public void onConnect(AsyncSocket socket) {
               // on successfully connected to server
           }

           @Override
           public void onError(Exception error) {
               // when an error occurred
               error.printStackTrace();
           }

           @Override
           public void onClosed(Exception error) {
               // when connection closed by server or an error occurred to forcefully close server connection
           }

           @Override
           public void onDisconnect(Exception error) {
               // when connection closed by server or self closed by calling disconnect
           }

           @Override
           public void onDataWrite(String message, Exception error) {
               // notify when data successfully sent to server
               Log.d("SocketHelper", "onDataWrite >> " + message);
               if (error != null)
                   error.printStackTrace();
           }

           @Override
           public void onDataReceived(String message, DataEmitter emitter) {
               // notify when new data received from server
               Log.d("SocketHelper", "onDataReceived >> " + message);
               if (message.startsWith("~Login")) {
                   // Request  LOGIN
               } else if (message.startsWith("~OTP")) {
                   // Request OTP
               } else if (message.startsWith("...")) {
                   // Request any?
               }
           }
       });

Send/Write data to server from anywhere throught app using sinleton

// delay in milis
helper.send("~LOGIN|ABCD|EFG|h|$$", delay);

OR

connect using base SocketServer class (for advance users)

final SocketServer server = SocketServer.getDefault();
        server.connectSocket("127.0.0.1", 8080, new ConnectCallback() {
            @Override
            public void onConnectCompleted(Exception ex, AsyncSocket socket) {
                if (ex != null) {
                    ex.printStackTrace();
                }
                if (socket == null) {
                    //not connected yet return
                    return;
                }
                // connected
                socket.setDataCallback(new DataCallback() {
                    @Override
                    public void onDataAvailable(DataEmitter emitter, ByteBufferReader bb) {
                        // triggered when new data available from server
                    }
                });

                socket.setWriteableCallback(new WritableCallback() {
                    @Override
                    public void onWriteable() {
                        // when something write/sent to server
                    }
                });

                socket.setClosedCallback(new CompletedCallback() {
                    @Override
                    public void onCompleted(Exception ex) {
                        // when connection closed
                    }
                });

                socket.setEndCallback(new CompletedCallback() {
                    @Override
                    public void onCompleted(Exception ex) {
                        // when connection ended
                    }
                });
            }
        });
        
        
        
        // later write to server.....
         SocketServer.getDefault().post(new Runnable() {
            @Override
            public void run() {
                // white data to server
                Util.writeAll(socketRef, dataToWrite, new CompletedCallback() {
                    @Override
                    public void onCompleted(Exception ex) {

                    }
                });
            }
        });

This library is typical for those applications which require continues client-server communications

THANKS

Thanks to @Koush