java 使用 rocketmq+WebSocket 实现一个在线多人聊天室

Question

1、rocketmq 使用不是很熟悉，
以下是我的 rocketMQ的配置

rocketmq:
  nameServer: 127.0.0.1:9876

2、启动是报错

Field rocketMQTemplate in com.mabo.rockMQ.producer.WebsocketProducer required a bean of type 'org.apache.rocketmq.spring.core.RocketMQTemplate' that could not be found.

3、WebsocketProducer.java

```java

package com.mabo.rockMQ.producer;

import com.alibaba.fastjson.JSONObject;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class WebsocketProducer {
    private static final Logger log = LoggerFactory.getLogger(WebsocketProducer.class);
    @Autowired
    RocketMQTemplate rocketMQTemplate;

    public void sendMsg(String classRoom,String userId,String msg) {
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("type",1);
        jsonObject.put("classRoom",classRoom);
        jsonObject.put("userId",userId);
        jsonObject.put("msg",msg);
        rocketMQTemplate.convertAndSend("websocket", jsonObject.toJSONString());
        log.info("send message success"+jsonObject);

    }

    public void closeUser(String classRoom,String userId,String msg) {
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("type",2);
        jsonObject.put("classRoom",classRoom);
        jsonObject.put("userId",userId);
        jsonObject.put("msg",msg);
        rocketMQTemplate.convertAndSend("websocket", jsonObject.toJSONString());
        log.info("send message success"+jsonObject);
    }
}

Answer 1

具体报啥错