java实现websocket客户端

package com.gds.restapi.sysMng.msg.websocket;

/**
 * @author zhangfq
 * @version 1.0
 * Description
 * <p> 中航工业光电所
 * @Date 2021-04-13 15:00
 */

import javax.websocket.*;
import java.net.URI;

/**
 * Created by Administrator on 2016/4/17.
 */
@ClientEndpoint
public class MyWebSocketClient {
    @OnOpen
    public void onOpen(Session session) {
        System.out.println("open ... ");
    }

    @OnMessage
    public void onMessage(String message) {
        System.out.println(message);
    }

    @OnError
    public void onError(Throwable t) {
        t.printStackTrace();
    }

    public static void sendStartVoice() throws Exception{
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        String uri ="ws://127.0.0.1:8900";
        Session session = container.connectToServer(MyWebSocketClient.class, URI.create(uri));
        session.getBasicRemote().sendText("ctrl:s");
        Thread.sleep(1000);
        session.close();
    }
    public static void sendStopVoice() throws Exception{
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        String uri ="ws://127.0.0.1:8900";
        Session session = container.connectToServer(MyWebSocketClient.class, URI.create(uri));
        session.getBasicRemote().sendText("ctrl:f");
        Thread.sleep(1000);
        session.close();
    }



    public static void main(String[] args)throws Exception{
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        String uri ="ws://127.0.0.1:8900";
        System.out.println("Connecting to 2"+ uri);

        Session session = container.connectToServer(MyWebSocketClient.class, URI.create(uri));
        session.getBasicRemote().sendText("ctrl:f");
        Thread.sleep(1000);
        session.close();
    }
}