WebSocket无法注入属性

踩坑一：
原因：

是因为Spring对象的创建都是以单例模式创建的，在启动时只创建一次WebSocket。而WebSocketServer在每个连接请求到来时，都会new一个对象。所以当你启动项目时，你想要注入的对象已经注入进去，但是当用户连接是，新创建的websocket对象没有你要注入的对象，所以会报NullPointerException
解决：

通过static关键字让webSocketService属于WebSocketServer类

1. private static WebSocketService webSocketService; //通过static关键字让webSocketService属于WebSocketServer类
3. @Autowired//注入到WebSocketServer类的webSocketService属性里
4. public void setKefuService(WebSocketService webSocketService){
5.     WebSocketServer.webSocketService= webSocketService;
6. }

复制代码

踩坑二：
使用@ServerEndpoint声明的websocket服务器中自动注入

• 错误方法，这样无法从容器中获取
  

1. @ServerEndpoint(value = "/chat/{username}")
2. @Service
3. public class WebSocketServer {
5.     @Resource // @Autowired
6.     private RabbitTemplate rabbitTemplate;  //null
7. }

复制代码

• 解决：使用上下文获取
  

1. @ServerEndpoint(value = "/chat/{username}")
2. @Service
3. public class WebSocketServer {
5.     /*
6.      * 提供一个spring context上下文(解决方案)
7.      */
8.     private static ApplicationContext context;
10.     public static void setApplicationContext(ApplicationContext applicationContext) {
11.         WebSocketServer.context = applicationContext;
12.     }
13. }

复制代码

• 在启动类中传入上下文
  

1. @SpringBootApplication
2. public class TalkApplication {
3.     public static void main(String[] args) {
4.         //解决springboot和websocket之间使用@autowired注入为空问题
5.         ConfigurableApplicationContext applicationContext =
6.                 SpringApplication.run(TalkApplication.class, args);
7.         //这里将Spring Application注入到websocket类中定义的Application中。
8.         WebSocketServer.setApplicationContext(applicationContext);
9.     }
10. }

复制代码

• 在使用的地方通过上下文去获取服务context.getBean();
  

1. public void sendSimpleQueue(String message) {
2.     String queueName = "talk";
3.     // 在使用的地方通过上下文去获取服务context.getBean();
4.     RabbitTemplate rabbitTemplate = context.getBean(RabbitTemplate.class);
5.    
6.     rabbitTemplate.convertAndSend(queueName, message);
7. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！