public class TcpServerConfig {

    ...

    // Nio Factory
    @Bean
    public AbstractServerConnectionFactory serverConnectionFactory() {
        TcpNioServerConnectionFactory tcpNioServerConnectionFactory = new TcpNioServerConnectionFactory(port);
        tcpNioServerConnectionFactory.setUsingDirectBuffers(true);
        tcpNioServerConnectionFactory.setSerializer(codec());
        tcpNioServerConnectionFactory.setDeserializer(codec());
        return tcpNioServerConnectionFactory;
    }

    // 메세지 수신 채널
    @Bean
    public MessageChannel inboundChannel() {
        return new DirectChannel();
    }
    
    // 게이트 웨이 설정
    @Bean
    public TcpInboundGateway inboundGateway(AbstractServerConnectionFactory serverConnectionFactory,
                                            MessageChannel inboundChannel) {
        TcpInboundGateway tcpInboundGateway = new TcpInboundGateway();
        tcpInboundGateway.setConnectionFactory(serverConnectionFactory);
        tcpInboundGateway.setRequestChannel(inboundChannel);
        return tcpInboundGateway;
    }

    // 직렬화, 역직렬화 코덱
    public ByteArrayCrLfSerializer codec() {
        ByteArrayCrLfSerializer crLfSerializer = new ByteArrayCrLfSerializer();
        crLfSerializer.setMaxMessageSize(204800000);
        return crLfSerializer;
    }

    public class TcpServerEndpoint {

    private final TcpService tcpService;

    @ServiceActivator(inputChannel = "inboundChannel", async = "true")
    public String process(String message) throws JsonProcessingException {
        return tcpService.processMessage(message);
    }
}

   public class TcpService {

    ...

    public String processMessage(String message) throws JsonProcessingException {
        LoginSessionRequest request = new Gson().fromJson(message,LoginSessionRequest.class);
        switch (request.getType()) {
            // 채팅 websocket connect시
            case "login": {
                ...
                tcpClientGateway.send(request.getUser_id() + SEP + ONLINE);
                break;
            }
            // 채팅 websocket disconnect 시
            case "logout": {
                ...
                return temp;
            }
            // 유저 위치값(방 이동시)
            case "state": {
                ...
                return lastRoom + SEP + place;
            }
            
            // 메세지 수신,미수신 처리
            case "direct":
            case "community": {
                ...
                return String.valueOf(check);
            }
            
            // 음성 채널 상태 정보값 수신
            case "before-enter": {
                ...
                return objectMapper.writeValueAsString(result);
            }
            
            // 음성 채널 입장시 상태값 저장
            case "enter": {
                ...
                return objectMapper.writeValueAsString(result);
            }
            
            // 시그널링 소켓 connect/disconnect
            case "signaling": {
                ...
                break;
            }
        }
        return "반환메세지";
    }
}