javax websocket client simple example

Question

Can someone please provide me very simple example of websocket client using javax websocket   I want to connect to websocket  ws   socket example com 1234   send message  add channel  and listen to messages  All messages  sent  amp  listened  are in JSON format   And btw is this library the best for simple websocket communication

User · Answer

TooTallNate has a simple client side https://github.com/TooTallNate/Java-WebSocket

Just add the java_websocket.jar in the dist folder into your project.

 import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.drafts.Draft_10;
 import org.java_websocket.handshake.ServerHandshake;
 import org.json.JSONException;
 import org.json.JSONObject;

  WebSocketClient mWs = new WebSocketClient( new URI( "ws://socket.example.com:1234" ), new Draft_10() )
{
                    @Override
                    public void onMessage( String message ) {
                     JSONObject obj = new JSONObject(message);
                     String channel = obj.getString("channel");
                    }

                    @Override
                    public void onOpen( ServerHandshake handshake ) {
                        System.out.println( "opened connection" );
                    }

                    @Override
                    public void onClose( int code, String reason, boolean remote ) {
                        System.out.println( "closed connection" );
                    }

                    @Override
                    public void onError( Exception ex ) {
                        ex.printStackTrace();
                    }

                };
 //open websocket
 mWs.connect();
 JSONObject obj = new JSONObject();
 obj.put("event", "addChannel");
 obj.put("channel", "ok_btccny_ticker");
 String message = obj.toString();
 //send message
 mWs.send(message);

// and to close websocket

 mWs.close();

User · Answer

I have Spring 4 2 in my project and many SockJS Stomp implementations usually work well with Spring Boot implementations  This implementation from Baeldung worked for me without changing from Spring 4 2 to 5   After Using the dependencies mentioned in his blog  it still gave me ClassNotFoundError  I added the below dependency to fix it     lt dependency gt           lt groupId gt org springframework lt  groupId gt           lt artifactId gt spring-core lt  artifactId gt           lt version gt 4 2 3 RELEASE lt  version gt       lt  dependency gt

User · Answer

Have a look at this Java EE 7 examples from Arun Gupta   I forked it on github   Main          author Arun Gupta     public class Client        final static CountDownLatch messageLatch   new CountDownLatch 1        public static void main String   args            try               WebSocketContainer container   ContainerProvider getWebSocketContainer                String uri    ws   echo websocket org 80                System out println  Connecting to     uri               container connectToServer MyClientEndpoint class  URI create uri                messageLatch await 100  TimeUnit SECONDS             catch  DeploymentException   InterruptedException   IOException ex                Logger getLogger Client class getName    log Level SEVERE  null  ex                       ClientEndpoint          author Arun Gupta      ClientEndpoint public class MyClientEndpoint        OnOpen     public void onOpen Session session            System out println  Connected to endpoint      session getBasicRemote             try               String name    Duke               System out println  Sending message to endpoint      name               session getBasicRemote   sendText name             catch  IOException ex                Logger getLogger MyClientEndpoint class getName    log Level SEVERE  null  ex                         OnMessage     public void processMessage String message            System out println  Received message in client      message           Client messageLatch countDown                OnError     public void processError Throwable t            t printStackTrace

User · Answer

Use this library org java websocket  First thing you should import that library in build gradle  repositories    mavenCentral        then add the implementation in dependency    implementation  org java-websocket Java-WebSocket 1 3 0    Then you can use this code  In your activity declare object for Websocketclient like  private WebSocketClient mWebSocketClient    then add this method for callback   private void ConnectToWebSocket     URI uri  try       uri   new URI  ws   your web socket url      catch  URISyntaxException e        e printStackTrace        return     mWebSocketClient   new WebSocketClient uri         Override     public void onOpen ServerHandshake serverHandshake            Log i  Websocket    Opened            mWebSocketClient send  Hello from     Build MANUFACTURER         Build MODEL               Override     public void onMessage String s            final String message   s          runOnUiThread new Runnable                  Override             public void run                     TextView textView    TextView findViewById R id edittext chatbox                   textView setText textView getText       n    message                                         Override     public void onClose int i  String s  boolean b            Log i  Websocket    Closed     s               Override     public void onError Exception e            Log i  Websocket    Error     e getMessage              mWebSocketClient connect

User · Answer

Here is one simple example   you can download and test it http   www pretechsol com 2014 12 java-ee-websocket-simple-example html

User · Answer

I ve found a great example using javax websocket here   http   www programmingforliving com 2013 08 jsr-356-java-api-for-websocket-client-api html  Here the code based on the example linked above   TestApp java   package testapp   import java net URI  import java net URISyntaxException   public class TestApp        public static void main String   args            try                  open websocket             final WebsocketClientEndpoint clientEndPoint   new WebsocketClientEndpoint new URI  wss   real okcoin cn 10440 websocket okcoinapi                     add listener             clientEndPoint addMessageHandler new WebsocketClientEndpoint MessageHandler                     public void handleMessage String message                        System out println message                                                     send message to websocket             clientEndPoint sendMessage    event   addChannel   channel   ok btccny ticker                      wait 5 seconds for messages from websocket             Thread sleep 5000              catch  InterruptedException ex                System err println  InterruptedException exception      ex getMessage               catch  URISyntaxException ex                System err println  URISyntaxException exception      ex getMessage                         WebsocketClientEndpoint java   package testapp   import java net URI  import javax websocket ClientEndpoint  import javax websocket CloseReason  import javax websocket ContainerProvider  import javax websocket OnClose  import javax websocket OnMessage  import javax websocket OnOpen  import javax websocket Session  import javax websocket WebSocketContainer          ChatServer Client        author Jiji Sasidharan      ClientEndpoint public class WebsocketClientEndpoint        Session userSession   null      private MessageHandler messageHandler       public WebsocketClientEndpoint URI endpointURI            try               WebSocketContainer container   ContainerProvider getWebSocketContainer                container connectToServer this  endpointURI             catch  Exception e                throw new RuntimeException e                                   Callback hook for Connection open events                 param userSession the userSession which is opened               OnOpen     public void onOpen Session userSession            System out println  opening websocket            this userSession   userSession                        Callback hook for Connection close events                 param userSession the userSession which is getting closed          param reason the reason for connection close              OnClose     public void onClose Session userSession  CloseReason reason            System out println  closing websocket            this userSession   null                        Callback hook for Message Events  This method will be invoked when a client send a message                 param message The text message              OnMessage     public void onMessage String message            if  this messageHandler    null                this messageHandler handleMessage message                                   register message handler                param msgHandler             public void addMessageHandler MessageHandler msgHandler            this messageHandler   msgHandler                        Send a message                 param message             public void sendMessage String message            this userSession getAsyncRemote   sendText message                         Message handler                 author Jiji Sasidharan             public static interface MessageHandler            public void handleMessage String message

[java] javax.websocket client simple example

Examples related to java

Examples related to websocket