45 lines
1.2 KiB
Java
45 lines
1.2 KiB
Java
package xin.merlin.myplayerbackend.utils.websocket;
|
|
|
|
import com.alibaba.fastjson2.JSON;
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
import org.springframework.stereotype.Component;
|
|
import xin.merlin.myplayerbackend.config.RabbitMQConfig;
|
|
import xin.merlin.myplayerbackend.utils.websocket.command.CommandDispatcher;
|
|
|
|
@Slf4j
|
|
@Component
|
|
@RequiredArgsConstructor
|
|
public class WebSocketMessageConsumer {
|
|
|
|
private final WebSocketSessionManager sessionManager;
|
|
|
|
private final CommandDispatcher commandDispatcher;
|
|
|
|
@RabbitListener(queues = RabbitMQConfig.WS_MESSAGE_QUEUE)
|
|
public void onMessage(String json) {
|
|
try {
|
|
JSONObject msg = JSON.parseObject(json);
|
|
commandDispatcher.dispatch(msg);
|
|
|
|
} catch (Exception e) {
|
|
log.info(e.getMessage());
|
|
}
|
|
}
|
|
|
|
@RabbitListener(queues = RabbitMQConfig.WS_VIDEO_QUEUE)
|
|
public void onVideoMessage(String json) {
|
|
try {
|
|
JSONObject msg = JSON.parseObject(json);
|
|
commandDispatcher.dispatch(msg);
|
|
|
|
} catch (Exception e) {
|
|
log.info(e.getMessage());
|
|
}
|
|
|
|
}
|
|
}
|
|
|