java - 空指针异常 : Cannot send from MessageListener to client via websocket with Spring boot

Question

在从 Redis 订阅消息后，我正在尝试向主题 /topic/room 发送消息。 我的代码如下。

@Component
public class RedisSubscriber implements MessageListener {

    static private Logger log = Logger.getLogger(RedisSubscriber.class.getName());

    @Autowired
    private SimpMessagingTemplate template;

    @Override
    public void onMessage(final Message message, final byte[] pattern) {

        log.info("template: " + template);
        template.convertAndSend("/topic/room", message);
        log.info("Message send: " + message.toString());
    }
}

结果如下。 我不知道为什么 SimpMessagingTemplate 对象为空。 SimpMessagingTemplate 似乎不是@Autowired。 我是否需要创建其他模板？ 请给我建议。

得到以下异常

2017-07-12 19:53:24.920  INFO 8724 --- [edisContainer-2] j.c.t.l.delivery.redis.RedisSubscriber   : template: null
2017-07-12 19:53:24.939 ERROR 8724 --- [edisContainer-2] o.s.d.r.l.a.MessageListenerAdapter       : Listener execution failed

java.lang.NullPointerException: null
    at XXXX.redis.RedisSubscriber.onMessage(RedisSubscriber.java:27) ~[classes/:na]
    at org.springframework.data.redis.listener.adapter.MessageListenerAdapter.onMessage(MessageListenerAdapter.java:299) ~[spring-data-redis-1.8.4.RELEASE.jar:na]
    at org.springframework.data.redis.listener.RedisMessageListenerContainer.executeListener(RedisMessageListenerContainer.java:249) [spring-data-redis-1.8.4.RELEASE.jar:na]
    at org.springframework.data.redis.listener.RedisMessageListenerContainer.processMessage(RedisMessageListenerContainer.java:239) [spring-data-redis-1.8.4.RELEASE.jar:na]
    at org.springframework.data.redis.listener.RedisMessageListenerContainer$1.run(RedisMessageListenerContainer.java:967) [spring-data-redis-1.8.4.RELEASE.jar:na]
    at java.lang.Thread.run(Thread.java:748) [na:1.8.0_131]

其他信息如下。 这就是我如何获取 RedisSubscriber 并将其注册到 MessageListenerAdapter。

@Configuration
@EnableScheduling
public class AppConfig {

    @Bean
    JedisConnectionFactory jedisConnectionFactory() {
        return new JedisConnectionFactory();
    }

    @Bean
    RedisTemplate<String, Object> redisTemplate() {
        final RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        template.setConnectionFactory(jedisConnectionFactory());
        template.setKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(new GenericToStringSerializer<Object>(Object.class));
        template.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
        return template;
    }

    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(new RedisSubscriber());
    }

    @Bean
    RedisMessageListenerContainer redisContainer() {
        final RedisMessageListenerContainer container = new RedisMessageListenerContainer();

        container.setConnectionFactory(jedisConnectionFactory());
        container.addMessageListener(messageListener(), topic());

        return container;
    }

    @Bean
    RedisPublisher redisPublisher() {
        return new RedisPublisher(redisTemplate(), topic());
    }

    @Bean
    ChannelTopic topic() {
        return new ChannelTopic("topic");
    }
}

Answer 1

在 AppConfig 中，您可以自动连接您的订阅者

@Configuration
@EnableScheduling
public class AppConfig {
    @Autowire
    RedisSubscriber redisSubscriber

    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(redisSubscriber);
    }
}

如果您的订阅者使用@Service 注释，您可以在订阅者类中自动连接服务:

@Service
public class RedisSubscriber implements MessageListener {
    @Autowired
    private SimpMessagingTemplate template // should be non-null
}