前言
本文主要給大家介紹了關(guān)于Spring Boot WebSocket整合及nginx配置的相關(guān)內(nèi)容，分享出來供大家參考學(xué)習(xí)，下面話不多說了，來一起看看詳細(xì)的介紹吧。
一：Spring Boot WebSocket整合
創(chuàng)建一個maven項目，加入如下依賴
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
<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> |
代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
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) + "位訪客")); } } |
|
1
2
3
4
5
6
7
8
9
10
11
12
|
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; @Configurationpublic class WebsocketConfiguration implements WebSocketConfigurer { public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(new CountWebSocketHandler(), "/web/count"); } } |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
package com.wh.web; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.web.socket.config.annotation.EnableWebSocket; @EnableWebSocket@SpringBootApplicationpublic class ServerApp { public static void main(String[] args) { SpringApplication.run(ServerApp.class, args); } } |
application.properties 內(nèi)容如下：
|
1
2
|
server.port=9080 spring.resources.static-locations=classpath:/webapp/html/ |
src/main/resources/webapp/html/index.html 內(nèi)容如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
<!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 通過在客戶端和后端服務(wù)器之間建立起一條隧道來支持WebSocket。
為了使nginx可以將來自客戶端的Upgrade請求發(fā)送給后端服務(wù)器，Upgrade和Connection的頭信息必須被顯式的設(shè)置。如下所示：
|
1
2
3
4
5
6
7
8
9
10
|
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; } |
一旦我們完成以上設(shè)置，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的錯誤
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對服務(wù)器之家的支持。
原文鏈接：http://blog.csdn.net/mn960mn/article/details/52184937
