关于Spring Boot WebSocket整合以及nginx配置详解

短命女 2022-12-18 08:59 185阅读 0赞

**前言**

本文主要给大家介绍了关于Spring Boot WebSocket整合及nginx配置的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍吧。

**一：Spring Boot WebSocket整合**

创建一个maven项目，加入如下依赖

<dependencyManagement> 
     <dependencies> 
      <dependency> 
       <groupId>org.springframework.boot</groupId> 
       <artifactId>spring-boot-dependencies</artifactId> 
       <version>1.4.0.RELEASE</version> 
       <scope>import</scope> 
       <type>pom</type> 
      </dependency> 
     </dependencies> 
    </dependencyManagement> 
      
    <dependencies> 
     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-web</artifactId> 
     </dependency> 
     <dependency> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-starter-websocket</artifactId> 
     </dependency> 
    </dependencies>

代码如下：

package com.wh.web; 
      
    import org.springframework.web.socket.TextMessage; 
    import org.springframework.web.socket.WebSocketSession; 
    import org.springframework.web.socket.handler.TextWebSocketHandler; 
      
    public class CountWebSocketHandler extends TextWebSocketHandler { 
      
     private static long count = 0; 
     protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { 
      session.sendMessage(new TextMessage("你是第" + (++count) + "位访客")); 
     } 
    }

package com.wh.web; 
      
    import org.springframework.context.annotation.Configuration; 
    import org.springframework.web.socket.config.annotation.WebSocketConfigurer; 
    import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; 
      
    @Configuration
    public class WebsocketConfiguration implements WebSocketConfigurer { 
     public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { 
      registry.addHandler(new CountWebSocketHandler(), "/web/count"); 
     } 
    }

package com.wh.web; 
      
    import org.springframework.boot.SpringApplication; 
    import org.springframework.boot.autoconfigure.SpringBootApplication; 
    import org.springframework.web.socket.config.annotation.EnableWebSocket; 
      
    @EnableWebSocket
    @SpringBootApplication
    public class ServerApp { 
     public static void main(String[] args) { 
      SpringApplication.run(ServerApp.class, args); 
     } 
    }

application.properties 内容如下：

server.port=9080 
    spring.resources.static-locations=classpath:/webapp/html/

src/main/resources/webapp/html/index.html  内容如下：

<!DOCTYPE html> 
    <html> 
    <head> 
    <meta charset="UTF-8" /> 
    <title>web socket</title> 
    </head> 
    <body> 
    <h1>web socket</h1> 
    <script type="text/javascript"> 
     var url = 'ws://'+window.location.hostname+':9080/web/count'; 
     var ws = new WebSocket(url); 
     ws.onopen = function(event) 
     { 
      ws.send('hello'); 
     }; 
       
     ws.onmessage = function(event) { 
      alert(event.data); 
     }; 
       
     ws.onerror = function(event) { 
      alert(event); 
     } 
    </script> 
    </body> 
    </html>

最后，启动main方法，访问http://127.0.0.1:9080/index.html即可看到输出

**二：nginx配置**

nginx 通过在客户端和后端服务器之间建立起一条隧道来支持WebSocket。

为了使nginx可以将来自客户端的Upgrade请求发送给后端服务器，Upgrade和Connection的头信息必须被显式的设置。如下所示：

location /web/count { 
      proxy_pass http://tomcat-server; 
      proxy_redirect off; 
      proxy_http_version 1.1; 
      proxy_set_header Upgrade $http_upgrade; 
      proxy_set_header Connection "upgrade"; 
      proxy_set_header Host $host:$server_port; 
      proxy_set_header X-Real-IP $remote_addr; 
      proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;  
    }

一旦我们完成以上设置，nginx就可以处理WebSocket连接了。

**注意：**必须要有  `proxy_set_header Host $host:$server_port;`   这个配置

否则，会报：`WebSocket connection to 'ws://192.168.1.104:9080/web/count' failed: Error during WebSocket handshake: Unexpected response code: 403`的错误