clusterws-client-java's Introduction

(Deprecated) ClusterWS

Build Scalable Node.js WebSockets Applications

For version 4.0.0 alpha version check ClusterWS Website (under work)

Lightweight, fast and powerful framework for building scalable WebSocket applications in Node.js. ClusterWS uses cWS a fork of uWebSockets.

Officially Supported Client Libraries

Consider to support development

Buy a coffee (via PayPal)

Become a Backer on Patreon

Find more about ClusterWS in Wiki Documentation.

clusterws-client-java's People

Contributors

Stargazers

Watchers

clusterws-client-java's Issues

socket.send

Submitting

Bug
Question
Suggetion
Other

Details

hi
I use the following code to watch from channel:

ClusterWS socket ;
oncreate (){
     initChat();
}
  private void initChat() {
    socket = new ClusterWS("url");
    socket.connect();
    socket.setReconnection(true, 2, 10, 20);

    socket.setClusterWSListener(new IClusterWSListener() {
      @Override
      public void onConnected() {
        Channel channel = socket.subscribe("match-wall");
        channel.watch(new Channel.IChannelListener() {
          @Override
          public void onDataReceived(String channelName, Object data) {
            Gson gson = new Gson();
            String json = gson.toJson(data);
            try {
              JSONObject object = new JSONObject(json);
              String action = object.getString("action");
              if (action.equals("publish")) {
                String username = object.getString("username");
                String message = object.getString("message");
                String photo = object.getString("photo");
                addMessage(username, message, photo);
              } else if (action.equals("number-of-users")) {
                //Todo
              }
            } catch (JSONException e) {
              e.printStackTrace();
            }

          }
        });
      }

      @Override
      public void onError(Exception exception) {
      }

      @Override
      public void onDisconnected(int code, String reason) {
      }
    });
  }

and this code to send data to server:

private void sendMessage() {
    hideKeyboard();
    String message = edtChatMsg.getText().toString().trim();
    if (TextUtils.isEmpty(message)) {
      edtChatMsg.requestFocus();
      return;
    }
    edtChatMsg.setText("");

    final JSONObject jsonObject = new JSONObject();
    try {
      jsonObject.put("username", mUsername);
      jsonObject.put("message", message);
    } catch (JSONException e) {
      e.printStackTrace();
    }

    Channel channel = socket.getChannelByName("match-wall");
    if (channel != null) {
      socket.send("match-wall-send-message", jsonObject.toString());
    } 
  }