zoukankan      html  css  js  c++  java
  • java websocket client

      websocket是H5新推出的协议,一般用于前端,但是在实际项目中我们需要用java代码来获取一些设备的实时运行数据,在后台处理后推送的前台界面,为了保证实时性,我们需要用到websocket协议,而刚好有一个叫java-websocket的开源项目,我们可以利用它来实现java版的websocket client。

      1、需要引入的依赖:

    <dependency>
                <groupId>org.java-websocket</groupId>
                <artifactId>Java-WebSocket</artifactId>
                <version>1.3.5</version>
            </dependency>

      2、客户端代码

    package com.example.demo;
    
    import java.net.URI;
    import java.net.URISyntaxException;
    import java.util.Iterator;
    
    import org.java_websocket.WebSocket;
    import org.java_websocket.client.WebSocketClient;
    import org.java_websocket.handshake.ServerHandshake;
     
    public class MyWebSocketClient extends WebSocketClient{
     
        public MyWebSocketClient(String url) throws URISyntaxException {
            super(new URI(url));
        }
     
        @Override
        public void onOpen(ServerHandshake shake) {
            System.out.println("握手...");
            for(Iterator<String> it=shake.iterateHttpFields();it.hasNext();) {
                String key = it.next();
                System.out.println(key+":"+shake.getFieldValue(key));
            }
        }
     
        @Override
        public void onMessage(String paramString) {
            System.out.println("接收到消息:"+paramString);
        }
     
        @Override
        public void onClose(int paramInt, String paramString, boolean paramBoolean) {
            System.out.println("关闭...");
        }
     
        @Override
        public void onError(Exception e) {
            System.out.println("异常"+e);
            
        }
        
        public static void main(String[] args) {
            try {
                MyWebSocketClient client = new MyWebSocketClient("ws://192.168.1.118:8080/websocket");
                client.connect();
                while (!client.getReadyState().equals(WebSocket.READYSTATE.OPEN)) {
                    System.out.println("还没有打开");
                }
                System.out.println("建立websocket连接");
                client.send("asd");
            } catch (URISyntaxException e) {
                e.printStackTrace();
            } 
        }
    
    }

      3、启动websocket server,可参考我的博客https://www.cnblogs.com/hhhshct/p/9507146.html,然后直接main方法运行,结果如下:

      

      

  • 相关阅读:
    轮播图案例
    如何使用google等一系列搜索引擎?
    开源项目weiciyuan运行前gradle调试过程记录
    onRetainNonConfigurationInstance方法状态保存
    关于stickybroadcast
    关于Bundle对象的思考
    android中finish和system.exit方法退出的区别
    关于RAW 和 ASSEST文件夹的差异
    图片缓存核心类LruCache
    Android常用开源库集合【持续更新】
  • 原文地址:https://www.cnblogs.com/hhhshct/p/9507446.html
Copyright © 2011-2022 走看看