StompProtocolOhos

[введите описание изображения]

2. В файле entry модуля build.gradle:

    ```gradle
dependencies {
      implementation('com.gitee.chinasoft_ohos:StompProtocolOhos:1.0.1')
    ......  
}

@Configuration
@EnableWebSocket

@EnableWebSocketMessageBroker

class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    void configureMessageBroker(MessageBrokerRegistry config) {

        long[] heartbeat = [ 30000, 30000 ];
        config.enableSimpleBroker("/topic", "/queue", "/exchange")
            .setTaskScheduler(new DefaultManagedTaskScheduler()) // enable heartbeats
            .setHeartbeatValue(heartbeat); // enable heartbeats
//        config.enableStompBrokerRelay("/topic", "/queue", "/exchange"); // Uncomment for external message broker (ActiveMQ, RabbitMQ)
        config.setApplicationDestinationPrefixes("/topic", "/queue"); // prefix in client queries
        config.setUserDestinationPrefix("/user");
    }

    @Override
    void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/example-endpoint").setAllowedOrigins("*").withSockJS()
    }

    @Override
    void configureWebSocketTransport(WebSocketTransportRegistration registration) {
        registration.setMessageSizeLimit(8 * 1024);
    }
}

@Slf4j
@RestController
class SocketController {

    @Autowired
    SocketService socketService

    @MessageMapping('/hello-msg-mapping')
    @SendTo('/topic/greetings')
    EchoModel echoMessageMapping(String message) {
        log.debug("React to hello-msg-mapping")
        return new EchoModel(message.trim())
    }

    @RequestMapping(value = '/hello-convert-and-send', method = RequestMethod.POST)
    void echoConvertAndSend(@RequestParam('msg') String message) {
        socketService.echoMessage(message)
    }
}

 private StompClient mStompClient;

 // ...
 
 mStompClient = Stomp.over(Stomp.ConnectionProvider.OKHTTP, "ws://" + OhOS_EMULATOR_LOCALHOST + ":" + RestClient.SERVER_PORT + "/example-endpoint/websocket");
 mStompClient.connect();
  
    mStompClient.topic("/topic/greetings")
                    .subscribeOn(Schedulers.io())
                    .observeOn(HarmonySchedulers.mainThread())
                    .subscribe(topicMessage -> {
                        debug("Received " + topicMessage.getPayload());
                        addItem(mGson.fromJson(topicMessage.getPayload(), EchoModel.class));
                    }, throwable -> {
                        debug("Error on subscribe topic" + throwable);
                    });
  
 // ...

 mStompClient.disconnect();

lifecycleDisposable = connectionProvider.lifecycle()
                    .subscribe(lifecycleEvent -> {
                    switch (lifecycleEvent.getType()) {
                        case OPENED:
                          HiLog.error(LABEL, "Socket opened");
                            break;

                        case CLOSED:
                            HiLog.error(LABEL, "Socket closed");
                            disconnect();
                            break;