TIL 17번째

👍 오늘 한 것

● OSI 7 계층 파악

● Redis Pub / Sub 사용하여 스프링부트에서 Publisher , Subcribe , Topic 부분 구현해보기

● 현재 협업중인 프로젝트 무한 대댓글 에서 값이 있음에도 불구하고 NULL이 찍히는 현상 픽스

● 알고리즘 2문제 풀기

 

 

메세지를 입력하거나, 입장하게되면 RedisPublisher.publish 로 발행

 

@RequiredArgsConstructor
@Controller
public class ChatController {

    private final RedisPublisher redisPublisher;
    private final ChatRoomRepository chatRoomRepository;

    /**
     * websocket "/pub/chat/message"로 들어오는 메시징을 처리한다.
     */
    @MessageMapping("/chat/message")
    public void message(ChatMessage message) {
        if (ChatMessage.MessageType.ENTER.equals(message.getType())) {
            chatRoomRepository.enterChatRoom(message.getRoomId());
            message.setMessage(message.getSender() + "님이 입장하셨습니다.");
        }
        // Websocket에 발행된 메시지를 redis로 발행한다(publish)
        redisPublisher.publish(chatRoomRepository.getTopic(message.getRoomId()), message);
    }
}

 

위에서 사용자가 입력한 메세지를 해당 Redis의 토픽채널에 발행을하면 

@RequiredArgsConstructor
@Service
public class RedisPublisher {

    private final RedisTemplate<String,Object> redisTemplate;

     public void publish(ChannelTopic topic, ChatMessage message){
         redisTemplate.convertAndSend(topic.getTopic(),message);
     }
}

* Redis에서 메시지가 발행(publish)되면 대기하고 있던 onMessage가 해당 메시지를 받아 처리한다.

@Slf4j
@RequiredArgsConstructor
@Service
public class RedisSubscriber implements MessageListener {

    private final ObjectMapper objectMapper;
    private final RedisTemplate redisTemplate;
    private final SimpMessageSendingOperations messagingTemplate;

    /**
     * Redis에서 메시지가 발행(publish)되면 대기하고 있던 onMessage가 해당 메시지를 받아 처리한다.
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        try {
            // redis에서 발행된 데이터를 받아 deserialize
            String publishMessage = (String) redisTemplate.getStringSerializer().deserialize(message.getBody());
            // ChatMessage 객채로 맵핑
            ChatMessage roomMessage = objectMapper.readValue(publishMessage, ChatMessage.class);
            // Websocket 구독자에게 채팅 메시지 Send
            messagingTemplate.convertAndSend("/sub/chat/room/" + roomMessage.getRoomId(), roomMessage);
        } catch (Exception e) {
            log.error(e.getMessage());
        }
    }
}

 

Stomp 를 사용하면 편한점은 각각 메세지를 전송하는 매체, 받는 매체의 역할이 정해져있다는 것이다. (PUB/SUB) 

(브로커라는 중간 매개체를 통해 데이터를 조율 할 수있음 현재 위의 코드에서는 REDIS 가 브로커라고 생각하면됨)

 

 

🤦‍ 근 몇일간 처음 접해보는 Socket 이라는 개념공부를 하고 구현하느라 정신이없다.. 어떤 일이던 처음은 항상 힘든 것 같다. 원래 몇일 전 까지 socket이라는 단어조차 몰랐는데 현재 프로젝트에 적용 할 일이 생겨 급하게 공부중이다. 

원래 우리가 자주 사용하던 HTTP 특징은 반이중 통신으로 클라이언트가 요청을 하고 서버가 요청을 받아 응답을하면 

연결이 끊기는 Stateless한 프로토콜이다. 

하지만 채팅기능은 이렇게 한번 사이클을돌고 연결이 끊기고를 무한 반복하면 큰 자원 손해이다. 이를 보완하기 나온 프로토콜이 Socket인데, 전이중 통신이자, Stateful하며 처음 Socket 연결을 할 때 빼고는 항상 연결되어 있는 상태의 프로토콜이다. (채팅에 적합한) 일반 소캣마저 브라우저에서 호환되지 않는 현상이 발생해 스프링전용 Socket인 SockJs를 사용하고 있고 이에 채팅기능을 조금더 발전시키고 편하게 사용하기위한 Stomp를 사용해서 Pub/Sub 기능을 사용했다.