@Override
    public void onOpen(final ServerHandshake serverHandshake) {
        LOG.info("websocket connection server[{}] is opened, sending sync msg", this.getURI().toString());
        send(DataEventTypeEnum.RUNNING_MODE.name());
        if (!alreadySync) {
            send(DataEventTypeEnum.MYSELF.name());
            alreadySync = true;
        }
    }
Instantiates a new shenyu websocket client.

@param serverUri the server uri
@param headers the headers
@param pluginDataSubscriber the plugin data subscriber
@param metaDataSubscribers the meta data subscribers
@param authDataSubscribers the auth data subscribers
@param proxySelectorDataSubscribers proxySelectorDataSubscribers,
@param discoveryUpstreamDataSubscribers discoveryUpstreamDataSubscribers,
shenyu-sync-data-center/shenyu-sync-data-websocket/src/main/java/org/apache/shenyu/plugin/sync/data/websocket/client/ShenyuWebsocketClient.java