import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void testSendAcknowledge() throws Exception {
    final TriggerFuture trigger = new TriggerFuture();
    SocketIOClient client = SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://koush.clockworkmod.com:8080/", null).get();

    client.setStringCallback(new StringCallback() {
        boolean isEcho = true;
        @Override
        public void onString(String string, Acknowledge acknowledge) {
            if (!isEcho) {
                trigger.trigger("hello".equals(string));
                return;
            }
            assertNotNull(acknowledge);
            isEcho = false;
            acknowledge.acknowledge(new JSONArray().put(string));
        }
    });

    client.emit("hello");

    assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
}
 

import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void testEndpoint() throws Exception {
    final TriggerFuture trigger = new TriggerFuture();
    SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), new SocketIORequest("http://koush.clockworkmod.com:8080/", "/chat"), new ConnectCallback() {
        @Override
        public void onConnectCompleted(Exception ex, SocketIOClient client) {
            assertNull(ex);
            client.setStringCallback(new StringCallback() {
                @Override
                public void onString(String string, Acknowledge acknowledge) {
                    trigger.trigger("hello".equals(string));
                }
            });
            client.emit("hello");
        }
    });
    assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
}
 

import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
/**
 * Socket connection callback
 *
 * @param ex     potential exception if error
 * @param client socket client
 */
@Override
public void onConnectCompleted(final Exception ex, final SocketIOClient client) {

    handler.post(new Runnable() {
        @Override
        public void run() {
            if (ex != null) {
                postError();
                return;
            }

            ioState = IOState.CONNECTED;

            socketIOClient = client;
            socketIOClient.setErrorCallback(ChatService.this);
            socketIOClient.setDisconnectCallback(ChatService.this);
            socketIOClient.addListener(ChatService.this);

            showForeground();

            post();
        }
    });
}
 

import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void testAcknowledge() throws Exception {
    final TriggerFuture trigger = new TriggerFuture();
    SocketIOClient client = SocketIOClient.connect(AsyncHttpClient.getDefaultInstance(), "http://koush.clockworkmod.com:8080/", null).get();

    client.emit("hello", new Acknowledge() {
        @Override
        public void acknowledge(JSONArray arguments) {
            trigger.trigger("hello".equals(arguments.optString(0)));
        }
    });

    assertTrue(trigger.get(TIMEOUT, TimeUnit.MILLISECONDS));
}
 

import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public WebRTCCliente(RTCListener listener, String host) {
  mListener = listener;
  factory = new PeerConnectionFactory();

  SocketIOClient.connect(host, new ConnectCallback() {

    @Override
    public void onConnectCompleted(Exception ex, SocketIOClient socket) {
      if (ex != null) {
        mListener.onStatusChanged("No se puedo conectar al Servidor WebSocket en la direccion: " + ex.getMessage());
        //Log.e(TAG,"WebRTCCliente connect failed: "+ex.getMessage());
        return;
      }
      mListener.onStatusChanged("Conectado al Servidor WebSocket.");

      //  Log.d(TAG, "Conectado al Servidor WebRTC.");
      MainActivity.conectado_servidor = true;
      client = socket;

      // specify which events you are interested in receiving
      client.addListener("id", messageHandler);
      client.addListener("message", messageHandler);
    }
  }, new Handler());

  iceServers.add(new PeerConnection.IceServer("stun:23.21.150.121"));
  iceServers.add(new PeerConnection.IceServer("stun:stun.l.google.com:19302"));

    //  Habilitar el uso de Datachannels 30.09/2014
     //  pcConstraints.optional.add(new MediaConstraints.KeyValuePair("RtpDataChannels", "true"));
    //
  pcConstraints.mandatory.add(new MediaConstraints.KeyValuePair("OfferToReceiveAudio", "false"));
  pcConstraints.mandatory.add(new MediaConstraints.KeyValuePair("OfferToReceiveVideo", "true"));

}
 

import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void connect(Context context, ConnectCallback callback) {
    SocketIOClient.connect(
            PreferencesHelper.getBaseUrl(context), callback, new Handler());
}
 

import com.koushikdutta.async.http.socketio.SocketIOClient; //导入依赖的package包/类
public void disconnect(SocketIOClient client) {
    client.disconnect();
}