pdms-oss-api/src/test/java/com/bridge/WebSocketTest.java

package com.bridge;


import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

@Slf4j
public class WebSocketTest {

    public static void main(String[] args) {
        try {
            SignUtil.signByMD5(new HashMap<>(), "");
            String url = "ws://127.0.0.1:8082/v1/ws/10001/battery";
            URI uri = new URI(url);
            WebSocketClient mWs = new WebSocketClient(uri) {
                @SneakyThrows
                @Override
                public void onOpen(ServerHandshake serverHandshake) {
                    log.info(" is Opend");
                    Map<String, Object> param = new HashMap<>();
                    param.put("appid", "10001");
                    param.put("timestamp", new Date().getTime());
//                    param.put("nonce","123");

                    String sign = SignUtil.signByMD5(param, "U19c8qqJ5E6pyM8ohKdWtO8bHguJ3neR");
                    param.put("sign", sign);
                    this.send(new ObjectMapper().writeValueAsString(param));
                }

                @Override
                public void onMessage(String s) {
                    System.out.println(s);
                }

                @Override
                public void onClose(int i, String s, boolean b) {

                }

                @Override
                public void onError(Exception e) {

                }
            };
            mWs.connect();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}