private static WebSocketService webSocketService; //通過static關(guān)鍵字讓webSocketService屬于WebSocketServer類
@Autowired//注入到WebSocketServer類的webSocketService屬性里
public void setKefuService(WebSocketService webSocketService){
    WebSocketServer.webSocketService= webSocketService;
}

@ServerEndpoint(value = "/chat/{username}")
@Service
public class WebSocketServer {
    @Resource // @Autowired
    private RabbitTemplate rabbitTemplate;  //null
}

@ServerEndpoint(value = "/chat/{username}")
@Service
public class WebSocketServer {
    /*
     * 提供一個(gè)spring context上下文(解決方案)
     */
    private static ApplicationContext context;
    public static void setApplicationContext(ApplicationContext applicationContext) {
        WebSocketServer.context = applicationContext;
    }
}

@SpringBootApplication
public class TalkApplication {
    public static void main(String[] args) {
        //解決springboot和websocket之間使用@autowired注入為空問題
        ConfigurableApplicationContext applicationContext =
                SpringApplication.run(TalkApplication.class, args);
        //這里將Spring Application注入到websocket類中定義的Application中。
        WebSocketServer.setApplicationContext(applicationContext);
    }
}

public void sendSimpleQueue(String message) {
    String queueName = "talk";
    // 在使用的地方通過上下文去獲取服務(wù)context.getBean();
    RabbitTemplate rabbitTemplate = context.getBean(RabbitTemplate.class);
    rabbitTemplate.convertAndSend(queueName, message);
}