Spring WebSocket：如何在ChannelInterceptorAdapter中将Message<?> payload转为POJO

这问题我之前做WebSocket审计功能时也踩过坑——Spring WebSocket在消息流转的不同阶段，payload的形态确实不一样：Controller层的@MessageMapping方法之所以能直接接收Notification这类POJO，是因为Spring自动帮你做了消息转换，把序列化后的字节数组转成了对应对象；但到了ChannelInterceptor的postSend方法里，你拿到的是还没经过（或已完成）序列化的原始字节数组，直接强转自然会报ClassCastException。

不过不用自己手动写反序列化逻辑，Spring自带的MessageConverter就能完美解决这个问题，下面是具体实现步骤：

方法：利用Spring内置的MessageConverter做转换 #

Spring WebSocket默认会注册MappingJackson2MessageConverter（如果你的项目引入了Jackson依赖），它负责处理JSON格式的消息序列化/反序列化。我们可以直接在拦截器中注入这个转换器，用它来把byte[]转成目标POJO：

1. 注入MessageConverter到拦截器 #

@Component
public class NotificationAuditInterceptor extends ChannelInterceptorAdapter {

    private final MessageConverter jsonMessageConverter;

    // 从Spring容器的消息转换器列表中，筛选出处理JSON的那个
    public NotificationAuditInterceptor(List<MessageConverter> messageConverters) {
        this.jsonMessageConverter = messageConverters.stream()
                .filter(converter -> converter instanceof MappingJackson2MessageConverter)
                .findFirst()
                .orElseThrow(() -> new IllegalStateException("Missing JSON message converter in Spring context"));
    }

2. 在postSend中完成转换 #

@Override
    public void postSend(Message<?> message, MessageChannel channel, boolean sent) {
        // 只处理SEND类型的消息（可根据你的需求调整消息类型）
        SimpMessageType messageType = (SimpMessageType) message.getHeaders()
                .get(SimpMessageHeaderAccessor.MESSAGE_TYPE_HEADER);
        if (SimpMessageType.SEND.equals(messageType)) {
            Object payload = message.getPayload();
            if (payload instanceof byte[]) {
                try {
                    // 用转换器把byte[]转换成Notification对象
                    Notification notification = (Notification) jsonMessageConverter.fromMessage(message, Notification.class);
                    // 这里就可以执行你的审计逻辑了，比如记录日志、存入数据库
                    System.out.println("Auditing notification: " + notification.toString());
                } catch (MessageConversionException ex) {
                    // 处理转换失败的情况，比如日志告警
                    ex.printStackTrace();
                }
            }
        }
        super.postSend(message, channel, sent);
    }
}

为什么这个方法靠谱？ #

• 它复用了Spring WebSocket的原生转换逻辑，和Controller层的转换规则完全一致，不会出现手动反序列化导致的格式不兼容问题
• 转换器会自动读取消息头中的contentType等元数据，适配不同的消息格式（不止JSON，如果你用了其他格式的转换器也能生效）
• 完全基于Spring现有API，不需要引入额外依赖或写自定义序列化逻辑

如果你的项目用的不是JSON格式的消息（比如XML），只需要替换对应的MessageConverter即可，原理是一样的。

内容的提问来源于stack exchange，提问作者Manuel Jordan